Package io.deephaven.sbe.standalone.gen
Class TableSubscribeEncoder
java.lang.Object
io.deephaven.sbe.standalone.gen.TableSubscribeEncoder
Subscribe request
-
Nested Class Summary
Nested Classes -
Field Summary
FieldsModifier and TypeFieldDescriptionstatic final int
static final ByteOrder
protected int
protected int
static final int
static final int
static final int
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionappendTo
(StringBuilder builder) org.agrona.MutableDirectBuffer
buffer()
columnsCount
(int count) static long
int
static String
static int
static int
filterId()
static String
filterMetaAttribute
(MetaAttribute metaAttribute) int
limit()
void
limit
(int limit) mode
(SubscribeMode value) static int
static int
static int
modeId()
static String
modeMetaAttribute
(MetaAttribute metaAttribute) static int
int
offset()
putFilter
(byte[] src, int srcOffset, int length) putFilter
(org.agrona.DirectBuffer src, int srcOffset, int length) putTableName
(byte[] src, int srcOffset, int length) putTableName
(org.agrona.DirectBuffer src, int srcOffset, int length) int
int
int
int
subscriptionId
(int value) static int
static int
static int
static int
static String
subscriptionIdMetaAttribute
(MetaAttribute metaAttribute) static int
static int
static int
static String
static int
static int
static String
tableNameMetaAttribute
(MetaAttribute metaAttribute) toString()
wrap
(org.agrona.MutableDirectBuffer buffer, int offset) wrapAndApplyHeader
(org.agrona.MutableDirectBuffer buffer, int offset, MessageHeaderEncoder headerEncoder)
-
Field Details
-
BLOCK_LENGTH
public static final int BLOCK_LENGTH- See Also:
-
TEMPLATE_ID
public static final int TEMPLATE_ID- See Also:
-
SCHEMA_ID
public static final int SCHEMA_ID- See Also:
-
SCHEMA_VERSION
public static final int SCHEMA_VERSION- See Also:
-
BYTE_ORDER
-
offset
protected int offset -
limit
protected int limit
-
-
Constructor Details
-
TableSubscribeEncoder
public TableSubscribeEncoder()
-
-
Method Details
-
sbeBlockLength
public int sbeBlockLength() -
sbeTemplateId
public int sbeTemplateId() -
sbeSchemaId
public int sbeSchemaId() -
sbeSchemaVersion
public int sbeSchemaVersion() -
sbeSemanticType
-
buffer
public org.agrona.MutableDirectBuffer buffer() -
offset
public int offset() -
wrap
-
wrapAndApplyHeader
public TableSubscribeEncoder wrapAndApplyHeader(org.agrona.MutableDirectBuffer buffer, int offset, MessageHeaderEncoder headerEncoder) -
encodedLength
public int encodedLength() -
limit
public int limit() -
limit
public void limit(int limit) -
subscriptionIdId
public static int subscriptionIdId() -
subscriptionIdSinceVersion
public static int subscriptionIdSinceVersion() -
subscriptionIdEncodingOffset
public static int subscriptionIdEncodingOffset() -
subscriptionIdEncodingLength
public static int subscriptionIdEncodingLength() -
subscriptionIdMetaAttribute
-
subscriptionIdNullValue
public static int subscriptionIdNullValue() -
subscriptionIdMinValue
public static int subscriptionIdMinValue() -
subscriptionIdMaxValue
public static int subscriptionIdMaxValue() -
subscriptionId
-
modeId
public static int modeId() -
modeSinceVersion
public static int modeSinceVersion() -
modeEncodingOffset
public static int modeEncodingOffset() -
modeEncodingLength
public static int modeEncodingLength() -
modeMetaAttribute
-
mode
-
columnsId
public static long columnsId() -
columnsCount
-
tableNameId
public static int tableNameId() -
tableNameCharacterEncoding
-
tableNameMetaAttribute
-
tableNameHeaderLength
public static int tableNameHeaderLength() -
putTableName
-
putTableName
-
tableName
-
filterId
public static int filterId() -
filterCharacterEncoding
-
filterMetaAttribute
-
filterHeaderLength
public static int filterHeaderLength() -
putFilter
-
putFilter
-
filter
-
toString
-
appendTo
-