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 intstatic final ByteOrderprotected intprotected intstatic final intstatic final intstatic final int -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionappendTo(StringBuilder builder) org.agrona.MutableDirectBufferbuffer()columnsCount(int count) static longintstatic Stringstatic intstatic intfilterId()static StringfilterMetaAttribute(MetaAttribute metaAttribute) intlimit()voidlimit(int limit) mode(SubscribeMode value) static intstatic intstatic intmodeId()static StringmodeMetaAttribute(MetaAttribute metaAttribute) static intintoffset()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) intintintintsubscriptionId(int value) static intstatic intstatic intstatic intstatic StringsubscriptionIdMetaAttribute(MetaAttribute metaAttribute) static intstatic intstatic intstatic Stringstatic intstatic intstatic StringtableNameMetaAttribute(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
-