Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

proto

package

Go to main page

Versions in this module

v1

v1.2.1

Nov 9, 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

v0

v0.6.1

Nov 17, 2020

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