hazelcast

package module

Go to main page

Versions in this module

v1

v1.4.1

Aug 22, 2023

v1.4.0

Mar 17, 2023

Changes in this version

+ const MaxBatchSize

+ const ReadResultSetSequenceUnavailable

+ const ServiceNameRingBuffer

+ type AtomicLong = icp.AtomicLong

+ type CPSubsystem = icp.Subsystem

type Client

+ func (c *Client) CPSubsystem() CPSubsystem

type FlakeIDGenerator

+ func (p FlakeIDGenerator) Name() string

type FlakeIDGeneratorConfig

+ func (f *FlakeIDGeneratorConfig) Clone() FlakeIDGeneratorConfig

type List

+ func (p List) Name() string

type Map

+ func (p Map) Name() string

type MultiMap

+ func (p MultiMap) Name() string

+ type OverflowPolicy int

+ const OverflowPolicyFail

+ const OverflowPolicyOverwrite

type PNCounter

+ func (p PNCounter) Name() string

type Queue

+ func (p Queue) Name() string

+ type ReadResultSet struct

+ func (rrs *ReadResultSet) Get(index int) (interface{}, error)

+ func (rrs *ReadResultSet) GetNextSequenceToReadFrom() int64

+ func (rrs *ReadResultSet) GetSequence(index int) (int64, error)

+ func (rrs *ReadResultSet) ReadCount() int32

+ func (rrs *ReadResultSet) Size() int

type ReplicatedMap

+ func (p ReplicatedMap) Name() string

+ type Ringbuffer struct

+ func (p Ringbuffer) Destroy(ctx context.Context) error

+ func (p Ringbuffer) Name() string

+ func (rb *Ringbuffer) Add(ctx context.Context, item interface{}, overflowPolicy OverflowPolicy) (sequence int64, err error)

+ func (rb *Ringbuffer) AddAll(ctx context.Context, overflowPolicy OverflowPolicy, items ...interface{}) (int64, error)

+ func (rb *Ringbuffer) Capacity(ctx context.Context) (int64, error)

+ func (rb *Ringbuffer) HeadSequence(ctx context.Context) (int64, error)

+ func (rb *Ringbuffer) ReadMany(ctx context.Context, startSequence int64, minCount int32, maxCount int32, ...) (ReadResultSet, error)

+ func (rb *Ringbuffer) ReadOne(ctx context.Context, sequence int64) (interface{}, error)

+ func (rb *Ringbuffer) RemainingCapacity(ctx context.Context) (int64, error)

+ func (rb *Ringbuffer) Size(ctx context.Context) (int64, error)

+ func (rb *Ringbuffer) TailSequence(ctx context.Context) (int64, error)

type Set

+ func (p Set) Name() string

type Topic

+ func (p Topic) Name() string

v1.3.2

Feb 9, 2023

v1.3.1

Oct 5, 2022

v1.3.0

Jul 21, 2022

Changes in this version

type Config

+ NearCacheInvalidation NearCacheInvalidationConfig

+ NearCaches []nearcache.Config

+ func (c *Config) AddNearCache(cfg nearcache.Config)

+ func (c *Config) GetNearCache(pattern string) (nearcache.Config, bool, error)

+ func (c Config) MarshalJSON() ([]byte, error)

+ type LocalMapStats struct

+ NearCacheStats nearcache.Stats

type Map

+ func (m *Map) AddListener(ctx context.Context, listener MapListener, includeValue bool) (types.UUID, error)

+ func (m *Map) AddListenerWithKey(ctx context.Context, listener MapListener, key interface{}, includeValue bool) (types.UUID, error)

+ func (m *Map) AddListenerWithPredicate(ctx context.Context, listener MapListener, predicate predicate.Predicate, ...) (types.UUID, error)

+ func (m *Map) AddListenerWithPredicateAndKey(ctx context.Context, listener MapListener, predicate predicate.Predicate, ...) (types.UUID, error)

+ func (m *Map) LocalMapStats() LocalMapStats

+ func (m *Map) RemoveListener(ctx context.Context, subscriptionID types.UUID) error

+ type MapListener struct

+ EntryAdded func(event *EntryNotified)

+ EntryEvicted func(event *EntryNotified)

+ EntryExpired func(event *EntryNotified)

+ EntryLoaded func(event *EntryNotified)

+ EntryMerged func(event *EntryNotified)

+ EntryRemoved func(event *EntryNotified)

+ EntryUpdated func(event *EntryNotified)

+ MapCleared func(event *EntryNotified)

+ MapEvicted func(event *EntryNotified)

+ type NearCacheInvalidationConfig struct

+ func (pc *NearCacheInvalidationConfig) ReconciliationIntervalSeconds() int

+ func (pc *NearCacheInvalidationConfig) SetMaxToleratedMissCount(count int)

+ func (pc *NearCacheInvalidationConfig) SetReconciliationIntervalSeconds(seconds int)

+ func (pc *NearCacheInvalidationConfig) UnmarshalJSON(b []byte) error

+ func (pc NearCacheInvalidationConfig) Clone() NearCacheInvalidationConfig

+ func (pc NearCacheInvalidationConfig) MarshalJSON() ([]byte, error)

+ func (pc NearCacheInvalidationConfig) MaxToleratedMissCount() int

+ func (pc NearCacheInvalidationConfig) Validate() error

v1.2.1

Jul 7, 2022

v1.2.0

Apr 13, 2022

Changes in this version

+ const ServiceNameMultiMap

type Client

+ func (c *Client) SQL() sql.Service

type Map

+ func (m *Map) ExecuteOnKey(ctx context.Context, entryProcessor interface{}, key interface{}) (interface{}, error)

+ func (m *Map) ExecuteOnKeys(ctx context.Context, entryProcessor interface{}, keys ...interface{}) ([]interface{}, error)

+ func (m *Map) SetTTLAffected(ctx context.Context, key interface{}, ttl time.Duration) (bool, error)

+ type MultiMap struct

+ func (m *MultiMap) Clear(ctx context.Context) error

+ func (m *MultiMap) ContainsEntry(ctx context.Context, key interface{}, value interface{}) (bool, error)

+ func (m *MultiMap) ContainsKey(ctx context.Context, key interface{}) (bool, error)

+ func (m *MultiMap) ContainsValue(ctx context.Context, value interface{}) (bool, error)

+ func (m *MultiMap) Delete(ctx context.Context, key interface{}) error

+ func (m *MultiMap) ForceUnlock(ctx context.Context, key interface{}) error

+ func (m *MultiMap) Get(ctx context.Context, key interface{}) ([]interface{}, error)

+ func (m *MultiMap) GetEntrySet(ctx context.Context) ([]types.Entry, error)

+ func (m *MultiMap) GetKeySet(ctx context.Context) ([]interface{}, error)

+ func (m *MultiMap) GetValues(ctx context.Context) ([]interface{}, error)

+ func (m *MultiMap) IsLocked(ctx context.Context, key interface{}) (bool, error)

+ func (m *MultiMap) Lock(ctx context.Context, key interface{}) error

+ func (m *MultiMap) LockWithLease(ctx context.Context, key interface{}, leaseTime time.Duration) error

+ func (m *MultiMap) NewLockContext(ctx context.Context) context.Context

+ func (m *MultiMap) Put(ctx context.Context, key interface{}, value interface{}) (bool, error)

+ func (m *MultiMap) PutAll(ctx context.Context, key interface{}, values ...interface{}) error

+ func (m *MultiMap) Remove(ctx context.Context, key interface{}) ([]interface{}, error)

+ func (m *MultiMap) RemoveEntry(ctx context.Context, key interface{}, value interface{}) (bool, error)

+ func (m *MultiMap) Size(ctx context.Context) (int, error)

+ func (m *MultiMap) TryLock(ctx context.Context, key interface{}) (bool, error)

+ func (m *MultiMap) TryLockWithLease(ctx context.Context, key interface{}, lease time.Duration) (bool, error)

+ func (m *MultiMap) TryLockWithLeaseAndTimeout(ctx context.Context, key interface{}, lease time.Duration, ...) (bool, error)

+ func (m *MultiMap) TryLockWithTimeout(ctx context.Context, key interface{}, timeout time.Duration) (bool, error)

+ func (m *MultiMap) Unlock(ctx context.Context, key interface{}) error

+ func (m *MultiMap) ValueCount(ctx context.Context, key interface{}) (int, error)

+ func (p MultiMap) Destroy(ctx context.Context) error

v1.1.1

Nov 9, 2021

Changes in this version

type Map

+ func (m *Map) ExecuteOnEntriesWithPredicate(ctx context.Context, entryProcessor interface{}, pred predicate.Predicate) ([]types.Entry, error)

v1.1.0

Sep 14, 2021

Changes in this version

+ const ClientVersion

+ const ServiceNameFlakeIDGenerator

type Client

+ func (c *Client) GetDistributedObjectsInfo(ctx context.Context) ([]types.DistributedObjectInfo, error)

type Config

+ Failover cluster.FailoverConfig

+ FlakeIDGenerators map[string]FlakeIDGeneratorConfig

+ func (c *Config) AddFlakeIDGenerator(name string, prefetchCount int32, prefetchExpiry types.Duration) error

+ type FlakeIDGenerator struct

+ func (f *FlakeIDGenerator) NewID(ctx context.Context) (int64, error)

+ func (p FlakeIDGenerator) Destroy(ctx context.Context) error

+ type FlakeIDGeneratorConfig struct

+ PrefetchCount int32

+ PrefetchExpiry types.Duration

+ func (f *FlakeIDGeneratorConfig) Validate() error

type LifecycleState

+ const LifecycleStateChangedCluster

v1.0.0

Jul 13, 2021

Changes in this version

+ const ServiceNameList

+ const ServiceNameMap

+ const ServiceNamePNCounter

+ const ServiceNameQueue

+ const ServiceNameReplicatedMap

+ const ServiceNameSet

+ const ServiceNameTopic

type Client

+ func StartNewClient(ctx context.Context) (*Client, error)

+ func StartNewClientWithConfig(ctx context.Context, config Config) (*Client, error)

+ func (c *Client) AddDistributedObjectListener(ctx context.Context, handler DistributedObjectNotifiedHandler) (types.UUID, error)

+ func (c *Client) AddLifecycleListener(handler LifecycleStateChangeHandler) (types.UUID, error)

+ func (c *Client) AddMembershipListener(handler cluster.MembershipStateChangeHandler) (types.UUID, error)

+ func (c *Client) RemoveDistributedObjectListener(ctx context.Context, subscriptionID types.UUID) error

+ func (c *Client) RemoveLifecycleListener(subscriptionID types.UUID) error

+ func (c *Client) RemoveMembershipListener(subscriptionID types.UUID) error

+ func (c *Client) Running() bool

+ type Config struct

+ ClientName string

+ Cluster cluster.Config

+ Labels []string

+ Logger logger.Config

+ Serialization serialization.Config

+ Stats StatsConfig

+ func (c *Config) AddLifecycleListener(handler LifecycleStateChangeHandler) types.UUID

+ func (c *Config) AddMembershipListener(handler cluster.MembershipStateChangeHandler) types.UUID

+ func (c *Config) Clone() Config

+ func (c *Config) SetLabels(labels ...string)

+ func (c *Config) Validate() error

+ type DistributedObjectEventType string

+ const DistributedObjectCreated

+ const DistributedObjectDestroyed

+ type DistributedObjectNotified struct

+ EventType DistributedObjectEventType

+ ObjectName string

+ ServiceName string

+ func (d DistributedObjectNotified) EventName() string

+ type DistributedObjectNotifiedHandler func(event DistributedObjectNotified)

+ type EntryEventType int32

+ const EntryAdded

+ const EntryAllCleared

+ const EntryAllEvicted

+ const EntryEvicted

+ const EntryExpired

+ const EntryInvalidated

+ const EntryLoaded

+ const EntryMerged

+ const EntryRemoved

+ const EntryUpdated

+ type EntryNotified struct

+ EventType EntryEventType

+ Key interface{}

+ MapName string

+ Member cluster.MemberInfo

+ MergingValue interface{}

+ NumberOfAffectedEntries int

+ OldValue interface{}

+ Value interface{}

+ func (e *EntryNotified) EventName() string

+ type EntryNotifiedHandler func(event *EntryNotified)

+ type ItemEventType int32

+ const ItemAdded

+ const ItemRemoved

+ type LifecycleState int

+ const LifecycleStateConnected

+ const LifecycleStateDisconnected

+ const LifecycleStateShutDown

+ const LifecycleStateShuttingDown

+ const LifecycleStateStarted

+ const LifecycleStateStarting

+ func (s LifecycleState) String() string

+ type LifecycleStateChangeHandler func(event LifecycleStateChanged)

+ type LifecycleStateChanged struct

+ State LifecycleState

+ func (e *LifecycleStateChanged) EventName() string

+ type List struct

+ func (l *List) Add(ctx context.Context, element interface{}) (bool, error)

+ func (l *List) AddAll(ctx context.Context, elements ...interface{}) (bool, error)

+ func (l *List) AddAllAt(ctx context.Context, index int, elements ...interface{}) (bool, error)

+ func (l *List) AddAt(ctx context.Context, index int, element interface{}) error

+ func (l *List) AddListener(ctx context.Context, includeValue bool, handler ListItemNotifiedHandler) (types.UUID, error)

+ func (l *List) Clear(ctx context.Context) error

+ func (l *List) Contains(ctx context.Context, element interface{}) (bool, error)

+ func (l *List) ContainsAll(ctx context.Context, elements ...interface{}) (bool, error)

+ func (l *List) Get(ctx context.Context, index int) (interface{}, error)

+ func (l *List) GetAll(ctx context.Context) ([]interface{}, error)

+ func (l *List) IndexOf(ctx context.Context, element interface{}) (int, error)

+ func (l *List) IsEmpty(ctx context.Context) (bool, error)

+ func (l *List) LastIndexOf(ctx context.Context, element interface{}) (int, error)

+ func (l *List) Remove(ctx context.Context, element interface{}) (bool, error)

+ func (l *List) RemoveAll(ctx context.Context, elements ...interface{}) (bool, error)

+ func (l *List) RemoveAt(ctx context.Context, index int) (interface{}, error)

+ func (l *List) RemoveListener(ctx context.Context, subscriptionID types.UUID) error

+ func (l *List) RetainAll(ctx context.Context, elements ...interface{}) (bool, error)

+ func (l *List) Set(ctx context.Context, index int, element interface{}) (interface{}, error)

+ func (l *List) Size(ctx context.Context) (int, error)

+ func (l *List) SubList(ctx context.Context, start int, end int) ([]interface{}, error)

+ func (p List) Destroy(ctx context.Context) error

+ type ListItemNotified struct

+ EventType ItemEventType

+ ListName string

+ Member cluster.MemberInfo

+ Value interface{}

+ func (q ListItemNotified) EventName() string

+ type ListItemNotifiedHandler func(event *ListItemNotified)

+ type Map struct

+ func (m *Map) AddEntryListener(ctx context.Context, config MapEntryListenerConfig, ...) (types.UUID, error)

+ func (m *Map) AddIndex(ctx context.Context, indexConfig types.IndexConfig) error

+ func (m *Map) AddInterceptor(ctx context.Context, interceptor interface{}) (string, error)

+ func (m *Map) Aggregate(ctx context.Context, agg aggregate.Aggregator) (interface{}, error)

+ func (m *Map) AggregateWithPredicate(ctx context.Context, agg aggregate.Aggregator, pred predicate.Predicate) (interface{}, error)

+ func (m *Map) Clear(ctx context.Context) error

+ func (m *Map) ContainsKey(ctx context.Context, key interface{}) (bool, error)

+ func (m *Map) ContainsValue(ctx context.Context, value interface{}) (bool, error)

+ func (m *Map) Delete(ctx context.Context, key interface{}) error

+ func (m *Map) Evict(ctx context.Context, key interface{}) (bool, error)

+ func (m *Map) EvictAll(ctx context.Context) error

+ func (m *Map) ExecuteOnEntries(ctx context.Context, entryProcessor interface{}) ([]types.Entry, error)

+ func (m *Map) Flush(ctx context.Context) error

+ func (m *Map) ForceUnlock(ctx context.Context, key interface{}) error

+ func (m *Map) Get(ctx context.Context, key interface{}) (interface{}, error)

+ func (m *Map) GetAll(ctx context.Context, keys ...interface{}) ([]types.Entry, error)

+ func (m *Map) GetEntrySet(ctx context.Context) ([]types.Entry, error)

+ func (m *Map) GetEntrySetWithPredicate(ctx context.Context, predicate predicate.Predicate) ([]types.Entry, error)

+ func (m *Map) GetEntryView(ctx context.Context, key interface{}) (*types.SimpleEntryView, error)

+ func (m *Map) GetKeySet(ctx context.Context) ([]interface{}, error)

+ func (m *Map) GetKeySetWithPredicate(ctx context.Context, predicate predicate.Predicate) ([]interface{}, error)

+ func (m *Map) GetValues(ctx context.Context) ([]interface{}, error)

+ func (m *Map) GetValuesWithPredicate(ctx context.Context, predicate predicate.Predicate) ([]interface{}, error)

+ func (m *Map) IsEmpty(ctx context.Context) (bool, error)

+ func (m *Map) IsLocked(ctx context.Context, key interface{}) (bool, error)

+ func (m *Map) LoadAllReplacing(ctx context.Context, keys ...interface{}) error

+ func (m *Map) LoadAllWithoutReplacing(ctx context.Context, keys ...interface{}) error

+ func (m *Map) Lock(ctx context.Context, key interface{}) error

+ func (m *Map) LockWithLease(ctx context.Context, key interface{}, leaseTime time.Duration) error

+ func (m *Map) NewLockContext(ctx context.Context) context.Context

+ func (m *Map) Put(ctx context.Context, key interface{}, value interface{}) (interface{}, error)

+ func (m *Map) PutAll(ctx context.Context, entries ...types.Entry) error

+ func (m *Map) PutIfAbsent(ctx context.Context, key interface{}, value interface{}) (interface{}, error)

+ func (m *Map) PutIfAbsentWithTTL(ctx context.Context, key interface{}, value interface{}, ttl time.Duration) (interface{}, error)

+ func (m *Map) PutIfAbsentWithTTLAndMaxIdle(ctx context.Context, key interface{}, value interface{}, ttl time.Duration, ...) (interface{}, error)

+ func (m *Map) PutTransient(ctx context.Context, key interface{}, value interface{}) error

+ func (m *Map) PutTransientWithMaxIdle(ctx context.Context, key interface{}, value interface{}, maxIdle time.Duration) error

+ func (m *Map) PutTransientWithTTL(ctx context.Context, key interface{}, value interface{}, ttl time.Duration) error

+ func (m *Map) PutTransientWithTTLAndMaxIdle(ctx context.Context, key interface{}, value interface{}, ttl time.Duration, ...) error

+ func (m *Map) PutWithMaxIdle(ctx context.Context, key interface{}, value interface{}, maxIdle time.Duration) (interface{}, error)

+ func (m *Map) PutWithTTL(ctx context.Context, key interface{}, value interface{}, ttl time.Duration) (interface{}, error)

+ func (m *Map) PutWithTTLAndMaxIdle(ctx context.Context, key interface{}, value interface{}, ttl time.Duration, ...) (interface{}, error)

+ func (m *Map) Remove(ctx context.Context, key interface{}) (interface{}, error)

+ func (m *Map) RemoveAll(ctx context.Context, predicate predicate.Predicate) error

+ func (m *Map) RemoveEntryListener(ctx context.Context, subscriptionID types.UUID) error

+ func (m *Map) RemoveIfSame(ctx context.Context, key interface{}, value interface{}) (bool, error)

+ func (m *Map) RemoveInterceptor(ctx context.Context, registrationID string) (bool, error)

+ func (m *Map) Replace(ctx context.Context, key interface{}, value interface{}) (interface{}, error)

+ func (m *Map) ReplaceIfSame(ctx context.Context, key interface{}, oldValue interface{}, ...) (bool, error)

+ func (m *Map) Set(ctx context.Context, key interface{}, value interface{}) error

+ func (m *Map) SetTTL(ctx context.Context, key interface{}, ttl time.Duration) error

+ func (m *Map) SetWithTTL(ctx context.Context, key interface{}, value interface{}, ttl time.Duration) error

+ func (m *Map) SetWithTTLAndMaxIdle(ctx context.Context, key interface{}, value interface{}, ttl time.Duration, ...) error

+ func (m *Map) Size(ctx context.Context) (int, error)

+ func (m *Map) TryLock(ctx context.Context, key interface{}) (bool, error)

+ func (m *Map) TryLockWithLease(ctx context.Context, key interface{}, lease time.Duration) (bool, error)

+ func (m *Map) TryLockWithLeaseAndTimeout(ctx context.Context, key interface{}, lease time.Duration, ...) (bool, error)

+ func (m *Map) TryLockWithTimeout(ctx context.Context, key interface{}, timeout time.Duration) (bool, error)

+ func (m *Map) TryPut(ctx context.Context, key interface{}, value interface{}) (bool, error)

+ func (m *Map) TryPutWithTimeout(ctx context.Context, key interface{}, value interface{}, timeout time.Duration) (bool, error)

+ func (m *Map) TryRemove(ctx context.Context, key interface{}) (interface{}, error)

+ func (m *Map) TryRemoveWithTimeout(ctx context.Context, key interface{}, timeout time.Duration) (interface{}, error)

+ func (m *Map) Unlock(ctx context.Context, key interface{}) error

+ func (p Map) Destroy(ctx context.Context) error

+ type MapEntryListenerConfig struct

+ IncludeValue bool

+ Key interface{}

+ Predicate predicate.Predicate

+ func (c *MapEntryListenerConfig) NotifyEntryAdded(enable bool)

+ func (c *MapEntryListenerConfig) NotifyEntryAllCleared(enable bool)

+ func (c *MapEntryListenerConfig) NotifyEntryAllEvicted(enable bool)

+ func (c *MapEntryListenerConfig) NotifyEntryEvicted(enable bool)

+ func (c *MapEntryListenerConfig) NotifyEntryExpired(enable bool)

+ func (c *MapEntryListenerConfig) NotifyEntryInvalidated(enable bool)

+ func (c *MapEntryListenerConfig) NotifyEntryLoaded(enable bool)

+ func (c *MapEntryListenerConfig) NotifyEntryMerged(enable bool)

+ func (c *MapEntryListenerConfig) NotifyEntryRemoved(enable bool)

+ func (c *MapEntryListenerConfig) NotifyEntryUpdated(enable bool)

+ type MessagePublished struct

+ Member cluster.MemberInfo

+ PublishTime time.Time

+ TopicName string

+ Value interface{}

+ func (m *MessagePublished) EventName() string

+ type PNCounter struct

+ func (p PNCounter) Destroy(ctx context.Context) error

+ func (pn *PNCounter) AddAndGet(ctx context.Context, delta int64) (int64, error)

+ func (pn *PNCounter) DecrementAndGet(ctx context.Context) (int64, error)

+ func (pn *PNCounter) Get(ctx context.Context) (int64, error)

+ func (pn *PNCounter) GetAndAdd(ctx context.Context, delta int64) (int64, error)

+ func (pn *PNCounter) GetAndDecrement(ctx context.Context) (int64, error)

+ func (pn *PNCounter) GetAndIncrement(ctx context.Context) (int64, error)

+ func (pn *PNCounter) GetAndSubtract(ctx context.Context, delta int64) (int64, error)

+ func (pn *PNCounter) IncrementAndGet(ctx context.Context) (int64, error)

+ func (pn *PNCounter) Reset()

+ func (pn *PNCounter) SubtractAndGet(ctx context.Context, delta int64) (int64, error)

+ type Queue struct

+ func (p Queue) Destroy(ctx context.Context) error

+ func (q *Queue) Add(ctx context.Context, value interface{}) (bool, error)

+ func (q *Queue) AddAll(ctx context.Context, values ...interface{}) (bool, error)

+ func (q *Queue) AddItemListener(ctx context.Context, includeValue bool, handler QueueItemNotifiedHandler) (types.UUID, error)

+ func (q *Queue) AddWithTimeout(ctx context.Context, value interface{}, timeout time.Duration) (bool, error)

+ func (q *Queue) Clear(ctx context.Context) error

+ func (q *Queue) Contains(ctx context.Context, value interface{}) (bool, error)

+ func (q *Queue) ContainsAll(ctx context.Context, values ...interface{}) (bool, error)

+ func (q *Queue) Drain(ctx context.Context) ([]interface{}, error)

+ func (q *Queue) DrainWithMaxSize(ctx context.Context, maxSize int) ([]interface{}, error)

+ func (q *Queue) GetAll(ctx context.Context) ([]interface{}, error)

+ func (q *Queue) IsEmpty(ctx context.Context) (bool, error)

+ func (q *Queue) Peek(ctx context.Context) (interface{}, error)

+ func (q *Queue) Poll(ctx context.Context) (interface{}, error)

+ func (q *Queue) PollWithTimeout(ctx context.Context, timeout time.Duration) (interface{}, error)

+ func (q *Queue) Put(ctx context.Context, value interface{}) error

+ func (q *Queue) RemainingCapacity(ctx context.Context) (int, error)

+ func (q *Queue) Remove(ctx context.Context, value interface{}) (bool, error)

+ func (q *Queue) RemoveAll(ctx context.Context, values ...interface{}) (bool, error)

+ func (q *Queue) RemoveListener(ctx context.Context, subscriptionID types.UUID) error

+ func (q *Queue) RetainAll(ctx context.Context, values ...interface{}) (bool, error)

+ func (q *Queue) Size(ctx context.Context) (int, error)

+ func (q *Queue) Take(ctx context.Context) (interface{}, error)

+ type QueueItemNotified struct

+ EventType ItemEventType

+ Member cluster.MemberInfo

+ QueueName string

+ Value interface{}

+ func (q QueueItemNotified) EventName() string

+ type QueueItemNotifiedHandler func(event *QueueItemNotified)

+ type ReplicatedMap struct

+ func (m *ReplicatedMap) AddEntryListener(ctx context.Context, handler EntryNotifiedHandler) (types.UUID, error)

+ func (m *ReplicatedMap) AddEntryListenerToKey(ctx context.Context, key interface{}, handler EntryNotifiedHandler) (types.UUID, error)

+ func (m *ReplicatedMap) AddEntryListenerToKeyWithPredicate(ctx context.Context, key interface{}, predicate predicate.Predicate, ...) (types.UUID, error)

+ func (m *ReplicatedMap) AddEntryListenerWithPredicate(ctx context.Context, predicate predicate.Predicate, ...) (types.UUID, error)

+ func (m *ReplicatedMap) Clear(ctx context.Context) error

+ func (m *ReplicatedMap) ContainsKey(ctx context.Context, key interface{}) (bool, error)

+ func (m *ReplicatedMap) ContainsValue(ctx context.Context, value interface{}) (bool, error)

+ func (m *ReplicatedMap) Get(ctx context.Context, key interface{}) (interface{}, error)

+ func (m *ReplicatedMap) GetEntrySet(ctx context.Context) ([]types.Entry, error)

+ func (m *ReplicatedMap) GetKeySet(ctx context.Context) ([]interface{}, error)

+ func (m *ReplicatedMap) GetValues(ctx context.Context) ([]interface{}, error)

+ func (m *ReplicatedMap) IsEmpty(ctx context.Context) (bool, error)

+ func (m *ReplicatedMap) Put(ctx context.Context, key interface{}, value interface{}) (interface{}, error)

+ func (m *ReplicatedMap) PutAll(ctx context.Context, keyValuePairs ...types.Entry) error

+ func (m *ReplicatedMap) Remove(ctx context.Context, key interface{}) (interface{}, error)

+ func (m *ReplicatedMap) RemoveEntryListener(ctx context.Context, subscriptionID types.UUID) error

+ func (m *ReplicatedMap) Size(ctx context.Context) (int, error)

+ func (p ReplicatedMap) Destroy(ctx context.Context) error

+ type Set struct

+ func (p Set) Destroy(ctx context.Context) error

+ func (s *Set) Add(ctx context.Context, item interface{}) (bool, error)

+ func (s *Set) AddAll(ctx context.Context, values ...interface{}) (bool, error)

+ func (s *Set) AddItemListener(ctx context.Context, includeValue bool, handler SetItemNotifiedHandler) (types.UUID, error)

+ func (s *Set) Clear(ctx context.Context) error

+ func (s *Set) Contains(ctx context.Context, value interface{}) (bool, error)

+ func (s *Set) ContainsAll(ctx context.Context, values ...interface{}) (bool, error)

+ func (s *Set) GetAll(ctx context.Context) ([]interface{}, error)

+ func (s *Set) IsEmpty(ctx context.Context) (bool, error)

+ func (s *Set) Remove(ctx context.Context, value interface{}) (bool, error)

+ func (s *Set) RemoveAll(ctx context.Context, values ...interface{}) (bool, error)

+ func (s *Set) RemoveListener(ctx context.Context, subscriptionID types.UUID) error

+ func (s *Set) RetainAll(ctx context.Context, values ...interface{}) (bool, error)

+ func (s *Set) Size(ctx context.Context) (int, error)

+ type SetItemNotified struct

+ EventType ItemEventType

+ Member cluster.MemberInfo

+ SetName string

+ Value interface{}

+ func (q SetItemNotified) EventName() string

+ type SetItemNotifiedHandler func(event *SetItemNotified)

+ type StatsConfig struct

+ Enabled bool

+ Period types.Duration

+ func (c *StatsConfig) Validate() error

+ type Topic struct

+ func (p Topic) Destroy(ctx context.Context) error

+ func (t *Topic) AddMessageListener(ctx context.Context, handler TopicMessageHandler) (types.UUID, error)

+ func (t *Topic) Publish(ctx context.Context, message interface{}) error

+ func (t *Topic) PublishAll(ctx context.Context, messages ...interface{}) error

+ func (t *Topic) RemoveListener(ctx context.Context, subscriptionID types.UUID) error

+ type TopicMessageHandler func(event *MessagePublished)

v1.0.0-preview.4

Jun 18, 2021

v1.0.0-preview.3

Jun 8, 2021

v1.0.0-preview.2

May 21, 2021

v1.0.0-preview.1

May 7, 2021

v0

v0.6.0

Mar 9, 2020

v0.5.0

Mar 20, 2019

Changes in this version

+ func NewConfig() *config.Config

+ type Client interface

+ Cluster func() core.Cluster

+ GetDistributedObject func(serviceName string, name string) (core.DistributedObject, error)

+ GetFlakeIDGenerator func(name string) (core.FlakeIDGenerator, error)

+ GetList func(name string) (core.List, error)

+ GetMap func(name string) (core.Map, error)

+ GetMultiMap func(name string) (core.MultiMap, error)

+ GetPNCounter func(name string) (core.PNCounter, error)

+ GetQueue func(name string) (core.Queue, error)

+ GetReliableTopic func(name string) (core.Topic, error)

+ GetReplicatedMap func(name string) (core.ReplicatedMap, error)

+ GetRingbuffer func(name string) (core.Ringbuffer, error)

+ GetSet func(name string) (core.Set, error)

+ GetTopic func(name string) (core.Topic, error)

+ LifecycleService func() core.LifecycleService

+ Name func() string

+ Shutdown func()

+ func NewClient() (Client, error)

+ func NewClientWithConfig(config *config.Config) (Client, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL