proto

package
v0.6.0 Latest Latest
Warning

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

 Go to latest Published: Mar 9, 2020 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const ClientType = "GOO"

Variables

This section is empty.

Functions

func AddressCodecEncode 

func AddressCodecEncode(msg *ClientMessage, address *Address)

Address Codec

func ClientAddMembershipListenerDecodeResponse 

func ClientAddMembershipListenerDecodeResponse(clientMessage *ClientMessage) func() (response string)

ClientAddMembershipListenerDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ClientAddMembershipListenerEventMemberAttributeChangeDecode 

func ClientAddMembershipListenerEventMemberAttributeChangeDecode(clientMessage *ClientMessage) (
	uuid string, key string, operationType int32, value string)

ClientAddMembershipListenerEventMemberAttributeChangeDecode decodes the corresponding event from the given client message. It returns the result parameters for the event.

func ClientAddMembershipListenerHandle 

func ClientAddMembershipListenerHandle(clientMessage *ClientMessage,
	handleEventMember ClientAddMembershipListenerHandleEventMemberFunc,
	handleEventMemberList ClientAddMembershipListenerHandleEventMemberListFunc,
	handleEventMemberAttributeChange ClientAddMembershipListenerHandleEventMemberAttributeChangeFunc)

ClientAddMembershipListenerHandle handles the event with the given event handler function.

func ClientAuthenticationCustomDecodeResponse 

func ClientAuthenticationCustomDecodeResponse(clientMessage *ClientMessage) func() (status uint8, address *Address, uuid string, ownerUuid string, serializationVersion uint8, serverHazelcastVersion string, clientUnregisteredMembers []*Member)

ClientAuthenticationCustomDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ClientAuthenticationDecodeResponse 

func ClientAuthenticationDecodeResponse(clientMessage *ClientMessage) func() (status uint8, address *Address, uuid string, ownerUuid string, serializationVersion uint8, serverHazelcastVersion string, clientUnregisteredMembers []*Member)

ClientAuthenticationDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ClientGetPartitionsDecodeResponse 

func ClientGetPartitionsDecodeResponse(clientMessage *ClientMessage) func() (partitions []*Pair, partitionStateVersion int32)

ClientGetPartitionsDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func DecodeStackTrace 

func DecodeStackTrace(msg *ClientMessage) core.StackTraceElement

func FlakeIDGeneratorNewIDBatchDecodeResponse 

func FlakeIDGeneratorNewIDBatchDecodeResponse(clientMessage *ClientMessage) func() (base int64, increment int64, batchSize int32)

FlakeIDGeneratorNewIDBatchDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func GetMapListenerFlags 

func GetMapListenerFlags(listener interface{}) (int32, error)

Helper function to get flags for listeners

func ListAddAllDecodeResponse 

func ListAddAllDecodeResponse(clientMessage *ClientMessage) func() (response bool)

ListAddAllDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ListAddAllWithIndexDecodeResponse 

func ListAddAllWithIndexDecodeResponse(clientMessage *ClientMessage) func() (response bool)

ListAddAllWithIndexDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ListAddDecodeResponse 

func ListAddDecodeResponse(clientMessage *ClientMessage) func() (response bool)

ListAddDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ListAddListenerDecodeResponse 

func ListAddListenerDecodeResponse(clientMessage *ClientMessage) func() (response string)

ListAddListenerDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ListAddListenerEventItemDecode 

func ListAddListenerEventItemDecode(clientMessage *ClientMessage) (
	item serialization.Data, uuid string, eventType int32)

ListAddListenerEventItemDecode decodes the corresponding event from the given client message. It returns the result parameters for the event.

func ListAddListenerHandle 

func ListAddListenerHandle(clientMessage *ClientMessage,
	handleEventItem ListAddListenerHandleEventItemFunc)

ListAddListenerHandle handles the event with the given event handler function.

func ListCompareAndRemoveAllDecodeResponse 

func ListCompareAndRemoveAllDecodeResponse(clientMessage *ClientMessage) func() (response bool)

ListCompareAndRemoveAllDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ListCompareAndRetainAllDecodeResponse 

func ListCompareAndRetainAllDecodeResponse(clientMessage *ClientMessage) func() (response bool)

ListCompareAndRetainAllDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ListContainsAllDecodeResponse 

func ListContainsAllDecodeResponse(clientMessage *ClientMessage) func() (response bool)

ListContainsAllDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ListContainsDecodeResponse 

func ListContainsDecodeResponse(clientMessage *ClientMessage) func() (response bool)

ListContainsDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ListGetAllDecodeResponse 

func ListGetAllDecodeResponse(clientMessage *ClientMessage) func() (response []serialization.Data)

ListGetAllDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ListGetDecodeResponse 

func ListGetDecodeResponse(clientMessage *ClientMessage) func() (response serialization.Data)

ListGetDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ListIndexOfDecodeResponse 

func ListIndexOfDecodeResponse(clientMessage *ClientMessage) func() (response int32)

ListIndexOfDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ListIsEmptyDecodeResponse 

func ListIsEmptyDecodeResponse(clientMessage *ClientMessage) func() (response bool)

ListIsEmptyDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ListLastIndexOfDecodeResponse 

func ListLastIndexOfDecodeResponse(clientMessage *ClientMessage) func() (response int32)

ListLastIndexOfDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ListRemoveDecodeResponse 

func ListRemoveDecodeResponse(clientMessage *ClientMessage) func() (response bool)

ListRemoveDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ListRemoveWithIndexDecodeResponse 

func ListRemoveWithIndexDecodeResponse(clientMessage *ClientMessage) func() (response serialization.Data)

ListRemoveWithIndexDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ListSetDecodeResponse 

func ListSetDecodeResponse(clientMessage *ClientMessage) func() (response serialization.Data)

ListSetDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ListSizeDecodeResponse 

func ListSizeDecodeResponse(clientMessage *ClientMessage) func() (response int32)

ListSizeDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ListSubDecodeResponse 

func ListSubDecodeResponse(clientMessage *ClientMessage) func() (response []serialization.Data)

ListSubDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapAddEntryListenerDecodeResponse 

func MapAddEntryListenerDecodeResponse(clientMessage *ClientMessage) func() (response string)

MapAddEntryListenerDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapAddEntryListenerEventEntryDecode 

func MapAddEntryListenerEventEntryDecode(clientMessage *ClientMessage) (
	key serialization.Data, value serialization.Data, oldValue serialization.Data, mergingValue serialization.Data, eventType int32, uuid string, numberOfAffectedEntries int32)

MapAddEntryListenerEventEntryDecode decodes the corresponding event from the given client message. It returns the result parameters for the event.

func MapAddEntryListenerHandle 

func MapAddEntryListenerHandle(clientMessage *ClientMessage,
	handleEventEntry MapAddEntryListenerHandleEventEntryFunc)

MapAddEntryListenerHandle handles the event with the given event handler function.

func MapAddEntryListenerToKeyDecodeResponse 

func MapAddEntryListenerToKeyDecodeResponse(clientMessage *ClientMessage) func() (response string)

MapAddEntryListenerToKeyDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapAddEntryListenerToKeyEventEntryDecode 

func MapAddEntryListenerToKeyEventEntryDecode(clientMessage *ClientMessage) (
	key serialization.Data, value serialization.Data, oldValue serialization.Data, mergingValue serialization.Data, eventType int32, uuid string, numberOfAffectedEntries int32)

MapAddEntryListenerToKeyEventEntryDecode decodes the corresponding event from the given client message. It returns the result parameters for the event.

func MapAddEntryListenerToKeyHandle 

func MapAddEntryListenerToKeyHandle(clientMessage *ClientMessage,
	handleEventEntry MapAddEntryListenerToKeyHandleEventEntryFunc)

MapAddEntryListenerToKeyHandle handles the event with the given event handler function.

func MapAddEntryListenerToKeyWithPredicateDecodeResponse 

func MapAddEntryListenerToKeyWithPredicateDecodeResponse(clientMessage *ClientMessage) func() (response string)

MapAddEntryListenerToKeyWithPredicateDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapAddEntryListenerToKeyWithPredicateEventEntryDecode 

func MapAddEntryListenerToKeyWithPredicateEventEntryDecode(clientMessage *ClientMessage) (
	key serialization.Data, value serialization.Data, oldValue serialization.Data, mergingValue serialization.Data, eventType int32, uuid string, numberOfAffectedEntries int32)

MapAddEntryListenerToKeyWithPredicateEventEntryDecode decodes the corresponding event from the given client message. It returns the result parameters for the event.

func MapAddEntryListenerToKeyWithPredicateHandle 

func MapAddEntryListenerToKeyWithPredicateHandle(clientMessage *ClientMessage,
	handleEventEntry MapAddEntryListenerToKeyWithPredicateHandleEventEntryFunc)

MapAddEntryListenerToKeyWithPredicateHandle handles the event with the given event handler function.

func MapAddEntryListenerWithPredicateDecodeResponse 

func MapAddEntryListenerWithPredicateDecodeResponse(clientMessage *ClientMessage) func() (response string)

MapAddEntryListenerWithPredicateDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapAddEntryListenerWithPredicateEventEntryDecode 

func MapAddEntryListenerWithPredicateEventEntryDecode(clientMessage *ClientMessage) (
	key serialization.Data, value serialization.Data, oldValue serialization.Data, mergingValue serialization.Data, eventType int32, uuid string, numberOfAffectedEntries int32)

MapAddEntryListenerWithPredicateEventEntryDecode decodes the corresponding event from the given client message. It returns the result parameters for the event.

func MapAddEntryListenerWithPredicateHandle 

func MapAddEntryListenerWithPredicateHandle(clientMessage *ClientMessage,
	handleEventEntry MapAddEntryListenerWithPredicateHandleEventEntryFunc)

MapAddEntryListenerWithPredicateHandle handles the event with the given event handler function.

func MapAggregateDecodeResponse 

func MapAggregateDecodeResponse(clientMessage *ClientMessage) func() (response serialization.Data)

MapAggregateDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapAggregateWithPredicateDecodeResponse 

func MapAggregateWithPredicateDecodeResponse(clientMessage *ClientMessage) func() (response serialization.Data)

MapAggregateWithPredicateDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapContainsKeyDecodeResponse 

func MapContainsKeyDecodeResponse(clientMessage *ClientMessage) func() (response bool)

MapContainsKeyDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapContainsValueDecodeResponse 

func MapContainsValueDecodeResponse(clientMessage *ClientMessage) func() (response bool)

MapContainsValueDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapEntriesWithPredicateDecodeResponse 

func MapEntriesWithPredicateDecodeResponse(clientMessage *ClientMessage) func() (response []*Pair)

MapEntriesWithPredicateDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapEntrySetDecodeResponse 

func MapEntrySetDecodeResponse(clientMessage *ClientMessage) func() (response []*Pair)

MapEntrySetDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapEvictDecodeResponse 

func MapEvictDecodeResponse(clientMessage *ClientMessage) func() (response bool)

MapEvictDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapExecuteOnAllKeysDecodeResponse 

func MapExecuteOnAllKeysDecodeResponse(clientMessage *ClientMessage) func() (response []*Pair)

MapExecuteOnAllKeysDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapExecuteOnKeyDecodeResponse 

func MapExecuteOnKeyDecodeResponse(clientMessage *ClientMessage) func() (response serialization.Data)

MapExecuteOnKeyDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapExecuteOnKeysDecodeResponse 

func MapExecuteOnKeysDecodeResponse(clientMessage *ClientMessage) func() (response []*Pair)

MapExecuteOnKeysDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapExecuteWithPredicateDecodeResponse 

func MapExecuteWithPredicateDecodeResponse(clientMessage *ClientMessage) func() (response []*Pair)

MapExecuteWithPredicateDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapGetAllDecodeResponse 

func MapGetAllDecodeResponse(clientMessage *ClientMessage) func() (response []*Pair)

MapGetAllDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapGetDecodeResponse 

func MapGetDecodeResponse(clientMessage *ClientMessage) func() (response serialization.Data)

MapGetDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapGetEntryViewDecodeResponse 

func MapGetEntryViewDecodeResponse(clientMessage *ClientMessage) func() (response *DataEntryView)

MapGetEntryViewDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapIsEmptyDecodeResponse 

func MapIsEmptyDecodeResponse(clientMessage *ClientMessage) func() (response bool)

MapIsEmptyDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapIsLockedDecodeResponse 

func MapIsLockedDecodeResponse(clientMessage *ClientMessage) func() (response bool)

MapIsLockedDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapKeySetDecodeResponse 

func MapKeySetDecodeResponse(clientMessage *ClientMessage) func() (response []serialization.Data)

MapKeySetDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapKeySetWithPredicateDecodeResponse 

func MapKeySetWithPredicateDecodeResponse(clientMessage *ClientMessage) func() (response []serialization.Data)

MapKeySetWithPredicateDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapProjectDecodeResponse 

func MapProjectDecodeResponse(clientMessage *ClientMessage) func() (response []serialization.Data)

MapProjectDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapProjectWithPredicateDecodeResponse 

func MapProjectWithPredicateDecodeResponse(clientMessage *ClientMessage) func() (response []serialization.Data)

MapProjectWithPredicateDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapPutDecodeResponse 

func MapPutDecodeResponse(clientMessage *ClientMessage) func() (response serialization.Data)

MapPutDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapPutIfAbsentDecodeResponse 

func MapPutIfAbsentDecodeResponse(clientMessage *ClientMessage) func() (response serialization.Data)

MapPutIfAbsentDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapRemoveDecodeResponse 

func MapRemoveDecodeResponse(clientMessage *ClientMessage) func() (response serialization.Data)

MapRemoveDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapRemoveIfSameDecodeResponse 

func MapRemoveIfSameDecodeResponse(clientMessage *ClientMessage) func() (response bool)

MapRemoveIfSameDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapReplaceDecodeResponse 

func MapReplaceDecodeResponse(clientMessage *ClientMessage) func() (response serialization.Data)

MapReplaceDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapReplaceIfSameDecodeResponse 

func MapReplaceIfSameDecodeResponse(clientMessage *ClientMessage) func() (response bool)

MapReplaceIfSameDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapSizeDecodeResponse 

func MapSizeDecodeResponse(clientMessage *ClientMessage) func() (response int32)

MapSizeDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapTryLockDecodeResponse 

func MapTryLockDecodeResponse(clientMessage *ClientMessage) func() (response bool)

MapTryLockDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapTryPutDecodeResponse 

func MapTryPutDecodeResponse(clientMessage *ClientMessage) func() (response bool)

MapTryPutDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapTryRemoveDecodeResponse 

func MapTryRemoveDecodeResponse(clientMessage *ClientMessage) func() (response bool)

MapTryRemoveDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapValuesDecodeResponse 

func MapValuesDecodeResponse(clientMessage *ClientMessage) func() (response []serialization.Data)

MapValuesDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MapValuesWithPredicateDecodeResponse 

func MapValuesWithPredicateDecodeResponse(clientMessage *ClientMessage) func() (response []serialization.Data)

MapValuesWithPredicateDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MultiMapAddEntryListenerDecodeResponse 

func MultiMapAddEntryListenerDecodeResponse(clientMessage *ClientMessage) func() (response string)

MultiMapAddEntryListenerDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MultiMapAddEntryListenerEventEntryDecode 

func MultiMapAddEntryListenerEventEntryDecode(clientMessage *ClientMessage) (
	key serialization.Data, value serialization.Data, oldValue serialization.Data, mergingValue serialization.Data, eventType int32, uuid string, numberOfAffectedEntries int32)

MultiMapAddEntryListenerEventEntryDecode decodes the corresponding event from the given client message. It returns the result parameters for the event.

func MultiMapAddEntryListenerHandle 

func MultiMapAddEntryListenerHandle(clientMessage *ClientMessage,
	handleEventEntry MultiMapAddEntryListenerHandleEventEntryFunc)

MultiMapAddEntryListenerHandle handles the event with the given event handler function.

func MultiMapAddEntryListenerToKeyDecodeResponse 

func MultiMapAddEntryListenerToKeyDecodeResponse(clientMessage *ClientMessage) func() (response string)

MultiMapAddEntryListenerToKeyDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MultiMapAddEntryListenerToKeyEventEntryDecode 

func MultiMapAddEntryListenerToKeyEventEntryDecode(clientMessage *ClientMessage) (
	key serialization.Data, value serialization.Data, oldValue serialization.Data, mergingValue serialization.Data, eventType int32, uuid string, numberOfAffectedEntries int32)

MultiMapAddEntryListenerToKeyEventEntryDecode decodes the corresponding event from the given client message. It returns the result parameters for the event.

func MultiMapAddEntryListenerToKeyHandle 

func MultiMapAddEntryListenerToKeyHandle(clientMessage *ClientMessage,
	handleEventEntry MultiMapAddEntryListenerToKeyHandleEventEntryFunc)

MultiMapAddEntryListenerToKeyHandle handles the event with the given event handler function.

func MultiMapContainsEntryDecodeResponse 

func MultiMapContainsEntryDecodeResponse(clientMessage *ClientMessage) func() (response bool)

MultiMapContainsEntryDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MultiMapContainsKeyDecodeResponse 

func MultiMapContainsKeyDecodeResponse(clientMessage *ClientMessage) func() (response bool)

MultiMapContainsKeyDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MultiMapContainsValueDecodeResponse 

func MultiMapContainsValueDecodeResponse(clientMessage *ClientMessage) func() (response bool)

MultiMapContainsValueDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MultiMapEntrySetDecodeResponse 

func MultiMapEntrySetDecodeResponse(clientMessage *ClientMessage) func() (response []*Pair)

MultiMapEntrySetDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MultiMapGetDecodeResponse 

func MultiMapGetDecodeResponse(clientMessage *ClientMessage) func() (response []serialization.Data)

MultiMapGetDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MultiMapIsLockedDecodeResponse 

func MultiMapIsLockedDecodeResponse(clientMessage *ClientMessage) func() (response bool)

MultiMapIsLockedDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MultiMapKeySetDecodeResponse 

func MultiMapKeySetDecodeResponse(clientMessage *ClientMessage) func() (response []serialization.Data)

MultiMapKeySetDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MultiMapPutDecodeResponse 

func MultiMapPutDecodeResponse(clientMessage *ClientMessage) func() (response bool)

MultiMapPutDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MultiMapRemoveDecodeResponse 

func MultiMapRemoveDecodeResponse(clientMessage *ClientMessage) func() (response []serialization.Data)

MultiMapRemoveDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MultiMapRemoveEntryDecodeResponse 

func MultiMapRemoveEntryDecodeResponse(clientMessage *ClientMessage) func() (response bool)

MultiMapRemoveEntryDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MultiMapSizeDecodeResponse 

func MultiMapSizeDecodeResponse(clientMessage *ClientMessage) func() (response int32)

MultiMapSizeDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MultiMapTryLockDecodeResponse 

func MultiMapTryLockDecodeResponse(clientMessage *ClientMessage) func() (response bool)

MultiMapTryLockDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MultiMapValueCountDecodeResponse 

func MultiMapValueCountDecodeResponse(clientMessage *ClientMessage) func() (response int32)

MultiMapValueCountDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func MultiMapValuesDecodeResponse 

func MultiMapValuesDecodeResponse(clientMessage *ClientMessage) func() (response []serialization.Data)

MultiMapValuesDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func NewItemEvent 

func NewItemEvent(name string, item interface{}, eventType int32, member core.Member) core.ItemEvent

func NewMapEvent 

func NewMapEvent(name string, member core.Member, eventType int32, numberOfAffectedEntries int32) core.MapEvent

func PNCounterAddDecodeResponse 

func PNCounterAddDecodeResponse(clientMessage *ClientMessage) func() (value int64, replicaTimestamps []*Pair, replicaCount int32)

PNCounterAddDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func PNCounterGetConfiguredReplicaCountDecodeResponse 

func PNCounterGetConfiguredReplicaCountDecodeResponse(clientMessage *ClientMessage) func() (response int32)

PNCounterGetConfiguredReplicaCountDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func PNCounterGetDecodeResponse 

func PNCounterGetDecodeResponse(clientMessage *ClientMessage) func() (value int64, replicaTimestamps []*Pair, replicaCount int32)

PNCounterGetDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func QueueAddAllDecodeResponse 

func QueueAddAllDecodeResponse(clientMessage *ClientMessage) func() (response bool)

QueueAddAllDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func QueueAddListenerDecodeResponse 

func QueueAddListenerDecodeResponse(clientMessage *ClientMessage) func() (response string)

QueueAddListenerDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func QueueAddListenerEventItemDecode 

func QueueAddListenerEventItemDecode(clientMessage *ClientMessage) (
	item serialization.Data, uuid string, eventType int32)

QueueAddListenerEventItemDecode decodes the corresponding event from the given client message. It returns the result parameters for the event.

func QueueAddListenerHandle 

func QueueAddListenerHandle(clientMessage *ClientMessage,
	handleEventItem QueueAddListenerHandleEventItemFunc)

QueueAddListenerHandle handles the event with the given event handler function.

func QueueCompareAndRemoveAllDecodeResponse 

func QueueCompareAndRemoveAllDecodeResponse(clientMessage *ClientMessage) func() (response bool)

QueueCompareAndRemoveAllDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func QueueCompareAndRetainAllDecodeResponse 

func QueueCompareAndRetainAllDecodeResponse(clientMessage *ClientMessage) func() (response bool)

QueueCompareAndRetainAllDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func QueueContainsAllDecodeResponse 

func QueueContainsAllDecodeResponse(clientMessage *ClientMessage) func() (response bool)

QueueContainsAllDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func QueueContainsDecodeResponse 

func QueueContainsDecodeResponse(clientMessage *ClientMessage) func() (response bool)

QueueContainsDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func QueueDrainToDecodeResponse 

func QueueDrainToDecodeResponse(clientMessage *ClientMessage) func() (response []serialization.Data)

QueueDrainToDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func QueueDrainToMaxSizeDecodeResponse 

func QueueDrainToMaxSizeDecodeResponse(clientMessage *ClientMessage) func() (response []serialization.Data)

QueueDrainToMaxSizeDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func QueueIsEmptyDecodeResponse 

func QueueIsEmptyDecodeResponse(clientMessage *ClientMessage) func() (response bool)

QueueIsEmptyDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func QueueIteratorDecodeResponse 

func QueueIteratorDecodeResponse(clientMessage *ClientMessage) func() (response []serialization.Data)

QueueIteratorDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func QueueOfferDecodeResponse 

func QueueOfferDecodeResponse(clientMessage *ClientMessage) func() (response bool)

QueueOfferDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func QueuePeekDecodeResponse 

func QueuePeekDecodeResponse(clientMessage *ClientMessage) func() (response serialization.Data)

QueuePeekDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func QueuePollDecodeResponse 

func QueuePollDecodeResponse(clientMessage *ClientMessage) func() (response serialization.Data)

QueuePollDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func QueueRemainingCapacityDecodeResponse 

func QueueRemainingCapacityDecodeResponse(clientMessage *ClientMessage) func() (response int32)

QueueRemainingCapacityDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func QueueRemoveDecodeResponse 

func QueueRemoveDecodeResponse(clientMessage *ClientMessage) func() (response bool)

QueueRemoveDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func QueueSizeDecodeResponse 

func QueueSizeDecodeResponse(clientMessage *ClientMessage) func() (response int32)

QueueSizeDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func QueueTakeDecodeResponse 

func QueueTakeDecodeResponse(clientMessage *ClientMessage) func() (response serialization.Data)

QueueTakeDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ReplicatedMapAddEntryListenerDecodeResponse 

func ReplicatedMapAddEntryListenerDecodeResponse(clientMessage *ClientMessage) func() (response string)

ReplicatedMapAddEntryListenerDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ReplicatedMapAddEntryListenerEventEntryDecode 

func ReplicatedMapAddEntryListenerEventEntryDecode(clientMessage *ClientMessage) (
	key serialization.Data, value serialization.Data, oldValue serialization.Data, mergingValue serialization.Data, eventType int32, uuid string, numberOfAffectedEntries int32)

ReplicatedMapAddEntryListenerEventEntryDecode decodes the corresponding event from the given client message. It returns the result parameters for the event.

func ReplicatedMapAddEntryListenerHandle 

func ReplicatedMapAddEntryListenerHandle(clientMessage *ClientMessage,
	handleEventEntry ReplicatedMapAddEntryListenerHandleEventEntryFunc)

ReplicatedMapAddEntryListenerHandle handles the event with the given event handler function.

func ReplicatedMapAddEntryListenerToKeyDecodeResponse 

func ReplicatedMapAddEntryListenerToKeyDecodeResponse(clientMessage *ClientMessage) func() (response string)

ReplicatedMapAddEntryListenerToKeyDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ReplicatedMapAddEntryListenerToKeyEventEntryDecode 

func ReplicatedMapAddEntryListenerToKeyEventEntryDecode(clientMessage *ClientMessage) (
	key serialization.Data, value serialization.Data, oldValue serialization.Data, mergingValue serialization.Data, eventType int32, uuid string, numberOfAffectedEntries int32)

ReplicatedMapAddEntryListenerToKeyEventEntryDecode decodes the corresponding event from the given client message. It returns the result parameters for the event.

func ReplicatedMapAddEntryListenerToKeyHandle 

func ReplicatedMapAddEntryListenerToKeyHandle(clientMessage *ClientMessage,
	handleEventEntry ReplicatedMapAddEntryListenerToKeyHandleEventEntryFunc)

ReplicatedMapAddEntryListenerToKeyHandle handles the event with the given event handler function.

func ReplicatedMapAddEntryListenerToKeyWithPredicateDecodeResponse 

func ReplicatedMapAddEntryListenerToKeyWithPredicateDecodeResponse(clientMessage *ClientMessage) func() (response string)

ReplicatedMapAddEntryListenerToKeyWithPredicateDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ReplicatedMapAddEntryListenerToKeyWithPredicateEventEntryDecode 

func ReplicatedMapAddEntryListenerToKeyWithPredicateEventEntryDecode(clientMessage *ClientMessage) (
	key serialization.Data, value serialization.Data, oldValue serialization.Data, mergingValue serialization.Data, eventType int32, uuid string, numberOfAffectedEntries int32)

ReplicatedMapAddEntryListenerToKeyWithPredicateEventEntryDecode decodes the corresponding event from the given client message. It returns the result parameters for the event.

func ReplicatedMapAddEntryListenerToKeyWithPredicateHandle 

func ReplicatedMapAddEntryListenerToKeyWithPredicateHandle(clientMessage *ClientMessage,
	handleEventEntry ReplicatedMapAddEntryListenerToKeyWithPredicateHandleEventEntryFunc)

ReplicatedMapAddEntryListenerToKeyWithPredicateHandle handles the event with the given event handler function.

func ReplicatedMapAddEntryListenerWithPredicateDecodeResponse 

func ReplicatedMapAddEntryListenerWithPredicateDecodeResponse(clientMessage *ClientMessage) func() (response string)

ReplicatedMapAddEntryListenerWithPredicateDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ReplicatedMapAddEntryListenerWithPredicateEventEntryDecode 

func ReplicatedMapAddEntryListenerWithPredicateEventEntryDecode(clientMessage *ClientMessage) (
	key serialization.Data, value serialization.Data, oldValue serialization.Data, mergingValue serialization.Data, eventType int32, uuid string, numberOfAffectedEntries int32)

ReplicatedMapAddEntryListenerWithPredicateEventEntryDecode decodes the corresponding event from the given client message. It returns the result parameters for the event.

func ReplicatedMapAddEntryListenerWithPredicateHandle 

func ReplicatedMapAddEntryListenerWithPredicateHandle(clientMessage *ClientMessage,
	handleEventEntry ReplicatedMapAddEntryListenerWithPredicateHandleEventEntryFunc)

ReplicatedMapAddEntryListenerWithPredicateHandle handles the event with the given event handler function.

func ReplicatedMapContainsKeyDecodeResponse 

func ReplicatedMapContainsKeyDecodeResponse(clientMessage *ClientMessage) func() (response bool)

ReplicatedMapContainsKeyDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ReplicatedMapContainsValueDecodeResponse 

func ReplicatedMapContainsValueDecodeResponse(clientMessage *ClientMessage) func() (response bool)

ReplicatedMapContainsValueDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ReplicatedMapEntrySetDecodeResponse 

func ReplicatedMapEntrySetDecodeResponse(clientMessage *ClientMessage) func() (response []*Pair)

ReplicatedMapEntrySetDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ReplicatedMapGetDecodeResponse 

func ReplicatedMapGetDecodeResponse(clientMessage *ClientMessage) func() (response serialization.Data)

ReplicatedMapGetDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ReplicatedMapIsEmptyDecodeResponse 

func ReplicatedMapIsEmptyDecodeResponse(clientMessage *ClientMessage) func() (response bool)

ReplicatedMapIsEmptyDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ReplicatedMapKeySetDecodeResponse 

func ReplicatedMapKeySetDecodeResponse(clientMessage *ClientMessage) func() (response []serialization.Data)

ReplicatedMapKeySetDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ReplicatedMapPutDecodeResponse 

func ReplicatedMapPutDecodeResponse(clientMessage *ClientMessage) func() (response serialization.Data)

ReplicatedMapPutDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ReplicatedMapRemoveDecodeResponse 

func ReplicatedMapRemoveDecodeResponse(clientMessage *ClientMessage) func() (response serialization.Data)

ReplicatedMapRemoveDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ReplicatedMapSizeDecodeResponse 

func ReplicatedMapSizeDecodeResponse(clientMessage *ClientMessage) func() (response int32)

ReplicatedMapSizeDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func ReplicatedMapValuesDecodeResponse 

func ReplicatedMapValuesDecodeResponse(clientMessage *ClientMessage) func() (response []serialization.Data)

ReplicatedMapValuesDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func RingbufferAddAllDecodeResponse 

func RingbufferAddAllDecodeResponse(clientMessage *ClientMessage) func() (response int64)

RingbufferAddAllDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func RingbufferAddDecodeResponse 

func RingbufferAddDecodeResponse(clientMessage *ClientMessage) func() (response int64)

RingbufferAddDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func RingbufferCapacityDecodeResponse 

func RingbufferCapacityDecodeResponse(clientMessage *ClientMessage) func() (response int64)

RingbufferCapacityDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func RingbufferHeadSequenceDecodeResponse 

func RingbufferHeadSequenceDecodeResponse(clientMessage *ClientMessage) func() (response int64)

RingbufferHeadSequenceDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func RingbufferReadManyDecodeResponse 

func RingbufferReadManyDecodeResponse(clientMessage *ClientMessage) func() (readCount int32, items []serialization.Data, itemSeqs []int64, nextSeq int64)

RingbufferReadManyDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func RingbufferReadOneDecodeResponse 

func RingbufferReadOneDecodeResponse(clientMessage *ClientMessage) func() (response serialization.Data)

RingbufferReadOneDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func RingbufferRemainingCapacityDecodeResponse 

func RingbufferRemainingCapacityDecodeResponse(clientMessage *ClientMessage) func() (response int64)

RingbufferRemainingCapacityDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func RingbufferSizeDecodeResponse 

func RingbufferSizeDecodeResponse(clientMessage *ClientMessage) func() (response int64)

RingbufferSizeDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func RingbufferTailSequenceDecodeResponse 

func RingbufferTailSequenceDecodeResponse(clientMessage *ClientMessage) func() (response int64)

RingbufferTailSequenceDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func SetAddAllDecodeResponse 

func SetAddAllDecodeResponse(clientMessage *ClientMessage) func() (response bool)

SetAddAllDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func SetAddDecodeResponse 

func SetAddDecodeResponse(clientMessage *ClientMessage) func() (response bool)

SetAddDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func SetAddListenerDecodeResponse 

func SetAddListenerDecodeResponse(clientMessage *ClientMessage) func() (response string)

SetAddListenerDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func SetAddListenerEventItemDecode 

func SetAddListenerEventItemDecode(clientMessage *ClientMessage) (
	item serialization.Data, uuid string, eventType int32)

SetAddListenerEventItemDecode decodes the corresponding event from the given client message. It returns the result parameters for the event.

func SetAddListenerHandle 

func SetAddListenerHandle(clientMessage *ClientMessage,
	handleEventItem SetAddListenerHandleEventItemFunc)

SetAddListenerHandle handles the event with the given event handler function.

func SetCompareAndRemoveAllDecodeResponse 

func SetCompareAndRemoveAllDecodeResponse(clientMessage *ClientMessage) func() (response bool)

SetCompareAndRemoveAllDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func SetCompareAndRetainAllDecodeResponse 

func SetCompareAndRetainAllDecodeResponse(clientMessage *ClientMessage) func() (response bool)

SetCompareAndRetainAllDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func SetContainsAllDecodeResponse 

func SetContainsAllDecodeResponse(clientMessage *ClientMessage) func() (response bool)

SetContainsAllDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func SetContainsDecodeResponse 

func SetContainsDecodeResponse(clientMessage *ClientMessage) func() (response bool)

SetContainsDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func SetGetAllDecodeResponse 

func SetGetAllDecodeResponse(clientMessage *ClientMessage) func() (response []serialization.Data)

SetGetAllDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func SetIsEmptyDecodeResponse 

func SetIsEmptyDecodeResponse(clientMessage *ClientMessage) func() (response bool)

SetIsEmptyDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func SetRemoveDecodeResponse 

func SetRemoveDecodeResponse(clientMessage *ClientMessage) func() (response bool)

SetRemoveDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func SetSizeDecodeResponse 

func SetSizeDecodeResponse(clientMessage *ClientMessage) func() (response int32)

SetSizeDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func TopicAddMessageListenerDecodeResponse 

func TopicAddMessageListenerDecodeResponse(clientMessage *ClientMessage) func() (response string)

TopicAddMessageListenerDecodeResponse decodes the given client message. It returns a function which returns the response parameters.

func TopicAddMessageListenerEventTopicDecode 

func TopicAddMessageListenerEventTopicDecode(clientMessage *ClientMessage) (
	item serialization.Data, publishTime int64, uuid string)

TopicAddMessageListenerEventTopicDecode decodes the corresponding event from the given client message. It returns the result parameters for the event.

func TopicAddMessageListenerHandle 

func TopicAddMessageListenerHandle(clientMessage *ClientMessage,
	handleEventTopic TopicAddMessageListenerHandleEventTopicFunc)

TopicAddMessageListenerHandle handles the event with the given event handler function.

func UUIDCodecDecode 

func UUIDCodecDecode(msg *ClientMessage) *uuid

func UUIDCodecEncode 

func UUIDCodecEncode(msg *ClientMessage, uuid uuid)

Types

type AbstractMapEvent 

type AbstractMapEvent struct {
	// contains filtered or unexported fields
}

func (*AbstractMapEvent) EventType 

func (e *AbstractMapEvent) EventType() int32

func (*AbstractMapEvent) Member 

func (e *AbstractMapEvent) Member() core.Member

func (*AbstractMapEvent) Name 

func (e *AbstractMapEvent) Name() string

func (*AbstractMapEvent) String 

func (e *AbstractMapEvent) String() string

type Address 

type Address struct {
	// contains filtered or unexported fields
}

func AddressCodecDecode 

func AddressCodecDecode(msg *ClientMessage) *Address

func NewAddressWithParameters 

func NewAddressWithParameters(Host string, Port int) *Address

func (*Address) Host 

func (a *Address) Host() string

func (*Address) Port 

func (a *Address) Port() int

func (*Address) String 

func (a *Address) String() string

type ClientAddMembershipListenerHandleEventMemberAttributeChangeFunc 

type ClientAddMembershipListenerHandleEventMemberAttributeChangeFunc func(string, string, int32, string)

ClientAddMembershipListenerHandleEventMemberAttributeChangeFunc is the event handler function.

type ClientAddMembershipListenerHandleEventMemberFunc 

type ClientAddMembershipListenerHandleEventMemberFunc func(*Member, int32)

ClientAddMembershipListenerHandleEventMemberFunc is the event handler function.

type ClientAddMembershipListenerHandleEventMemberListFunc 

type ClientAddMembershipListenerHandleEventMemberListFunc func([]*Member)

ClientAddMembershipListenerHandleEventMemberListFunc is the event handler function.

type ClientMessage 

type ClientMessage struct {
	Buffer []byte

	IsRetryable bool
	// contains filtered or unexported fields
}

ClientMessage is the carrier framed data as defined below. Any request parameter, response or event data will be carried in the payload. 

0                   1                   2                   3
0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1
+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
|R|                      Frame Length                           |
+-------------+---------------+---------------------------------+
|  Version    |B|E|  Flags    |               Type              |
+-------------+---------------+---------------------------------+
|                                                               |
+                       CorrelationID                           +
|                                                               |
+---------------------------------------------------------------+
|                        PartitionID                            |
+-----------------------------+---------------------------------+
|        Data Offset          |                                 |
+-----------------------------+                                 |
|                      Message Payload Data                    ...
|                                                              ...

func ClientAddMembershipListenerEncodeRequest 

func ClientAddMembershipListenerEncodeRequest(localOnly bool) *ClientMessage

ClientAddMembershipListenerEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ClientAuthenticationCustomEncodeRequest 

func ClientAuthenticationCustomEncodeRequest(credentials serialization.Data, uuid string, ownerUuid string, isOwnerConnection bool, clientType string, serializationVersion uint8, clientHazelcastVersion string) *ClientMessage

ClientAuthenticationCustomEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ClientAuthenticationEncodeRequest 

func ClientAuthenticationEncodeRequest(username string, password string, uuid string, ownerUuid string, isOwnerConnection bool, clientType string, serializationVersion uint8, clientHazelcastVersion string) *ClientMessage

ClientAuthenticationEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ClientCreateProxyEncodeRequest 

func ClientCreateProxyEncodeRequest(name string, serviceName string, target *Address) *ClientMessage

ClientCreateProxyEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ClientDestroyProxyEncodeRequest 

func ClientDestroyProxyEncodeRequest(name string, serviceName string) *ClientMessage

ClientDestroyProxyEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ClientGetPartitionsEncodeRequest 

func ClientGetPartitionsEncodeRequest() *ClientMessage

ClientGetPartitionsEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ClientPingEncodeRequest 

func ClientPingEncodeRequest() *ClientMessage

ClientPingEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ClientStatisticsEncodeRequest 

func ClientStatisticsEncodeRequest(stats string) *ClientMessage

ClientStatisticsEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func FlakeIDGeneratorNewIDBatchEncodeRequest 

func FlakeIDGeneratorNewIDBatchEncodeRequest(name string, batchSize int32) *ClientMessage

FlakeIDGeneratorNewIDBatchEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ListAddAllEncodeRequest 

func ListAddAllEncodeRequest(name string, valueList []serialization.Data) *ClientMessage

ListAddAllEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ListAddAllWithIndexEncodeRequest 

func ListAddAllWithIndexEncodeRequest(name string, index int32, valueList []serialization.Data) *ClientMessage

ListAddAllWithIndexEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ListAddEncodeRequest 

func ListAddEncodeRequest(name string, value serialization.Data) *ClientMessage

ListAddEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ListAddListenerEncodeRequest 

func ListAddListenerEncodeRequest(name string, includeValue bool, localOnly bool) *ClientMessage

ListAddListenerEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ListAddWithIndexEncodeRequest 

func ListAddWithIndexEncodeRequest(name string, index int32, value serialization.Data) *ClientMessage

ListAddWithIndexEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ListClearEncodeRequest 

func ListClearEncodeRequest(name string) *ClientMessage

ListClearEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ListCompareAndRemoveAllEncodeRequest 

func ListCompareAndRemoveAllEncodeRequest(name string, values []serialization.Data) *ClientMessage

ListCompareAndRemoveAllEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ListCompareAndRetainAllEncodeRequest 

func ListCompareAndRetainAllEncodeRequest(name string, values []serialization.Data) *ClientMessage

ListCompareAndRetainAllEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ListContainsAllEncodeRequest 

func ListContainsAllEncodeRequest(name string, values []serialization.Data) *ClientMessage

ListContainsAllEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ListContainsEncodeRequest 

func ListContainsEncodeRequest(name string, value serialization.Data) *ClientMessage

ListContainsEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ListGetAllEncodeRequest 

func ListGetAllEncodeRequest(name string) *ClientMessage

ListGetAllEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ListGetEncodeRequest 

func ListGetEncodeRequest(name string, index int32) *ClientMessage

ListGetEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ListIndexOfEncodeRequest 

func ListIndexOfEncodeRequest(name string, value serialization.Data) *ClientMessage

ListIndexOfEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ListIsEmptyEncodeRequest 

func ListIsEmptyEncodeRequest(name string) *ClientMessage

ListIsEmptyEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ListLastIndexOfEncodeRequest 

func ListLastIndexOfEncodeRequest(name string, value serialization.Data) *ClientMessage

ListLastIndexOfEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ListRemoveEncodeRequest 

func ListRemoveEncodeRequest(name string, value serialization.Data) *ClientMessage

ListRemoveEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ListRemoveListenerEncodeRequest 

func ListRemoveListenerEncodeRequest(name string, registrationId string) *ClientMessage

ListRemoveListenerEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ListRemoveWithIndexEncodeRequest 

func ListRemoveWithIndexEncodeRequest(name string, index int32) *ClientMessage

ListRemoveWithIndexEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ListSetEncodeRequest 

func ListSetEncodeRequest(name string, index int32, value serialization.Data) *ClientMessage

ListSetEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ListSizeEncodeRequest 

func ListSizeEncodeRequest(name string) *ClientMessage

ListSizeEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ListSubEncodeRequest 

func ListSubEncodeRequest(name string, from int32, to int32) *ClientMessage

ListSubEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapAddEntryListenerEncodeRequest 

func MapAddEntryListenerEncodeRequest(name string, includeValue bool, listenerFlags int32, localOnly bool) *ClientMessage

MapAddEntryListenerEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapAddEntryListenerToKeyEncodeRequest 

func MapAddEntryListenerToKeyEncodeRequest(name string, key serialization.Data, includeValue bool, listenerFlags int32, localOnly bool) *ClientMessage

MapAddEntryListenerToKeyEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapAddEntryListenerToKeyWithPredicateEncodeRequest 

func MapAddEntryListenerToKeyWithPredicateEncodeRequest(name string, key serialization.Data, predicate serialization.Data, includeValue bool, listenerFlags int32, localOnly bool) *ClientMessage

MapAddEntryListenerToKeyWithPredicateEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapAddEntryListenerWithPredicateEncodeRequest 

func MapAddEntryListenerWithPredicateEncodeRequest(name string, predicate serialization.Data, includeValue bool, listenerFlags int32, localOnly bool) *ClientMessage

MapAddEntryListenerWithPredicateEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapAddIndexEncodeRequest 

func MapAddIndexEncodeRequest(name string, attribute string, ordered bool) *ClientMessage

MapAddIndexEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapAggregateEncodeRequest 

func MapAggregateEncodeRequest(name string, aggregator serialization.Data) *ClientMessage

MapAggregateEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapAggregateWithPredicateEncodeRequest 

func MapAggregateWithPredicateEncodeRequest(name string, aggregator serialization.Data, predicate serialization.Data) *ClientMessage

MapAggregateWithPredicateEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapClearEncodeRequest 

func MapClearEncodeRequest(name string) *ClientMessage

MapClearEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapContainsKeyEncodeRequest 

func MapContainsKeyEncodeRequest(name string, key serialization.Data, threadId int64) *ClientMessage

MapContainsKeyEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapContainsValueEncodeRequest 

func MapContainsValueEncodeRequest(name string, value serialization.Data) *ClientMessage

MapContainsValueEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapDeleteEncodeRequest 

func MapDeleteEncodeRequest(name string, key serialization.Data, threadId int64) *ClientMessage

MapDeleteEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapEntriesWithPredicateEncodeRequest 

func MapEntriesWithPredicateEncodeRequest(name string, predicate serialization.Data) *ClientMessage

MapEntriesWithPredicateEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapEntrySetEncodeRequest 

func MapEntrySetEncodeRequest(name string) *ClientMessage

MapEntrySetEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapEvictAllEncodeRequest 

func MapEvictAllEncodeRequest(name string) *ClientMessage

MapEvictAllEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapEvictEncodeRequest 

func MapEvictEncodeRequest(name string, key serialization.Data, threadId int64) *ClientMessage

MapEvictEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapExecuteOnAllKeysEncodeRequest 

func MapExecuteOnAllKeysEncodeRequest(name string, entryProcessor serialization.Data) *ClientMessage

MapExecuteOnAllKeysEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapExecuteOnKeyEncodeRequest 

func MapExecuteOnKeyEncodeRequest(name string, entryProcessor serialization.Data, key serialization.Data, threadId int64) *ClientMessage

MapExecuteOnKeyEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapExecuteOnKeysEncodeRequest 

func MapExecuteOnKeysEncodeRequest(name string, entryProcessor serialization.Data, keys []serialization.Data) *ClientMessage

MapExecuteOnKeysEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapExecuteWithPredicateEncodeRequest 

func MapExecuteWithPredicateEncodeRequest(name string, entryProcessor serialization.Data, predicate serialization.Data) *ClientMessage

MapExecuteWithPredicateEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapFlushEncodeRequest 

func MapFlushEncodeRequest(name string) *ClientMessage

MapFlushEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapForceUnlockEncodeRequest 

func MapForceUnlockEncodeRequest(name string, key serialization.Data, referenceId int64) *ClientMessage

MapForceUnlockEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapGetAllEncodeRequest 

func MapGetAllEncodeRequest(name string, keys []serialization.Data) *ClientMessage

MapGetAllEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapGetEncodeRequest 

func MapGetEncodeRequest(name string, key serialization.Data, threadId int64) *ClientMessage

MapGetEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapGetEntryViewEncodeRequest 

func MapGetEntryViewEncodeRequest(name string, key serialization.Data, threadId int64) *ClientMessage

MapGetEntryViewEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapIsEmptyEncodeRequest 

func MapIsEmptyEncodeRequest(name string) *ClientMessage

MapIsEmptyEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapIsLockedEncodeRequest 

func MapIsLockedEncodeRequest(name string, key serialization.Data) *ClientMessage

MapIsLockedEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapKeySetEncodeRequest 

func MapKeySetEncodeRequest(name string) *ClientMessage

MapKeySetEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapKeySetWithPredicateEncodeRequest 

func MapKeySetWithPredicateEncodeRequest(name string, predicate serialization.Data) *ClientMessage

MapKeySetWithPredicateEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapLockEncodeRequest 

func MapLockEncodeRequest(name string, key serialization.Data, threadId int64, ttl int64, referenceId int64) *ClientMessage

MapLockEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapProjectEncodeRequest 

func MapProjectEncodeRequest(name string, projection serialization.Data) *ClientMessage

MapProjectEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapProjectWithPredicateEncodeRequest 

func MapProjectWithPredicateEncodeRequest(name string, projection serialization.Data, predicate serialization.Data) *ClientMessage

MapProjectWithPredicateEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapPutAllEncodeRequest 

func MapPutAllEncodeRequest(name string, entries []*Pair) *ClientMessage

MapPutAllEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapPutEncodeRequest 

func MapPutEncodeRequest(name string, key serialization.Data, value serialization.Data, threadId int64, ttl int64) *ClientMessage

MapPutEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapPutIfAbsentEncodeRequest 

func MapPutIfAbsentEncodeRequest(name string, key serialization.Data, value serialization.Data, threadId int64, ttl int64) *ClientMessage

MapPutIfAbsentEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapPutTransientEncodeRequest 

func MapPutTransientEncodeRequest(name string, key serialization.Data, value serialization.Data, threadId int64, ttl int64) *ClientMessage

MapPutTransientEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapRemoveAllEncodeRequest 

func MapRemoveAllEncodeRequest(name string, predicate serialization.Data) *ClientMessage

MapRemoveAllEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapRemoveEncodeRequest 

func MapRemoveEncodeRequest(name string, key serialization.Data, threadId int64) *ClientMessage

MapRemoveEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapRemoveEntryListenerEncodeRequest 

func MapRemoveEntryListenerEncodeRequest(name string, registrationId string) *ClientMessage

MapRemoveEntryListenerEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapRemoveIfSameEncodeRequest 

func MapRemoveIfSameEncodeRequest(name string, key serialization.Data, value serialization.Data, threadId int64) *ClientMessage

MapRemoveIfSameEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapReplaceEncodeRequest 

func MapReplaceEncodeRequest(name string, key serialization.Data, value serialization.Data, threadId int64) *ClientMessage

MapReplaceEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapReplaceIfSameEncodeRequest 

func MapReplaceIfSameEncodeRequest(name string, key serialization.Data, testValue serialization.Data, value serialization.Data, threadId int64) *ClientMessage

MapReplaceIfSameEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapSetEncodeRequest 

func MapSetEncodeRequest(name string, key serialization.Data, value serialization.Data, threadId int64, ttl int64) *ClientMessage

MapSetEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapSizeEncodeRequest 

func MapSizeEncodeRequest(name string) *ClientMessage

MapSizeEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapTryLockEncodeRequest 

func MapTryLockEncodeRequest(name string, key serialization.Data, threadId int64, lease int64, timeout int64, referenceId int64) *ClientMessage

MapTryLockEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapTryPutEncodeRequest 

func MapTryPutEncodeRequest(name string, key serialization.Data, value serialization.Data, threadId int64, timeout int64) *ClientMessage

MapTryPutEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapTryRemoveEncodeRequest 

func MapTryRemoveEncodeRequest(name string, key serialization.Data, threadId int64, timeout int64) *ClientMessage

MapTryRemoveEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapUnlockEncodeRequest 

func MapUnlockEncodeRequest(name string, key serialization.Data, threadId int64, referenceId int64) *ClientMessage

MapUnlockEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapValuesEncodeRequest 

func MapValuesEncodeRequest(name string) *ClientMessage

MapValuesEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MapValuesWithPredicateEncodeRequest 

func MapValuesWithPredicateEncodeRequest(name string, predicate serialization.Data) *ClientMessage

MapValuesWithPredicateEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MultiMapAddEntryListenerEncodeRequest 

func MultiMapAddEntryListenerEncodeRequest(name string, includeValue bool, localOnly bool) *ClientMessage

MultiMapAddEntryListenerEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MultiMapAddEntryListenerToKeyEncodeRequest 

func MultiMapAddEntryListenerToKeyEncodeRequest(name string, key serialization.Data, includeValue bool, localOnly bool) *ClientMessage

MultiMapAddEntryListenerToKeyEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MultiMapClearEncodeRequest 

func MultiMapClearEncodeRequest(name string) *ClientMessage

MultiMapClearEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MultiMapContainsEntryEncodeRequest 

func MultiMapContainsEntryEncodeRequest(name string, key serialization.Data, value serialization.Data, threadId int64) *ClientMessage

MultiMapContainsEntryEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MultiMapContainsKeyEncodeRequest 

func MultiMapContainsKeyEncodeRequest(name string, key serialization.Data, threadId int64) *ClientMessage

MultiMapContainsKeyEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MultiMapContainsValueEncodeRequest 

func MultiMapContainsValueEncodeRequest(name string, value serialization.Data) *ClientMessage

MultiMapContainsValueEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MultiMapDeleteEncodeRequest 

func MultiMapDeleteEncodeRequest(name string, key serialization.Data, threadId int64) *ClientMessage

MultiMapDeleteEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MultiMapEntrySetEncodeRequest 

func MultiMapEntrySetEncodeRequest(name string) *ClientMessage

MultiMapEntrySetEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MultiMapForceUnlockEncodeRequest 

func MultiMapForceUnlockEncodeRequest(name string, key serialization.Data, referenceId int64) *ClientMessage

MultiMapForceUnlockEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MultiMapGetEncodeRequest 

func MultiMapGetEncodeRequest(name string, key serialization.Data, threadId int64) *ClientMessage

MultiMapGetEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MultiMapIsLockedEncodeRequest 

func MultiMapIsLockedEncodeRequest(name string, key serialization.Data) *ClientMessage

MultiMapIsLockedEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MultiMapKeySetEncodeRequest 

func MultiMapKeySetEncodeRequest(name string) *ClientMessage

MultiMapKeySetEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MultiMapLockEncodeRequest 

func MultiMapLockEncodeRequest(name string, key serialization.Data, threadId int64, ttl int64, referenceId int64) *ClientMessage

MultiMapLockEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MultiMapPutEncodeRequest 

func MultiMapPutEncodeRequest(name string, key serialization.Data, value serialization.Data, threadId int64) *ClientMessage

MultiMapPutEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MultiMapRemoveEncodeRequest 

func MultiMapRemoveEncodeRequest(name string, key serialization.Data, threadId int64) *ClientMessage

MultiMapRemoveEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MultiMapRemoveEntryEncodeRequest 

func MultiMapRemoveEntryEncodeRequest(name string, key serialization.Data, value serialization.Data, threadId int64) *ClientMessage

MultiMapRemoveEntryEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MultiMapRemoveEntryListenerEncodeRequest 

func MultiMapRemoveEntryListenerEncodeRequest(name string, registrationId string) *ClientMessage

MultiMapRemoveEntryListenerEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MultiMapSizeEncodeRequest 

func MultiMapSizeEncodeRequest(name string) *ClientMessage

MultiMapSizeEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MultiMapTryLockEncodeRequest 

func MultiMapTryLockEncodeRequest(name string, key serialization.Data, threadId int64, lease int64, timeout int64, referenceId int64) *ClientMessage

MultiMapTryLockEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MultiMapUnlockEncodeRequest 

func MultiMapUnlockEncodeRequest(name string, key serialization.Data, threadId int64, referenceId int64) *ClientMessage

MultiMapUnlockEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MultiMapValueCountEncodeRequest 

func MultiMapValueCountEncodeRequest(name string, key serialization.Data, threadId int64) *ClientMessage

MultiMapValueCountEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func MultiMapValuesEncodeRequest 

func MultiMapValuesEncodeRequest(name string) *ClientMessage

MultiMapValuesEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func NewClientMessage 

func NewClientMessage(buffer []byte, payloadSize int) *ClientMessage

func PNCounterAddEncodeRequest 

func PNCounterAddEncodeRequest(name string, delta int64, getBeforeUpdate bool, replicaTimestamps []*Pair, targetReplica *Address) *ClientMessage

PNCounterAddEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func PNCounterGetConfiguredReplicaCountEncodeRequest 

func PNCounterGetConfiguredReplicaCountEncodeRequest(name string) *ClientMessage

PNCounterGetConfiguredReplicaCountEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func PNCounterGetEncodeRequest 

func PNCounterGetEncodeRequest(name string, replicaTimestamps []*Pair, targetReplica *Address) *ClientMessage

PNCounterGetEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func QueueAddAllEncodeRequest 

func QueueAddAllEncodeRequest(name string, dataList []serialization.Data) *ClientMessage

QueueAddAllEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func QueueAddListenerEncodeRequest 

func QueueAddListenerEncodeRequest(name string, includeValue bool, localOnly bool) *ClientMessage

QueueAddListenerEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func QueueClearEncodeRequest 

func QueueClearEncodeRequest(name string) *ClientMessage

QueueClearEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func QueueCompareAndRemoveAllEncodeRequest 

func QueueCompareAndRemoveAllEncodeRequest(name string, dataList []serialization.Data) *ClientMessage

QueueCompareAndRemoveAllEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func QueueCompareAndRetainAllEncodeRequest 

func QueueCompareAndRetainAllEncodeRequest(name string, dataList []serialization.Data) *ClientMessage

QueueCompareAndRetainAllEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func QueueContainsAllEncodeRequest 

func QueueContainsAllEncodeRequest(name string, dataList []serialization.Data) *ClientMessage

QueueContainsAllEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func QueueContainsEncodeRequest 

func QueueContainsEncodeRequest(name string, value serialization.Data) *ClientMessage

QueueContainsEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func QueueDrainToEncodeRequest 

func QueueDrainToEncodeRequest(name string) *ClientMessage

QueueDrainToEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func QueueDrainToMaxSizeEncodeRequest 

func QueueDrainToMaxSizeEncodeRequest(name string, maxSize int32) *ClientMessage

QueueDrainToMaxSizeEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func QueueIsEmptyEncodeRequest 

func QueueIsEmptyEncodeRequest(name string) *ClientMessage

QueueIsEmptyEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func QueueIteratorEncodeRequest 

func QueueIteratorEncodeRequest(name string) *ClientMessage

QueueIteratorEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func QueueOfferEncodeRequest 

func QueueOfferEncodeRequest(name string, value serialization.Data, timeoutMillis int64) *ClientMessage

QueueOfferEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func QueuePeekEncodeRequest 

func QueuePeekEncodeRequest(name string) *ClientMessage

QueuePeekEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func QueuePollEncodeRequest 

func QueuePollEncodeRequest(name string, timeoutMillis int64) *ClientMessage

QueuePollEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func QueuePutEncodeRequest 

func QueuePutEncodeRequest(name string, value serialization.Data) *ClientMessage

QueuePutEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func QueueRemainingCapacityEncodeRequest 

func QueueRemainingCapacityEncodeRequest(name string) *ClientMessage

QueueRemainingCapacityEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func QueueRemoveEncodeRequest 

func QueueRemoveEncodeRequest(name string, value serialization.Data) *ClientMessage

QueueRemoveEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func QueueRemoveListenerEncodeRequest 

func QueueRemoveListenerEncodeRequest(name string, registrationId string) *ClientMessage

QueueRemoveListenerEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func QueueSizeEncodeRequest 

func QueueSizeEncodeRequest(name string) *ClientMessage

QueueSizeEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func QueueTakeEncodeRequest 

func QueueTakeEncodeRequest(name string) *ClientMessage

QueueTakeEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ReplicatedMapAddEntryListenerEncodeRequest 

func ReplicatedMapAddEntryListenerEncodeRequest(name string, localOnly bool) *ClientMessage

ReplicatedMapAddEntryListenerEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ReplicatedMapAddEntryListenerToKeyEncodeRequest 

func ReplicatedMapAddEntryListenerToKeyEncodeRequest(name string, key serialization.Data, localOnly bool) *ClientMessage

ReplicatedMapAddEntryListenerToKeyEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ReplicatedMapAddEntryListenerToKeyWithPredicateEncodeRequest 

func ReplicatedMapAddEntryListenerToKeyWithPredicateEncodeRequest(name string, key serialization.Data, predicate serialization.Data, localOnly bool) *ClientMessage

ReplicatedMapAddEntryListenerToKeyWithPredicateEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ReplicatedMapAddEntryListenerWithPredicateEncodeRequest 

func ReplicatedMapAddEntryListenerWithPredicateEncodeRequest(name string, predicate serialization.Data, localOnly bool) *ClientMessage

ReplicatedMapAddEntryListenerWithPredicateEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ReplicatedMapClearEncodeRequest 

func ReplicatedMapClearEncodeRequest(name string) *ClientMessage

ReplicatedMapClearEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ReplicatedMapContainsKeyEncodeRequest 

func ReplicatedMapContainsKeyEncodeRequest(name string, key serialization.Data) *ClientMessage

ReplicatedMapContainsKeyEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ReplicatedMapContainsValueEncodeRequest 

func ReplicatedMapContainsValueEncodeRequest(name string, value serialization.Data) *ClientMessage

ReplicatedMapContainsValueEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ReplicatedMapEntrySetEncodeRequest 

func ReplicatedMapEntrySetEncodeRequest(name string) *ClientMessage

ReplicatedMapEntrySetEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ReplicatedMapGetEncodeRequest 

func ReplicatedMapGetEncodeRequest(name string, key serialization.Data) *ClientMessage

ReplicatedMapGetEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ReplicatedMapIsEmptyEncodeRequest 

func ReplicatedMapIsEmptyEncodeRequest(name string) *ClientMessage

ReplicatedMapIsEmptyEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ReplicatedMapKeySetEncodeRequest 

func ReplicatedMapKeySetEncodeRequest(name string) *ClientMessage

ReplicatedMapKeySetEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ReplicatedMapPutAllEncodeRequest 

func ReplicatedMapPutAllEncodeRequest(name string, entries []*Pair) *ClientMessage

ReplicatedMapPutAllEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ReplicatedMapPutEncodeRequest 

func ReplicatedMapPutEncodeRequest(name string, key serialization.Data, value serialization.Data, ttl int64) *ClientMessage

ReplicatedMapPutEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ReplicatedMapRemoveEncodeRequest 

func ReplicatedMapRemoveEncodeRequest(name string, key serialization.Data) *ClientMessage

ReplicatedMapRemoveEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ReplicatedMapRemoveEntryListenerEncodeRequest 

func ReplicatedMapRemoveEntryListenerEncodeRequest(name string, registrationId string) *ClientMessage

ReplicatedMapRemoveEntryListenerEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ReplicatedMapSizeEncodeRequest 

func ReplicatedMapSizeEncodeRequest(name string) *ClientMessage

ReplicatedMapSizeEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func ReplicatedMapValuesEncodeRequest 

func ReplicatedMapValuesEncodeRequest(name string) *ClientMessage

ReplicatedMapValuesEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func RingbufferAddAllEncodeRequest 

func RingbufferAddAllEncodeRequest(name string, valueList []serialization.Data, overflowPolicy int32) *ClientMessage

RingbufferAddAllEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func RingbufferAddEncodeRequest 

func RingbufferAddEncodeRequest(name string, overflowPolicy int32, value serialization.Data) *ClientMessage

RingbufferAddEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func RingbufferCapacityEncodeRequest 

func RingbufferCapacityEncodeRequest(name string) *ClientMessage

RingbufferCapacityEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func RingbufferHeadSequenceEncodeRequest 

func RingbufferHeadSequenceEncodeRequest(name string) *ClientMessage

RingbufferHeadSequenceEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func RingbufferReadManyEncodeRequest 

func RingbufferReadManyEncodeRequest(name string, startSequence int64, minCount int32, maxCount int32, filter serialization.Data) *ClientMessage

RingbufferReadManyEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func RingbufferReadOneEncodeRequest 

func RingbufferReadOneEncodeRequest(name string, sequence int64) *ClientMessage

RingbufferReadOneEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func RingbufferRemainingCapacityEncodeRequest 

func RingbufferRemainingCapacityEncodeRequest(name string) *ClientMessage

RingbufferRemainingCapacityEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func RingbufferSizeEncodeRequest 

func RingbufferSizeEncodeRequest(name string) *ClientMessage

RingbufferSizeEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func RingbufferTailSequenceEncodeRequest 

func RingbufferTailSequenceEncodeRequest(name string) *ClientMessage

RingbufferTailSequenceEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func SetAddAllEncodeRequest 

func SetAddAllEncodeRequest(name string, valueList []serialization.Data) *ClientMessage

SetAddAllEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func SetAddEncodeRequest 

func SetAddEncodeRequest(name string, value serialization.Data) *ClientMessage

SetAddEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func SetAddListenerEncodeRequest 

func SetAddListenerEncodeRequest(name string, includeValue bool, localOnly bool) *ClientMessage

SetAddListenerEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func SetClearEncodeRequest 

func SetClearEncodeRequest(name string) *ClientMessage

SetClearEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func SetCompareAndRemoveAllEncodeRequest 

func SetCompareAndRemoveAllEncodeRequest(name string, values []serialization.Data) *ClientMessage

SetCompareAndRemoveAllEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func SetCompareAndRetainAllEncodeRequest 

func SetCompareAndRetainAllEncodeRequest(name string, values []serialization.Data) *ClientMessage

SetCompareAndRetainAllEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func SetContainsAllEncodeRequest 

func SetContainsAllEncodeRequest(name string, items []serialization.Data) *ClientMessage

SetContainsAllEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func SetContainsEncodeRequest 

func SetContainsEncodeRequest(name string, value serialization.Data) *ClientMessage

SetContainsEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func SetGetAllEncodeRequest 

func SetGetAllEncodeRequest(name string) *ClientMessage

SetGetAllEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func SetIsEmptyEncodeRequest 

func SetIsEmptyEncodeRequest(name string) *ClientMessage

SetIsEmptyEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func SetRemoveEncodeRequest 

func SetRemoveEncodeRequest(name string, value serialization.Data) *ClientMessage

SetRemoveEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func SetRemoveListenerEncodeRequest 

func SetRemoveListenerEncodeRequest(name string, registrationId string) *ClientMessage

SetRemoveListenerEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func SetSizeEncodeRequest 

func SetSizeEncodeRequest(name string) *ClientMessage

SetSizeEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func TopicAddMessageListenerEncodeRequest 

func TopicAddMessageListenerEncodeRequest(name string, localOnly bool) *ClientMessage

TopicAddMessageListenerEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func TopicPublishEncodeRequest 

func TopicPublishEncodeRequest(name string, message serialization.Data) *ClientMessage

TopicPublishEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func TopicRemoveMessageListenerEncodeRequest 

func TopicRemoveMessageListenerEncodeRequest(name string, registrationId string) *ClientMessage

TopicRemoveMessageListenerEncodeRequest creates and encodes a client message with the given parameters. It returns the encoded client message.

func (*ClientMessage) Accumulate 

func (m *ClientMessage) Accumulate(newMsg *ClientMessage)

func (*ClientMessage) AddFlags 

func (m *ClientMessage) AddFlags(v uint8)

func (*ClientMessage) AppendBool 

func (m *ClientMessage) AppendBool(v bool)

func (*ClientMessage) AppendByte 

func (m *ClientMessage) AppendByte(v uint8)

func (*ClientMessage) AppendByteArray 

func (m *ClientMessage) AppendByteArray(arr []byte)

func (*ClientMessage) AppendData 

func (m *ClientMessage) AppendData(v serialization.Data)

func (*ClientMessage) AppendInt32 

func (m *ClientMessage) AppendInt32(v int32)

func (*ClientMessage) AppendInt64 

func (m *ClientMessage) AppendInt64(v int64)

func (*ClientMessage) AppendString 

func (m *ClientMessage) AppendString(str string)

func (*ClientMessage) AppendUint8 

func (m *ClientMessage) AppendUint8(v uint8)

func (*ClientMessage) CloneMessage 

func (m *ClientMessage) CloneMessage() *ClientMessage

func (*ClientMessage) CorrelationID 

func (m *ClientMessage) CorrelationID() int64

func (*ClientMessage) DataOffset 

func (m *ClientMessage) DataOffset() uint16

func (*ClientMessage) Flags 

func (m *ClientMessage) Flags() uint8

func (*ClientMessage) FrameLength 

func (m *ClientMessage) FrameLength() int32

func (*ClientMessage) HasFlags 

func (m *ClientMessage) HasFlags(flags uint8) uint8

func (*ClientMessage) IsComplete 

func (m *ClientMessage) IsComplete() bool

func (*ClientMessage) MessageType 

func (m *ClientMessage) MessageType() bufutil.MessageType

func (*ClientMessage) PartitionID 

func (m *ClientMessage) PartitionID() int32

func (*ClientMessage) ReadBool 

func (m *ClientMessage) ReadBool() bool

func (*ClientMessage) ReadByteArray 

func (m *ClientMessage) ReadByteArray() []byte

func (*ClientMessage) ReadData 

func (m *ClientMessage) ReadData() serialization.Data

func (*ClientMessage) ReadInt32 

func (m *ClientMessage) ReadInt32() int32

func (*ClientMessage) ReadInt64 

func (m *ClientMessage) ReadInt64() int64

func (*ClientMessage) ReadString 

func (m *ClientMessage) ReadString() string

func (*ClientMessage) ReadUint8 

func (m *ClientMessage) ReadUint8() uint8

func (*ClientMessage) SetCorrelationID 

func (m *ClientMessage) SetCorrelationID(val int64)

func (*ClientMessage) SetDataOffset 

func (m *ClientMessage) SetDataOffset(v uint16)

func (*ClientMessage) SetFlags 

func (m *ClientMessage) SetFlags(v uint8)

func (*ClientMessage) SetFrameLength 

func (m *ClientMessage) SetFrameLength(v int32)

func (*ClientMessage) SetMessageType 

func (m *ClientMessage) SetMessageType(v bufutil.MessageType)

func (*ClientMessage) SetPartitionID 

func (m *ClientMessage) SetPartitionID(val int32)

func (*ClientMessage) SetVersion 

func (m *ClientMessage) SetVersion(v uint8)

func (*ClientMessage) UpdateFrameLength 

func (m *ClientMessage) UpdateFrameLength()

Helpers

type DataEntryView 

type DataEntryView struct {
	// contains filtered or unexported fields
}

func DataEntryViewCodecDecode 

func DataEntryViewCodecDecode(msg *ClientMessage) *DataEntryView

func (*DataEntryView) Cost 

func (ev *DataEntryView) Cost() int64

func (*DataEntryView) CreationTime 

func (ev *DataEntryView) CreationTime() int64

func (DataEntryView) Equal 

func (ev DataEntryView) Equal(ev2 DataEntryView) bool

func (*DataEntryView) EvictionCriteriaNumber 

func (ev *DataEntryView) EvictionCriteriaNumber() int64

func (*DataEntryView) ExpirationTime 

func (ev *DataEntryView) ExpirationTime() int64

func (*DataEntryView) Hits 

func (ev *DataEntryView) Hits() int64

func (*DataEntryView) KeyData 

func (ev *DataEntryView) KeyData() serialization.Data

func (*DataEntryView) LastAccessTime 

func (ev *DataEntryView) LastAccessTime() int64

func (*DataEntryView) LastStoredTime 

func (ev *DataEntryView) LastStoredTime() int64

func (*DataEntryView) LastUpdateTime 

func (ev *DataEntryView) LastUpdateTime() int64

func (*DataEntryView) TTL 

func (ev *DataEntryView) TTL() int64

func (*DataEntryView) ValueData 

func (ev *DataEntryView) ValueData() serialization.Data

func (*DataEntryView) Version 

func (ev *DataEntryView) Version() int64

type DecodeListenerResponse 

type DecodeListenerResponse func(message *ClientMessage) string

type DistributedObjectInfo 

type DistributedObjectInfo struct {
	// contains filtered or unexported fields
}

func DistributedObjectInfoCodecDecode 

func DistributedObjectInfoCodecDecode(msg *ClientMessage) *DistributedObjectInfo

func (*DistributedObjectInfo) Name 

func (i *DistributedObjectInfo) Name() string

func (*DistributedObjectInfo) ServiceName 

func (i *DistributedObjectInfo) ServiceName() string

type EncodeListenerRemoveRequest 

type EncodeListenerRemoveRequest func(registrationID string) *ClientMessage

type EntryEvent 

type EntryEvent struct {
	*AbstractMapEvent
	// contains filtered or unexported fields
}

func NewEntryEvent 

func NewEntryEvent(name string, member core.Member, eventType int32, key interface{}, value interface{},
	oldValue interface{}, mergingValue interface{}) *EntryEvent

func (*EntryEvent) Key 

func (e *EntryEvent) Key() interface{}

func (*EntryEvent) MergingValue 

func (e *EntryEvent) MergingValue() interface{}

func (*EntryEvent) OldValue 

func (e *EntryEvent) OldValue() interface{}

func (*EntryEvent) Value 

func (e *EntryEvent) Value() interface{}

type EntryView 

type EntryView struct {
	// contains filtered or unexported fields
}

func NewEntryView 

func NewEntryView(key interface{}, value interface{}, cost int64, creationTime int64, expirationTime int64, hits int64,
	lastAccessTime int64, lastStoredTime int64, lastUpdateTime int64, version int64, evictionCriteriaNumber int64, ttl int64) *EntryView

func (*EntryView) Cost 

func (ev *EntryView) Cost() int64

func (*EntryView) CreationTime 

func (ev *EntryView) CreationTime() time.Time

func (*EntryView) EvictionCriteriaNumber 

func (ev *EntryView) EvictionCriteriaNumber() int64

func (*EntryView) ExpirationTime 

func (ev *EntryView) ExpirationTime() time.Time

func (*EntryView) Hits 

func (ev *EntryView) Hits() int64

func (*EntryView) Key 

func (ev *EntryView) Key() interface{}

func (*EntryView) LastAccessTime 

func (ev *EntryView) LastAccessTime() time.Time

func (*EntryView) LastStoredTime 

func (ev *EntryView) LastStoredTime() time.Time

func (*EntryView) LastUpdateTime 

func (ev *EntryView) LastUpdateTime() time.Time

func (*EntryView) TTL 

func (ev *EntryView) TTL() time.Duration

func (*EntryView) Value 

func (ev *EntryView) Value() interface{}

func (*EntryView) Version 

func (ev *EntryView) Version() int64

type ItemEvent 

type ItemEvent struct {
	// contains filtered or unexported fields
}

func (*ItemEvent) EventType 

func (e *ItemEvent) EventType() int32

func (*ItemEvent) Item 

func (e *ItemEvent) Item() interface{}

func (*ItemEvent) Member 

func (e *ItemEvent) Member() core.Member

func (*ItemEvent) Name 

func (e *ItemEvent) Name() string

type ListAddListenerHandleEventItemFunc 

type ListAddListenerHandleEventItemFunc func(serialization.Data, string, int32)

ListAddListenerHandleEventItemFunc is the event handler function.

type MapAddEntryListenerHandleEventEntryFunc 

type MapAddEntryListenerHandleEventEntryFunc func(serialization.Data, serialization.Data, serialization.Data, serialization.Data, int32, string, int32)

MapAddEntryListenerHandleEventEntryFunc is the event handler function.

type MapAddEntryListenerToKeyHandleEventEntryFunc 

type MapAddEntryListenerToKeyHandleEventEntryFunc func(serialization.Data, serialization.Data, serialization.Data, serialization.Data, int32, string, int32)

MapAddEntryListenerToKeyHandleEventEntryFunc is the event handler function.

type MapAddEntryListenerToKeyWithPredicateHandleEventEntryFunc 

type MapAddEntryListenerToKeyWithPredicateHandleEventEntryFunc func(serialization.Data, serialization.Data, serialization.Data, serialization.Data, int32, string, int32)

MapAddEntryListenerToKeyWithPredicateHandleEventEntryFunc is the event handler function.

type MapAddEntryListenerWithPredicateHandleEventEntryFunc 

type MapAddEntryListenerWithPredicateHandleEventEntryFunc func(serialization.Data, serialization.Data, serialization.Data, serialization.Data, int32, string, int32)

MapAddEntryListenerWithPredicateHandleEventEntryFunc is the event handler function.

type MapEvent 

type MapEvent struct {
	*AbstractMapEvent
	// contains filtered or unexported fields
}

func (*MapEvent) NumberOfAffectedEntries 

func (e *MapEvent) NumberOfAffectedEntries() int32

func (*MapEvent) String 

func (e *MapEvent) String() string

type Member 

type Member struct {
	// contains filtered or unexported fields
}

func ClientAddMembershipListenerEventMemberDecode 

func ClientAddMembershipListenerEventMemberDecode(clientMessage *ClientMessage) (
	member *Member, eventType int32)

ClientAddMembershipListenerEventMemberDecode decodes the corresponding event from the given client message. It returns the result parameters for the event.

func ClientAddMembershipListenerEventMemberListDecode 

func ClientAddMembershipListenerEventMemberListDecode(clientMessage *ClientMessage) (
	members []*Member)

ClientAddMembershipListenerEventMemberListDecode decodes the corresponding event from the given client message. It returns the result parameters for the event.

func MemberCodecDecode 

func MemberCodecDecode(msg *ClientMessage) *Member

func NewMember 

func NewMember(address Address, uuid string, isLiteMember bool, attributes map[string]string) *Member

func (*Member) Address 

func (m *Member) Address() core.Address

func (*Member) Attributes 

func (m *Member) Attributes() map[string]string

func (*Member) Equal 

func (m *Member) Equal(member2 Member) bool

func (*Member) HasSameAddress 

func (m *Member) HasSameAddress(member *Member) bool

func (*Member) IsLiteMember 

func (m *Member) IsLiteMember() bool

func (*Member) String 

func (m *Member) String() string

func (*Member) UUID 

func (m *Member) UUID() string

type MemberAttributeEvent 

type MemberAttributeEvent struct {
	// contains filtered or unexported fields
}

func NewMemberAttributeEvent 

func NewMemberAttributeEvent(operationType int32, key string, value string, member core.Member) *MemberAttributeEvent

func (*MemberAttributeEvent) Key 

func (m *MemberAttributeEvent) Key() string

func (*MemberAttributeEvent) Member 

func (m *MemberAttributeEvent) Member() core.Member

func (*MemberAttributeEvent) OperationType 

func (m *MemberAttributeEvent) OperationType() int32

func (*MemberAttributeEvent) Value 

func (m *MemberAttributeEvent) Value() string

type MultiMapAddEntryListenerHandleEventEntryFunc 

type MultiMapAddEntryListenerHandleEventEntryFunc func(serialization.Data, serialization.Data, serialization.Data, serialization.Data, int32, string, int32)

MultiMapAddEntryListenerHandleEventEntryFunc is the event handler function.

type MultiMapAddEntryListenerToKeyHandleEventEntryFunc 

type MultiMapAddEntryListenerToKeyHandleEventEntryFunc func(serialization.Data, serialization.Data, serialization.Data, serialization.Data, int32, string, int32)

MultiMapAddEntryListenerToKeyHandleEventEntryFunc is the event handler function.

type Pair 

type Pair struct {
	// contains filtered or unexported fields
}

func NewPair 

func NewPair(key interface{}, value interface{}) *Pair

func (*Pair) Key 

func (p *Pair) Key() interface{}

func (*Pair) Value 

func (p *Pair) Value() interface{}

type QueueAddListenerHandleEventItemFunc 

type QueueAddListenerHandleEventItemFunc func(serialization.Data, string, int32)

QueueAddListenerHandleEventItemFunc is the event handler function.

type ReplicatedMapAddEntryListenerHandleEventEntryFunc 

type ReplicatedMapAddEntryListenerHandleEventEntryFunc func(serialization.Data, serialization.Data, serialization.Data, serialization.Data, int32, string, int32)

ReplicatedMapAddEntryListenerHandleEventEntryFunc is the event handler function.

type ReplicatedMapAddEntryListenerToKeyHandleEventEntryFunc 

type ReplicatedMapAddEntryListenerToKeyHandleEventEntryFunc func(serialization.Data, serialization.Data, serialization.Data, serialization.Data, int32, string, int32)

ReplicatedMapAddEntryListenerToKeyHandleEventEntryFunc is the event handler function.

type ReplicatedMapAddEntryListenerToKeyWithPredicateHandleEventEntryFunc 

type ReplicatedMapAddEntryListenerToKeyWithPredicateHandleEventEntryFunc func(serialization.Data, serialization.Data, serialization.Data, serialization.Data, int32, string, int32)

ReplicatedMapAddEntryListenerToKeyWithPredicateHandleEventEntryFunc is the event handler function.

type ReplicatedMapAddEntryListenerWithPredicateHandleEventEntryFunc 

type ReplicatedMapAddEntryListenerWithPredicateHandleEventEntryFunc func(serialization.Data, serialization.Data, serialization.Data, serialization.Data, int32, string, int32)

ReplicatedMapAddEntryListenerWithPredicateHandleEventEntryFunc is the event handler function.

type ServerError 

type ServerError struct {
	// contains filtered or unexported fields
}

func ErrorCodecDecode 

func ErrorCodecDecode(msg *ClientMessage) *ServerError

func (*ServerError) CauseClassName 

func (e *ServerError) CauseClassName() string

func (*ServerError) CauseErrorCode 

func (e *ServerError) CauseErrorCode() int32

func (*ServerError) ClassName 

func (e *ServerError) ClassName() string

func (*ServerError) Error 

func (e *ServerError) Error() string

func (*ServerError) ErrorCode 

func (e *ServerError) ErrorCode() int32

func (*ServerError) Message 

func (e *ServerError) Message() string

func (*ServerError) StackTrace 

func (e *ServerError) StackTrace() []core.StackTraceElement

type SetAddListenerHandleEventItemFunc 

type SetAddListenerHandleEventItemFunc func(serialization.Data, string, int32)

SetAddListenerHandleEventItemFunc is the event handler function.

type StackTraceElement 

type StackTraceElement struct {
	// contains filtered or unexported fields
}

func (*StackTraceElement) DeclaringClass 

func (e *StackTraceElement) DeclaringClass() string

func (*StackTraceElement) FileName 

func (e *StackTraceElement) FileName() string

func (*StackTraceElement) LineNumber 

func (e *StackTraceElement) LineNumber() int32

func (*StackTraceElement) MethodName 

func (e *StackTraceElement) MethodName() string

type TopicAddMessageListenerHandleEventTopicFunc 

type TopicAddMessageListenerHandleEventTopicFunc func(serialization.Data, int64, string)

TopicAddMessageListenerHandleEventTopicFunc is the event handler function.

type TopicMessage 

type TopicMessage struct {
	// contains filtered or unexported fields
}

func NewTopicMessage 

func NewTopicMessage(messageObject interface{}, publishTime int64, publishingMember core.Member) *TopicMessage

func (*TopicMessage) MessageObject 

func (m *TopicMessage) MessageObject() interface{}

func (*TopicMessage) PublishTime 

func (m *TopicMessage) PublishTime() time.Time

func (*TopicMessage) PublishingMember 

func (m *TopicMessage) PublishingMember() core.Member

Source Files

View all Source files

Directories

Path Synopsis

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.