proto

package

Go to main page

Versions in this module

v1

v1.4.2

Aug 7, 2024

v1.4.1

Aug 22, 2023

v1.4.0

Mar 17, 2023

v1.3.2

Feb 9, 2023

v1.3.1

Oct 5, 2022

v1.3.0

Jul 21, 2022

Changes in this version

+ const EntryListIntegerLongSizeInBytes

+ const EntryListIntegerUUIDEntrySizeInBytes

v1.2.1

Jul 7, 2022

Changes in this version

+ const EntryListUUIDLongEntrySizeInBytes

v1.2.0

Apr 13, 2022

Changes in this version

+ const LocalDateSizeInBytes

+ const LocalDateTimeSizeInBytes

+ const LocalTimeSizeInBytes

+ const OffsetDateTimeSizeInBytes

+ const RequestTTLOffset

+ const RequestThreadIDOffset

v1.1.1

Nov 9, 2021

v1.1.0

Sep 14, 2021

v1.0.0

Jul 13, 2021

Changes in this version

+ const BackupEventFlag

+ const BeginDataStructureFlag

+ const BeginFragmentFlag

+ const BooleanSizeInBytes

+ const ByteSizeInBytes

+ const CharSizeInBytes

+ const CorrelationIDFieldOffset

+ const CorrelationIDOffset

+ const DefaultFlags

+ const DoubleSizeInBytes

+ const EndDataStructureFlag

+ const EndFragmentFlag

+ const EntrySizeInBytes

+ const FloatSizeInBytes

+ const FragmentationIDOffset

+ const IntSizeInBytes

+ const IsEventFlag

+ const IsFinalFlag

+ const IsNullFlag

+ const LongSizeInBytes

+ const MessageTypeOffset

+ const PartitionIDOffset

+ const RequestIncludeValueOffset

+ const RequestListenerFlagsOffset

+ const RequestLocalOnlyOffset

+ const RequestReferenceIdOffset

+ const RequestThreadIdOffset

+ const RequestTtlOffset

+ const ResponseBackupAcksOffset

+ const ShortSizeInBytes

+ const SizeOfFrameLengthAndFlags

+ const TypeFieldOffset

+ const UUIDSizeInBytes

+ const UnfragmentedMessage

+ const UuidSizeInBytes

+ var BeginFrame = NewFrameWith([]byte{}, BeginDataStructureFlag)

+ var EndFrame = NewFrameWith([]byte{}, EndDataStructureFlag)

+ var NullFrame = NewFrameWith([]byte{}, IsNullFlag)

+ func NewStackTraceElement(className, methodName, fileName string, lineNumber int32) hzerrors.StackTraceElement

type ClientMessage

+ Err error

+ Frames []*Frame

+ Retryable bool

+ func NewClientMessageForDecode(frame *Frame) *ClientMessage

+ func NewClientMessageForEncode() *ClientMessage

+ func (m *ClientMessage) AddFrame(frame *Frame)

+ func (m *ClientMessage) Copy() *ClientMessage

+ func (m *ClientMessage) DropFragmentationFrame()

+ func (m *ClientMessage) FragmentationID() int64

+ func (m *ClientMessage) FrameIterator() *ForwardFrameIterator

+ func (m *ClientMessage) HasBackupEventFlag() bool

+ func (m *ClientMessage) HasEventFlag() bool

+ func (m *ClientMessage) HasFinalFrame() bool

+ func (m *ClientMessage) HasUnFragmentedMessageFlags() bool

+ func (m *ClientMessage) NumberOfBackupAcks() uint8

+ func (m *ClientMessage) SetPartitionId(partitionId int32)

+ func (m *ClientMessage) SetRetryable(retryable bool)

+ func (m *ClientMessage) TotalLength() int

+ func (m *ClientMessage) Type() int32

+ func (m *ClientMessage) Write(w io.Writer) error

+ type ClientMessageHandler func(clientMessage *ClientMessage)

+ type ErrorHolder struct

+ ClassName string

+ ErrorCode int32

+ Message string

+ StackTraceElements []hzerrors.StackTraceElement

+ func NewErrorHolder(errorCode int32, className, message string, ...) ErrorHolder

+ type ForwardFrameIterator struct

+ func NewForwardFrameIterator(frames []*Frame) *ForwardFrameIterator

+ func (it *ForwardFrameIterator) HasNext() bool

+ func (it *ForwardFrameIterator) Next() *Frame

+ func (it *ForwardFrameIterator) PeekNext() *Frame

+ type Frame struct

+ Content []byte

+ func NewBeginFrame() *Frame

+ func NewEndFrame() *Frame

+ func NewFrame(content []byte) *Frame

+ func NewFrameWith(content []byte, flags uint16) *Frame

+ func NewNullFrame() *Frame

+ func (frame *Frame) Copy() *Frame

+ func (frame *Frame) DeepCopy() *Frame

+ func (frame Frame) GetLength() int

+ func (frame Frame) HasBackupEventFlag() bool

+ func (frame Frame) HasBeginFragmentFlag() bool

+ func (frame Frame) HasEndFragmentFlag() bool

+ func (frame Frame) HasEventFlag() bool

+ func (frame Frame) HasUnFragmentedMessageFlags() bool

+ func (frame Frame) IsBeginFrame() bool

+ func (frame Frame) IsEndFrame() bool

+ func (frame Frame) IsFinalFrame() bool

+ func (frame Frame) IsFlagSet(flagMask uint16) bool

+ func (frame Frame) IsNullFrame() bool

v1.0.0-preview.4

Jun 18, 2021

v1.0.0-preview.3

Jun 8, 2021

v1.0.0-preview.2

May 21, 2021

v1.0.0-preview.1

May 7, 2021

v0

v0.6.0

Mar 9, 2020

v0.5.0

Mar 20, 2019

Changes in this version

+ const ClientType

+ func AddressCodecEncode(msg *ClientMessage, address *Address)

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

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

+ func ClientAddMembershipListenerHandle(clientMessage *ClientMessage, ...)

+ func ClientAuthenticationCustomDecodeResponse(clientMessage *ClientMessage) func() (status uint8, address *Address, uuid string, ownerUuid string, ...)

+ func ClientAuthenticationDecodeResponse(clientMessage *ClientMessage) func() (status uint8, address *Address, uuid string, ownerUuid string, ...)

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

+ func DecodeStackTrace(msg *ClientMessage) core.StackTraceElement

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

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

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

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

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

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

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

+ func ListAddListenerHandle(clientMessage *ClientMessage, ...)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func MapAddEntryListenerEventEntryDecode(clientMessage *ClientMessage) (key serialization.Data, value serialization.Data, oldValue serialization.Data, ...)

+ func MapAddEntryListenerHandle(clientMessage *ClientMessage, ...)

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

+ func MapAddEntryListenerToKeyEventEntryDecode(clientMessage *ClientMessage) (key serialization.Data, value serialization.Data, oldValue serialization.Data, ...)

+ func MapAddEntryListenerToKeyHandle(clientMessage *ClientMessage, ...)

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

+ func MapAddEntryListenerToKeyWithPredicateEventEntryDecode(clientMessage *ClientMessage) (key serialization.Data, value serialization.Data, oldValue serialization.Data, ...)

+ func MapAddEntryListenerToKeyWithPredicateHandle(clientMessage *ClientMessage, ...)

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

+ func MapAddEntryListenerWithPredicateEventEntryDecode(clientMessage *ClientMessage) (key serialization.Data, value serialization.Data, oldValue serialization.Data, ...)

+ func MapAddEntryListenerWithPredicateHandle(clientMessage *ClientMessage, ...)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func MultiMapAddEntryListenerEventEntryDecode(clientMessage *ClientMessage) (key serialization.Data, value serialization.Data, oldValue serialization.Data, ...)

+ func MultiMapAddEntryListenerHandle(clientMessage *ClientMessage, ...)

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

+ func MultiMapAddEntryListenerToKeyEventEntryDecode(clientMessage *ClientMessage) (key serialization.Data, value serialization.Data, oldValue serialization.Data, ...)

+ func MultiMapAddEntryListenerToKeyHandle(clientMessage *ClientMessage, ...)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func QueueAddListenerHandle(clientMessage *ClientMessage, ...)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func ReplicatedMapAddEntryListenerEventEntryDecode(clientMessage *ClientMessage) (key serialization.Data, value serialization.Data, oldValue serialization.Data, ...)

+ func ReplicatedMapAddEntryListenerHandle(clientMessage *ClientMessage, ...)

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

+ func ReplicatedMapAddEntryListenerToKeyEventEntryDecode(clientMessage *ClientMessage) (key serialization.Data, value serialization.Data, oldValue serialization.Data, ...)

+ func ReplicatedMapAddEntryListenerToKeyHandle(clientMessage *ClientMessage, ...)

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

+ func ReplicatedMapAddEntryListenerToKeyWithPredicateEventEntryDecode(clientMessage *ClientMessage) (key serialization.Data, value serialization.Data, oldValue serialization.Data, ...)

+ func ReplicatedMapAddEntryListenerToKeyWithPredicateHandle(clientMessage *ClientMessage, ...)

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

+ func ReplicatedMapAddEntryListenerWithPredicateEventEntryDecode(clientMessage *ClientMessage) (key serialization.Data, value serialization.Data, oldValue serialization.Data, ...)

+ func ReplicatedMapAddEntryListenerWithPredicateHandle(clientMessage *ClientMessage, ...)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func RingbufferReadManyDecodeResponse(clientMessage *ClientMessage) ...

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

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

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

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

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

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

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

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

+ func SetAddListenerHandle(clientMessage *ClientMessage, ...)

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

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

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

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

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

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

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

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

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

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

+ func TopicAddMessageListenerHandle(clientMessage *ClientMessage, ...)

+ func UUIDCodecDecode(msg *ClientMessage) *uuid

+ func UUIDCodecEncode(msg *ClientMessage, uuid uuid)

+ type AbstractMapEvent struct

+ func (e *AbstractMapEvent) EventType() int32

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

+ func (e *AbstractMapEvent) Name() string

+ func (e *AbstractMapEvent) String() string

+ type Address struct

+ func AddressCodecDecode(msg *ClientMessage) *Address

+ func NewAddressWithParameters(Host string, Port int) *Address

+ func (a *Address) Host() string

+ func (a *Address) Port() int

+ func (a *Address) String() string

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

+ type ClientAddMembershipListenerHandleEventMemberFunc func(*Member, int32)

+ type ClientAddMembershipListenerHandleEventMemberListFunc func([]*Member)

+ type ClientMessage struct

+ Buffer []byte

+ IsRetryable bool

+ func ClientAddMembershipListenerEncodeRequest(localOnly bool) *ClientMessage

+ func ClientAuthenticationCustomEncodeRequest(credentials serialization.Data, uuid string, ownerUuid string, ...) *ClientMessage

+ func ClientAuthenticationEncodeRequest(username string, password string, uuid string, ownerUuid string, ...) *ClientMessage

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

+ func ClientDestroyProxyEncodeRequest(name string, serviceName string) *ClientMessage

+ func ClientGetPartitionsEncodeRequest() *ClientMessage

+ func ClientPingEncodeRequest() *ClientMessage

+ func ClientStatisticsEncodeRequest(stats string) *ClientMessage

+ func FlakeIDGeneratorNewIDBatchEncodeRequest(name string, batchSize int32) *ClientMessage

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

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

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

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

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

+ func ListClearEncodeRequest(name string) *ClientMessage

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

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

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

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

+ func ListGetAllEncodeRequest(name string) *ClientMessage

+ func ListGetEncodeRequest(name string, index int32) *ClientMessage

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

+ func ListIsEmptyEncodeRequest(name string) *ClientMessage

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

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

+ func ListRemoveListenerEncodeRequest(name string, registrationId string) *ClientMessage

+ func ListRemoveWithIndexEncodeRequest(name string, index int32) *ClientMessage

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

+ func ListSizeEncodeRequest(name string) *ClientMessage

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

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

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

+ func MapAddEntryListenerToKeyWithPredicateEncodeRequest(name string, key serialization.Data, predicate serialization.Data, ...) *ClientMessage

+ func MapAddEntryListenerWithPredicateEncodeRequest(name string, predicate serialization.Data, includeValue bool, ...) *ClientMessage

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

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

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

+ func MapClearEncodeRequest(name string) *ClientMessage

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

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

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

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

+ func MapEntrySetEncodeRequest(name string) *ClientMessage

+ func MapEvictAllEncodeRequest(name string) *ClientMessage

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

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

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

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

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

+ func MapFlushEncodeRequest(name string) *ClientMessage

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

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

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

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

+ func MapIsEmptyEncodeRequest(name string) *ClientMessage

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

+ func MapKeySetEncodeRequest(name string) *ClientMessage

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

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

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

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

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

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

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

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

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

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

+ func MapRemoveEntryListenerEncodeRequest(name string, registrationId string) *ClientMessage

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

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

+ func MapReplaceIfSameEncodeRequest(name string, key serialization.Data, testValue serialization.Data, ...) *ClientMessage

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

+ func MapSizeEncodeRequest(name string) *ClientMessage

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

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

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

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

+ func MapValuesEncodeRequest(name string) *ClientMessage

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

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

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

+ func MultiMapClearEncodeRequest(name string) *ClientMessage

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

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

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

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

+ func MultiMapEntrySetEncodeRequest(name string) *ClientMessage

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

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

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

+ func MultiMapKeySetEncodeRequest(name string) *ClientMessage

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

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

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

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

+ func MultiMapRemoveEntryListenerEncodeRequest(name string, registrationId string) *ClientMessage

+ func MultiMapSizeEncodeRequest(name string) *ClientMessage

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

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

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

+ func MultiMapValuesEncodeRequest(name string) *ClientMessage

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

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

+ func PNCounterGetConfiguredReplicaCountEncodeRequest(name string) *ClientMessage

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

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

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

+ func QueueClearEncodeRequest(name string) *ClientMessage

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

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

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

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

+ func QueueDrainToEncodeRequest(name string) *ClientMessage

+ func QueueDrainToMaxSizeEncodeRequest(name string, maxSize int32) *ClientMessage

+ func QueueIsEmptyEncodeRequest(name string) *ClientMessage

+ func QueueIteratorEncodeRequest(name string) *ClientMessage

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

+ func QueuePeekEncodeRequest(name string) *ClientMessage

+ func QueuePollEncodeRequest(name string, timeoutMillis int64) *ClientMessage

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

+ func QueueRemainingCapacityEncodeRequest(name string) *ClientMessage

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

+ func QueueRemoveListenerEncodeRequest(name string, registrationId string) *ClientMessage

+ func QueueSizeEncodeRequest(name string) *ClientMessage

+ func QueueTakeEncodeRequest(name string) *ClientMessage

+ func ReplicatedMapAddEntryListenerEncodeRequest(name string, localOnly bool) *ClientMessage

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

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

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

+ func ReplicatedMapClearEncodeRequest(name string) *ClientMessage

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

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

+ func ReplicatedMapEntrySetEncodeRequest(name string) *ClientMessage

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

+ func ReplicatedMapIsEmptyEncodeRequest(name string) *ClientMessage

+ func ReplicatedMapKeySetEncodeRequest(name string) *ClientMessage

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

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

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

+ func ReplicatedMapRemoveEntryListenerEncodeRequest(name string, registrationId string) *ClientMessage

+ func ReplicatedMapSizeEncodeRequest(name string) *ClientMessage

+ func ReplicatedMapValuesEncodeRequest(name string) *ClientMessage

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

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

+ func RingbufferCapacityEncodeRequest(name string) *ClientMessage

+ func RingbufferHeadSequenceEncodeRequest(name string) *ClientMessage

+ func RingbufferReadManyEncodeRequest(name string, startSequence int64, minCount int32, maxCount int32, ...) *ClientMessage

+ func RingbufferReadOneEncodeRequest(name string, sequence int64) *ClientMessage

+ func RingbufferRemainingCapacityEncodeRequest(name string) *ClientMessage

+ func RingbufferSizeEncodeRequest(name string) *ClientMessage

+ func RingbufferTailSequenceEncodeRequest(name string) *ClientMessage

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

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

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

+ func SetClearEncodeRequest(name string) *ClientMessage

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

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

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

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

+ func SetGetAllEncodeRequest(name string) *ClientMessage

+ func SetIsEmptyEncodeRequest(name string) *ClientMessage

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

+ func SetRemoveListenerEncodeRequest(name string, registrationId string) *ClientMessage

+ func SetSizeEncodeRequest(name string) *ClientMessage

+ func TopicAddMessageListenerEncodeRequest(name string, localOnly bool) *ClientMessage

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

+ func TopicRemoveMessageListenerEncodeRequest(name string, registrationId string) *ClientMessage

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

+ func (m *ClientMessage) AddFlags(v uint8)

+ func (m *ClientMessage) AppendBool(v bool)

+ func (m *ClientMessage) AppendByte(v uint8)

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

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

+ func (m *ClientMessage) AppendInt32(v int32)

+ func (m *ClientMessage) AppendInt64(v int64)

+ func (m *ClientMessage) AppendString(str string)

+ func (m *ClientMessage) AppendUint8(v uint8)

+ func (m *ClientMessage) CloneMessage() *ClientMessage

+ func (m *ClientMessage) CorrelationID() int64

+ func (m *ClientMessage) DataOffset() uint16

+ func (m *ClientMessage) Flags() uint8

+ func (m *ClientMessage) FrameLength() int32

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

+ func (m *ClientMessage) IsComplete() bool

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

+ func (m *ClientMessage) PartitionID() int32

+ func (m *ClientMessage) ReadBool() bool

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

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

+ func (m *ClientMessage) ReadInt32() int32

+ func (m *ClientMessage) ReadInt64() int64

+ func (m *ClientMessage) ReadString() string

+ func (m *ClientMessage) ReadUint8() uint8

+ func (m *ClientMessage) SetCorrelationID(val int64)

+ func (m *ClientMessage) SetDataOffset(v uint16)

+ func (m *ClientMessage) SetFlags(v uint8)

+ func (m *ClientMessage) SetFrameLength(v int32)

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

+ func (m *ClientMessage) SetPartitionID(val int32)

+ func (m *ClientMessage) SetVersion(v uint8)

+ func (m *ClientMessage) UpdateFrameLength()

+ type DataEntryView struct

+ func DataEntryViewCodecDecode(msg *ClientMessage) *DataEntryView

+ func (ev *DataEntryView) Cost() int64

+ func (ev *DataEntryView) CreationTime() int64

+ func (ev *DataEntryView) EvictionCriteriaNumber() int64

+ func (ev *DataEntryView) ExpirationTime() int64

+ func (ev *DataEntryView) Hits() int64

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

+ func (ev *DataEntryView) LastAccessTime() int64

+ func (ev *DataEntryView) LastStoredTime() int64

+ func (ev *DataEntryView) LastUpdateTime() int64

+ func (ev *DataEntryView) TTL() int64

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

+ func (ev *DataEntryView) Version() int64

+ func (ev DataEntryView) Equal(ev2 DataEntryView) bool

+ type DecodeListenerResponse func(message *ClientMessage) string

+ type DistributedObjectInfo struct

+ func DistributedObjectInfoCodecDecode(msg *ClientMessage) *DistributedObjectInfo

+ func (i *DistributedObjectInfo) Name() string

+ func (i *DistributedObjectInfo) ServiceName() string

+ type EncodeListenerRemoveRequest func(registrationID string) *ClientMessage

+ type EntryEvent struct

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

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

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

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

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

+ type EntryView struct

+ func NewEntryView(key interface{}, value interface{}, cost int64, creationTime int64, ...) *EntryView

+ func (ev *EntryView) Cost() int64

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

+ func (ev *EntryView) EvictionCriteriaNumber() int64

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

+ func (ev *EntryView) Hits() int64

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

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

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

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

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

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

+ func (ev *EntryView) Version() int64

+ type ItemEvent struct

+ func (e *ItemEvent) EventType() int32

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

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

+ func (e *ItemEvent) Name() string

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

+ type MapAddEntryListenerHandleEventEntryFunc func(serialization.Data, serialization.Data, serialization.Data, serialization.Data, ...)

+ type MapAddEntryListenerToKeyHandleEventEntryFunc func(serialization.Data, serialization.Data, serialization.Data, serialization.Data, ...)

+ type MapAddEntryListenerToKeyWithPredicateHandleEventEntryFunc func(serialization.Data, serialization.Data, serialization.Data, serialization.Data, ...)

+ type MapAddEntryListenerWithPredicateHandleEventEntryFunc func(serialization.Data, serialization.Data, serialization.Data, serialization.Data, ...)

+ type MapEvent struct

+ func (e *MapEvent) NumberOfAffectedEntries() int32

+ func (e *MapEvent) String() string

+ type Member struct

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

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

+ func MemberCodecDecode(msg *ClientMessage) *Member

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

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

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

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

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

+ func (m *Member) IsLiteMember() bool

+ func (m *Member) String() string

+ func (m *Member) UUID() string

+ type MemberAttributeEvent struct

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

+ func (m *MemberAttributeEvent) Key() string

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

+ func (m *MemberAttributeEvent) OperationType() int32

+ func (m *MemberAttributeEvent) Value() string

+ type MultiMapAddEntryListenerHandleEventEntryFunc func(serialization.Data, serialization.Data, serialization.Data, serialization.Data, ...)

+ type MultiMapAddEntryListenerToKeyHandleEventEntryFunc func(serialization.Data, serialization.Data, serialization.Data, serialization.Data, ...)

+ type Pair struct

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

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

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

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

+ type ReplicatedMapAddEntryListenerHandleEventEntryFunc func(serialization.Data, serialization.Data, serialization.Data, serialization.Data, ...)

+ type ReplicatedMapAddEntryListenerToKeyHandleEventEntryFunc func(serialization.Data, serialization.Data, serialization.Data, serialization.Data, ...)

+ type ReplicatedMapAddEntryListenerToKeyWithPredicateHandleEventEntryFunc func(serialization.Data, serialization.Data, serialization.Data, serialization.Data, ...)

+ type ReplicatedMapAddEntryListenerWithPredicateHandleEventEntryFunc func(serialization.Data, serialization.Data, serialization.Data, serialization.Data, ...)

+ type ServerError struct

+ func ErrorCodecDecode(msg *ClientMessage) *ServerError

+ func (e *ServerError) CauseClassName() string

+ func (e *ServerError) CauseErrorCode() int32

+ func (e *ServerError) ClassName() string

+ func (e *ServerError) Error() string

+ func (e *ServerError) ErrorCode() int32

+ func (e *ServerError) Message() string

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

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

+ type StackTraceElement struct

+ func (e *StackTraceElement) DeclaringClass() string

+ func (e *StackTraceElement) FileName() string

+ func (e *StackTraceElement) LineNumber() int32

+ func (e *StackTraceElement) MethodName() string

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

+ type TopicMessage struct

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

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

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

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL