internal

Documentation

Index

• Variables
• type DefaultNearCacheManager
  • func NewDefaultNearCacheManager(service spi.SerializationService, properties *property.HazelcastProperties) *DefaultNearCacheManager
  • func (d *DefaultNearCacheManager) DestroyAllNearCaches()
  • func (d *DefaultNearCacheManager) DestroyNearCache(name string) bool
  • func (d *DefaultNearCacheManager) GetOrCreateNearCache(name string, config *config.NearCacheConfig) nearcache.NearCache
  • func (d *DefaultNearCacheManager) ListAllNearCaches() []nearcache.NearCache
  • func (d *DefaultNearCacheManager) NearCache(name string) (nearcache.NearCache, bool)
• type NearCache
  • func NewNearCache(name string, nearCacheCfg *config.NearCacheConfig, ...) *NearCache
  • func (d *NearCache) Clear()
  • func (d *NearCache) Destroy()
  • func (d *NearCache) Get(key interface{}) interface{}
  • func (d *NearCache) Initialize()
  • func (d *NearCache) Invalidate(key interface{})
  • func (d *NearCache) Put(key interface{}, value interface{})
  • func (d *NearCache) Record(key interface{}) (nearcache.Record, bool)
  • func (d *NearCache) SetStaleReadDetector(detector nearcache.StaleReadDetector)
  • func (d *NearCache) Size() int
  • func (d *NearCache) StaleReadDetector() nearcache.StaleReadDetector
  • func (d *NearCache) TryPublishReserved(key interface{}, value interface{}, reservationID int64, deserialize bool) (interface{}, bool)
  • func (d *NearCache) TryReserveForUpdate(key interface{}, keyData serialization.Data) (int64, bool)

Variables

var (
	ExpirationTaskInitialDelaySeconds = property.NewHazelcastPropertyInt64WithTimeUnit(
		"hazelcast.internal.nearcache.expiration.task.initial.delay.seconds", 5, time.Second,
	)
	ExpirationTaskPeriodSeconds = property.NewHazelcastPropertyInt64WithTimeUnit(
		"hazelcast.internal.nearcache.expiration.task.period.seconds", 5, time.Second,
	)
)

Types

type DefaultNearCacheManager

type DefaultNearCacheManager struct {
	// contains filtered or unexported fields
}

func NewDefaultNearCacheManager

func NewDefaultNearCacheManager(service spi.SerializationService,
	properties *property.HazelcastProperties) *DefaultNearCacheManager

func (*DefaultNearCacheManager) DestroyAllNearCaches

func (d *DefaultNearCacheManager) DestroyAllNearCaches()

func (*DefaultNearCacheManager) DestroyNearCache

func (d *DefaultNearCacheManager) DestroyNearCache(name string) bool

func (*DefaultNearCacheManager) GetOrCreateNearCache

func (d *DefaultNearCacheManager) GetOrCreateNearCache(name string, config *config.NearCacheConfig) nearcache.NearCache

func (*DefaultNearCacheManager) ListAllNearCaches

func (d *DefaultNearCacheManager) ListAllNearCaches() []nearcache.NearCache

func (*DefaultNearCacheManager) NearCache

func (d *DefaultNearCacheManager) NearCache(name string) (nearcache.NearCache, bool)

type NearCache

type NearCache struct {
	// contains filtered or unexported fields
}

func NewNearCache

func NewNearCache(name string, nearCacheCfg *config.NearCacheConfig,
	service spi.SerializationService, properties *property.HazelcastProperties) *NearCache

func (*NearCache) Clear

func (d *NearCache) Clear()

func (*NearCache) Destroy

func (d *NearCache) Destroy()

func (*NearCache) Get

func (d *NearCache) Get(key interface{}) interface{}

func (*NearCache) Initialize

func (d *NearCache) Initialize()

func (*NearCache) Invalidate

func (d *NearCache) Invalidate(key interface{})

func (*NearCache) Put

func (d *NearCache) Put(key interface{}, value interface{})

func (*NearCache) Record

func (d *NearCache) Record(key interface{}) (nearcache.Record, bool)

func (*NearCache) SetStaleReadDetector

func (d *NearCache) SetStaleReadDetector(detector nearcache.StaleReadDetector)

func (*NearCache) Size

func (d *NearCache) Size() int

func (*NearCache) StaleReadDetector

func (d *NearCache) StaleReadDetector() nearcache.StaleReadDetector

func (*NearCache) TryPublishReserved

func (d *NearCache) TryPublishReserved(key interface{}, value interface{}, reservationID int64,
	deserialize bool) (interface{}, bool)

func (*NearCache) TryReserveForUpdate

func (d *NearCache) TryReserveForUpdate(key interface{}, keyData serialization.Data) (int64, bool)