Versions in this module Expand all Collapse all v0 v0.6.0 Mar 9, 2020 Changes in this version + type EntryLoadedListener interface + EntryLoaded func(event EntryEvent) v0.5.0 Mar 20, 2019 Changes in this version + const LifecycleStateConnected + const LifecycleStateDisconnected + const LifecycleStateShutdown + const LifecycleStateShuttingDown + const LifecycleStateStarted + const LifecycleStateStarting + const MemberAttributeOperationTypePut + const MemberAttributeOperationTypeRemove + const OverflowPolicyFail + const OverflowPolicyOverwrite + var MemberSelectors = &selectors + type AbstractMapEvent interface + EventType func() int32 + Member func() Member + Name func() string + String func() string + type Address interface + Host func() string + Port func() int + type Cluster interface + AddMembershipListener func(listener interface{}) string + GetMembers func() []Member + RemoveMembershipListener func(registrationID string) bool + type DistributedObject interface + Destroy func() (bool, error) + Name func() string + PartitionKey func() string + ServiceName func() string + type EntryAddedListener interface + EntryAdded func(event EntryEvent) + type EntryEvent interface + Key func() interface{} + MergingValue func() interface{} + OldValue func() interface{} + Value func() interface{} + type EntryEvictedListener interface + EntryEvicted func(event EntryEvent) + type EntryExpiredListener interface + EntryExpired func(event EntryEvent) + type EntryMergedListener interface + EntryMerged func(event EntryEvent) + type EntryRemovedListener interface + EntryRemoved func(event EntryEvent) + type EntryUpdatedListener interface + EntryUpdated func(event EntryEvent) + type EntryView interface + Cost func() int64 + CreationTime func() time.Time + EvictionCriteriaNumber func() int64 + ExpirationTime func() time.Time + Hits func() int64 + Key func() interface{} + LastAccessTime func() time.Time + LastStoredTime func() time.Time + LastUpdateTime func() time.Time + TTL func() time.Duration + Value func() interface{} + Version func() int64 + type FlakeIDGenerator interface + NewID func() (id int64, err error) + type HazelcastAuthenticationError struct + func NewHazelcastAuthenticationError(message string, cause error) *HazelcastAuthenticationError + type HazelcastCertificateError struct + func NewHazelcastCertificateError(message string, cause error) *HazelcastCertificateError + type HazelcastClientNotActiveError struct + func NewHazelcastClientNotActiveError(message string, cause error) *HazelcastClientNotActiveError + type HazelcastClientServiceNotFoundError struct + func NewHazelcastClientServiceNotFoundError(message string, cause error) *HazelcastClientServiceNotFoundError + type HazelcastConsistencyLostError struct + func NewHazelcastConsistencyLostError(message string, cause error) *HazelcastConsistencyLostError + type HazelcastEOFError struct + func NewHazelcastEOFError(message string, cause error) *HazelcastEOFError + type HazelcastError interface + Cause func() error + Error func() string + ServerError func() ServerError + type HazelcastErrorType struct + func NewHazelcastErrorType(message string, cause error) *HazelcastErrorType + func (e *HazelcastErrorType) Cause() error + func (e *HazelcastErrorType) Error() string + func (e *HazelcastErrorType) ServerError() ServerError + type HazelcastIOError struct + func NewHazelcastIOError(message string, cause error) *HazelcastIOError + type HazelcastIllegalArgumentError struct + func NewHazelcastIllegalArgumentError(message string, cause error) *HazelcastIllegalArgumentError + type HazelcastIllegalStateError struct + func NewHazelcastIllegalStateError(message string, cause error) *HazelcastIllegalStateError + type HazelcastInstanceNotActiveError struct + func NewHazelcastInstanceNotActiveError(message string, cause error) *HazelcastInstanceNotActiveError + type HazelcastJSONValue struct + func CreateHazelcastJSONValue(object interface{}) (*HazelcastJSONValue, error) + func CreateHazelcastJSONValueFromString(jsonString string) *HazelcastJSONValue + func (h *HazelcastJSONValue) ToString() string + func (h *HazelcastJSONValue) Unmarshal(v interface{}) error + type HazelcastNilPointerError struct + func NewHazelcastNilPointerError(message string, cause error) *HazelcastNilPointerError + type HazelcastNoDataMemberInClusterError struct + func NewHazelcastNoDataMemberInClusterError(message string, cause error) *HazelcastNoDataMemberInClusterError + type HazelcastOperationTimeoutError struct + func NewHazelcastOperationTimeoutError(message string, cause error) *HazelcastOperationTimeoutError + type HazelcastSerializationError struct + func NewHazelcastSerializationError(message string, cause error) *HazelcastSerializationError + type HazelcastTargetDisconnectedError struct + func NewHazelcastTargetDisconnectedError(message string, cause error) *HazelcastTargetDisconnectedError + type HazelcastTargetNotMemberError struct + func NewHazelcastTargetNotMemberError(message string, cause error) *HazelcastTargetNotMemberError + type HazelcastTopicOverflowError struct + func NewHazelcastTopicOverflowError(message string, cause error) *HazelcastTopicOverflowError + type HazelcastUnsupportedOperationError struct + func NewHazelcastUnsupportedOperationError(message string, cause error) *HazelcastUnsupportedOperationError + type ItemAddedListener interface + ItemAdded func(event ItemEvent) + type ItemEvent interface + EventType func() int32 + Item func() interface{} + Member func() Member + Name func() string + type ItemRemovedListener interface + ItemRemoved func(event ItemEvent) + type LifecycleListener interface + LifecycleStateChanged func(string) + type LifecycleService interface + AddLifecycleListener func(listener interface{}) string + IsRunning func() bool + RemoveLifecycleListener func(registrationID string) bool + type List interface + Add func(element interface{}) (changed bool, err error) + AddAll func(elements []interface{}) (changed bool, err error) + AddAllAt func(index int32, elements []interface{}) (changed bool, err error) + AddAt func(index int32, element interface{}) (err error) + AddItemListener func(listener interface{}, includeValue bool) (registrationID string, err error) + Clear func() (err error) + Contains func(element interface{}) (found bool, err error) + ContainsAll func(elements []interface{}) (foundAll bool, err error) + Get func(index int32) (element interface{}, err error) + IndexOf func(element interface{}) (index int32, err error) + IsEmpty func() (empty bool, err error) + LastIndexOf func(element interface{}) (index int32, err error) + Remove func(element interface{}) (changed bool, err error) + RemoveAll func(elements []interface{}) (changed bool, err error) + RemoveAt func(index int32) (previousElement interface{}, err error) + RemoveItemListener func(registrationID string) (removed bool, err error) + RetainAll func(elements []interface{}) (changed bool, err error) + Set func(index int32, element interface{}) (previousElement interface{}, err error) + Size func() (size int32, err error) + SubList func(start int32, end int32) (elements []interface{}, err error) + ToSlice func() (elements []interface{}, err error) + type LoadBalancer interface + Init func(cluster Cluster) + Next func() Member + type Map interface + AddEntryListener func(listener interface{}, includeValue bool) (registrationID string, err error) + AddEntryListenerToKey func(listener interface{}, key interface{}, includeValue bool) (registrationID string, err error) + AddEntryListenerToKeyWithPredicate func(listener interface{}, predicate interface{}, key interface{}, ...) (registrationID string, err error) + AddEntryListenerWithPredicate func(listener interface{}, predicate interface{}, includeValue bool) (registrationID string, err error) + AddIndex func(attribute string, ordered bool) (err error) + Aggregate func(aggregator interface{}) (result interface{}, err error) + AggregateWithPredicate func(aggregator interface{}, predicate interface{}) (result interface{}, err error) + Clear func() (err error) + ContainsKey func(key interface{}) (found bool, err error) + ContainsValue func(value interface{}) (found bool, err error) + Delete func(key interface{}) (err error) + EntrySet func() (resultPairs []Pair, err error) + EntrySetWithPredicate func(predicate interface{}) (resultPairs []Pair, err error) + Evict func(key interface{}) (evicted bool, err error) + EvictAll func() (err error) + ExecuteOnEntries func(entryProcessor interface{}) (keyToResultPairs []Pair, err error) + ExecuteOnEntriesWithPredicate func(entryProcessor interface{}, predicate interface{}) (keyToResultPairs []Pair, err error) + ExecuteOnKey func(key interface{}, entryProcessor interface{}) (result interface{}, err error) + ExecuteOnKeys func(keys []interface{}, entryProcessor interface{}) (keyToResultPairs []Pair, err error) + Flush func() (err error) + ForceUnlock func(key interface{}) (err error) + Get func(key interface{}) (value interface{}, err error) + GetAll func(keys []interface{}) (entryMap map[interface{}]interface{}, err error) + GetEntryView func(key interface{}) (entryView EntryView, err error) + IsEmpty func() (empty bool, err error) + IsLocked func(key interface{}) (locked bool, err error) + KeySet func() (keySet []interface{}, err error) + KeySetWithPredicate func(predicate interface{}) (keySet []interface{}, err error) + Lock func(key interface{}) (err error) + LockWithLeaseTime func(key interface{}, lease time.Duration) (err error) + Project func(projection interface{}) (result []interface{}, err error) + ProjectWithPredicate func(projection interface{}, predicate interface{}) (result []interface{}, err error) + Put func(key interface{}, value interface{}) (oldValue interface{}, err error) + PutAll func(entries map[interface{}]interface{}) (err error) + PutIfAbsent func(key interface{}, value interface{}) (oldValue interface{}, err error) + PutTransient func(key interface{}, value interface{}, ttl time.Duration) (err error) + Remove func(key interface{}) (value interface{}, err error) + RemoveAll func(predicate interface{}) (err error) + RemoveEntryListener func(registrationID string) (removed bool, err error) + RemoveIfSame func(key interface{}, value interface{}) (ok bool, err error) + Replace func(key interface{}, value interface{}) (oldValue interface{}, err error) + ReplaceIfSame func(key interface{}, oldValue interface{}, newValue interface{}) (replaced bool, err error) + Set func(key interface{}, value interface{}) (err error) + SetWithTTL func(key interface{}, value interface{}, ttl time.Duration) (err error) + Size func() (size int32, err error) + TryLock func(key interface{}) (locked bool, err error) + TryLockWithTimeout func(key interface{}, timeout time.Duration) (locked bool, err error) + TryLockWithTimeoutAndLease func(key interface{}, timeout time.Duration, lease time.Duration) (locked bool, err error) + TryPut func(key interface{}, value interface{}) (ok bool, err error) + TryPutWithTimeout func(key interface{}, value interface{}, timeout time.Duration) (ok bool, err error) + TryRemove func(key interface{}, timeout time.Duration) (ok bool, err error) + Unlock func(key interface{}) (err error) + Values func() (values []interface{}, err error) + ValuesWithPredicate func(predicate interface{}) (values []interface{}, err error) + type MapClearedListener interface + MapCleared func(event MapEvent) + type MapEvent interface + NumberOfAffectedEntries func() int32 + type MapEvictedListener interface + MapEvicted func(event MapEvent) + type Member interface + Address func() Address + Attributes func() map[string]string + IsLiteMember func() bool + UUID func() string + type MemberAddedListener interface + MemberAdded func(member Member) + type MemberAttributeChangedListener interface + MemberAttributeChanged func(event MemberAttributeEvent) + type MemberAttributeEvent interface + Key func() string + Member func() Member + OperationType func() int32 + Value func() string + type MemberRemovedListener interface + MemberRemoved func(member Member) + type MemberSelector interface + Select func(member Member) (selected bool) + type Message interface + MessageObject func() interface{} + PublishTime func() time.Time + PublishingMember func() Member + type MessageListener interface + OnMessage func(message Message) error + type MultiMap interface + AddEntryListener func(listener interface{}, includeValue bool) (registrationID string, err error) + AddEntryListenerToKey func(listener interface{}, key interface{}, includeValue bool) (registrationID string, err error) + Clear func() (err error) + ContainsEntry func(key interface{}, value interface{}) (found bool, err error) + ContainsKey func(key interface{}) (found bool, err error) + ContainsValue func(value interface{}) (found bool, err error) + Delete func(key interface{}) (err error) + EntrySet func() (resultPairs []Pair, err error) + ForceUnlock func(key interface{}) (err error) + Get func(key interface{}) (values []interface{}, err error) + IsLocked func(key interface{}) (locked bool, err error) + KeySet func() (keySet []interface{}, err error) + Lock func(key interface{}) (err error) + LockWithLeaseTime func(key interface{}, lease time.Duration) (err error) + Put func(key interface{}, value interface{}) (increased bool, err error) + Remove func(key interface{}, value interface{}) (removed bool, err error) + RemoveAll func(key interface{}) (oldValues []interface{}, err error) + RemoveEntryListener func(registrationID string) (removed bool, err error) + Size func() (size int32, err error) + TryLock func(key interface{}) (locked bool, err error) + TryLockWithTimeout func(key interface{}, timeout time.Duration) (locked bool, err error) + TryLockWithTimeoutAndLease func(key interface{}, timeout time.Duration, lease time.Duration) (locked bool, err error) + Unlock func(key interface{}) (err error) + ValueCount func(key interface{}) (valueCount int32, err error) + Values func() (values []interface{}, err error) + type OverflowPolicy interface + Policy func() policy + type PNCounter interface + AddAndGet func(delta int64) (updatedValue int64, err error) + DecrementAndGet func() (updatedValue int64, err error) + Get func() (currentValue int64, err error) + GetAndAdd func(delta int64) (previousValue int64, err error) + GetAndDecrement func() (previousValue int64, err error) + GetAndIncrement func() (previousValue int64, err error) + GetAndSubtract func(delta int64) (previousValue int64, err error) + IncrementAndGet func() (updatedValue int64, err error) + Reset func() + SubtractAndGet func(delta int64) (updatedValue int64, err error) + type Pair interface + Key func() interface{} + Value func() interface{} + type Queue interface + AddAll func(items []interface{}) (changed bool, err error) + AddItemListener func(listener interface{}, includeValue bool) (registrationID string, err error) + Clear func() (err error) + Contains func(item interface{}) (found bool, err error) + ContainsAll func(items []interface{}) (foundAll bool, err error) + DrainTo func(slice *[]interface{}) (movedAmount int32, err error) + DrainToWithMaxSize func(slice *[]interface{}, maxElements int32) (movedAmount int32, err error) + IsEmpty func() (empty bool, err error) + Offer func(item interface{}) (added bool, err error) + OfferWithTimeout func(item interface{}, timeout time.Duration) (added bool, err error) + Peek func() (item interface{}, err error) + Poll func() (item interface{}, err error) + PollWithTimeout func(timeout time.Duration) (item interface{}, err error) + Put func(item interface{}) (err error) + RemainingCapacity func() (remainingCapacity int32, err error) + Remove func(item interface{}) (removed bool, err error) + RemoveAll func(items []interface{}) (changed bool, err error) + RemoveItemListener func(registrationID string) (removed bool, err error) + RetainAll func(items []interface{}) (changed bool, err error) + Size func() (size int32, err error) + Take func() (item interface{}, err error) + ToSlice func() (items []interface{}, err error) + type RandomLoadBalancer struct + func NewRandomLoadBalancer() *RandomLoadBalancer + func (b *RandomLoadBalancer) Init(cluster Cluster) + func (b *RandomLoadBalancer) Next() Member + type ReadResultSet interface + Get func(index int32) (item interface{}, err error) + ReadCount func() (readCount int32) + Sequence func(index int32) (sequence int64, err error) + Size func() (size int32) + type ReliableMessageListener interface + IsLossTolerant func() bool + IsTerminal func(err error) (bool, error) + RetrieveInitialSequence func() int64 + StoreSequence func(sequence int64) + type ReplicatedMap interface + AddEntryListener func(listener interface{}) (registrationID string, err error) + AddEntryListenerToKey func(listener interface{}, key interface{}) (registrationID string, err error) + AddEntryListenerToKeyWithPredicate func(listener interface{}, predicate interface{}, key interface{}) (registrationID string, err error) + AddEntryListenerWithPredicate func(listener interface{}, predicate interface{}) (registrationID string, err error) + Clear func() (err error) + ContainsKey func(key interface{}) (found bool, err error) + ContainsValue func(value interface{}) (found bool, err error) + EntrySet func() (resultPairs []Pair, err error) + Get func(key interface{}) (value interface{}, err error) + IsEmpty func() (empty bool, err error) + KeySet func() (keySet []interface{}, err error) + Put func(key interface{}, value interface{}) (oldValue interface{}, err error) + PutAll func(entries map[interface{}]interface{}) (err error) + PutWithTTL func(key interface{}, value interface{}, ttl time.Duration) (oldValue interface{}, err error) + Remove func(key interface{}) (value interface{}, err error) + RemoveEntryListener func(registrationID string) (removed bool, err error) + Size func() (size int32, err error) + Values func() (values []interface{}, err error) + type Ringbuffer interface + Add func(item interface{}, overflowPolicy OverflowPolicy) (sequence int64, err error) + AddAll func(items []interface{}, overflowPolicy OverflowPolicy) (lastSequence int64, err error) + Capacity func() (capacity int64, err error) + HeadSequence func() (headSequence int64, err error) + ReadMany func(startSequence int64, minCount int32, maxCount int32, filter interface{}) (readResultSet ReadResultSet, err error) + ReadOne func(sequence int64) (item interface{}, err error) + RemainingCapacity func() (remainingCapacity int64, err error) + Size func() (size int64, err error) + TailSequence func() (tailSequence int64, err error) + type RoundRobinLoadBalancer struct + func NewRoundRobinLoadBalancer() *RoundRobinLoadBalancer + func (rrl *RoundRobinLoadBalancer) Init(cluster Cluster) + func (rrl *RoundRobinLoadBalancer) Next() Member + type ServerError interface + CauseClassName func() string + CauseErrorCode func() int32 + ClassName func() string + ErrorCode func() int32 + Message func() string + StackTrace func() []StackTraceElement + type Set interface + Add func(item interface{}) (added bool, err error) + AddAll func(items []interface{}) (changed bool, err error) + AddItemListener func(listener interface{}, includeValue bool) (registrationID string, err error) + Clear func() (err error) + Contains func(item interface{}) (found bool, err error) + ContainsAll func(items []interface{}) (foundAll bool, err error) + IsEmpty func() (empty bool, err error) + Remove func(item interface{}) (removed bool, err error) + RemoveAll func(items []interface{}) (changed bool, err error) + RemoveItemListener func(registrationID string) (removed bool, err error) + RetainAll func(items []interface{}) (changed bool, err error) + Size func() (size int32, err error) + ToSlice func() (items []interface{}, err error) + type StackTraceElement interface + DeclaringClass func() string + FileName func() string + LineNumber func() int32 + MethodName func() string + type Topic interface + AddMessageListener func(messageListener MessageListener) (registrationID string, err error) + Publish func(message interface{}) (err error) + RemoveMessageListener func(registrationID string) (removed bool, err error) + type TopicOverloadPolicy int + const TopicOverLoadPolicyBlock + const TopicOverLoadPolicyDiscardNewest + const TopicOverLoadPolicyDiscardOldest + const TopicOverLoadPolicyError