Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -25,4 +25,4 @@
@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.FIELD, ElementType.PARAMETER, ElementType.LOCAL_VARIABLE, ElementType.METHOD})
public @interface Bool {
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -25,4 +25,4 @@
@Retention(RetentionPolicy.RUNTIME)
@Inherited
public @interface TimeOfDay {
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -25,4 +25,4 @@
@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.FIELD, ElementType.PARAMETER, ElementType.LOCAL_VARIABLE, ElementType.METHOD})
public @interface TimestampMs {
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -25,4 +25,4 @@
@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.FIELD, ElementType.PARAMETER, ElementType.LOCAL_VARIABLE, ElementType.METHOD})
public @interface TimestampNs {
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
License for the specific language governing permissions and limitations under
the License.
*/
*/
namespace EPAM.Deltix.Timebase.Messages;
option JavaPackage = "com.epam.deltix.timebase.messages";

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -42,4 +42,4 @@ class MarketMessage : InstrumentMessage {
[SchemaType(DataType = SchemaDataType.VARCHAR, Encoding = "ALPHANUMERIC(10)")]
[SchemaElement]
Int64? SourceId;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -33,4 +33,4 @@ class Argument {
[SchemaElement()]
[SchemaType(DataType = SchemaDataType.OBJECT, NestedTypes = { typeof(FieldType) }, IsNullable = false)]
FieldType DataType;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -29,4 +29,4 @@ class InitArgument: Argument {
[SchemaType()]
Text? DefaultValue;

}
}
Original file line number Diff line number Diff line change
Expand Up @@ -42,4 +42,4 @@ class StatefulFunctionMessage : InstrumentMessage {
[SchemaElement()]
[SchemaType(DataType = SchemaDataType.OBJECT, NestedTypes = { typeof(FieldType) }, IsNullable = false)]
FieldType ReturnType;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -37,4 +37,4 @@ class StatelessFunctionMessage : InstrumentMessage {
[SchemaElement()]
[SchemaType(DataType = SchemaDataType.OBJECT, NestedTypes = { typeof(FieldType) }, IsNullable = false)]
FieldType ReturnType;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -38,4 +38,4 @@ class Descriptor {
[SchemaElement]
[SchemaType(IsNullable=true)]
Text? Description;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -26,4 +26,4 @@ class DescriptorRef {
[SchemaElement]
[SchemaType(IsNullable=false)]
Text Name;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -33,4 +33,4 @@ class EnumConstant {
[SchemaElement]
[SchemaType(IsNullable=false)]
Int16 Value;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -33,4 +33,4 @@ class EnumDescriptor : UniqueDescriptor {
[SchemaElement]
[SchemaType(IsNullable=false)]
Boolean IsBitmask;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -41,5 +41,4 @@ class Field : Descriptor {
typeof(VarcharFieldType)
})]
FieldType Type;
}

}
Original file line number Diff line number Diff line change
Expand Up @@ -211,5 +211,4 @@ class VarcharFieldType : FieldType {

override Text BaseName = "VARCHAR";

}

}
Original file line number Diff line number Diff line change
Expand Up @@ -35,4 +35,4 @@ class NonStaticField : Field {
[SchemaElement]
[SchemaType(IsNullable=true)]
Text? RelativeTo;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -45,4 +45,4 @@ class SchemaChangeMessage : InstrumentMessage {
/// Message version
[SchemaElement]
UInt64 Version;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -56,4 +56,4 @@ class SchemaDescriptorChangeAction {
[SchemaArrayType(IsNullable = true, IsElementNullable = false,
ElementTypes = { typeof(SchemaFieldChangeAction) })]
List<SchemaFieldChangeAction>? FieldChangeActions;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -37,4 +37,4 @@ enum SchemaDescriptorChangeType {
/// Content type change operation.
[SchemaElement(Name = "CONTENT_TYPE_CHANGE")]
CONTENT_TYPE_CHANGE = 0x10;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -28,4 +28,4 @@ class SchemaDescriptorTransformation {
[SchemaElement]
[SchemaType(IsNullable=false)]
SchemaDescriptorTransformationType TransformationType;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,6 @@
License for the specific language governing permissions and limitations under
the License.
*/

namespace EPAM.Deltix.Timebase.Messages.Schema;
option JavaPackage = "com.epam.deltix.timebase.messages.schema";

Expand All @@ -26,4 +25,4 @@ enum SchemaDescriptorTransformationType {
/// Drop record operation.
[SchemaElement(Name = "DROP_RECORD")]
DROP_RECORD = 0;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -49,4 +49,4 @@ class SchemaFieldChangeAction {
typeof(SchemaFieldDataTransformation)
})]
SchemaFieldDataTransformation? DataTransformation;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -55,4 +55,4 @@ enum SchemaFieldChangeType {
/// Change field relation attribute operation.
[SchemaElement(Name = "RELATION_CHANGE")]
RELATION_CHANGE = 0x400;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -33,4 +33,4 @@ class SchemaFieldDataTransformation {
[SchemaElement]
[SchemaType(IsNullable=true)]
Text? DefaultValue;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -48,4 +48,4 @@ class StreamMessage : InstrumentMessage {
[SchemaElement()]
[SchemaArrayType(ElementTypes = { typeof(TypeDescriptor), typeof(EnumDescriptor) }, IsNullable = false, IsElementNullable = false)]
List<UniqueDescriptor> AllTypes;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -46,4 +46,4 @@ class TypeDescriptor : UniqueDescriptor {
[SchemaArrayType(IsNullable = false, IsElementNullable = false,
ElementTypes = { typeof(StaticField), typeof(NonStaticField) })]
List<Field> Fields;
}
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,31 @@
/*
Copyright 2021 EPAM Systems, Inc

See the NOTICE file distributed with this work for additional information
regarding copyright ownership. Licensed under the Apache License,
Version 2.0 (the "License"); you may not use this file except in compliance
with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
License for the specific language governing permissions and limitations under
the License.
*/
namespace EPAM.Deltix.Timebase.Messages.Service;
option JavaPackage = "com.epam.deltix.timebase.messages.service";

import EPAM.Deltix.Timebase.Messages.*;

/// Security feed status.
[SchemaElement(Name = "com.epam.deltix.timebase.messages.service.FeedStatus", Title = "Security Feed Status")]
enum FeedStatus {
/// Feed for this security is available again.
[SchemaElement(Name = "AVAILABLE")]
AVAILABLE = 0;
/// Feed for this security and exchange code is no longer available.
[SchemaElement(Name = "NOT_AVAILABLE")]
NOT_AVAILABLE = 1;
}
Original file line number Diff line number Diff line change
@@ -0,0 +1,40 @@
/*
Copyright 2021 EPAM Systems, Inc

See the NOTICE file distributed with this work for additional information
regarding copyright ownership. Licensed under the Apache License,
Version 2.0 (the "License"); you may not use this file except in compliance
with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS, WITHOUT
WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
License for the specific language governing permissions and limitations under
the License.
*/
namespace EPAM.Deltix.Timebase.Messages.Service;
option JavaPackage = "com.epam.deltix.timebase.messages.service";

import EPAM.Deltix.Timebase.Messages.*;

[SchemaElement(Name = "com.epam.deltix.timebase.messages.service.SecurityFeedStatusMessage", Title = "Security StatusMessage")]
class SecurityFeedStatusMessage : InstrumentMessage {

/// Exchange code.
[SchemaElement(Title = "ExchangeId", Name = "exchangeId")]
Int64 ExchangeId;

/// Main status classification.
[SchemaElement(Title = "Status", Name = "status")]
FeedStatus Status;

/// Nullable original status sent by vendor.
[SchemaElement(Title = "OriginalStatus", Name = "originalStatus")]
Text OriginalStatus;

/// Deltix comment about this status.
[SchemaElement(Title = "Cause", Name = "cause")]
Text Cause;
}
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
License for the specific language governing permissions and limitations under
the License.
*/
*/
namespace EPAM.Deltix.Timebase.Messages.Universal;
option JavaPackage = "com.epam.deltix.timebase.messages.universal";

Expand All @@ -28,4 +28,4 @@ enum AggressorSide {
/// Sell side.
[SchemaElement(Name = "SELL")]
SELL = 1;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
License for the specific language governing permissions and limitations under
the License.
*/
*/
namespace EPAM.Deltix.Timebase.Messages.Universal;
option JavaPackage = "com.epam.deltix.timebase.messages.universal";

Expand All @@ -40,4 +40,4 @@ class BaseEntry {
[SchemaElement(Title = "Contract ID")]
[SchemaType(Encoding = "ALPHANUMERIC(10)", DataType = SchemaDataType.VARCHAR)]
Int64? ContractId;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
License for the specific language governing permissions and limitations under
the License.
*/
*/
namespace EPAM.Deltix.Timebase.Messages.Universal;
option JavaPackage = "com.epam.deltix.timebase.messages.universal";

Expand Down Expand Up @@ -53,4 +53,4 @@ class BasePriceEntry : BaseEntry {
[Identifier]
[SchemaElement(Title = "Participant")]
Text? ParticipantId;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -13,8 +13,7 @@
WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
License for the specific language governing permissions and limitations under
the License.
*/

*/
namespace EPAM.Deltix.Timebase.Messages.Universal;
option JavaPackage = "com.epam.deltix.timebase.messages.universal";

Expand All @@ -39,4 +38,4 @@ class BookResetEntry : BaseEntry {
[SchemaType(IsNullable = false)]
[SchemaElement(Title = "Model Type")]
DataModelType ModelType;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
License for the specific language governing permissions and limitations under
the License.
*/
*/
namespace EPAM.Deltix.Timebase.Messages.Universal;
option JavaPackage = "com.epam.deltix.timebase.messages.universal";

Expand All @@ -38,4 +38,4 @@ enum BookUpdateAction {
/// If available, an add data block will be sent to fill in the last price level.
[SchemaElement(Name = "DELETE")]
DELETE = 2;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
License for the specific language governing permissions and limitations under
the License.
*/
*/
namespace EPAM.Deltix.Timebase.Messages.Universal;
option JavaPackage = "com.epam.deltix.timebase.messages.universal";

Expand All @@ -36,4 +36,4 @@ enum DataModelType {
/// Maximal level of details availabe in input market data.
[SchemaElement(Name = "MAX")]
MAX = 3;
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@
WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
License for the specific language governing permissions and limitations under
the License.
*/
*/
namespace EPAM.Deltix.Timebase.Messages.Universal;
option JavaPackage = "com.epam.deltix.timebase.messages.universal";

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -13,8 +13,7 @@
WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the
License for the specific language governing permissions and limitations under
the License.
*/

*/
namespace EPAM.Deltix.Timebase.Messages.Universal;
option JavaPackage = "com.epam.deltix.timebase.messages.universal";

Expand All @@ -39,4 +38,4 @@ class L1Entry : BasePriceEntry {
[SchemaType(IsNullable = false)]
[SchemaElement(Title = "Side")]
QuoteSide Side;
}
}
Loading