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

Directories

Path Synopsis