Documentation ¶
Index ¶
- Constants
- Variables
- func DecodeAttributeConfig(frameIterator *proto.ForwardFrameIterator) types.AttributeConfig
- func DecodeBitmapIndexOptions(frameIterator *proto.ForwardFrameIterator) types.BitmapIndexOptions
- func DecodeBoolean(buffer []byte, offset int32) bool
- func DecodeByte(buffer []byte, offset int32) byte
- func DecodeCPGroupCreateCPGroupResponse(clientMessage *proto.ClientMessage) types.RaftGroupId
- func DecodeCPMapCompareAndSetResponse(clientMessage *proto.ClientMessage) bool
- func DecodeCPMapDeleteResponse(clientMessage *proto.ClientMessage) iserialization.Data
- func DecodeCPMapGetResponse(clientMessage *proto.ClientMessage) iserialization.Data
- func DecodeCPMapPutResponse(clientMessage *proto.ClientMessage) iserialization.Data
- func DecodeCPMapRemoveResponse(clientMessage *proto.ClientMessage) iserialization.Data
- func DecodeCPMapSetResponse(clientMessage *proto.ClientMessage) iserialization.Data
- func DecodeCacheConfigHolder(frameIterator *proto.ForwardFrameIterator) types.CacheConfigHolder
- func DecodeCacheCreateConfigResponse(clientMessage *proto.ClientMessage) types.CacheConfigHolder
- func DecodeCacheGetAllResponse(clientMessage *proto.ClientMessage) []proto.Pair
- func DecodeCacheGetConfigResponse(clientMessage *proto.ClientMessage) types.CacheConfigHolder
- func DecodeCacheGetResponse(clientMessage *proto.ClientMessage) iserialization.Data
- func DecodeCachePutResponse(clientMessage *proto.ClientMessage) iserialization.Data
- func DecodeCapacity(frameIterator *proto.ForwardFrameIterator) types.Capacity
- func DecodeData(frameIterator *proto.ForwardFrameIterator) iserialization.Data
- func DecodeDataPersistenceConfig(frameIterator *proto.ForwardFrameIterator) types.DataPersistenceConfig
- func DecodeDiskTierConfig(frameIterator *proto.ForwardFrameIterator) types.DiskTierConfig
- func DecodeDouble(buffer []byte, offset int32) float64
- func DecodeDurationConfig(frameIterator *proto.ForwardFrameIterator) types.DurationConfig
- func DecodeEntryListForDataAndData(frameIterator *proto.ForwardFrameIterator) []proto.Pair
- func DecodeEventJournalConfig(frameIterator *proto.ForwardFrameIterator) types.EventJournalConfig
- func DecodeEvictionConfigHolder(frameIterator *proto.ForwardFrameIterator) types.EvictionConfigHolder
- func DecodeFloat(buffer []byte, offset int32) float32
- func DecodeHotRestartConfig(frameIterator *proto.ForwardFrameIterator) types.HotRestartConfig
- func DecodeIndexConfig(frameIterator *proto.ForwardFrameIterator) types.IndexConfig
- func DecodeInt(buffer []byte, offset int32) int32
- func DecodeJetGetJobAndSqlSummaryListResponse(clientMessage *proto.ClientMessage) []types.JobAndSqlSummary
- func DecodeJetUploadJobMultipartResponse(clientMessage *proto.ClientMessage) bool
- func DecodeJobAndSqlSummary(frameIterator *proto.ForwardFrameIterator) types.JobAndSqlSummary
- func DecodeListMultiFrame(frameIterator *proto.ForwardFrameIterator, ...)
- func DecodeListMultiFrameForDataContainsNullable(frameIterator *proto.ForwardFrameIterator) []iserialization.Data
- func DecodeListMultiFrameForIndexConfig(frameIterator *proto.ForwardFrameIterator) []types.IndexConfig
- func DecodeListMultiFrameForJobAndSqlSummary(frameIterator *proto.ForwardFrameIterator) []types.JobAndSqlSummary
- func DecodeListMultiFrameForMCEvent(frameIterator *proto.ForwardFrameIterator) []types.MCEvent
- func DecodeListMultiFrameForString(frameIterator *proto.ForwardFrameIterator) []string
- func DecodeListenerConfigHolder(frameIterator *proto.ForwardFrameIterator) types.ListenerConfigHolder
- func DecodeLong(buffer []byte, offset int32) int64
- func DecodeMCAddWanBatchPublisherConfigResponse(clientMessage *proto.ClientMessage) (addedPublisherIds []string, ignoredPublisherIds []string)
- func DecodeMCEvent(frameIterator *proto.ForwardFrameIterator) types.MCEvent
- func DecodeMCGetClusterMetadataResponse(clientMessage *proto.ClientMessage) types.ClusterMetadata
- func DecodeMCGetMapConfigResponse(clientMessage *proto.ClientMessage) types.MapConfig
- func DecodeMCGetMemberConfigResponse(clientMessage *proto.ClientMessage) string
- func DecodeMCGetTimedMemberStateResponse(clientMessage *proto.ClientMessage) string
- func DecodeMCPollMCEventsResponse(clientMessage *proto.ClientMessage) []types.MCEvent
- func DecodeMCWanSyncMapResponse(clientMessage *proto.ClientMessage) clientTypes.UUID
- func DecodeMapForStringAndString(iterator *proto.ForwardFrameIterator) map[string]string
- func DecodeMapStoreConfigHolder(frameIterator *proto.ForwardFrameIterator) types.MapStoreConfigHolder
- func DecodeMemoryTierConfig(frameIterator *proto.ForwardFrameIterator) types.MemoryTierConfig
- func DecodeMergePolicyConfig(frameIterator *proto.ForwardFrameIterator) types.MergePolicyConfig
- func DecodeMerkleTreeConfig(frameIterator *proto.ForwardFrameIterator) types.MerkleTreeConfig
- func DecodeNearCacheConfigHolder(frameIterator *proto.ForwardFrameIterator) types.NearCacheConfigHolder
- func DecodeNearCachePreloaderConfig(frameIterator *proto.ForwardFrameIterator) types.NearCachePreloaderConfig
- func DecodeNullableData(frameIterator *proto.ForwardFrameIterator) iserialization.Data
- func DecodeNullableForBitmapIndexOptions(frameIterator *proto.ForwardFrameIterator) types.BitmapIndexOptions
- func DecodeNullableForCacheConfigHolder(frameIterator *proto.ForwardFrameIterator) types.CacheConfigHolder
- func DecodeNullableForData(frameIterator *proto.ForwardFrameIterator) iserialization.Data
- func DecodeNullableForNearCachePreloaderConfig(frameIterator *proto.ForwardFrameIterator) types.NearCachePreloaderConfig
- func DecodeNullableForSqlSummary(it *proto.ForwardFrameIterator) (types.SqlSummary, bool)
- func DecodeNullableForString(frameIterator *proto.ForwardFrameIterator) string
- func DecodeNullableListMultiFrameForIndexConfig(frameIterator *proto.ForwardFrameIterator) []types.IndexConfig
- func DecodeNullableListMultiFrameForListenerConfigHolder(frameIterator *proto.ForwardFrameIterator) []types.ListenerConfigHolder
- func DecodeNullableListMultiFrameForString(frameIterator *proto.ForwardFrameIterator) []string
- func DecodeNullableMapForStringAndString(frameIterator *proto.ForwardFrameIterator) map[string]string
- func DecodePredicateConfigHolder(frameIterator *proto.ForwardFrameIterator) types.PredicateConfigHolder
- func DecodeQueryCacheConfigHolder(frameIterator *proto.ForwardFrameIterator) types.QueryCacheConfigHolder
- func DecodeRaftGroupId(frameIterator *proto.ForwardFrameIterator) types.RaftGroupId
- func DecodeShort(buffer []byte, offset int32) int16
- func DecodeSqlSummary(frameIterator *proto.ForwardFrameIterator) types.SqlSummary
- func DecodeString(frameIterator *proto.ForwardFrameIterator) string
- func DecodeTieredStoreConfig(frameIterator *proto.ForwardFrameIterator) types.TieredStoreConfig
- func DecodeTimedExpiryPolicyFactoryConfig(frameIterator *proto.ForwardFrameIterator) types.TimedExpiryPolicyFactoryConfig
- func DecodeTimedMemberStateJsonString(jsonString string) (*types.TimedMemberStateWrapper, error)
- func DecodeUUID(buffer []byte, offset int32) clientTypes.UUID
- func DecodeWanReplicationRef(frameIterator *proto.ForwardFrameIterator) types.WanReplicationRef
- func EncodeAttributeConfig(clientMessage *proto.ClientMessage, attributeConfig types.AttributeConfig)
- func EncodeBitmapIndexOptions(clientMessage *proto.ClientMessage, ...)
- func EncodeBoolean(buffer []byte, offset int32, value bool)
- func EncodeByte(buffer []byte, offset int32, value byte)
- func EncodeByteArray(message *proto.ClientMessage, value []byte)
- func EncodeCPGroupCreateCPGroupRequest(proxyName string) *proto.ClientMessage
- func EncodeCPGroupDestroyCPObjectRequest(groupId types.RaftGroupId, serviceName string, objectName string) *proto.ClientMessage
- func EncodeCPMapCompareAndSetRequest(groupId types.RaftGroupId, name string, key iserialization.Data, ...) *proto.ClientMessage
- func EncodeCPMapDeleteRequest(groupId types.RaftGroupId, name string, key iserialization.Data) *proto.ClientMessage
- func EncodeCPMapGetRequest(groupId types.RaftGroupId, name string, key iserialization.Data) *proto.ClientMessage
- func EncodeCPMapPutRequest(groupId types.RaftGroupId, name string, key iserialization.Data, ...) *proto.ClientMessage
- func EncodeCPMapRemoveRequest(groupId types.RaftGroupId, name string, key iserialization.Data) *proto.ClientMessage
- func EncodeCPMapSetRequest(groupId types.RaftGroupId, name string, key iserialization.Data, ...) *proto.ClientMessage
- func EncodeCacheConfigHolder(clientMessage *proto.ClientMessage, cacheConfigHolder types.CacheConfigHolder)
- func EncodeCacheCreateConfigRequest(cacheConfig types.CacheConfigHolder, createAlsoOnOthers bool) *proto.ClientMessage
- func EncodeCacheGetAllRequest(name string, keys []iserialization.Data, expiryPolicy iserialization.Data) *proto.ClientMessage
- func EncodeCacheGetConfigRequest(name string, simpleName string) *proto.ClientMessage
- func EncodeCacheGetRequest(name string, key iserialization.Data, expiryPolicy iserialization.Data) *proto.ClientMessage
- func EncodeCachePutAllRequest(name string, entries []proto.Pair, expiryPolicy iserialization.Data, ...) *proto.ClientMessage
- func EncodeCachePutRequest(name string, key interface{}, value interface{}, ...) *proto.ClientMessage
- func EncodeCapacity(clientMessage *proto.ClientMessage, capacity types.Capacity)
- func EncodeData(message *proto.ClientMessage, value interface{})
- func EncodeDataPersistenceConfig(clientMessage *proto.ClientMessage, ...)
- func EncodeDiskTierConfig(clientMessage *proto.ClientMessage, diskTierConfig types.DiskTierConfig)
- func EncodeDouble(buffer []byte, offset int32, value float64)
- func EncodeDurationConfig(clientMessage *proto.ClientMessage, durationConfig types.DurationConfig)
- func EncodeDynamicConfigAddCacheConfigRequest(c *types.CacheConfigInput) *proto.ClientMessage
- func EncodeDynamicConfigAddDurableExecutorConfigRequest(es *types.DurableExecutorServiceConfig) *proto.ClientMessage
- func EncodeDynamicConfigAddExecutorConfigRequest(es *types.ExecutorServiceConfig) *proto.ClientMessage
- func EncodeDynamicConfigAddMapConfigRequest(c *types.AddMapConfigInput) *proto.ClientMessage
- func EncodeDynamicConfigAddMultiMapConfigRequest(c *types.MultiMapConfig) *proto.ClientMessage
- func EncodeDynamicConfigAddQueueConfigRequest(input *types.QueueConfigInput) *proto.ClientMessage
- func EncodeDynamicConfigAddReplicatedMapConfigRequest(c *types.ReplicatedMapConfig) *proto.ClientMessage
- func EncodeDynamicConfigAddScheduledExecutorConfigRequest(es *types.ScheduledExecutorServiceConfig) *proto.ClientMessage
- func EncodeDynamicConfigAddTopicConfigRequest(t *types.TopicConfig) *proto.ClientMessage
- func EncodeEntryListForDataAndData(message *proto.ClientMessage, entries []proto.Pair)
- func EncodeEventJournalConfig(clientMessage *proto.ClientMessage, ...)
- func EncodeEvictionConfigHolder(clientMessage *proto.ClientMessage, ...)
- func EncodeFloat(buffer []byte, offset int32, value float32)
- func EncodeHotRestartConfig(clientMessage *proto.ClientMessage, hotRestartConfig types.HotRestartConfig)
- func EncodeIndexConfig(clientMessage *proto.ClientMessage, indexConfig types.IndexConfig)
- func EncodeInt(buffer []byte, offset, value int32)
- func EncodeJetExportSnapshotRequest(jobId int64, name string, cancelJob bool) *proto.ClientMessage
- func EncodeJetGetJobAndSqlSummaryListRequest() *proto.ClientMessage
- func EncodeJetResumeJobRequest(jobId int64) *proto.ClientMessage
- func EncodeJetTerminateJobRequest(job codecTypes.JetTerminateJob) *proto.ClientMessage
- func EncodeJetUploadJobMetaDataRequest(jobMetaData types.JobMetaData) *proto.ClientMessage
- func EncodeJetUploadJobMultipartRequest(sessionId types.UUID, currentPartNumber int32, totalPartNumber int32, ...) *proto.ClientMessage
- func EncodeListMultiFrameAttributeConfig(message *proto.ClientMessage, values []types.AttributeConfig)
- func EncodeListMultiFrameForData(message *proto.ClientMessage, values []iserialization.Data)
- func EncodeListMultiFrameForString(message *proto.ClientMessage, values []string)
- func EncodeListMultiFrameIndexConfig(message *proto.ClientMessage, values []types.IndexConfig)
- func EncodeListMultiFrameListenerConfigHolder(message *proto.ClientMessage, values []types.ListenerConfigHolder)
- func EncodeListMultiFrameQueryCacheConfigHolder(message *proto.ClientMessage, values []types.QueryCacheConfigHolder)
- func EncodeListenerConfigHolder(clientMessage *proto.ClientMessage, ...)
- func EncodeLong(buffer []byte, offset int32, value int64)
- func EncodeMCAddWanBatchPublisherConfigRequest(name string, targetCluster string, publisherId string, endpoints string, ...) *proto.ClientMessage
- func EncodeMCChangeClusterStateRequest(newState types.ClusterState) *proto.ClientMessage
- func EncodeMCChangeWanReplicationStateRequest(wanReplicationName string, wanPublisherId string, newState byte) *proto.ClientMessage
- func EncodeMCClearWanQueuesRequest(wanReplicationName string, wanPublisherId string) *proto.ClientMessage
- func EncodeMCEvent(clientMessage *proto.ClientMessage, mCEvent types.MCEvent)
- func EncodeMCGetClusterMetadataRequest() *proto.ClientMessage
- func EncodeMCGetMapConfigRequest(mapName string) *proto.ClientMessage
- func EncodeMCGetMemberConfigRequest() *proto.ClientMessage
- func EncodeMCGetTimedMemberStateRequest() *proto.ClientMessage
- func EncodeMCInterruptHotRestartBackupRequest() *proto.ClientMessage
- func EncodeMCPollMCEventsRequest() *proto.ClientMessage
- func EncodeMCTriggerHotRestartBackupRequest() *proto.ClientMessage
- func EncodeMCUpdateMapConfigRequest(mapName string, timeToLiveSeconds int32, maxIdleSeconds int32, ...) *proto.ClientMessage
- func EncodeMCWanSyncMapRequest(wanSync types.WanSyncRef) *proto.ClientMessage
- func EncodeMapForStringAndString(message *proto.ClientMessage, values map[string]string)
- func EncodeMapStoreConfigHolder(clientMessage *proto.ClientMessage, ...)
- func EncodeMemoryTierConfig(clientMessage *proto.ClientMessage, memoryTierConfig types.MemoryTierConfig)
- func EncodeMergePolicyConfig(clientMessage *proto.ClientMessage, mergePolicyConfig types.MergePolicyConfig)
- func EncodeMerkleTreeConfig(clientMessage *proto.ClientMessage, merkleTreeConfig types.MerkleTreeConfig)
- func EncodeNearCacheConfigHolder(clientMessage *proto.ClientMessage, ...)
- func EncodeNearCachePreloaderConfig(clientMessage *proto.ClientMessage, ...)
- func EncodeNullable(message *proto.ClientMessage, value interface{}, encoder Encoder)
- func EncodeNullableData(message *proto.ClientMessage, data iserialization.Data)
- func EncodeNullableForBitmapIndexOptions(message *proto.ClientMessage, options types.BitmapIndexOptions)
- func EncodeNullableForData(message *proto.ClientMessage, data iserialization.Data)
- func EncodeNullableForEncodeTimedExpiryPolicyFactoryConfig(clientMessage *proto.ClientMessage, ...)
- func EncodeNullableForEventJournalConfig(clientMessage *proto.ClientMessage, ...)
- func EncodeNullableForEvictionConfigHolder(clientMessage *proto.ClientMessage, ...)
- func EncodeNullableForHotRestartConfig(clientMessage *proto.ClientMessage, hotRestartConfig types.HotRestartConfig)
- func EncodeNullableForMapStoreConfigHolder(clientMessage *proto.ClientMessage, ...)
- func EncodeNullableForMerkleTreeConfig(clientMessage *proto.ClientMessage, merkleTreeConfig types.MerkleTreeConfig)
- func EncodeNullableForNearCacheConfigHolder(clientMessage *proto.ClientMessage, ...)
- func EncodeNullableForNearCachePreloaderConfig(clientMessage *proto.ClientMessage, ...)
- func EncodeNullableForQueueStoreConfigHolder(clientMessage *proto.ClientMessage, _ types.QueueStoreConfigHolder)
- func EncodeNullableForString(message *proto.ClientMessage, value string)
- func EncodeNullableForWanReplicationRef(clientMessage *proto.ClientMessage, wanReplicationRef types.WanReplicationRef)
- func EncodeNullableListMultiFrameForAttributeConfig(message *proto.ClientMessage, values []types.AttributeConfig)
- func EncodeNullableListMultiFrameForIndexConfig(message *proto.ClientMessage, values []types.IndexConfig)
- func EncodeNullableListMultiFrameForListenerConfigHolder(message *proto.ClientMessage, values []types.ListenerConfigHolder)
- func EncodeNullableListMultiFrameForQueryCacheConfigHolder(message *proto.ClientMessage, values []types.QueryCacheConfigHolder)
- func EncodeNullableListMultiFrameForString(message *proto.ClientMessage, values []string)
- func EncodeNullableMapForStringAndString(message *proto.ClientMessage, values map[string]string)
- func EncodePredicateConfigHolder(clientMessage *proto.ClientMessage, ...)
- func EncodeQueryCacheConfigHolder(clientMessage *proto.ClientMessage, ...)
- func EncodeRaftGroupId(clientMessage *proto.ClientMessage, raftGroupId types.RaftGroupId)
- func EncodeShort(buffer []byte, offset, value int32)
- func EncodeString(message *proto.ClientMessage, value interface{})
- func EncodeTieredStoreConfig(clientMessage *proto.ClientMessage, tieredStoreConfig types.TieredStoreConfig)
- func EncodeTimedExpiryPolicyFactoryConfig(clientMessage *proto.ClientMessage, ...)
- func EncodeUUID(buffer []byte, offset int32, uuid clientTypes.UUID)
- func EncodeWanReplicationRef(clientMessage *proto.ClientMessage, wanReplicationRef types.WanReplicationRef)
- func FastForwardToEndFrame(frameIterator *proto.ForwardFrameIterator)
- func NextFrameIsDataStructureEndFrame(frameIterator *proto.ForwardFrameIterator) bool
- func NextFrameIsNullFrame(frameIterator *proto.ForwardFrameIterator) bool
- type Decoder
- type Encoder
Constants ¶
View Source
const ( BitmapIndexOptionsCodecUniqueKeyTransformationFieldOffset = 0 BitmapIndexOptionsCodecUniqueKeyTransformationInitialFrameSize = BitmapIndexOptionsCodecUniqueKeyTransformationFieldOffset + proto.IntSizeInBytes )
View Source
const ( CacheConfigHolderCodecBackupCountFieldOffset = 0 CacheConfigHolderCodecAsyncBackupCountFieldOffset = CacheConfigHolderCodecBackupCountFieldOffset + proto.IntSizeInBytes CacheConfigHolderCodecReadThroughFieldOffset = CacheConfigHolderCodecAsyncBackupCountFieldOffset + proto.IntSizeInBytes CacheConfigHolderCodecWriteThroughFieldOffset = CacheConfigHolderCodecReadThroughFieldOffset + proto.BooleanSizeInBytes CacheConfigHolderCodecStoreByValueFieldOffset = CacheConfigHolderCodecWriteThroughFieldOffset + proto.BooleanSizeInBytes CacheConfigHolderCodecManagementEnabledFieldOffset = CacheConfigHolderCodecStoreByValueFieldOffset + proto.BooleanSizeInBytes CacheConfigHolderCodecStatisticsEnabledFieldOffset = CacheConfigHolderCodecManagementEnabledFieldOffset + proto.BooleanSizeInBytes CacheConfigHolderCodecDisablePerEntryInvalidationEventsFieldOffset = CacheConfigHolderCodecStatisticsEnabledFieldOffset + proto.BooleanSizeInBytes CacheConfigHolderCodecDisablePerEntryInvalidationEventsInitialFrameSize = CacheConfigHolderCodecDisablePerEntryInvalidationEventsFieldOffset + proto.BooleanSizeInBytes )
View Source
const ( CacheCreateConfigCodecRequestMessageType = int32(0x130600) CacheCreateConfigCodecResponseMessageType = int32(0x130601) CacheCreateConfigCodecRequestCreateAlsoOnOthersOffset = proto.PartitionIDOffset + proto.IntSizeInBytes CacheCreateConfigCodecRequestInitialFrameSize = CacheCreateConfigCodecRequestCreateAlsoOnOthersOffset + proto.BooleanSizeInBytes )
View Source
const ( CacheGetAllCodecRequestMessageType = int32(0x130900) CacheGetAllCodecResponseMessageType = int32(0x130901) CacheGetAllCodecRequestInitialFrameSize = proto.PartitionIDOffset + proto.IntSizeInBytes )
View Source
const ( CacheGetCodecRequestMessageType = int32(0x130D00) CacheGetCodecResponseMessageType = int32(0x130D01) CacheGetCodecRequestInitialFrameSize = proto.PartitionIDOffset + proto.IntSizeInBytes )
View Source
const ( CacheGetConfigCodecRequestMessageType = int32(0x130C00) CacheGetConfigCodecResponseMessageType = int32(0x130C01) CacheGetConfigCodecRequestInitialFrameSize = proto.PartitionIDOffset + proto.IntSizeInBytes )
View Source
const ( CachePutAllCodecRequestMessageType = int32(0x131B00) CachePutAllCodecResponseMessageType = int32(0x131B01) CachePutAllCodecRequestCompletionIdOffset = proto.PartitionIDOffset + proto.IntSizeInBytes CachePutAllCodecRequestInitialFrameSize = CachePutAllCodecRequestCompletionIdOffset + proto.IntSizeInBytes )
View Source
const ( CachePutCodecRequestMessageType = int32(0x131300) CachePutCodecResponseMessageType = int32(0x131301) CachePutCodecRequestGetOffset = proto.PartitionIDOffset + proto.IntSizeInBytes CachePutCodecRequestCompletionIdOffset = CachePutCodecRequestGetOffset + proto.BooleanSizeInBytes CachePutCodecRequestInitialFrameSize = CachePutCodecRequestCompletionIdOffset + proto.IntSizeInBytes )
View Source
const ( CapacityCodecValueFieldOffset = 0 CapacityCodecUnitFieldOffset = CapacityCodecValueFieldOffset + proto.LongSizeInBytes CapacityCodecUnitInitialFrameSize = CapacityCodecUnitFieldOffset + proto.IntSizeInBytes )
View Source
const ( CPGroupCreateCPGroupCodecRequestMessageType = int32(0x1E0100) CPGroupCreateCPGroupCodecResponseMessageType = int32(0x1E0101) CPGroupCreateCPGroupCodecRequestInitialFrameSize = proto.PartitionIDOffset + proto.IntSizeInBytes )
View Source
const ( CPGroupDestroyCPObjectCodecRequestMessageType = int32(0x1E0200) CPGroupDestroyCPObjectCodecResponseMessageType = int32(0x1E0201) CPGroupDestroyCPObjectCodecRequestInitialFrameSize = proto.PartitionIDOffset + proto.IntSizeInBytes )
View Source
const ( CPMapCompareAndSetCodecRequestMessageType = int32(0x230600) CPMapCompareAndSetCodecResponseMessageType = int32(0x230601) CPMapCompareAndSetCodecRequestInitialFrameSize = proto.PartitionIDOffset + proto.IntSizeInBytes CPMapCompareAndSetResponseResponseOffset = proto.ResponseBackupAcksOffset + proto.ByteSizeInBytes )
View Source
const ( CPMapDeleteCodecRequestMessageType = int32(0x230500) CPMapDeleteCodecResponseMessageType = int32(0x230501) CPMapDeleteCodecRequestInitialFrameSize = proto.PartitionIDOffset + proto.IntSizeInBytes )
View Source
const ( CPMapGetCodecRequestMessageType = int32(0x230100) CPMapGetCodecResponseMessageType = int32(0x230101) CPMapGetCodecRequestInitialFrameSize = proto.PartitionIDOffset + proto.IntSizeInBytes )
View Source
const ( CPMapPutCodecRequestMessageType = int32(0x230200) CPMapPutCodecResponseMessageType = int32(0x230201) CPMapPutCodecRequestInitialFrameSize = proto.PartitionIDOffset + proto.IntSizeInBytes )
View Source
const ( CPMapRemoveCodecRequestMessageType = int32(0x230400) CPMapRemoveCodecResponseMessageType = int32(0x230401) CPMapRemoveCodecRequestInitialFrameSize = proto.PartitionIDOffset + proto.IntSizeInBytes )
View Source
const ( CPMapSetCodecRequestMessageType = int32(0x230300) CPMapSetCodecResponseMessageType = int32(0x230301) CPMapSetCodecRequestInitialFrameSize = proto.PartitionIDOffset + proto.IntSizeInBytes )
View Source
const ( DataPersistenceConfigCodecEnabledFieldOffset = 0 DataPersistenceConfigCodecFsyncFieldOffset = DataPersistenceConfigCodecEnabledFieldOffset + proto.BooleanSizeInBytes DataPersistenceConfigCodecFsyncInitialFrameSize = DataPersistenceConfigCodecFsyncFieldOffset + proto.BooleanSizeInBytes )
View Source
const ( DiskTierConfigCodecEnabledFieldOffset = 0 DiskTierConfigCodecEnabledInitialFrameSize = DiskTierConfigCodecEnabledFieldOffset + proto.BooleanSizeInBytes )
View Source
const ( DurationConfigCodecDurationAmountFieldOffset = 0 DurationConfigCodecTimeUnitFieldOffset = DurationConfigCodecDurationAmountFieldOffset + proto.LongSizeInBytes DurationConfigCodecTimeUnitInitialFrameSize = DurationConfigCodecTimeUnitFieldOffset + proto.IntSizeInBytes )
View Source
const ( DynamicConfigAddCacheConfigCodecRequestMessageType = int32(0x1B0E00) DynamicConfigAddCacheConfigCodecResponseMessageType = int32(0x1B0E01) DynamicConfigAddCacheConfigCodecRequestStatisticsEnabledOffset = proto.PartitionIDOffset + proto.IntSizeInBytes DynamicConfigAddCacheConfigCodecRequestManagementEnabledOffset = DynamicConfigAddCacheConfigCodecRequestStatisticsEnabledOffset + proto.BooleanSizeInBytes DynamicConfigAddCacheConfigCodecRequestReadThroughOffset = DynamicConfigAddCacheConfigCodecRequestManagementEnabledOffset + proto.BooleanSizeInBytes DynamicConfigAddCacheConfigCodecRequestWriteThroughOffset = DynamicConfigAddCacheConfigCodecRequestReadThroughOffset + proto.BooleanSizeInBytes DynamicConfigAddCacheConfigCodecRequestBackupCountOffset = DynamicConfigAddCacheConfigCodecRequestWriteThroughOffset + proto.BooleanSizeInBytes DynamicConfigAddCacheConfigCodecRequestAsyncBackupCountOffset = DynamicConfigAddCacheConfigCodecRequestBackupCountOffset + proto.IntSizeInBytes DynamicConfigAddCacheConfigCodecRequestMergeBatchSizeOffset = DynamicConfigAddCacheConfigCodecRequestAsyncBackupCountOffset + proto.IntSizeInBytes DynamicConfigAddCacheConfigCodecRequestDisablePerEntryInvalidationEventsOffset = DynamicConfigAddCacheConfigCodecRequestMergeBatchSizeOffset + proto.IntSizeInBytes DynamicConfigAddCacheConfigCodecRequestInitialFrameSize = DynamicConfigAddCacheConfigCodecRequestDisablePerEntryInvalidationEventsOffset + proto.BooleanSizeInBytes )
View Source
const ( DynamicConfigAddDurableExecutorConfigCodecRequestMessageType = int32(0x1B0900) DynamicConfigAddDurableExecutorConfigCodecResponseMessageType = int32(0x1B0901) DynamicConfigAddDurableExecutorConfigCodecRequestPoolSizeOffset = proto.PartitionIDOffset + proto.IntSizeInBytes DynamicConfigAddDurableExecutorConfigCodecRequestDurabilityOffset = DynamicConfigAddDurableExecutorConfigCodecRequestPoolSizeOffset + proto.IntSizeInBytes DynamicConfigAddDurableExecutorConfigCodecRequestCapacityOffset = DynamicConfigAddDurableExecutorConfigCodecRequestDurabilityOffset + proto.IntSizeInBytes DynamicConfigAddDurableExecutorConfigCodecRequestStatisticsEnabledOffset = DynamicConfigAddDurableExecutorConfigCodecRequestCapacityOffset + proto.IntSizeInBytes DynamicConfigAddDurableExecutorConfigCodecRequestInitialFrameSize = DynamicConfigAddDurableExecutorConfigCodecRequestStatisticsEnabledOffset + proto.BooleanSizeInBytes )
View Source
const ( DynamicConfigAddExecutorConfigCodecRequestMessageType = int32(0x1B0800) DynamicConfigAddExecutorConfigCodecResponseMessageType = int32(0x1B0801) DynamicConfigAddExecutorConfigCodecRequestPoolSizeOffset = proto.PartitionIDOffset + proto.IntSizeInBytes DynamicConfigAddExecutorConfigCodecRequestQueueCapacityOffset = DynamicConfigAddExecutorConfigCodecRequestPoolSizeOffset + proto.IntSizeInBytes DynamicConfigAddExecutorConfigCodecRequestStatisticsEnabledOffset = DynamicConfigAddExecutorConfigCodecRequestQueueCapacityOffset + proto.IntSizeInBytes DynamicConfigAddExecutorConfigCodecRequestInitialFrameSize = DynamicConfigAddExecutorConfigCodecRequestStatisticsEnabledOffset + proto.BooleanSizeInBytes )
View Source
const ( DynamicConfigAddMapConfigCodecRequestMessageType = int32(0x1B0C00) DynamicConfigAddMapConfigCodecResponseMessageType = int32(0x1B0C01) DynamicConfigAddMapConfigCodecRequestBackupCountOffset = proto.PartitionIDOffset + proto.IntSizeInBytes DynamicConfigAddMapConfigCodecRequestAsyncBackupCountOffset = DynamicConfigAddMapConfigCodecRequestBackupCountOffset + proto.IntSizeInBytes DynamicConfigAddMapConfigCodecRequestTimeToLiveSecondsOffset = DynamicConfigAddMapConfigCodecRequestAsyncBackupCountOffset + proto.IntSizeInBytes DynamicConfigAddMapConfigCodecRequestMaxIdleSecondsOffset = DynamicConfigAddMapConfigCodecRequestTimeToLiveSecondsOffset + proto.IntSizeInBytes DynamicConfigAddMapConfigCodecRequestReadBackupDataOffset = DynamicConfigAddMapConfigCodecRequestMaxIdleSecondsOffset + proto.IntSizeInBytes DynamicConfigAddMapConfigCodecRequestMergeBatchSizeOffset = DynamicConfigAddMapConfigCodecRequestReadBackupDataOffset + proto.BooleanSizeInBytes DynamicConfigAddMapConfigCodecRequestStatisticsEnabledOffset = DynamicConfigAddMapConfigCodecRequestMergeBatchSizeOffset + proto.IntSizeInBytes DynamicConfigAddMapConfigCodecRequestMetadataPolicyOffset = DynamicConfigAddMapConfigCodecRequestStatisticsEnabledOffset + proto.BooleanSizeInBytes DynamicConfigAddMapConfigCodecRequestPerEntryStatsEnabledOffset = DynamicConfigAddMapConfigCodecRequestMetadataPolicyOffset + proto.IntSizeInBytes DynamicConfigAddMapConfigCodecRequestInitialFrameSize = DynamicConfigAddMapConfigCodecRequestPerEntryStatsEnabledOffset + proto.BooleanSizeInBytes )
View Source
const ( DynamicConfigAddMultiMapConfigCodecRequestMessageType = int32(0x1B0100) DynamicConfigAddMultiMapConfigCodecResponseMessageType = int32(0x1B0101) DynamicConfigAddMultiMapConfigCodecRequestBinaryOffset = proto.PartitionIDOffset + proto.IntSizeInBytes DynamicConfigAddMultiMapConfigCodecRequestBackupCountOffset = DynamicConfigAddMultiMapConfigCodecRequestBinaryOffset + proto.BooleanSizeInBytes DynamicConfigAddMultiMapConfigCodecRequestAsyncBackupCountOffset = DynamicConfigAddMultiMapConfigCodecRequestBackupCountOffset + proto.IntSizeInBytes DynamicConfigAddMultiMapConfigCodecRequestStatisticsEnabledOffset = DynamicConfigAddMultiMapConfigCodecRequestAsyncBackupCountOffset + proto.IntSizeInBytes DynamicConfigAddMultiMapConfigCodecRequestMergeBatchSizeOffset = DynamicConfigAddMultiMapConfigCodecRequestStatisticsEnabledOffset + proto.BooleanSizeInBytes DynamicConfigAddMultiMapConfigCodecRequestInitialFrameSize = DynamicConfigAddMultiMapConfigCodecRequestMergeBatchSizeOffset + proto.IntSizeInBytes )
View Source
const ( DynamicConfigAddQueueConfigCodecRequestMessageType = int32(0x1B0B00) DynamicConfigAddQueueConfigCodecResponseMessageType = int32(0x1B0B01) DynamicConfigAddQueueConfigCodecRequestBackupCountOffset = proto.PartitionIDOffset + proto.IntSizeInBytes DynamicConfigAddQueueConfigCodecRequestAsyncBackupCountOffset = DynamicConfigAddQueueConfigCodecRequestBackupCountOffset + proto.IntSizeInBytes DynamicConfigAddQueueConfigCodecRequestMaxSizeOffset = DynamicConfigAddQueueConfigCodecRequestAsyncBackupCountOffset + proto.IntSizeInBytes DynamicConfigAddQueueConfigCodecRequestEmptyQueueTtlOffset = DynamicConfigAddQueueConfigCodecRequestMaxSizeOffset + proto.IntSizeInBytes DynamicConfigAddQueueConfigCodecRequestStatisticsEnabledOffset = DynamicConfigAddQueueConfigCodecRequestEmptyQueueTtlOffset + proto.IntSizeInBytes DynamicConfigAddQueueConfigCodecRequestMergeBatchSizeOffset = DynamicConfigAddQueueConfigCodecRequestStatisticsEnabledOffset + proto.BooleanSizeInBytes DynamicConfigAddQueueConfigCodecRequestInitialFrameSize = DynamicConfigAddQueueConfigCodecRequestMergeBatchSizeOffset + proto.IntSizeInBytes )
View Source
const ( DynamicConfigAddReplicatedMapConfigCodecRequestMessageType = int32(0x1B0600) DynamicConfigAddReplicatedMapConfigCodecResponseMessageType = int32(0x1B0601) DynamicConfigAddReplicatedMapConfigCodecRequestAsyncFillupOffset = proto.PartitionIDOffset + proto.IntSizeInBytes DynamicConfigAddReplicatedMapConfigCodecRequestStatisticsEnabledOffset = DynamicConfigAddReplicatedMapConfigCodecRequestAsyncFillupOffset + proto.BooleanSizeInBytes DynamicConfigAddReplicatedMapConfigCodecRequestMergeBatchSizeOffset = DynamicConfigAddReplicatedMapConfigCodecRequestStatisticsEnabledOffset + proto.BooleanSizeInBytes DynamicConfigAddReplicatedMapConfigCodecRequestInitialFrameSize = DynamicConfigAddReplicatedMapConfigCodecRequestMergeBatchSizeOffset + proto.IntSizeInBytes )
View Source
const ( DynamicConfigAddScheduledExecutorConfigCodecRequestMessageType = int32(0x1B0A00) DynamicConfigAddScheduledExecutorConfigCodecResponseMessageType = int32(0x1B0A01) DynamicConfigAddScheduledExecutorConfigCodecRequestPoolSizeOffset = proto.PartitionIDOffset + proto.IntSizeInBytes DynamicConfigAddScheduledExecutorConfigCodecRequestDurabilityOffset = DynamicConfigAddScheduledExecutorConfigCodecRequestPoolSizeOffset + proto.IntSizeInBytes DynamicConfigAddScheduledExecutorConfigCodecRequestCapacityOffset = DynamicConfigAddScheduledExecutorConfigCodecRequestDurabilityOffset + proto.IntSizeInBytes DynamicConfigAddScheduledExecutorConfigCodecRequestMergeBatchSizeOffset = DynamicConfigAddScheduledExecutorConfigCodecRequestCapacityOffset + proto.IntSizeInBytes DynamicConfigAddScheduledExecutorConfigCodecRequestStatisticsEnabledOffset = DynamicConfigAddScheduledExecutorConfigCodecRequestMergeBatchSizeOffset + proto.IntSizeInBytes DynamicConfigAddScheduledExecutorConfigCodecRequestInitialFrameSize = DynamicConfigAddScheduledExecutorConfigCodecRequestStatisticsEnabledOffset + proto.BooleanSizeInBytes )
View Source
const ( DynamicConfigAddTopicConfigCodecRequestMessageType = int32(0x1B0700) DynamicConfigAddTopicConfigCodecResponseMessageType = int32(0x1B0701) DynamicConfigAddTopicConfigCodecRequestGlobalOrderingEnabledOffset = proto.PartitionIDOffset + proto.IntSizeInBytes DynamicConfigAddTopicConfigCodecRequestStatisticsEnabledOffset = DynamicConfigAddTopicConfigCodecRequestGlobalOrderingEnabledOffset + proto.BooleanSizeInBytes DynamicConfigAddTopicConfigCodecRequestMultiThreadingEnabledOffset = DynamicConfigAddTopicConfigCodecRequestStatisticsEnabledOffset + proto.BooleanSizeInBytes DynamicConfigAddTopicConfigCodecRequestInitialFrameSize = DynamicConfigAddTopicConfigCodecRequestMultiThreadingEnabledOffset + proto.BooleanSizeInBytes )
View Source
const ( EventJournalConfigCodecEnabledFieldOffset = 0 EventJournalConfigCodecCapacityFieldOffset = EventJournalConfigCodecEnabledFieldOffset + proto.BooleanSizeInBytes EventJournalConfigCodecTimeToLiveSecondsFieldOffset = EventJournalConfigCodecCapacityFieldOffset + proto.IntSizeInBytes EventJournalConfigCodecTimeToLiveSecondsInitialFrameSize = EventJournalConfigCodecTimeToLiveSecondsFieldOffset + proto.IntSizeInBytes )
View Source
const ( EvictionConfigHolderCodecSizeFieldOffset = 0 EvictionConfigHolderCodecSizeInitialFrameSize = EvictionConfigHolderCodecSizeFieldOffset + proto.IntSizeInBytes )
View Source
const ( HotRestartConfigCodecEnabledFieldOffset = 0 HotRestartConfigCodecFsyncFieldOffset = HotRestartConfigCodecEnabledFieldOffset + proto.BooleanSizeInBytes HotRestartConfigCodecFsyncInitialFrameSize = HotRestartConfigCodecFsyncFieldOffset + proto.BooleanSizeInBytes )
View Source
const ( IndexConfigCodecTypeFieldOffset = 0 IndexConfigCodecTypeInitialFrameSize = IndexConfigCodecTypeFieldOffset + proto.IntSizeInBytes )
View Source
const ( JetExportSnapshotCodecRequestMessageType = int32(0xFE0A00) JetExportSnapshotCodecResponseMessageType = int32(0xFE0A01) JetExportSnapshotCodecRequestJobIdOffset = proto.PartitionIDOffset + proto.IntSizeInBytes JetExportSnapshotCodecRequestCancelJobOffset = JetExportSnapshotCodecRequestJobIdOffset + proto.LongSizeInBytes JetExportSnapshotCodecRequestInitialFrameSize = JetExportSnapshotCodecRequestCancelJobOffset + proto.BooleanSizeInBytes )
View Source
const ( JetGetJobAndSqlSummaryListCodecRequestMessageType = int32(0xFE0F00) JetGetJobAndSqlSummaryListCodecResponseMessageType = int32(0xFE0F01) JetGetJobAndSqlSummaryListCodecRequestInitialFrameSize = proto.PartitionIDOffset + proto.IntSizeInBytes )
View Source
const ( JetResumeJobCodecRequestMessageType = int32(0xFE0900) JetResumeJobCodecResponseMessageType = int32(0xFE0901) JetResumeJobCodecRequestJobIdOffset = proto.PartitionIDOffset + proto.IntSizeInBytes JetResumeJobCodecRequestInitialFrameSize = JetResumeJobCodecRequestJobIdOffset + proto.LongSizeInBytes )
View Source
const ( JetTerminateJobCodecRequestMessageType = int32(0xFE0200) JetTerminateJobCodecResponseMessageType = int32(0xFE0201) JetTerminateJobCodecRequestJobIdOffset = proto.PartitionIDOffset + proto.IntSizeInBytes JetTerminateJobCodecRequestTerminateModeOffset = JetTerminateJobCodecRequestJobIdOffset + proto.LongSizeInBytes JetTerminateJobCodecRequestLightJobCoordinatorOffset = JetTerminateJobCodecRequestTerminateModeOffset + proto.IntSizeInBytes JetTerminateJobCodecRequestInitialFrameSize = JetTerminateJobCodecRequestLightJobCoordinatorOffset + proto.UuidSizeInBytes )
View Source
const ( JetUploadJobMetaDataCodecRequestMessageType = int32(0xFE1100) JetUploadJobMetaDataCodecResponseMessageType = int32(0xFE1101) JetUploadJobMetaDataCodecRequestSessionIdOffset = proto.PartitionIDOffset + proto.IntSizeInBytes JetUploadJobMetaDataCodecRequestJarOnMemberOffset = JetUploadJobMetaDataCodecRequestSessionIdOffset + proto.UuidSizeInBytes JetUploadJobMetaDataCodecRequestInitialFrameSize = JetUploadJobMetaDataCodecRequestJarOnMemberOffset + proto.BooleanSizeInBytes )
View Source
const ( JetUploadJobMultipartCodecRequestMessageType = int32(0xFE1100) JetUploadJobMultipartCodecResponseMessageType = int32(0xFE1101) JetUploadJobMultipartCodecRequestSessionIdOffset = proto.PartitionIDOffset + proto.IntSizeInBytes JetUploadJobMultipartCodecRequestCurrentPartNumberOffset = JetUploadJobMultipartCodecRequestSessionIdOffset + proto.UuidSizeInBytes JetUploadJobMultipartCodecRequestTotalPartNumberOffset = JetUploadJobMultipartCodecRequestCurrentPartNumberOffset + proto.IntSizeInBytes JetUploadJobMultipartCodecRequestPartSizeOffset = JetUploadJobMultipartCodecRequestTotalPartNumberOffset + proto.IntSizeInBytes JetUploadJobMultipartCodecRequestInitialFrameSize = JetUploadJobMultipartCodecRequestPartSizeOffset + proto.IntSizeInBytes JetUploadJobMultipartResponseResponseOffset = proto.ResponseBackupAcksOffset + proto.ByteSizeInBytes )
View Source
const ( JobAndSqlSummaryCodecLightJobFieldOffset = 0 JobAndSqlSummaryCodecJobIdFieldOffset = JobAndSqlSummaryCodecLightJobFieldOffset + proto.BooleanSizeInBytes JobAndSqlSummaryCodecExecutionIdFieldOffset = JobAndSqlSummaryCodecJobIdFieldOffset + proto.LongSizeInBytes JobAndSqlSummaryCodecStatusFieldOffset = JobAndSqlSummaryCodecExecutionIdFieldOffset + proto.LongSizeInBytes JobAndSqlSummaryCodecSubmissionTimeFieldOffset = JobAndSqlSummaryCodecStatusFieldOffset + proto.IntSizeInBytes JobAndSqlSummaryCodecCompletionTimeFieldOffset = JobAndSqlSummaryCodecSubmissionTimeFieldOffset + proto.LongSizeInBytes JobAndSqlSummaryCodecCompletionTimeInitialFrameSize = JobAndSqlSummaryCodecCompletionTimeFieldOffset + proto.LongSizeInBytes )
View Source
const ( ListenerConfigHolderCodecListenerTypeFieldOffset = 0 ListenerConfigHolderCodecIncludeValueFieldOffset = ListenerConfigHolderCodecListenerTypeFieldOffset + proto.IntSizeInBytes ListenerConfigHolderCodecLocalFieldOffset = ListenerConfigHolderCodecIncludeValueFieldOffset + proto.BooleanSizeInBytes ListenerConfigHolderCodecLocalInitialFrameSize = ListenerConfigHolderCodecLocalFieldOffset + proto.BooleanSizeInBytes )
View Source
const ( MapStoreConfigHolderCodecEnabledFieldOffset = 0 MapStoreConfigHolderCodecWriteCoalescingFieldOffset = MapStoreConfigHolderCodecEnabledFieldOffset + proto.BooleanSizeInBytes MapStoreConfigHolderCodecWriteDelaySecondsFieldOffset = MapStoreConfigHolderCodecWriteCoalescingFieldOffset + proto.BooleanSizeInBytes MapStoreConfigHolderCodecWriteBatchSizeFieldOffset = MapStoreConfigHolderCodecWriteDelaySecondsFieldOffset + proto.IntSizeInBytes MapStoreConfigHolderCodecWriteBatchSizeInitialFrameSize = MapStoreConfigHolderCodecWriteBatchSizeFieldOffset + proto.IntSizeInBytes )
View Source
const ( MCAddWanBatchPublisherConfigCodecRequestMessageType = int32(0x201500) MCAddWanBatchPublisherConfigCodecResponseMessageType = int32(0x201501) MCAddWanBatchPublisherConfigCodecRequestQueueCapacityOffset = proto.PartitionIDOffset + proto.IntSizeInBytes MCAddWanBatchPublisherConfigCodecRequestBatchSizeOffset = MCAddWanBatchPublisherConfigCodecRequestQueueCapacityOffset + proto.IntSizeInBytes MCAddWanBatchPublisherConfigCodecRequestBatchMaxDelayMillisOffset = MCAddWanBatchPublisherConfigCodecRequestBatchSizeOffset + proto.IntSizeInBytes MCAddWanBatchPublisherConfigCodecRequestResponseTimeoutMillisOffset = MCAddWanBatchPublisherConfigCodecRequestBatchMaxDelayMillisOffset + proto.IntSizeInBytes MCAddWanBatchPublisherConfigCodecRequestAckTypeOffset = MCAddWanBatchPublisherConfigCodecRequestResponseTimeoutMillisOffset + proto.IntSizeInBytes MCAddWanBatchPublisherConfigCodecRequestQueueFullBehaviorOffset = MCAddWanBatchPublisherConfigCodecRequestAckTypeOffset + proto.IntSizeInBytes MCAddWanBatchPublisherConfigCodecRequestConsistencyCheckStrategyOffset = MCAddWanBatchPublisherConfigCodecRequestQueueFullBehaviorOffset + proto.IntSizeInBytes MCAddWanBatchPublisherConfigCodecRequestInitialFrameSize = MCAddWanBatchPublisherConfigCodecRequestConsistencyCheckStrategyOffset + proto.ByteSizeInBytes )
View Source
const ( MCChangeClusterStateCodecRequestMessageType = int32(0x200200) MCChangeClusterStateCodecResponseMessageType = int32(0x200201) MCChangeClusterStateCodecRequestNewStateOffset = proto.PartitionIDOffset + proto.IntSizeInBytes MCChangeClusterStateCodecRequestInitialFrameSize = MCChangeClusterStateCodecRequestNewStateOffset + proto.IntSizeInBytes )
View Source
const ( MCChangeWanReplicationStateCodecRequestMessageType = int32(0x201300) MCChangeWanReplicationStateCodecResponseMessageType = int32(0x201301) MCChangeWanReplicationStateCodecRequestNewStateOffset = proto.PartitionIDOffset + proto.IntSizeInBytes MCChangeWanReplicationStateCodecRequestInitialFrameSize = MCChangeWanReplicationStateCodecRequestNewStateOffset + proto.ByteSizeInBytes )
View Source
const ( MCClearWanQueuesCodecRequestMessageType = int32(0x201400) MCClearWanQueuesCodecResponseMessageType = int32(0x201401) MCClearWanQueuesCodecRequestInitialFrameSize = proto.PartitionIDOffset + proto.IntSizeInBytes )
View Source
const ( MCEventCodecTimestampFieldOffset = 0 MCEventCodecTypeFieldOffset = MCEventCodecTimestampFieldOffset + proto.LongSizeInBytes MCEventCodecTypeInitialFrameSize = MCEventCodecTypeFieldOffset + proto.IntSizeInBytes )
View Source
const ( MCGetClusterMetadataCodecRequestMessageType = int32(0x200E00) MCGetClusterMetadataCodecResponseMessageType = int32(0x200E01) MCGetClusterMetadataCodecRequestInitialFrameSize = proto.PartitionIDOffset + proto.IntSizeInBytes MCGetClusterMetadataResponseCurrentStateOffset = proto.ResponseBackupAcksOffset + proto.ByteSizeInBytes MCGetClusterMetadataResponseClusterTimeOffset = MCGetClusterMetadataResponseCurrentStateOffset + proto.ByteSizeInBytes )
View Source
const ( MCGetMapConfigCodecRequestMessageType = int32(0x200300) MCGetMapConfigCodecResponseMessageType = int32(0x200301) MCGetMapConfigCodecRequestInitialFrameSize = proto.PartitionIDOffset + proto.IntSizeInBytes MCGetMapConfigResponseInMemoryFormatOffset = proto.ResponseBackupAcksOffset + proto.ByteSizeInBytes MCGetMapConfigResponseBackupCountOffset = MCGetMapConfigResponseInMemoryFormatOffset + proto.IntSizeInBytes MCGetMapConfigResponseAsyncBackupCountOffset = MCGetMapConfigResponseBackupCountOffset + proto.IntSizeInBytes MCGetMapConfigResponseTimeToLiveSecondsOffset = MCGetMapConfigResponseAsyncBackupCountOffset + proto.IntSizeInBytes MCGetMapConfigResponseMaxIdleSecondsOffset = MCGetMapConfigResponseTimeToLiveSecondsOffset + proto.IntSizeInBytes MCGetMapConfigResponseMaxSizeOffset = MCGetMapConfigResponseMaxIdleSecondsOffset + proto.IntSizeInBytes MCGetMapConfigResponseMaxSizePolicyOffset = MCGetMapConfigResponseMaxSizeOffset + proto.IntSizeInBytes MCGetMapConfigResponseReadBackupDataOffset = MCGetMapConfigResponseMaxSizePolicyOffset + proto.IntSizeInBytes MCGetMapConfigResponseEvictionPolicyOffset = MCGetMapConfigResponseReadBackupDataOffset + proto.BooleanSizeInBytes )
View Source
const ( MCGetMemberConfigCodecRequestMessageType = int32(0x200500) MCGetMemberConfigCodecResponseMessageType = int32(0x200501) MCGetMemberConfigCodecRequestInitialFrameSize = proto.PartitionIDOffset + proto.IntSizeInBytes )
View Source
const ( MCGetTimedMemberStateCodecRequestMessageType = int32(0x200B00) MCGetTimedMemberStateCodecResponseMessageType = int32(0x200B01) MCGetTimedMemberStateCodecRequestInitialFrameSize = proto.PartitionIDOffset + proto.IntSizeInBytes )
View Source
const ( MCInterruptHotRestartBackupCodecRequestMessageType = int32(0x202000) MCInterruptHotRestartBackupCodecResponseMessageType = int32(0x202001) MCInterruptHotRestartBackupCodecRequestInitialFrameSize = proto.PartitionIDOffset + proto.IntSizeInBytes )
View Source
const ( MCPollMCEventsCodecRequestMessageType = int32(0x201800) MCPollMCEventsCodecResponseMessageType = int32(0x201801) MCPollMCEventsCodecRequestInitialFrameSize = proto.PartitionIDOffset + proto.IntSizeInBytes )
View Source
const ( MCTriggerHotRestartBackupCodecRequestMessageType = int32(0x201F00) MCTriggerHotRestartBackupCodecResponseMessageType = int32(0x201F01) MCTriggerHotRestartBackupCodecRequestInitialFrameSize = proto.PartitionIDOffset + proto.IntSizeInBytes )
View Source
const ( MCUpdateMapConfigCodecRequestMessageType = int32(0x200400) MCUpdateMapConfigCodecResponseMessageType = int32(0x200401) MCUpdateMapConfigCodecRequestTimeToLiveSecondsOffset = proto.PartitionIDOffset + proto.IntSizeInBytes MCUpdateMapConfigCodecRequestMaxIdleSecondsOffset = MCUpdateMapConfigCodecRequestTimeToLiveSecondsOffset + proto.IntSizeInBytes MCUpdateMapConfigCodecRequestEvictionPolicyOffset = MCUpdateMapConfigCodecRequestMaxIdleSecondsOffset + proto.IntSizeInBytes MCUpdateMapConfigCodecRequestReadBackupDataOffset = MCUpdateMapConfigCodecRequestEvictionPolicyOffset + proto.IntSizeInBytes MCUpdateMapConfigCodecRequestMaxSizeOffset = MCUpdateMapConfigCodecRequestReadBackupDataOffset + proto.BooleanSizeInBytes MCUpdateMapConfigCodecRequestMaxSizePolicyOffset = MCUpdateMapConfigCodecRequestMaxSizeOffset + proto.IntSizeInBytes MCUpdateMapConfigCodecRequestInitialFrameSize = MCUpdateMapConfigCodecRequestMaxSizePolicyOffset + proto.IntSizeInBytes )
View Source
const ( MCWanSyncMapCodecRequestMessageType = int32(0x201600) MCWanSyncMapCodecResponseMessageType = int32(0x201601) MCWanSyncMapCodecRequestWanSyncTypeOffset = proto.PartitionIDOffset + proto.IntSizeInBytes MCWanSyncMapCodecRequestInitialFrameSize = MCWanSyncMapCodecRequestWanSyncTypeOffset + proto.IntSizeInBytes MCWanSyncMapResponseUuidOffset = proto.ResponseBackupAcksOffset + proto.ByteSizeInBytes )
View Source
const ( MergePolicyConfigCodecBatchSizeFieldOffset = 0 MergePolicyConfigCodecBatchSizeInitialFrameSize = MergePolicyConfigCodecBatchSizeFieldOffset + proto.IntSizeInBytes )
View Source
const ( MerkleTreeConfigCodecEnabledFieldOffset = 0 MerkleTreeConfigCodecDepthFieldOffset = MerkleTreeConfigCodecEnabledFieldOffset + proto.BooleanSizeInBytes MerkleTreeConfigCodecEnabledSetFieldOffset = MerkleTreeConfigCodecDepthFieldOffset + proto.IntSizeInBytes MerkleTreeConfigCodecEnabledSetInitialFrameSize = MerkleTreeConfigCodecEnabledSetFieldOffset + proto.BooleanSizeInBytes )
View Source
const ( NearCacheConfigHolderCodecSerializeKeysFieldOffset = 0 NearCacheConfigHolderCodecInvalidateOnChangeFieldOffset = NearCacheConfigHolderCodecSerializeKeysFieldOffset + proto.BooleanSizeInBytes NearCacheConfigHolderCodecTimeToLiveSecondsFieldOffset = NearCacheConfigHolderCodecInvalidateOnChangeFieldOffset + proto.BooleanSizeInBytes NearCacheConfigHolderCodecMaxIdleSecondsFieldOffset = NearCacheConfigHolderCodecTimeToLiveSecondsFieldOffset + proto.IntSizeInBytes NearCacheConfigHolderCodecCacheLocalEntriesFieldOffset = NearCacheConfigHolderCodecMaxIdleSecondsFieldOffset + proto.IntSizeInBytes NearCacheConfigHolderCodecCacheLocalEntriesInitialFrameSize = NearCacheConfigHolderCodecCacheLocalEntriesFieldOffset + proto.BooleanSizeInBytes )
View Source
const ( NearCachePreloaderConfigCodecEnabledFieldOffset = 0 NearCachePreloaderConfigCodecStoreInitialDelaySecondsFieldOffset = NearCachePreloaderConfigCodecEnabledFieldOffset + proto.BooleanSizeInBytes NearCachePreloaderConfigCodecStoreIntervalSecondsFieldOffset = NearCachePreloaderConfigCodecStoreInitialDelaySecondsFieldOffset + proto.IntSizeInBytes NearCachePreloaderConfigCodecStoreIntervalSecondsInitialFrameSize = NearCachePreloaderConfigCodecStoreIntervalSecondsFieldOffset + proto.IntSizeInBytes )
View Source
const ( QueryCacheConfigHolderCodecBatchSizeFieldOffset = 0 QueryCacheConfigHolderCodecBufferSizeFieldOffset = QueryCacheConfigHolderCodecBatchSizeFieldOffset + proto.IntSizeInBytes QueryCacheConfigHolderCodecDelaySecondsFieldOffset = QueryCacheConfigHolderCodecBufferSizeFieldOffset + proto.IntSizeInBytes QueryCacheConfigHolderCodecIncludeValueFieldOffset = QueryCacheConfigHolderCodecDelaySecondsFieldOffset + proto.IntSizeInBytes QueryCacheConfigHolderCodecPopulateFieldOffset = QueryCacheConfigHolderCodecIncludeValueFieldOffset + proto.BooleanSizeInBytes QueryCacheConfigHolderCodecCoalesceFieldOffset = QueryCacheConfigHolderCodecPopulateFieldOffset + proto.BooleanSizeInBytes QueryCacheConfigHolderCodecCoalesceInitialFrameSize = QueryCacheConfigHolderCodecCoalesceFieldOffset + proto.BooleanSizeInBytes )
View Source
const ( RaftGroupIdCodecSeedFieldOffset = 0 RaftGroupIdCodecIdFieldOffset = RaftGroupIdCodecSeedFieldOffset + proto.LongSizeInBytes RaftGroupIdCodecIdInitialFrameSize = RaftGroupIdCodecIdFieldOffset + proto.LongSizeInBytes )
View Source
const ( SqlSummaryCodecUnboundedFieldOffset = 0 SqlSummaryCodecUnboundedInitialFrameSize = SqlSummaryCodecUnboundedFieldOffset + proto.BooleanSizeInBytes )
View Source
const ( TieredStoreConfigCodecEnabledFieldOffset = 0 TieredStoreConfigCodecEnabledInitialFrameSize = TieredStoreConfigCodecEnabledFieldOffset + proto.BooleanSizeInBytes )
View Source
const ( TimedExpiryPolicyFactoryConfigCodecExpiryPolicyTypeFieldOffset = 0 TimedExpiryPolicyFactoryConfigCodecExpiryPolicyTypeInitialFrameSize = TimedExpiryPolicyFactoryConfigCodecExpiryPolicyTypeFieldOffset + proto.IntSizeInBytes )
View Source
const ( WanReplicationRefCodecRepublishingEnabledFieldOffset = 0 WanReplicationRefCodecRepublishingEnabledInitialFrameSize = WanReplicationRefCodecRepublishingEnabledFieldOffset + proto.BooleanSizeInBytes )
Variables ¶
View Source
var ( EncodeUnit = map[string]int32{ "BYTES": 0, "KILOBYTES": 1, "MEGABYTES": 2, "GIGABYTES": 3, } DecodeUnit = map[int32]string{ 0: "BYTES", 1: "KILOBYTES", 2: "MEGABYTES", 3: "GIGABYTES", } )
Functions ¶
func DecodeAttributeConfig ¶
func DecodeAttributeConfig(frameIterator *proto.ForwardFrameIterator) types.AttributeConfig
func DecodeBitmapIndexOptions ¶
func DecodeBitmapIndexOptions(frameIterator *proto.ForwardFrameIterator) types.BitmapIndexOptions
func DecodeBoolean ¶
func DecodeByte ¶
func DecodeCPGroupCreateCPGroupResponse ¶
func DecodeCPGroupCreateCPGroupResponse(clientMessage *proto.ClientMessage) types.RaftGroupId
func DecodeCPMapCompareAndSetResponse ¶
func DecodeCPMapCompareAndSetResponse(clientMessage *proto.ClientMessage) bool
func DecodeCPMapDeleteResponse ¶
func DecodeCPMapDeleteResponse(clientMessage *proto.ClientMessage) iserialization.Data
func DecodeCPMapGetResponse ¶
func DecodeCPMapGetResponse(clientMessage *proto.ClientMessage) iserialization.Data
func DecodeCPMapPutResponse ¶
func DecodeCPMapPutResponse(clientMessage *proto.ClientMessage) iserialization.Data
func DecodeCPMapRemoveResponse ¶
func DecodeCPMapRemoveResponse(clientMessage *proto.ClientMessage) iserialization.Data
func DecodeCPMapSetResponse ¶
func DecodeCPMapSetResponse(clientMessage *proto.ClientMessage) iserialization.Data
func DecodeCacheConfigHolder ¶
func DecodeCacheConfigHolder(frameIterator *proto.ForwardFrameIterator) types.CacheConfigHolder
func DecodeCacheCreateConfigResponse ¶
func DecodeCacheCreateConfigResponse(clientMessage *proto.ClientMessage) types.CacheConfigHolder
func DecodeCacheGetAllResponse ¶
func DecodeCacheGetAllResponse(clientMessage *proto.ClientMessage) []proto.Pair
func DecodeCacheGetConfigResponse ¶
func DecodeCacheGetConfigResponse(clientMessage *proto.ClientMessage) types.CacheConfigHolder
func DecodeCacheGetResponse ¶
func DecodeCacheGetResponse(clientMessage *proto.ClientMessage) iserialization.Data
func DecodeCachePutResponse ¶
func DecodeCachePutResponse(clientMessage *proto.ClientMessage) iserialization.Data
func DecodeCapacity ¶
func DecodeCapacity(frameIterator *proto.ForwardFrameIterator) types.Capacity
func DecodeData ¶
func DecodeData(frameIterator *proto.ForwardFrameIterator) iserialization.Data
func DecodeDataPersistenceConfig ¶
func DecodeDataPersistenceConfig(frameIterator *proto.ForwardFrameIterator) types.DataPersistenceConfig
func DecodeDiskTierConfig ¶
func DecodeDiskTierConfig(frameIterator *proto.ForwardFrameIterator) types.DiskTierConfig
func DecodeDouble ¶
func DecodeDurationConfig ¶
func DecodeDurationConfig(frameIterator *proto.ForwardFrameIterator) types.DurationConfig
func DecodeEntryListForDataAndData ¶
func DecodeEntryListForDataAndData(frameIterator *proto.ForwardFrameIterator) []proto.Pair
func DecodeEventJournalConfig ¶
func DecodeEventJournalConfig(frameIterator *proto.ForwardFrameIterator) types.EventJournalConfig
func DecodeEvictionConfigHolder ¶
func DecodeEvictionConfigHolder(frameIterator *proto.ForwardFrameIterator) types.EvictionConfigHolder
func DecodeFloat ¶
func DecodeHotRestartConfig ¶
func DecodeHotRestartConfig(frameIterator *proto.ForwardFrameIterator) types.HotRestartConfig
func DecodeIndexConfig ¶
func DecodeIndexConfig(frameIterator *proto.ForwardFrameIterator) types.IndexConfig
func DecodeJetGetJobAndSqlSummaryListResponse ¶
func DecodeJetGetJobAndSqlSummaryListResponse(clientMessage *proto.ClientMessage) []types.JobAndSqlSummary
func DecodeJetUploadJobMultipartResponse ¶
func DecodeJetUploadJobMultipartResponse(clientMessage *proto.ClientMessage) bool
func DecodeJobAndSqlSummary ¶
func DecodeJobAndSqlSummary(frameIterator *proto.ForwardFrameIterator) types.JobAndSqlSummary
func DecodeListMultiFrame ¶
func DecodeListMultiFrame(frameIterator *proto.ForwardFrameIterator, decoder func(frameIterator *proto.ForwardFrameIterator))
func DecodeListMultiFrameForDataContainsNullable ¶
func DecodeListMultiFrameForDataContainsNullable(frameIterator *proto.ForwardFrameIterator) []iserialization.Data
func DecodeListMultiFrameForIndexConfig ¶
func DecodeListMultiFrameForIndexConfig(frameIterator *proto.ForwardFrameIterator) []types.IndexConfig
func DecodeListMultiFrameForJobAndSqlSummary ¶
func DecodeListMultiFrameForJobAndSqlSummary(frameIterator *proto.ForwardFrameIterator) []types.JobAndSqlSummary
func DecodeListMultiFrameForMCEvent ¶
func DecodeListMultiFrameForMCEvent(frameIterator *proto.ForwardFrameIterator) []types.MCEvent
func DecodeListMultiFrameForString ¶
func DecodeListMultiFrameForString(frameIterator *proto.ForwardFrameIterator) []string
func DecodeListenerConfigHolder ¶
func DecodeListenerConfigHolder(frameIterator *proto.ForwardFrameIterator) types.ListenerConfigHolder
func DecodeLong ¶
func DecodeMCAddWanBatchPublisherConfigResponse ¶
func DecodeMCAddWanBatchPublisherConfigResponse(clientMessage *proto.ClientMessage) (addedPublisherIds []string, ignoredPublisherIds []string)
func DecodeMCEvent ¶
func DecodeMCEvent(frameIterator *proto.ForwardFrameIterator) types.MCEvent
func DecodeMCGetClusterMetadataResponse ¶
func DecodeMCGetClusterMetadataResponse(clientMessage *proto.ClientMessage) types.ClusterMetadata
func DecodeMCGetMapConfigResponse ¶
func DecodeMCGetMapConfigResponse(clientMessage *proto.ClientMessage) types.MapConfig
func DecodeMCGetMemberConfigResponse ¶
func DecodeMCGetMemberConfigResponse(clientMessage *proto.ClientMessage) string
func DecodeMCGetTimedMemberStateResponse ¶
func DecodeMCGetTimedMemberStateResponse(clientMessage *proto.ClientMessage) string
func DecodeMCPollMCEventsResponse ¶
func DecodeMCPollMCEventsResponse(clientMessage *proto.ClientMessage) []types.MCEvent
func DecodeMCWanSyncMapResponse ¶
func DecodeMCWanSyncMapResponse(clientMessage *proto.ClientMessage) clientTypes.UUID
func DecodeMapForStringAndString ¶
func DecodeMapForStringAndString(iterator *proto.ForwardFrameIterator) map[string]string
func DecodeMapStoreConfigHolder ¶
func DecodeMapStoreConfigHolder(frameIterator *proto.ForwardFrameIterator) types.MapStoreConfigHolder
func DecodeMemoryTierConfig ¶
func DecodeMemoryTierConfig(frameIterator *proto.ForwardFrameIterator) types.MemoryTierConfig
func DecodeMergePolicyConfig ¶
func DecodeMergePolicyConfig(frameIterator *proto.ForwardFrameIterator) types.MergePolicyConfig
func DecodeMerkleTreeConfig ¶
func DecodeMerkleTreeConfig(frameIterator *proto.ForwardFrameIterator) types.MerkleTreeConfig
func DecodeNearCacheConfigHolder ¶
func DecodeNearCacheConfigHolder(frameIterator *proto.ForwardFrameIterator) types.NearCacheConfigHolder
func DecodeNearCachePreloaderConfig ¶
func DecodeNearCachePreloaderConfig(frameIterator *proto.ForwardFrameIterator) types.NearCachePreloaderConfig
func DecodeNullableData ¶
func DecodeNullableData(frameIterator *proto.ForwardFrameIterator) iserialization.Data
func DecodeNullableForBitmapIndexOptions ¶
func DecodeNullableForBitmapIndexOptions(frameIterator *proto.ForwardFrameIterator) types.BitmapIndexOptions
manual
func DecodeNullableForCacheConfigHolder ¶
func DecodeNullableForCacheConfigHolder(frameIterator *proto.ForwardFrameIterator) types.CacheConfigHolder
func DecodeNullableForData ¶
func DecodeNullableForData(frameIterator *proto.ForwardFrameIterator) iserialization.Data
func DecodeNullableForNearCachePreloaderConfig ¶
func DecodeNullableForNearCachePreloaderConfig(frameIterator *proto.ForwardFrameIterator) types.NearCachePreloaderConfig
manual
func DecodeNullableForSqlSummary ¶
func DecodeNullableForSqlSummary(it *proto.ForwardFrameIterator) (types.SqlSummary, bool)
func DecodeNullableForString ¶
func DecodeNullableForString(frameIterator *proto.ForwardFrameIterator) string
func DecodeNullableListMultiFrameForIndexConfig ¶
func DecodeNullableListMultiFrameForIndexConfig(frameIterator *proto.ForwardFrameIterator) []types.IndexConfig
manual
func DecodeNullableListMultiFrameForListenerConfigHolder ¶
func DecodeNullableListMultiFrameForListenerConfigHolder(frameIterator *proto.ForwardFrameIterator) []types.ListenerConfigHolder
manual
func DecodeNullableListMultiFrameForString ¶
func DecodeNullableListMultiFrameForString(frameIterator *proto.ForwardFrameIterator) []string
func DecodeNullableMapForStringAndString ¶
func DecodeNullableMapForStringAndString(frameIterator *proto.ForwardFrameIterator) map[string]string
func DecodePredicateConfigHolder ¶
func DecodePredicateConfigHolder(frameIterator *proto.ForwardFrameIterator) types.PredicateConfigHolder
func DecodeQueryCacheConfigHolder ¶
func DecodeQueryCacheConfigHolder(frameIterator *proto.ForwardFrameIterator) types.QueryCacheConfigHolder
func DecodeRaftGroupId ¶
func DecodeRaftGroupId(frameIterator *proto.ForwardFrameIterator) types.RaftGroupId
func DecodeShort ¶
func DecodeSqlSummary ¶
func DecodeSqlSummary(frameIterator *proto.ForwardFrameIterator) types.SqlSummary
func DecodeString ¶
func DecodeString(frameIterator *proto.ForwardFrameIterator) string
func DecodeTieredStoreConfig ¶
func DecodeTieredStoreConfig(frameIterator *proto.ForwardFrameIterator) types.TieredStoreConfig
func DecodeTimedExpiryPolicyFactoryConfig ¶
func DecodeTimedExpiryPolicyFactoryConfig(frameIterator *proto.ForwardFrameIterator) types.TimedExpiryPolicyFactoryConfig
func DecodeTimedMemberStateJsonString ¶
func DecodeTimedMemberStateJsonString(jsonString string) (*types.TimedMemberStateWrapper, error)
func DecodeUUID ¶
func DecodeUUID(buffer []byte, offset int32) clientTypes.UUID
func DecodeWanReplicationRef ¶
func DecodeWanReplicationRef(frameIterator *proto.ForwardFrameIterator) types.WanReplicationRef
func EncodeAttributeConfig ¶
func EncodeAttributeConfig(clientMessage *proto.ClientMessage, attributeConfig types.AttributeConfig)
func EncodeBitmapIndexOptions ¶
func EncodeBitmapIndexOptions(clientMessage *proto.ClientMessage, bitmapIndexOptions types.BitmapIndexOptions)
func EncodeBoolean ¶
func EncodeByte ¶
func EncodeByteArray ¶
func EncodeByteArray(message *proto.ClientMessage, value []byte)
func EncodeCPGroupCreateCPGroupRequest ¶
func EncodeCPGroupCreateCPGroupRequest(proxyName string) *proto.ClientMessage
func EncodeCPGroupDestroyCPObjectRequest ¶
func EncodeCPGroupDestroyCPObjectRequest(groupId types.RaftGroupId, serviceName string, objectName string) *proto.ClientMessage
func EncodeCPMapCompareAndSetRequest ¶
func EncodeCPMapCompareAndSetRequest(groupId types.RaftGroupId, name string, key iserialization.Data, expectedValue iserialization.Data, newValue iserialization.Data) *proto.ClientMessage
func EncodeCPMapDeleteRequest ¶
func EncodeCPMapDeleteRequest(groupId types.RaftGroupId, name string, key iserialization.Data) *proto.ClientMessage
func EncodeCPMapGetRequest ¶
func EncodeCPMapGetRequest(groupId types.RaftGroupId, name string, key iserialization.Data) *proto.ClientMessage
func EncodeCPMapPutRequest ¶
func EncodeCPMapPutRequest(groupId types.RaftGroupId, name string, key iserialization.Data, value iserialization.Data) *proto.ClientMessage
func EncodeCPMapRemoveRequest ¶
func EncodeCPMapRemoveRequest(groupId types.RaftGroupId, name string, key iserialization.Data) *proto.ClientMessage
func EncodeCPMapSetRequest ¶
func EncodeCPMapSetRequest(groupId types.RaftGroupId, name string, key iserialization.Data, value iserialization.Data) *proto.ClientMessage
func EncodeCacheConfigHolder ¶
func EncodeCacheConfigHolder(clientMessage *proto.ClientMessage, cacheConfigHolder types.CacheConfigHolder)
func EncodeCacheCreateConfigRequest ¶
func EncodeCacheCreateConfigRequest(cacheConfig types.CacheConfigHolder, createAlsoOnOthers bool) *proto.ClientMessage
func EncodeCacheGetAllRequest ¶
func EncodeCacheGetAllRequest(name string, keys []iserialization.Data, expiryPolicy iserialization.Data) *proto.ClientMessage
func EncodeCacheGetConfigRequest ¶
func EncodeCacheGetConfigRequest(name string, simpleName string) *proto.ClientMessage
func EncodeCacheGetRequest ¶
func EncodeCacheGetRequest(name string, key iserialization.Data, expiryPolicy iserialization.Data) *proto.ClientMessage
func EncodeCachePutAllRequest ¶
func EncodeCachePutAllRequest(name string, entries []proto.Pair, expiryPolicy iserialization.Data, completionId int32) *proto.ClientMessage
func EncodeCachePutRequest ¶
func EncodeCachePutRequest(name string, key interface{}, value interface{}, expiryPolicy iserialization.Data, get bool, completionId int32) *proto.ClientMessage
func EncodeCapacity ¶
func EncodeCapacity(clientMessage *proto.ClientMessage, capacity types.Capacity)
func EncodeData ¶
func EncodeData(message *proto.ClientMessage, value interface{})
func EncodeDataPersistenceConfig ¶
func EncodeDataPersistenceConfig(clientMessage *proto.ClientMessage, dataPersistenceConfig types.DataPersistenceConfig)
func EncodeDiskTierConfig ¶
func EncodeDiskTierConfig(clientMessage *proto.ClientMessage, diskTierConfig types.DiskTierConfig)
func EncodeDouble ¶
func EncodeDurationConfig ¶
func EncodeDurationConfig(clientMessage *proto.ClientMessage, durationConfig types.DurationConfig)
func EncodeDynamicConfigAddCacheConfigRequest ¶
func EncodeDynamicConfigAddCacheConfigRequest(c *types.CacheConfigInput) *proto.ClientMessage
func EncodeDynamicConfigAddDurableExecutorConfigRequest ¶
func EncodeDynamicConfigAddDurableExecutorConfigRequest(es *types.DurableExecutorServiceConfig) *proto.ClientMessage
func EncodeDynamicConfigAddExecutorConfigRequest ¶
func EncodeDynamicConfigAddExecutorConfigRequest(es *types.ExecutorServiceConfig) *proto.ClientMessage
func EncodeDynamicConfigAddMapConfigRequest ¶
func EncodeDynamicConfigAddMapConfigRequest(c *types.AddMapConfigInput) *proto.ClientMessage
func EncodeDynamicConfigAddMultiMapConfigRequest ¶
func EncodeDynamicConfigAddMultiMapConfigRequest(c *types.MultiMapConfig) *proto.ClientMessage
func EncodeDynamicConfigAddQueueConfigRequest ¶
func EncodeDynamicConfigAddQueueConfigRequest(input *types.QueueConfigInput) *proto.ClientMessage
func EncodeDynamicConfigAddReplicatedMapConfigRequest ¶
func EncodeDynamicConfigAddReplicatedMapConfigRequest(c *types.ReplicatedMapConfig) *proto.ClientMessage
func EncodeDynamicConfigAddScheduledExecutorConfigRequest ¶
func EncodeDynamicConfigAddScheduledExecutorConfigRequest(es *types.ScheduledExecutorServiceConfig) *proto.ClientMessage
func EncodeDynamicConfigAddTopicConfigRequest ¶
func EncodeDynamicConfigAddTopicConfigRequest(t *types.TopicConfig) *proto.ClientMessage
func EncodeEntryListForDataAndData ¶
func EncodeEntryListForDataAndData(message *proto.ClientMessage, entries []proto.Pair)
func EncodeEventJournalConfig ¶
func EncodeEventJournalConfig(clientMessage *proto.ClientMessage, eventJournalConfig types.EventJournalConfig)
func EncodeEvictionConfigHolder ¶
func EncodeEvictionConfigHolder(clientMessage *proto.ClientMessage, evictionConfigHolder types.EvictionConfigHolder)
func EncodeFloat ¶
func EncodeHotRestartConfig ¶
func EncodeHotRestartConfig(clientMessage *proto.ClientMessage, hotRestartConfig types.HotRestartConfig)
func EncodeIndexConfig ¶
func EncodeIndexConfig(clientMessage *proto.ClientMessage, indexConfig types.IndexConfig)
func EncodeJetExportSnapshotRequest ¶
func EncodeJetExportSnapshotRequest(jobId int64, name string, cancelJob bool) *proto.ClientMessage
func EncodeJetGetJobAndSqlSummaryListRequest ¶
func EncodeJetGetJobAndSqlSummaryListRequest() *proto.ClientMessage
func EncodeJetResumeJobRequest ¶
func EncodeJetResumeJobRequest(jobId int64) *proto.ClientMessage
func EncodeJetTerminateJobRequest ¶
func EncodeJetTerminateJobRequest(job codecTypes.JetTerminateJob) *proto.ClientMessage
func EncodeJetUploadJobMetaDataRequest ¶
func EncodeJetUploadJobMetaDataRequest(jobMetaData types.JobMetaData) *proto.ClientMessage
func EncodeListMultiFrameAttributeConfig ¶
func EncodeListMultiFrameAttributeConfig(message *proto.ClientMessage, values []types.AttributeConfig)
manual
func EncodeListMultiFrameForData ¶
func EncodeListMultiFrameForData(message *proto.ClientMessage, values []iserialization.Data)
func EncodeListMultiFrameForString ¶
func EncodeListMultiFrameForString(message *proto.ClientMessage, values []string)
func EncodeListMultiFrameIndexConfig ¶
func EncodeListMultiFrameIndexConfig(message *proto.ClientMessage, values []types.IndexConfig)
manual
func EncodeListMultiFrameListenerConfigHolder ¶
func EncodeListMultiFrameListenerConfigHolder(message *proto.ClientMessage, values []types.ListenerConfigHolder)
manual
func EncodeListMultiFrameQueryCacheConfigHolder ¶
func EncodeListMultiFrameQueryCacheConfigHolder(message *proto.ClientMessage, values []types.QueryCacheConfigHolder)
manual
func EncodeListenerConfigHolder ¶
func EncodeListenerConfigHolder(clientMessage *proto.ClientMessage, listenerConfigHolder types.ListenerConfigHolder)
func EncodeLong ¶
func EncodeMCAddWanBatchPublisherConfigRequest ¶
func EncodeMCAddWanBatchPublisherConfigRequest(name string, targetCluster string, publisherId string, endpoints string, queueCapacity int32, batchSize int32, batchMaxDelayMillis int32, responseTimeoutMillis int32, ackType int32, queueFullBehavior int32, consistencyCheckStrategy byte) *proto.ClientMessage
func EncodeMCChangeClusterStateRequest ¶
func EncodeMCChangeClusterStateRequest(newState types.ClusterState) *proto.ClientMessage
func EncodeMCChangeWanReplicationStateRequest ¶
func EncodeMCChangeWanReplicationStateRequest(wanReplicationName string, wanPublisherId string, newState byte) *proto.ClientMessage
func EncodeMCClearWanQueuesRequest ¶
func EncodeMCClearWanQueuesRequest(wanReplicationName string, wanPublisherId string) *proto.ClientMessage
func EncodeMCEvent ¶
func EncodeMCEvent(clientMessage *proto.ClientMessage, mCEvent types.MCEvent)
func EncodeMCGetClusterMetadataRequest ¶
func EncodeMCGetClusterMetadataRequest() *proto.ClientMessage
func EncodeMCGetMapConfigRequest ¶
func EncodeMCGetMapConfigRequest(mapName string) *proto.ClientMessage
func EncodeMCGetMemberConfigRequest ¶
func EncodeMCGetMemberConfigRequest() *proto.ClientMessage
func EncodeMCGetTimedMemberStateRequest ¶
func EncodeMCGetTimedMemberStateRequest() *proto.ClientMessage
func EncodeMCInterruptHotRestartBackupRequest ¶
func EncodeMCInterruptHotRestartBackupRequest() *proto.ClientMessage
func EncodeMCPollMCEventsRequest ¶
func EncodeMCPollMCEventsRequest() *proto.ClientMessage
func EncodeMCTriggerHotRestartBackupRequest ¶
func EncodeMCTriggerHotRestartBackupRequest() *proto.ClientMessage
func EncodeMCWanSyncMapRequest ¶
func EncodeMCWanSyncMapRequest(wanSync types.WanSyncRef) *proto.ClientMessage
func EncodeMapForStringAndString ¶
func EncodeMapForStringAndString(message *proto.ClientMessage, values map[string]string)
func EncodeMapStoreConfigHolder ¶
func EncodeMapStoreConfigHolder(clientMessage *proto.ClientMessage, mapStoreConfigHolder types.MapStoreConfigHolder)
func EncodeMemoryTierConfig ¶
func EncodeMemoryTierConfig(clientMessage *proto.ClientMessage, memoryTierConfig types.MemoryTierConfig)
func EncodeMergePolicyConfig ¶
func EncodeMergePolicyConfig(clientMessage *proto.ClientMessage, mergePolicyConfig types.MergePolicyConfig)
func EncodeMerkleTreeConfig ¶
func EncodeMerkleTreeConfig(clientMessage *proto.ClientMessage, merkleTreeConfig types.MerkleTreeConfig)
func EncodeNearCacheConfigHolder ¶
func EncodeNearCacheConfigHolder(clientMessage *proto.ClientMessage, nearCacheConfigHolder types.NearCacheConfigHolder)
func EncodeNearCachePreloaderConfig ¶
func EncodeNearCachePreloaderConfig(clientMessage *proto.ClientMessage, nearCachePreloaderConfig types.NearCachePreloaderConfig)
func EncodeNullable ¶
func EncodeNullable(message *proto.ClientMessage, value interface{}, encoder Encoder)
func EncodeNullableData ¶
func EncodeNullableData(message *proto.ClientMessage, data iserialization.Data)
func EncodeNullableForBitmapIndexOptions ¶
func EncodeNullableForBitmapIndexOptions(message *proto.ClientMessage, options types.BitmapIndexOptions)
manual
func EncodeNullableForData ¶
func EncodeNullableForData(message *proto.ClientMessage, data iserialization.Data)
func EncodeNullableForEncodeTimedExpiryPolicyFactoryConfig ¶
func EncodeNullableForEncodeTimedExpiryPolicyFactoryConfig(clientMessage *proto.ClientMessage, timedExpiryPolicyFactoryConfig types.TimedExpiryPolicyFactoryConfig)
manual
func EncodeNullableForEventJournalConfig ¶
func EncodeNullableForEventJournalConfig(clientMessage *proto.ClientMessage, eventJournalConfig types.EventJournalConfig)
manual
func EncodeNullableForEvictionConfigHolder ¶
func EncodeNullableForEvictionConfigHolder(clientMessage *proto.ClientMessage, evictionConfigHolder types.EvictionConfigHolder)
manual
func EncodeNullableForHotRestartConfig ¶
func EncodeNullableForHotRestartConfig(clientMessage *proto.ClientMessage, hotRestartConfig types.HotRestartConfig)
manual
func EncodeNullableForMapStoreConfigHolder ¶
func EncodeNullableForMapStoreConfigHolder(clientMessage *proto.ClientMessage, mapStoreConfigHolder types.MapStoreConfigHolder)
manual
func EncodeNullableForMerkleTreeConfig ¶
func EncodeNullableForMerkleTreeConfig(clientMessage *proto.ClientMessage, merkleTreeConfig types.MerkleTreeConfig)
manual
func EncodeNullableForNearCacheConfigHolder ¶
func EncodeNullableForNearCacheConfigHolder(clientMessage *proto.ClientMessage, nearCacheConfigHolder types.NearCacheConfigHolder)
manual
func EncodeNullableForNearCachePreloaderConfig ¶
func EncodeNullableForNearCachePreloaderConfig(clientMessage *proto.ClientMessage, nearCachePreloaderConfig types.NearCachePreloaderConfig)
manual
func EncodeNullableForQueueStoreConfigHolder ¶
func EncodeNullableForQueueStoreConfigHolder(clientMessage *proto.ClientMessage, _ types.QueueStoreConfigHolder)
manual
func EncodeNullableForString ¶
func EncodeNullableForString(message *proto.ClientMessage, value string)
func EncodeNullableForWanReplicationRef ¶
func EncodeNullableForWanReplicationRef(clientMessage *proto.ClientMessage, wanReplicationRef types.WanReplicationRef)
manual
func EncodeNullableListMultiFrameForAttributeConfig ¶
func EncodeNullableListMultiFrameForAttributeConfig(message *proto.ClientMessage, values []types.AttributeConfig)
manual
func EncodeNullableListMultiFrameForIndexConfig ¶
func EncodeNullableListMultiFrameForIndexConfig(message *proto.ClientMessage, values []types.IndexConfig)
manual
func EncodeNullableListMultiFrameForListenerConfigHolder ¶
func EncodeNullableListMultiFrameForListenerConfigHolder(message *proto.ClientMessage, values []types.ListenerConfigHolder)
manual
func EncodeNullableListMultiFrameForQueryCacheConfigHolder ¶
func EncodeNullableListMultiFrameForQueryCacheConfigHolder(message *proto.ClientMessage, values []types.QueryCacheConfigHolder)
manual
func EncodeNullableListMultiFrameForString ¶
func EncodeNullableListMultiFrameForString(message *proto.ClientMessage, values []string)
func EncodeNullableMapForStringAndString ¶
func EncodeNullableMapForStringAndString(message *proto.ClientMessage, values map[string]string)
func EncodePredicateConfigHolder ¶
func EncodePredicateConfigHolder(clientMessage *proto.ClientMessage, predicateConfigHolder types.PredicateConfigHolder)
func EncodeQueryCacheConfigHolder ¶
func EncodeQueryCacheConfigHolder(clientMessage *proto.ClientMessage, queryCacheConfigHolder types.QueryCacheConfigHolder)
func EncodeRaftGroupId ¶
func EncodeRaftGroupId(clientMessage *proto.ClientMessage, raftGroupId types.RaftGroupId)
func EncodeShort ¶
func EncodeString ¶
func EncodeString(message *proto.ClientMessage, value interface{})
func EncodeTieredStoreConfig ¶
func EncodeTieredStoreConfig(clientMessage *proto.ClientMessage, tieredStoreConfig types.TieredStoreConfig)
func EncodeTimedExpiryPolicyFactoryConfig ¶
func EncodeTimedExpiryPolicyFactoryConfig(clientMessage *proto.ClientMessage, timedExpiryPolicyFactoryConfig types.TimedExpiryPolicyFactoryConfig)
func EncodeUUID ¶
func EncodeUUID(buffer []byte, offset int32, uuid clientTypes.UUID)
func EncodeWanReplicationRef ¶
func EncodeWanReplicationRef(clientMessage *proto.ClientMessage, wanReplicationRef types.WanReplicationRef)
func FastForwardToEndFrame ¶
func FastForwardToEndFrame(frameIterator *proto.ForwardFrameIterator)
func NextFrameIsDataStructureEndFrame ¶
func NextFrameIsDataStructureEndFrame(frameIterator *proto.ForwardFrameIterator) bool
func NextFrameIsNullFrame ¶
func NextFrameIsNullFrame(frameIterator *proto.ForwardFrameIterator) bool
Types ¶
type Decoder ¶
type Decoder func(frameIterator *proto.ForwardFrameIterator) iserialization.Data
Decoder creates iserialization.Data
type Encoder ¶
type Encoder func(message *proto.ClientMessage, value interface{})
Encoder for ClientMessage and value
Source Files ¶
- attribute_config_codec.go
- bitmap_index_options_codec.go
- builtin.go
- cache_config_holder_codec.go
- cache_create_config_codec.go
- cache_get_all_codec.go
- cache_get_codec.go
- cache_get_config_codec.go
- cache_put_all_codec.go
- cache_put_codec.go
- capacity_codec.go
- cp_group_create_cp_group_codec.go
- cp_group_destroy_cp_object_codec.go
- cp_map_compare_and_set_codec.go
- cp_map_delete_codec.go
- cp_map_get_codec.go
- cp_map_put_codec.go
- cp_map_remove_codec.go
- cp_map_set_codec.go
- data_persistence_config_codec.go
- disk_tier_config_codec.go
- duration_config_codec.go
- dynamic_config_add_cache_config_codec.go
- dynamic_config_add_durable_executor_config_codec.go
- dynamic_config_add_executor_config_codec.go
- dynamic_config_add_map_config_codec.go
- dynamic_config_add_multimap_config_codec.go
- dynamic_config_add_queue_config_codec.go
- dynamic_config_add_replicatedmap_config_codec.go
- dynamic_config_add_scheduled_executor_config_codec.go
- dynamic_config_add_topic_config_codec.go
- event_journal_config_codec.go
- eviction_config_holder_codec.go
- hot_restart_config_codec.go
- index_config_codec.go
- jet_export_snapshot_codec.go
- jet_get_job_and_sql_summary_list_codec.go
- jet_resume_job_codec.go
- jet_terminate_job_codec.go
- jet_upload_job_meta_data_codec.go
- jet_upload_job_multipart_codec.go
- job_and_sql_summary_codec.go
- listener_config_holder_codec.go
- map_store_config_holder_codec.go
- mc_add_wan_batch_publisher_config_codec.go
- mc_change_cluster_state_codec.go
- mc_change_wan_replication_state_codec.go
- mc_clear_wan_queues_codec.go
- mc_event_codec.go
- mc_get_cluster_metadata_codec.go
- mc_get_map_config_codec.go
- mc_get_member_config_codec.go
- mc_get_timed_member_state_codec.go
- mc_interrupt_hot_restart_backup_codec.go
- mc_poll_mc_events_codec.go
- mc_trigger_hot_restart_backup_codec.go
- mc_update_map_config_codec.go
- mc_wan_sync_map_codec.go
- memory_tier_config_codec.go
- merge_policy_config_codec.go
- merkle_tree_config_codec.go
- near_cache_config_holder_codec.go
- near_cache_preloader_config_codec.go
- predicate_config_holder_codec.go
- query_cache_config_holder_codec.go
- raft_group_id_codec.go
- sql_summary_codec.go
- tiered_store_config_codec.go
- timed_expiry_policy_factory_config_codec.go
- wan_replication_ref_codec.go
Click to show internal directories.
Click to hide internal directories.