codec

package
v0.0.0-...-c55d01b Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 18, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

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 DecodeBoolean(buffer []byte, offset int32) bool

func DecodeByte 

func DecodeByte(buffer []byte, offset int32) byte

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 DecodeDouble(buffer []byte, offset int32) float64

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 DecodeFloat(buffer []byte, offset int32) float32

func DecodeHotRestartConfig 

func DecodeHotRestartConfig(frameIterator *proto.ForwardFrameIterator) types.HotRestartConfig

func DecodeIndexConfig 

func DecodeIndexConfig(frameIterator *proto.ForwardFrameIterator) types.IndexConfig

func DecodeInt 

func DecodeInt(buffer []byte, offset int32) int32

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 DecodeLong(buffer []byte, offset int32) int64

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 DecodeShort(buffer []byte, offset int32) int16

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 EncodeBoolean(buffer []byte, offset int32, value bool)

func EncodeByte 

func EncodeByte(buffer []byte, offset int32, value byte)

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 EncodeDouble(buffer []byte, offset int32, value float64)

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 EncodeFloat(buffer []byte, offset int32, value float32)

func EncodeHotRestartConfig 

func EncodeHotRestartConfig(clientMessage *proto.ClientMessage, hotRestartConfig types.HotRestartConfig)

func EncodeIndexConfig 

func EncodeIndexConfig(clientMessage *proto.ClientMessage, indexConfig types.IndexConfig)

func EncodeInt 

func EncodeInt(buffer []byte, offset, value int32)

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 EncodeJetUploadJobMultipartRequest 

func EncodeJetUploadJobMultipartRequest(sessionId types.UUID, currentPartNumber int32, totalPartNumber int32, partData []byte, partSize int32) *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 EncodeLong(buffer []byte, offset int32, value int64)

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 EncodeMCUpdateMapConfigRequest 

func EncodeMCUpdateMapConfigRequest(mapName string, timeToLiveSeconds int32, maxIdleSeconds int32, evictionPolicy int32, readBackupData bool, maxSize int32, maxSizePolicy int32) *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 EncodeShort(buffer []byte, offset, value int32)

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

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.