invalidation

Documentation

Index

• type DefaultStaleReadDetector
  • func NewDefaultStaleReadDetector(handler *RepairingHandler, service clientspi.PartitionService) *DefaultStaleReadDetector
  • func (d *DefaultStaleReadDetector) IsStaleRead(key interface{}, record nearcache.Record) bool
  • func (d *DefaultStaleReadDetector) MetaDataContainer(partitionID int32) nearcache.MetaDataContainer
  • func (d *DefaultStaleReadDetector) PartitionID(keyData serialization.Data) int32
• type MetaDataContainer
  • func NewMetaDataContainer() *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
  • func NewMetaDataFetcher(service clientspi.InvocationService, cluster core.Cluster, handlers *sync.Map) *MetaDataFetcher
• type RepairingHandler
  • func NewRepairingHandler(localUUID string, name string, nearCache nearcache.NearCache, ...) *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
  • func NewRepairingTask(properties *property.HazelcastProperties, service spi.SerializationService, ...) *RepairingTask
  • func (r *RepairingTask) RegisterAndGetHandler(dataStructureName string, cache nearcache.NearCache) nearcache.RepairingHandler
  • func (r *RepairingTask) Shutdown()

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()