Documentation ¶
Index ¶
- Variables
- func GetCurrentTargetReplicaAddress(pn core.PNCounter) core.Address
- type AddressProvider
- type AddressTranslator
- 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) LifecycleService() core.LifecycleService
- func (c *HazelcastClient) Name() string
- func (c *HazelcastClient) Shutdown()
- type LazyReadResultSet
- 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 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 { InvocationService invocationService Config *config.Config PartitionService *partitionService 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) LifecycleService ¶
func (c *HazelcastClient) LifecycleService() core.LifecycleService
func (*HazelcastClient) Name ¶
func (c *HazelcastClient) Name() string
func (*HazelcastClient) Shutdown ¶
func (c *HazelcastClient) Shutdown()
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 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
- 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.