Documentation ¶
Index ¶
- type DefaultStaleReadDetector
- type MetaDataContainer
- func (m *MetaDataContainer) AddAndGetMissedSequenceCount(missCount int64) int64
- func (m *MetaDataContainer) CompareAndSetSequence(prevSequence int64, newSequence int64) bool
- func (m *MetaDataContainer) CompareAndSetStaleSequence(lastKnownStaleSeq int64, lastReceivedSeq int64) bool
- func (m *MetaDataContainer) CompareAndSetUUID(prevUUID string, newUUID string) bool
- func (m *MetaDataContainer) MissedSequenceCount() int64
- func (m *MetaDataContainer) ResetSequence()
- func (m *MetaDataContainer) ResetStaleSequence()
- func (m *MetaDataContainer) Sequence() int64
- func (m *MetaDataContainer) SetSequence(sequence int64)
- func (m *MetaDataContainer) SetUUID(uuid string)
- func (m *MetaDataContainer) StaleSequence() int64
- func (m *MetaDataContainer) UUID() string
- type MetaDataFetcher
- type RepairingHandler
- func (r *RepairingHandler) CheckOrRepairSequence(partition int32, nextSeq int64, viaAntiEntropy bool)
- func (r *RepairingHandler) CheckOrRepairUUID(partition int32, newUUID string)
- func (r *RepairingHandler) GetPartitionIDOrDefault(key serialization.Data) int32
- func (r *RepairingHandler) HandleBatchInvalidation(keys []serialization.Data, sourceUUIDs []string, partitionUUIDs []*proto.UUID, ...)
- func (r *RepairingHandler) HandleSingleInvalidation(key serialization.Data, sourceUUID string, partitionUUID *proto.UUID, ...)
- func (r *RepairingHandler) InitSequence(partitionID int32, partitionSeq int64)
- func (r *RepairingHandler) InitUUID(partitionID int32, partitionUUID string)
- func (r *RepairingHandler) MetaDataContainer(partitionID int32) *MetaDataContainer
- func (r *RepairingHandler) Name() string
- func (r *RepairingHandler) UpdateLastKnownStaleSequence(metaData *MetaDataContainer, partition int32)
- type RepairingTask
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DefaultStaleReadDetector ¶
type DefaultStaleReadDetector struct {
// contains filtered or unexported fields
}
func NewDefaultStaleReadDetector ¶
func NewDefaultStaleReadDetector(handler *RepairingHandler, service clientspi.PartitionService) *DefaultStaleReadDetector
func (*DefaultStaleReadDetector) IsStaleRead ¶
func (d *DefaultStaleReadDetector) IsStaleRead(key interface{}, record nearcache.Record) bool
func (*DefaultStaleReadDetector) MetaDataContainer ¶
func (d *DefaultStaleReadDetector) MetaDataContainer(partitionID int32) nearcache.MetaDataContainer
func (*DefaultStaleReadDetector) PartitionID ¶
func (d *DefaultStaleReadDetector) PartitionID(keyData serialization.Data) int32
type MetaDataContainer ¶
type MetaDataContainer struct {
// contains filtered or unexported fields
}
func NewMetaDataContainer ¶
func NewMetaDataContainer() *MetaDataContainer
func (*MetaDataContainer) AddAndGetMissedSequenceCount ¶
func (m *MetaDataContainer) AddAndGetMissedSequenceCount(missCount int64) int64
func (*MetaDataContainer) CompareAndSetSequence ¶
func (m *MetaDataContainer) CompareAndSetSequence(prevSequence int64, newSequence int64) bool
func (*MetaDataContainer) CompareAndSetStaleSequence ¶
func (m *MetaDataContainer) CompareAndSetStaleSequence(lastKnownStaleSeq int64, lastReceivedSeq int64) bool
func (*MetaDataContainer) CompareAndSetUUID ¶
func (m *MetaDataContainer) CompareAndSetUUID(prevUUID string, newUUID string) bool
func (*MetaDataContainer) MissedSequenceCount ¶
func (m *MetaDataContainer) MissedSequenceCount() int64
func (*MetaDataContainer) ResetSequence ¶
func (m *MetaDataContainer) ResetSequence()
func (*MetaDataContainer) ResetStaleSequence ¶
func (m *MetaDataContainer) ResetStaleSequence()
func (*MetaDataContainer) Sequence ¶
func (m *MetaDataContainer) Sequence() int64
func (*MetaDataContainer) SetSequence ¶
func (m *MetaDataContainer) SetSequence(sequence int64)
func (*MetaDataContainer) SetUUID ¶
func (m *MetaDataContainer) SetUUID(uuid string)
func (*MetaDataContainer) StaleSequence ¶
func (m *MetaDataContainer) StaleSequence() int64
func (*MetaDataContainer) UUID ¶
func (m *MetaDataContainer) UUID() string
type MetaDataFetcher ¶
type MetaDataFetcher struct {
// contains filtered or unexported fields
}
func NewMetaDataFetcher ¶
func NewMetaDataFetcher(service clientspi.InvocationService, cluster core.Cluster, handlers *sync.Map) *MetaDataFetcher
type RepairingHandler ¶
type RepairingHandler struct {
// contains filtered or unexported fields
}
func NewRepairingHandler ¶
func NewRepairingHandler(localUUID string, name string, nearCache nearcache.NearCache, service spi.SerializationService, partitionService clientspi.PartitionService) *RepairingHandler
func (*RepairingHandler) CheckOrRepairSequence ¶
func (r *RepairingHandler) CheckOrRepairSequence(partition int32, nextSeq int64, viaAntiEntropy bool)
func (*RepairingHandler) CheckOrRepairUUID ¶
func (r *RepairingHandler) CheckOrRepairUUID(partition int32, newUUID string)
func (*RepairingHandler) GetPartitionIDOrDefault ¶
func (r *RepairingHandler) GetPartitionIDOrDefault(key serialization.Data) int32
func (*RepairingHandler) HandleBatchInvalidation ¶
func (r *RepairingHandler) HandleBatchInvalidation(keys []serialization.Data, sourceUUIDs []string, partitionUUIDs []*proto.UUID, sequences []int64)
func (*RepairingHandler) HandleSingleInvalidation ¶
func (r *RepairingHandler) HandleSingleInvalidation(key serialization.Data, sourceUUID string, partitionUUID *proto.UUID, sequence int64)
func (*RepairingHandler) InitSequence ¶
func (r *RepairingHandler) InitSequence(partitionID int32, partitionSeq int64)
func (*RepairingHandler) InitUUID ¶
func (r *RepairingHandler) InitUUID(partitionID int32, partitionUUID string)
func (*RepairingHandler) MetaDataContainer ¶
func (r *RepairingHandler) MetaDataContainer(partitionID int32) *MetaDataContainer
func (*RepairingHandler) Name ¶
func (r *RepairingHandler) Name() string
func (*RepairingHandler) UpdateLastKnownStaleSequence ¶
func (r *RepairingHandler) UpdateLastKnownStaleSequence(metaData *MetaDataContainer, partition int32)
type RepairingTask ¶
type RepairingTask struct {
// contains filtered or unexported fields
}
func NewRepairingTask ¶
func NewRepairingTask(properties *property.HazelcastProperties, service spi.SerializationService, partitionService clientspi.PartitionService, invocationService clientspi.InvocationService, cluster core.Cluster, localUUID string) *RepairingTask
func (*RepairingTask) RegisterAndGetHandler ¶
func (r *RepairingTask) RegisterAndGetHandler(dataStructureName string, cache nearcache.NearCache) nearcache.RepairingHandler
func (*RepairingTask) Shutdown ¶
func (r *RepairingTask) Shutdown()
Click to show internal directories.
Click to hide internal directories.