internal

Documentation

Index

• Variables
• func GetCurrentTargetReplicaAddress(pn core.PNCounter) core.Address
• type AddressProvider
• type AddressTranslator
• type Connection
  • func (c *Connection) StartTime() int64
  • func (c *Connection) String() string
• type HazelcastClient
  • func NewHazelcastClient(config *config.Config) (*HazelcastClient, error)
  • 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
  • func NewLazyReadResultSet(readCount int32, itemsData []serialization.Data, itemSeqs []int64, ...) (rs *LazyReadResultSet)
  • func (rs *LazyReadResultSet) Get(index int32) (result interface{}, err error)
  • func (rs *LazyReadResultSet) ReadCount() int32
  • func (rs *LazyReadResultSet) Sequence(index int32) (sequence int64, err error)
  • func (rs *LazyReadResultSet) Size() int32
• 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

Variables

var ClientVersion = "0.5-SNAPSHOT" //TODO This should be replace with a build time version variable, BuildInfo etc.

Functions

func GetCurrentTargetReplicaAddress

func GetCurrentTargetReplicaAddress(pn core.PNCounter) core.Address

GetCurrentTargetReplicaAddress returns the current target replica address to which this proxy is sending invocations. It is public for testing purposes.

Types

type AddressProvider

type AddressProvider interface {
	LoadAddresses() []core.Address
}

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) GetList

func (c *HazelcastClient) GetList(name string) (core.List, error)

func (*HazelcastClient) GetMap

func (c *HazelcastClient) GetMap(name string) (core.Map, 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) GetSet

func (c *HazelcastClient) GetSet(name string) (core.Set, 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) Name

func (p ReliableTopicProxy) Name() string

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