internal

package
v0.10.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 18, 2020 License: Apache-2.0 Imports: 39 Imported by: 0

Documentation

Index

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

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 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) 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) 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 (mp NearCachedMapProxy) AddEntryListener(listener interface{}, includeValue bool) (registrationID string, err error)

func (NearCachedMapProxy) AddEntryListenerToKey 

func (mp NearCachedMapProxy) AddEntryListenerToKey(listener interface{}, key interface{}, includeValue bool) (
	registrationID string, err error)

func (NearCachedMapProxy) AddEntryListenerToKeyWithPredicate 

func (mp NearCachedMapProxy) AddEntryListenerToKeyWithPredicate(listener interface{}, predicate interface{}, key interface{},
	includeValue bool) (string, error)

func (NearCachedMapProxy) AddEntryListenerWithPredicate 

func (mp NearCachedMapProxy) AddEntryListenerWithPredicate(listener interface{}, predicate interface{}, includeValue bool) (
	string, error)

func (NearCachedMapProxy) AddIndex 

func (mp NearCachedMapProxy) AddIndex(attribute string, ordered bool) (err error)

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 (mp NearCachedMapProxy) ContainsValue(value interface{}) (found bool, err error)

func (*NearCachedMapProxy) Delete 

func (n *NearCachedMapProxy) Delete(key interface{}) error

func (NearCachedMapProxy) EntrySet 

func (mp NearCachedMapProxy) EntrySet() (resultPairs []core.Pair, err error)

func (NearCachedMapProxy) EntrySetWithPredicate 

func (mp NearCachedMapProxy) EntrySetWithPredicate(predicate interface{}) (resultPairs []core.Pair, err error)

func (*NearCachedMapProxy) Evict 

func (n *NearCachedMapProxy) Evict(key interface{}) (bool, error)

func (*NearCachedMapProxy) EvictAll 

func (n *NearCachedMapProxy) EvictAll() error

func (NearCachedMapProxy) ExecuteOnEntries 

func (mp NearCachedMapProxy) ExecuteOnEntries(entryProcessor interface{}) (keyToResultPairs []core.Pair, err error)

func (NearCachedMapProxy) ExecuteOnEntriesWithPredicate 

func (mp NearCachedMapProxy) ExecuteOnEntriesWithPredicate(entryProcessor interface{},
	predicate interface{}) (keyToResultPairs []core.Pair, err error)

func (*NearCachedMapProxy) ExecuteOnKey 

func (n *NearCachedMapProxy) ExecuteOnKey(key interface{}, entryProcessor interface{}) (interface{}, error)

func (NearCachedMapProxy) ExecuteOnKeys 

func (mp NearCachedMapProxy) ExecuteOnKeys(keys []interface{}, entryProcessor interface{}) (keyToResultPairs []core.Pair, err error)

func (NearCachedMapProxy) Flush 

func (mp NearCachedMapProxy) Flush() (err error)

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 (mp NearCachedMapProxy) GetEntryView(key interface{}) (entryView core.EntryView, err error)

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

func (mp NearCachedMapProxy) IsEmpty() (empty bool, err error)

func (NearCachedMapProxy) IsLocked 

func (mp NearCachedMapProxy) IsLocked(key interface{}) (locked bool, err error)

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

func (mp NearCachedMapProxy) Lock(key interface{}) (err error)

func (NearCachedMapProxy) LockWithLeaseTime 

func (mp NearCachedMapProxy) LockWithLeaseTime(key interface{}, lease time.Duration) (err error)

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 (mp NearCachedMapProxy) RemoveEntryListener(registrationID string) (bool, error)

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

func (mp NearCachedMapProxy) Size() (size int32, err error)

func (NearCachedMapProxy) TryLock 

func (mp NearCachedMapProxy) TryLock(key interface{}) (locked bool, err error)

func (NearCachedMapProxy) TryLockWithTimeout 

func (mp NearCachedMapProxy) TryLockWithTimeout(key interface{}, timeout time.Duration) (locked bool, err error)

func (NearCachedMapProxy) TryLockWithTimeoutAndLease 

func (mp NearCachedMapProxy) TryLockWithTimeoutAndLease(key interface{}, timeout time.Duration, lease time.Duration) (
	locked bool, err error)

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

func (mp NearCachedMapProxy) Unlock(key interface{}) (err 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) 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

Source Files

View all Source files

Directories

Path Synopsis
internal
internal/invalidation
internal/record
internal/record/comparator
nearcachespi
bufutil
util
colutil
iputil
murmur
precond
timeutil
versionutil

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.