Documentation ¶
Index ¶
- Variables
- func GetCurrentTargetReplicaAddress(pn core.PNCounter) core.Address
- type AddressProvider
- type AddressTranslator
- type ClusterService
- func (cs *ClusterService) AddMembershipListener(listener interface{}) string
- func (cs *ClusterService) GetMember(address core.Address) core.Member
- func (cs *ClusterService) GetMemberByUUID(uuid string) core.Member
- func (cs *ClusterService) GetMembers() []core.Member
- func (cs *ClusterService) GetMembersWithSelector(selector core.MemberSelector) (members []core.Member)
- func (cs *ClusterService) RemoveMembershipListener(registrationID string) bool
- type Connection
- type HazelcastClient
- func (c *HazelcastClient) Cluster() core.Cluster
- func (c *HazelcastClient) GetDistributedObject(serviceName string, name string) (core.DistributedObject, error)
- func (c *HazelcastClient) GetFlakeIDGenerator(name string) (core.FlakeIDGenerator, error)
- func (c *HazelcastClient) GetList(name string) (core.List, error)
- func (c *HazelcastClient) GetMap(name string) (core.Map, error)
- func (c *HazelcastClient) GetMultiMap(name string) (core.MultiMap, error)
- func (c *HazelcastClient) GetPNCounter(name string) (core.PNCounter, error)
- func (c *HazelcastClient) GetQueue(name string) (core.Queue, error)
- func (c *HazelcastClient) GetReliableTopic(name string) (core.Topic, error)
- func (c *HazelcastClient) GetReplicatedMap(name string) (core.ReplicatedMap, error)
- func (c *HazelcastClient) GetRingbuffer(name string) (core.Ringbuffer, error)
- func (c *HazelcastClient) GetSet(name string) (core.Set, error)
- func (c *HazelcastClient) GetTopic(name string) (core.Topic, error)
- func (c *HazelcastClient) InvocationService() InvocationService
- func (c *HazelcastClient) LifecycleService() core.LifecycleService
- func (c *HazelcastClient) Name() string
- func (c *HazelcastClient) PartitionService() clientspi.PartitionService
- func (c *HazelcastClient) Shutdown()
- type InvocationService
- type LazyReadResultSet
- type NearCachedMapProxy
- func (mp NearCachedMapProxy) AddEntryListener(listener interface{}, includeValue bool) (registrationID string, err error)
- func (mp NearCachedMapProxy) AddEntryListenerToKey(listener interface{}, key interface{}, includeValue bool) (registrationID string, err error)
- func (mp NearCachedMapProxy) AddEntryListenerToKeyWithPredicate(listener interface{}, predicate interface{}, key interface{}, ...) (string, error)
- func (mp NearCachedMapProxy) AddEntryListenerWithPredicate(listener interface{}, predicate interface{}, includeValue bool) (string, error)
- func (mp NearCachedMapProxy) AddIndex(attribute string, ordered bool) (err error)
- func (mp NearCachedMapProxy) Aggregate(aggregator interface{}) (result interface{}, err error)
- func (mp NearCachedMapProxy) AggregateWithPredicate(aggregator interface{}, predicate interface{}) (result interface{}, err error)
- func (n *NearCachedMapProxy) Clear() error
- func (n *NearCachedMapProxy) ContainsKey(key interface{}) (bool, error)
- func (mp NearCachedMapProxy) ContainsValue(value interface{}) (found bool, err error)
- func (n *NearCachedMapProxy) Delete(key interface{}) error
- func (mp NearCachedMapProxy) EntrySet() (resultPairs []core.Pair, err error)
- func (mp NearCachedMapProxy) EntrySetWithPredicate(predicate interface{}) (resultPairs []core.Pair, err error)
- func (n *NearCachedMapProxy) Evict(key interface{}) (bool, error)
- func (n *NearCachedMapProxy) EvictAll() error
- func (mp NearCachedMapProxy) ExecuteOnEntries(entryProcessor interface{}) (keyToResultPairs []core.Pair, err error)
- func (mp NearCachedMapProxy) ExecuteOnEntriesWithPredicate(entryProcessor interface{}, predicate interface{}) (keyToResultPairs []core.Pair, err error)
- func (n *NearCachedMapProxy) ExecuteOnKey(key interface{}, entryProcessor interface{}) (interface{}, error)
- func (mp NearCachedMapProxy) ExecuteOnKeys(keys []interface{}, entryProcessor interface{}) (keyToResultPairs []core.Pair, err error)
- func (mp NearCachedMapProxy) Flush() (err error)
- func (mp NearCachedMapProxy) ForceUnlock(key interface{}) (err error)
- func (n *NearCachedMapProxy) Get(key interface{}) (interface{}, error)
- func (n *NearCachedMapProxy) GetAll(keys []interface{}) (map[interface{}]interface{}, error)
- func (mp NearCachedMapProxy) GetEntryView(key interface{}) (entryView core.EntryView, err error)
- func (n *NearCachedMapProxy) HandleMapBatchInvalidationEventV14(keys []serialization.Data, sourceUUIDs []string, partitionUUIDs []*proto.UUID, ...)
- func (n *NearCachedMapProxy) HandleMapInvalidationEventV14(key serialization.Data, sourceUUID string, partitionUUID *proto.UUID, ...)
- func (mp NearCachedMapProxy) IsEmpty() (empty bool, err error)
- func (mp NearCachedMapProxy) IsLocked(key interface{}) (locked bool, err error)
- func (mp NearCachedMapProxy) KeySet() (keySet []interface{}, err error)
- func (mp NearCachedMapProxy) KeySetWithPredicate(predicate interface{}) (keySet []interface{}, err error)
- func (mp NearCachedMapProxy) Lock(key interface{}) (err error)
- func (mp NearCachedMapProxy) LockWithLeaseTime(key interface{}, lease time.Duration) (err error)
- func (n *NearCachedMapProxy) NearCache() nearcache.NearCache
- func (mp NearCachedMapProxy) Project(projection interface{}) (result []interface{}, err error)
- func (mp NearCachedMapProxy) ProjectWithPredicate(projection interface{}, predicate interface{}) (result []interface{}, err error)
- func (n *NearCachedMapProxy) Put(key interface{}, value interface{}) (interface{}, error)
- func (n *NearCachedMapProxy) PutAll(entries map[interface{}]interface{}) error
- func (n *NearCachedMapProxy) PutIfAbsent(key, value interface{}) (interface{}, error)
- func (n *NearCachedMapProxy) PutTransient(key, value interface{}, duration time.Duration) error
- func (n *NearCachedMapProxy) Remove(key interface{}) (interface{}, error)
- func (n *NearCachedMapProxy) RemoveAll(predicate interface{}) error
- func (mp NearCachedMapProxy) RemoveEntryListener(registrationID string) (bool, error)
- func (n *NearCachedMapProxy) RemoveIfSame(key interface{}, value interface{}) (bool, error)
- func (n *NearCachedMapProxy) Replace(key, value interface{}) (interface{}, error)
- func (n *NearCachedMapProxy) ReplaceIfSame(key, value, oldValue interface{}) (bool, error)
- func (n *NearCachedMapProxy) Set(key, value interface{}) error
- func (n *NearCachedMapProxy) SetWithTTL(key, value interface{}, ttl time.Duration) error
- func (mp NearCachedMapProxy) Size() (size int32, err error)
- func (mp NearCachedMapProxy) TryLock(key interface{}) (locked bool, err error)
- func (mp NearCachedMapProxy) TryLockWithTimeout(key interface{}, timeout time.Duration) (locked bool, err error)
- func (mp NearCachedMapProxy) TryLockWithTimeoutAndLease(key interface{}, timeout time.Duration, lease time.Duration) (locked bool, err error)
- func (n *NearCachedMapProxy) TryPut(key, value interface{}) (bool, error)
- func (n *NearCachedMapProxy) TryPutWithTimeout(key, value interface{}, duration time.Duration) (bool, error)
- func (n *NearCachedMapProxy) TryRemove(key interface{}, duration time.Duration) (bool, error)
- func (mp NearCachedMapProxy) Unlock(key interface{}) (err error)
- func (mp NearCachedMapProxy) Values() (values []interface{}, err error)
- func (mp NearCachedMapProxy) ValuesWithPredicate(predicate interface{}) (values []interface{}, err error)
- type PartitionService
- type ReliableTopicProxy
- func (r *ReliableTopicProxy) AddMessageListener(messageListener core.MessageListener) (registrationID string, err error)
- func (r *ReliableTopicProxy) Destroy() (bool, error)
- func (p ReliableTopicProxy) Name() string
- func (p ReliableTopicProxy) PartitionKey() string
- func (r *ReliableTopicProxy) Publish(message interface{}) (err error)
- func (r *ReliableTopicProxy) RemoveMessageListener(registrationID string) (removed bool, err error)
- func (r *ReliableTopicProxy) Ringbuffer() core.Ringbuffer
- func (p ReliableTopicProxy) ServiceName() string
Constants ¶
This section is empty.
Variables ¶
View Source
var ClientVersion = "0.5-SNAPSHOT" //TODO This should be replace with a build time version variable, BuildInfo etc.
Functions ¶
Types ¶
type AddressProvider ¶
type AddressTranslator ¶
type AddressTranslator interface { // Translate translates the given address to another address specific // to network or service Translate(address core.Address) core.Address }
AddressTranslator is used to resolve private ip address of cloud services.
type ClusterService ¶
type ClusterService struct {
// contains filtered or unexported fields
}
func (*ClusterService) AddMembershipListener ¶
func (cs *ClusterService) AddMembershipListener(listener interface{}) string
func (*ClusterService) GetMember ¶
func (cs *ClusterService) GetMember(address core.Address) core.Member
func (*ClusterService) GetMemberByUUID ¶
func (cs *ClusterService) GetMemberByUUID(uuid string) core.Member
func (*ClusterService) GetMembers ¶
func (cs *ClusterService) GetMembers() []core.Member
func (*ClusterService) GetMembersWithSelector ¶
func (cs *ClusterService) GetMembersWithSelector(selector core.MemberSelector) (members []core.Member)
func (*ClusterService) RemoveMembershipListener ¶
func (cs *ClusterService) RemoveMembershipListener(registrationID string) bool
type Connection ¶
type Connection struct {
// contains filtered or unexported fields
}
func (*Connection) StartTime ¶
func (c *Connection) StartTime() int64
func (*Connection) String ¶
func (c *Connection) String() string
type HazelcastClient ¶
type HazelcastClient struct { Config *config.Config SerializationService spi.SerializationService ConnectionManager connectionManager ListenerService *listenerService ClusterService *ClusterService ProxyManager *proxyManager LoadBalancer core.LoadBalancer HeartBeatService *heartBeatService // contains filtered or unexported fields }
func NewHazelcastClient ¶
func NewHazelcastClient(config *config.Config) (*HazelcastClient, error)
func (*HazelcastClient) Cluster ¶
func (c *HazelcastClient) Cluster() core.Cluster
func (*HazelcastClient) GetDistributedObject ¶
func (c *HazelcastClient) GetDistributedObject(serviceName string, name string) (core.DistributedObject, error)
func (*HazelcastClient) GetFlakeIDGenerator ¶
func (c *HazelcastClient) GetFlakeIDGenerator(name string) (core.FlakeIDGenerator, error)
func (*HazelcastClient) GetMultiMap ¶
func (c *HazelcastClient) GetMultiMap(name string) (core.MultiMap, error)
func (*HazelcastClient) GetPNCounter ¶
func (c *HazelcastClient) GetPNCounter(name string) (core.PNCounter, error)
func (*HazelcastClient) GetQueue ¶
func (c *HazelcastClient) GetQueue(name string) (core.Queue, error)
func (*HazelcastClient) GetReliableTopic ¶
func (c *HazelcastClient) GetReliableTopic(name string) (core.Topic, error)
func (*HazelcastClient) GetReplicatedMap ¶
func (c *HazelcastClient) GetReplicatedMap(name string) (core.ReplicatedMap, error)
func (*HazelcastClient) GetRingbuffer ¶
func (c *HazelcastClient) GetRingbuffer(name string) (core.Ringbuffer, error)
func (*HazelcastClient) GetTopic ¶
func (c *HazelcastClient) GetTopic(name string) (core.Topic, error)
func (*HazelcastClient) InvocationService ¶
func (c *HazelcastClient) InvocationService() InvocationService
func (*HazelcastClient) LifecycleService ¶
func (c *HazelcastClient) LifecycleService() core.LifecycleService
func (*HazelcastClient) Name ¶
func (c *HazelcastClient) Name() string
func (*HazelcastClient) PartitionService ¶
func (c *HazelcastClient) PartitionService() clientspi.PartitionService
func (*HazelcastClient) Shutdown ¶
func (c *HazelcastClient) Shutdown()
type InvocationService ¶
type InvocationService interface { InvokeOnTarget(message *proto.ClientMessage, address core.Address) clientspi.InvocationResult InvocationTimeout() time.Duration // contains filtered or unexported methods }
type LazyReadResultSet ¶
type LazyReadResultSet struct {
// contains filtered or unexported fields
}
func NewLazyReadResultSet ¶
func NewLazyReadResultSet(readCount int32, itemsData []serialization.Data, itemSeqs []int64, ss spi.SerializationService) (rs *LazyReadResultSet)
func (*LazyReadResultSet) Get ¶
func (rs *LazyReadResultSet) Get(index int32) (result interface{}, err error)
func (*LazyReadResultSet) ReadCount ¶
func (rs *LazyReadResultSet) ReadCount() int32
func (*LazyReadResultSet) Sequence ¶
func (rs *LazyReadResultSet) Sequence(index int32) (sequence int64, err error)
func (*LazyReadResultSet) Size ¶
func (rs *LazyReadResultSet) Size() int32
type NearCachedMapProxy ¶
type NearCachedMapProxy struct {
// contains filtered or unexported fields
}
func (NearCachedMapProxy) AddEntryListener ¶
func (NearCachedMapProxy) AddEntryListenerToKey ¶
func (NearCachedMapProxy) AddEntryListenerToKeyWithPredicate ¶
func (NearCachedMapProxy) AddEntryListenerWithPredicate ¶
func (NearCachedMapProxy) Aggregate ¶
func (mp NearCachedMapProxy) Aggregate(aggregator interface{}) (result interface{}, err error)
func (NearCachedMapProxy) AggregateWithPredicate ¶
func (mp NearCachedMapProxy) AggregateWithPredicate(aggregator interface{}, predicate interface{}) (result interface{}, err error)
func (*NearCachedMapProxy) Clear ¶
func (n *NearCachedMapProxy) Clear() error
func (*NearCachedMapProxy) ContainsKey ¶
func (n *NearCachedMapProxy) ContainsKey(key interface{}) (bool, error)
func (NearCachedMapProxy) ContainsValue ¶
func (*NearCachedMapProxy) Delete ¶
func (n *NearCachedMapProxy) Delete(key interface{}) error
func (NearCachedMapProxy) EntrySetWithPredicate ¶
func (*NearCachedMapProxy) Evict ¶
func (n *NearCachedMapProxy) Evict(key interface{}) (bool, error)
func (*NearCachedMapProxy) EvictAll ¶
func (n *NearCachedMapProxy) EvictAll() error
func (NearCachedMapProxy) ExecuteOnEntries ¶
func (NearCachedMapProxy) ExecuteOnEntriesWithPredicate ¶
func (*NearCachedMapProxy) ExecuteOnKey ¶
func (n *NearCachedMapProxy) ExecuteOnKey(key interface{}, entryProcessor interface{}) (interface{}, error)
func (NearCachedMapProxy) ExecuteOnKeys ¶
func (NearCachedMapProxy) ForceUnlock ¶
func (mp NearCachedMapProxy) ForceUnlock(key interface{}) (err error)
func (*NearCachedMapProxy) Get ¶
func (n *NearCachedMapProxy) Get(key interface{}) (interface{}, error)
func (*NearCachedMapProxy) GetAll ¶
func (n *NearCachedMapProxy) GetAll(keys []interface{}) (map[interface{}]interface{}, error)
func (NearCachedMapProxy) GetEntryView ¶
func (*NearCachedMapProxy) HandleMapBatchInvalidationEventV14 ¶
func (n *NearCachedMapProxy) HandleMapBatchInvalidationEventV14(keys []serialization.Data, sourceUUIDs []string, partitionUUIDs []*proto.UUID, sequences []int64)
func (*NearCachedMapProxy) HandleMapInvalidationEventV14 ¶
func (n *NearCachedMapProxy) HandleMapInvalidationEventV14(key serialization.Data, sourceUUID string, partitionUUID *proto.UUID, sequence int64)
func (NearCachedMapProxy) KeySet ¶
func (mp NearCachedMapProxy) KeySet() (keySet []interface{}, err error)
func (NearCachedMapProxy) KeySetWithPredicate ¶
func (mp NearCachedMapProxy) KeySetWithPredicate(predicate interface{}) (keySet []interface{}, err error)
func (NearCachedMapProxy) LockWithLeaseTime ¶
func (*NearCachedMapProxy) NearCache ¶
func (n *NearCachedMapProxy) NearCache() nearcache.NearCache
NearCache is used for testing
func (NearCachedMapProxy) Project ¶
func (mp NearCachedMapProxy) Project(projection interface{}) (result []interface{}, err error)
func (NearCachedMapProxy) ProjectWithPredicate ¶
func (mp NearCachedMapProxy) ProjectWithPredicate(projection interface{}, predicate interface{}) (result []interface{}, err error)
func (*NearCachedMapProxy) Put ¶
func (n *NearCachedMapProxy) Put(key interface{}, value interface{}) (interface{}, error)
func (*NearCachedMapProxy) PutAll ¶
func (n *NearCachedMapProxy) PutAll(entries map[interface{}]interface{}) error
func (*NearCachedMapProxy) PutIfAbsent ¶
func (n *NearCachedMapProxy) PutIfAbsent(key, value interface{}) (interface{}, error)
func (*NearCachedMapProxy) PutTransient ¶
func (n *NearCachedMapProxy) PutTransient(key, value interface{}, duration time.Duration) error
func (*NearCachedMapProxy) Remove ¶
func (n *NearCachedMapProxy) Remove(key interface{}) (interface{}, error)
func (*NearCachedMapProxy) RemoveAll ¶
func (n *NearCachedMapProxy) RemoveAll(predicate interface{}) error
func (NearCachedMapProxy) RemoveEntryListener ¶
func (*NearCachedMapProxy) RemoveIfSame ¶
func (n *NearCachedMapProxy) RemoveIfSame(key interface{}, value interface{}) (bool, error)
func (*NearCachedMapProxy) Replace ¶
func (n *NearCachedMapProxy) Replace(key, value interface{}) (interface{}, error)
func (*NearCachedMapProxy) ReplaceIfSame ¶
func (n *NearCachedMapProxy) ReplaceIfSame(key, value, oldValue interface{}) (bool, error)
func (*NearCachedMapProxy) Set ¶
func (n *NearCachedMapProxy) Set(key, value interface{}) error
func (*NearCachedMapProxy) SetWithTTL ¶
func (n *NearCachedMapProxy) SetWithTTL(key, value interface{}, ttl time.Duration) error
func (NearCachedMapProxy) TryLockWithTimeout ¶
func (NearCachedMapProxy) TryLockWithTimeoutAndLease ¶
func (*NearCachedMapProxy) TryPut ¶
func (n *NearCachedMapProxy) TryPut(key, value interface{}) (bool, error)
func (*NearCachedMapProxy) TryPutWithTimeout ¶
func (n *NearCachedMapProxy) TryPutWithTimeout(key, value interface{}, duration time.Duration) (bool, error)
func (*NearCachedMapProxy) TryRemove ¶
func (n *NearCachedMapProxy) TryRemove(key interface{}, duration time.Duration) (bool, error)
func (NearCachedMapProxy) Values ¶
func (mp NearCachedMapProxy) Values() (values []interface{}, err error)
func (NearCachedMapProxy) ValuesWithPredicate ¶
func (mp NearCachedMapProxy) ValuesWithPredicate(predicate interface{}) (values []interface{}, err error)
type PartitionService ¶
type PartitionService struct {
// contains filtered or unexported fields
}
func (*PartitionService) GetPartitionCount ¶
func (ps *PartitionService) GetPartitionCount() int32
func (*PartitionService) GetPartitionID ¶
func (ps *PartitionService) GetPartitionID(keyData serialization.Data) int32
func (*PartitionService) GetPartitionIDForObject ¶
func (ps *PartitionService) GetPartitionIDForObject(key interface{}) int32
func (*PartitionService) GetPartitionIDWithKey ¶
func (ps *PartitionService) GetPartitionIDWithKey(key interface{}) (int32, error)
type ReliableTopicProxy ¶
type ReliableTopicProxy struct {
// contains filtered or unexported fields
}
func (*ReliableTopicProxy) AddMessageListener ¶
func (r *ReliableTopicProxy) AddMessageListener(messageListener core.MessageListener) (registrationID string, err error)
func (*ReliableTopicProxy) Destroy ¶
func (r *ReliableTopicProxy) Destroy() (bool, error)
func (ReliableTopicProxy) PartitionKey ¶
func (p ReliableTopicProxy) PartitionKey() string
func (*ReliableTopicProxy) Publish ¶
func (r *ReliableTopicProxy) Publish(message interface{}) (err error)
func (*ReliableTopicProxy) RemoveMessageListener ¶
func (r *ReliableTopicProxy) RemoveMessageListener(registrationID string) (removed bool, err error)
func (*ReliableTopicProxy) Ringbuffer ¶
func (r *ReliableTopicProxy) Ringbuffer() core.Ringbuffer
func (ReliableTopicProxy) ServiceName ¶
func (p ReliableTopicProxy) ServiceName() string
Source Files ¶
- address_provider.go
- address_translator.go
- client.go
- cluster.go
- connection.go
- connection_manager.go
- error.go
- flake_id_generator.go
- heartbeat.go
- invocation.go
- lifecycle.go
- list.go
- listener.go
- logger.go
- map.go
- message_builder.go
- multi_map.go
- near_cached_map.go
- partition.go
- pn_counter.go
- proxy.go
- proxy_manager.go
- queue.go
- reliable_topic.go
- replicated_map.go
- ringbuffer.go
- set.go
- statistics.go
- statistics_osmetric.go
- topic.go
- vector_clock.go
Click to show internal directories.
Click to hide internal directories.