protocol

Oct 4, 2026

Changes in this version

type ClientInfo

+ func (m *ClientInfo) AppendJSON(b []byte) []byte

+ func (m *ClientInfo) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *ClientInfo) MarshalCF() ([]byte, error)

+ func (m *ClientInfo) MarshalToCF(b []byte) (int, error)

+ func (m *ClientInfo) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *ClientInfo) SizeCF() (n int)

+ func (m *ClientInfo) UnmarshalCF(b []byte) error

type Command

+ func (m *Command) AppendJSON(b []byte) []byte

+ func (m *Command) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *Command) MarshalCF() ([]byte, error)

+ func (m *Command) MarshalToCF(b []byte) (int, error)

+ func (m *Command) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *Command) SizeCF() (n int)

+ func (m *Command) UnmarshalCF(b []byte) error

type Connect

+ func (m *Connect) AppendJSON(b []byte) []byte

+ func (m *Connect) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *Connect) MarshalCF() ([]byte, error)

+ func (m *Connect) MarshalToCF(b []byte) (int, error)

+ func (m *Connect) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *Connect) SizeCF() (n int)

+ func (m *Connect) UnmarshalCF(b []byte) error

type ConnectRequest

+ func (m *ConnectRequest) AppendJSON(b []byte) []byte

+ func (m *ConnectRequest) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *ConnectRequest) MarshalCF() ([]byte, error)

+ func (m *ConnectRequest) MarshalToCF(b []byte) (int, error)

+ func (m *ConnectRequest) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *ConnectRequest) SizeCF() (n int)

+ func (m *ConnectRequest) UnmarshalCF(b []byte) error

type ConnectResult

+ func (m *ConnectResult) AppendJSON(b []byte) []byte

+ func (m *ConnectResult) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *ConnectResult) MarshalCF() ([]byte, error)

+ func (m *ConnectResult) MarshalToCF(b []byte) (int, error)

+ func (m *ConnectResult) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *ConnectResult) SizeCF() (n int)

+ func (m *ConnectResult) UnmarshalCF(b []byte) error

type Dictionary

+ func (m *Dictionary) AppendJSON(b []byte) []byte

+ func (m *Dictionary) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *Dictionary) MarshalCF() ([]byte, error)

+ func (m *Dictionary) MarshalToCF(b []byte) (int, error)

+ func (m *Dictionary) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *Dictionary) SizeCF() (n int)

+ func (m *Dictionary) UnmarshalCF(b []byte) error

type Disconnect

+ func (m *Disconnect) AppendJSON(b []byte) []byte

+ func (m *Disconnect) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *Disconnect) MarshalCF() ([]byte, error)

+ func (m *Disconnect) MarshalToCF(b []byte) (int, error)

+ func (m *Disconnect) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *Disconnect) SizeCF() (n int)

+ func (m *Disconnect) UnmarshalCF(b []byte) error

type EmulationRequest

+ func (m *EmulationRequest) AppendJSON(b []byte) []byte

+ func (m *EmulationRequest) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *EmulationRequest) MarshalCF() ([]byte, error)

+ func (m *EmulationRequest) MarshalToCF(b []byte) (int, error)

+ func (m *EmulationRequest) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *EmulationRequest) SizeCF() (n int)

+ func (m *EmulationRequest) UnmarshalCF(b []byte) error

type Error

+ func (m *Error) AppendJSON(b []byte) []byte

+ func (m *Error) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *Error) MarshalCF() ([]byte, error)

+ func (m *Error) MarshalToCF(b []byte) (int, error)

+ func (m *Error) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *Error) SizeCF() (n int)

+ func (m *Error) UnmarshalCF(b []byte) error

type FilterNode

+ func (m *FilterNode) AppendJSON(b []byte) []byte

+ func (m *FilterNode) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *FilterNode) MarshalCF() ([]byte, error)

+ func (m *FilterNode) MarshalToCF(b []byte) (int, error)

+ func (m *FilterNode) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *FilterNode) SizeCF() (n int)

+ func (m *FilterNode) UnmarshalCF(b []byte) error

type HistoryRequest

+ func (m *HistoryRequest) AppendJSON(b []byte) []byte

+ func (m *HistoryRequest) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *HistoryRequest) MarshalCF() ([]byte, error)

+ func (m *HistoryRequest) MarshalToCF(b []byte) (int, error)

+ func (m *HistoryRequest) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *HistoryRequest) SizeCF() (n int)

+ func (m *HistoryRequest) UnmarshalCF(b []byte) error

type HistoryResult

+ func (m *HistoryResult) AppendJSON(b []byte) []byte

+ func (m *HistoryResult) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *HistoryResult) MarshalCF() ([]byte, error)

+ func (m *HistoryResult) MarshalToCF(b []byte) (int, error)

+ func (m *HistoryResult) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *HistoryResult) SizeCF() (n int)

+ func (m *HistoryResult) UnmarshalCF(b []byte) error

type Join

+ func (m *Join) AppendJSON(b []byte) []byte

+ func (m *Join) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *Join) MarshalCF() ([]byte, error)

+ func (m *Join) MarshalToCF(b []byte) (int, error)

+ func (m *Join) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *Join) SizeCF() (n int)

+ func (m *Join) UnmarshalCF(b []byte) error

type KeyedItem

+ func (m *KeyedItem) AppendJSON(b []byte) []byte

+ func (m *KeyedItem) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *KeyedItem) MarshalCF() ([]byte, error)

+ func (m *KeyedItem) MarshalToCF(b []byte) (int, error)

+ func (m *KeyedItem) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *KeyedItem) SizeCF() (n int)

+ func (m *KeyedItem) UnmarshalCF(b []byte) error

type Leave

+ func (m *Leave) AppendJSON(b []byte) []byte

+ func (m *Leave) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *Leave) MarshalCF() ([]byte, error)

+ func (m *Leave) MarshalToCF(b []byte) (int, error)

+ func (m *Leave) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *Leave) SizeCF() (n int)

+ func (m *Leave) UnmarshalCF(b []byte) error

type Message

+ func (m *Message) AppendJSON(b []byte) []byte

+ func (m *Message) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *Message) MarshalCF() ([]byte, error)

+ func (m *Message) MarshalToCF(b []byte) (int, error)

+ func (m *Message) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *Message) SizeCF() (n int)

+ func (m *Message) UnmarshalCF(b []byte) error

type PingRequest

+ func (m *PingRequest) AppendJSON(b []byte) []byte

+ func (m *PingRequest) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *PingRequest) MarshalCF() ([]byte, error)

+ func (m *PingRequest) MarshalToCF(b []byte) (int, error)

+ func (m *PingRequest) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *PingRequest) SizeCF() (n int)

+ func (m *PingRequest) UnmarshalCF(b []byte) error

type PingResult

+ func (m *PingResult) AppendJSON(b []byte) []byte

+ func (m *PingResult) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *PingResult) MarshalCF() ([]byte, error)

+ func (m *PingResult) MarshalToCF(b []byte) (int, error)

+ func (m *PingResult) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *PingResult) SizeCF() (n int)

+ func (m *PingResult) UnmarshalCF(b []byte) error

type PresenceRequest

+ func (m *PresenceRequest) AppendJSON(b []byte) []byte

+ func (m *PresenceRequest) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *PresenceRequest) MarshalCF() ([]byte, error)

+ func (m *PresenceRequest) MarshalToCF(b []byte) (int, error)

+ func (m *PresenceRequest) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *PresenceRequest) SizeCF() (n int)

+ func (m *PresenceRequest) UnmarshalCF(b []byte) error

type PresenceResult

+ func (m *PresenceResult) AppendJSON(b []byte) []byte

+ func (m *PresenceResult) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *PresenceResult) MarshalCF() ([]byte, error)

+ func (m *PresenceResult) MarshalToCF(b []byte) (int, error)

+ func (m *PresenceResult) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *PresenceResult) SizeCF() (n int)

+ func (m *PresenceResult) UnmarshalCF(b []byte) error

type PresenceStatsRequest

+ func (m *PresenceStatsRequest) AppendJSON(b []byte) []byte

+ func (m *PresenceStatsRequest) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *PresenceStatsRequest) MarshalCF() ([]byte, error)

+ func (m *PresenceStatsRequest) MarshalToCF(b []byte) (int, error)

+ func (m *PresenceStatsRequest) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *PresenceStatsRequest) SizeCF() (n int)

+ func (m *PresenceStatsRequest) UnmarshalCF(b []byte) error

type PresenceStatsResult

+ func (m *PresenceStatsResult) AppendJSON(b []byte) []byte

+ func (m *PresenceStatsResult) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *PresenceStatsResult) MarshalCF() ([]byte, error)

+ func (m *PresenceStatsResult) MarshalToCF(b []byte) (int, error)

+ func (m *PresenceStatsResult) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *PresenceStatsResult) SizeCF() (n int)

+ func (m *PresenceStatsResult) UnmarshalCF(b []byte) error

type Publication

+ func (m *Publication) AppendJSON(b []byte) []byte

+ func (m *Publication) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *Publication) MarshalCF() ([]byte, error)

+ func (m *Publication) MarshalToCF(b []byte) (int, error)

+ func (m *Publication) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *Publication) SizeCF() (n int)

+ func (m *Publication) UnmarshalCF(b []byte) error

type PublishRequest

+ func (m *PublishRequest) AppendJSON(b []byte) []byte

+ func (m *PublishRequest) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *PublishRequest) MarshalCF() ([]byte, error)

+ func (m *PublishRequest) MarshalToCF(b []byte) (int, error)

+ func (m *PublishRequest) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *PublishRequest) SizeCF() (n int)

+ func (m *PublishRequest) UnmarshalCF(b []byte) error

type PublishResult

+ func (m *PublishResult) AppendJSON(b []byte) []byte

+ func (m *PublishResult) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *PublishResult) MarshalCF() ([]byte, error)

+ func (m *PublishResult) MarshalToCF(b []byte) (int, error)

+ func (m *PublishResult) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *PublishResult) SizeCF() (n int)

+ func (m *PublishResult) UnmarshalCF(b []byte) error

type Push

+ func (m *Push) AppendJSON(b []byte) []byte

+ func (m *Push) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *Push) MarshalCF() ([]byte, error)

+ func (m *Push) MarshalToCF(b []byte) (int, error)

+ func (m *Push) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *Push) SizeCF() (n int)

+ func (m *Push) UnmarshalCF(b []byte) error

type RPCRequest

+ func (m *RPCRequest) AppendJSON(b []byte) []byte

+ func (m *RPCRequest) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *RPCRequest) MarshalCF() ([]byte, error)

+ func (m *RPCRequest) MarshalToCF(b []byte) (int, error)

+ func (m *RPCRequest) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *RPCRequest) SizeCF() (n int)

+ func (m *RPCRequest) UnmarshalCF(b []byte) error

type RPCResult

+ func (m *RPCResult) AppendJSON(b []byte) []byte

+ func (m *RPCResult) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *RPCResult) MarshalCF() ([]byte, error)

+ func (m *RPCResult) MarshalToCF(b []byte) (int, error)

+ func (m *RPCResult) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *RPCResult) SizeCF() (n int)

+ func (m *RPCResult) UnmarshalCF(b []byte) error

type Refresh

+ func (m *Refresh) AppendJSON(b []byte) []byte

+ func (m *Refresh) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *Refresh) MarshalCF() ([]byte, error)

+ func (m *Refresh) MarshalToCF(b []byte) (int, error)

+ func (m *Refresh) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *Refresh) SizeCF() (n int)

+ func (m *Refresh) UnmarshalCF(b []byte) error

type RefreshRequest

+ func (m *RefreshRequest) AppendJSON(b []byte) []byte

+ func (m *RefreshRequest) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *RefreshRequest) MarshalCF() ([]byte, error)

+ func (m *RefreshRequest) MarshalToCF(b []byte) (int, error)

+ func (m *RefreshRequest) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *RefreshRequest) SizeCF() (n int)

+ func (m *RefreshRequest) UnmarshalCF(b []byte) error

type RefreshResult

+ func (m *RefreshResult) AppendJSON(b []byte) []byte

+ func (m *RefreshResult) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *RefreshResult) MarshalCF() ([]byte, error)

+ func (m *RefreshResult) MarshalToCF(b []byte) (int, error)

+ func (m *RefreshResult) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *RefreshResult) SizeCF() (n int)

+ func (m *RefreshResult) UnmarshalCF(b []byte) error

type Reply

+ func (m *Reply) AppendJSON(b []byte) []byte

+ func (m *Reply) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *Reply) MarshalCF() ([]byte, error)

+ func (m *Reply) MarshalToCF(b []byte) (int, error)

+ func (m *Reply) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *Reply) SizeCF() (n int)

+ func (m *Reply) UnmarshalCF(b []byte) error

type SendRequest

+ func (m *SendRequest) AppendJSON(b []byte) []byte

+ func (m *SendRequest) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *SendRequest) MarshalCF() ([]byte, error)

+ func (m *SendRequest) MarshalToCF(b []byte) (int, error)

+ func (m *SendRequest) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *SendRequest) SizeCF() (n int)

+ func (m *SendRequest) UnmarshalCF(b []byte) error

type StreamPosition

+ func (m *StreamPosition) AppendJSON(b []byte) []byte

+ func (m *StreamPosition) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *StreamPosition) MarshalCF() ([]byte, error)

+ func (m *StreamPosition) MarshalToCF(b []byte) (int, error)

+ func (m *StreamPosition) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *StreamPosition) SizeCF() (n int)

+ func (m *StreamPosition) UnmarshalCF(b []byte) error

type SubRefreshRequest

+ func (m *SubRefreshRequest) AppendJSON(b []byte) []byte

+ func (m *SubRefreshRequest) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *SubRefreshRequest) MarshalCF() ([]byte, error)

+ func (m *SubRefreshRequest) MarshalToCF(b []byte) (int, error)

+ func (m *SubRefreshRequest) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *SubRefreshRequest) SizeCF() (n int)

+ func (m *SubRefreshRequest) UnmarshalCF(b []byte) error

type SubRefreshResult

+ func (m *SubRefreshResult) AppendJSON(b []byte) []byte

+ func (m *SubRefreshResult) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *SubRefreshResult) MarshalCF() ([]byte, error)

+ func (m *SubRefreshResult) MarshalToCF(b []byte) (int, error)

+ func (m *SubRefreshResult) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *SubRefreshResult) SizeCF() (n int)

+ func (m *SubRefreshResult) UnmarshalCF(b []byte) error

type Subscribe

+ func (m *Subscribe) AppendJSON(b []byte) []byte

+ func (m *Subscribe) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *Subscribe) MarshalCF() ([]byte, error)

+ func (m *Subscribe) MarshalToCF(b []byte) (int, error)

+ func (m *Subscribe) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *Subscribe) SizeCF() (n int)

+ func (m *Subscribe) UnmarshalCF(b []byte) error

type SubscribeRequest

+ func (m *SubscribeRequest) AppendJSON(b []byte) []byte

+ func (m *SubscribeRequest) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *SubscribeRequest) MarshalCF() ([]byte, error)

+ func (m *SubscribeRequest) MarshalToCF(b []byte) (int, error)

+ func (m *SubscribeRequest) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *SubscribeRequest) SizeCF() (n int)

+ func (m *SubscribeRequest) UnmarshalCF(b []byte) error

type SubscribeResult

+ func (m *SubscribeResult) AppendJSON(b []byte) []byte

+ func (m *SubscribeResult) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *SubscribeResult) MarshalCF() ([]byte, error)

+ func (m *SubscribeResult) MarshalToCF(b []byte) (int, error)

+ func (m *SubscribeResult) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *SubscribeResult) SizeCF() (n int)

+ func (m *SubscribeResult) UnmarshalCF(b []byte) error

type TrackBatch

+ func (m *TrackBatch) AppendJSON(b []byte) []byte

+ func (m *TrackBatch) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *TrackBatch) MarshalCF() ([]byte, error)

+ func (m *TrackBatch) MarshalToCF(b []byte) (int, error)

+ func (m *TrackBatch) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *TrackBatch) SizeCF() (n int)

+ func (m *TrackBatch) UnmarshalCF(b []byte) error

type Unsubscribe

+ func (m *Unsubscribe) AppendJSON(b []byte) []byte

+ func (m *Unsubscribe) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *Unsubscribe) MarshalCF() ([]byte, error)

+ func (m *Unsubscribe) MarshalToCF(b []byte) (int, error)

+ func (m *Unsubscribe) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *Unsubscribe) SizeCF() (n int)

+ func (m *Unsubscribe) UnmarshalCF(b []byte) error

type UnsubscribeRequest

+ func (m *UnsubscribeRequest) AppendJSON(b []byte) []byte

+ func (m *UnsubscribeRequest) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *UnsubscribeRequest) MarshalCF() ([]byte, error)

+ func (m *UnsubscribeRequest) MarshalToCF(b []byte) (int, error)

+ func (m *UnsubscribeRequest) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *UnsubscribeRequest) SizeCF() (n int)

+ func (m *UnsubscribeRequest) UnmarshalCF(b []byte) error

type UnsubscribeResult

+ func (m *UnsubscribeResult) AppendJSON(b []byte) []byte

+ func (m *UnsubscribeResult) DecodeJSON(b []byte, i int, f cfjson.Flags) int

+ func (m *UnsubscribeResult) MarshalCF() ([]byte, error)

+ func (m *UnsubscribeResult) MarshalToCF(b []byte) (int, error)

+ func (m *UnsubscribeResult) MarshalToSizedBufferCF(b []byte) (int, error)

+ func (m *UnsubscribeResult) SizeCF() (n int)

+ func (m *UnsubscribeResult) UnmarshalCF(b []byte) error

Aug 30, 2026

Changes in this version

+ const MinDictionaryCompressionLevel

Aug 17, 2026

Changes in this version

+ const FrameCodecCompressed

+ const FrameCodecRaw

+ var ErrEmptyFrame = errors.New("centrifugal: empty frame")

+ var ErrFrameTooLarge = errors.New("centrifugal: decompressed frame too large")

+ var ErrUnknownFrameCodec = errors.New("centrifugal: unknown frame codec")

+ func DeflateDictionary(dict []byte) []byte

+ func InflateDictionary(data []byte, maxSize int) ([]byte, error)

type ConnectRequest

+ Dict string

+ Profile string

+ func (x *ConnectRequest) GetDict() string

+ func (x *ConnectRequest) GetProfile() string

type ConnectResult

+ Dict *Dictionary

+ Flag int64

+ func (x *ConnectResult) GetDict() *Dictionary

+ func (x *ConnectResult) GetFlag() int64

+ type DeflateFrameCodec struct

+ func NewDeflateFrameCodec(id string, dict []byte) *DeflateFrameCodec

+ func (c *DeflateFrameCodec) Compress(dst, src []byte) []byte

+ func (c *DeflateFrameCodec) Decompress(dst, frame []byte, maxSize int) ([]byte, error)

+ func (c *DeflateFrameCodec) Dict() []byte

+ func (c *DeflateFrameCodec) ID() string

+ type Dictionary struct

+ Data Raw

+ DataB64 string

+ Id string

+ func (*Dictionary) Descriptor() ([]byte, []int)

+ func (*Dictionary) ProtoMessage()

+ func (m *Dictionary) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Dictionary) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Dictionary) MarshalVT() (dAtA []byte, err error)

+ func (m *Dictionary) SizeVT() (n int)

+ func (m *Dictionary) UnmarshalVT(dAtA []byte) error

+ func (v *Dictionary) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v Dictionary) MarshalEasyJSON(w *writer)

+ func (x *Dictionary) GetData() []byte

+ func (x *Dictionary) GetDataB64() string

+ func (x *Dictionary) GetId() string

+ func (x *Dictionary) ProtoReflect() protoreflect.Message

+ func (x *Dictionary) Reset()

+ func (x *Dictionary) String() string

May 12, 2026

Changes in this version

type SubRefreshRequest

+ Track []*TrackBatch

+ Untrack []string

+ func (x *SubRefreshRequest) GetTrack() []*TrackBatch

+ func (x *SubRefreshRequest) GetUntrack() []string

+ type TrackBatch struct

+ Items []*KeyedItem

+ Signature string

+ func (*TrackBatch) Descriptor() ([]byte, []int)

+ func (*TrackBatch) ProtoMessage()

+ func (m *TrackBatch) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *TrackBatch) MarshalToVT(dAtA []byte) (int, error)

+ func (m *TrackBatch) MarshalVT() (dAtA []byte, err error)

+ func (m *TrackBatch) SizeVT() (n int)

+ func (m *TrackBatch) UnmarshalVT(dAtA []byte) error

+ func (v *TrackBatch) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v TrackBatch) MarshalEasyJSON(w *writer)

+ func (x *TrackBatch) GetItems() []*KeyedItem

+ func (x *TrackBatch) GetSignature() string

+ func (x *TrackBatch) ProtoReflect() protoreflect.Message

+ func (x *TrackBatch) Reset()

+ func (x *TrackBatch) String() string

Apr 10, 2026

Changes in this version

+ type KeyedItem struct

+ Key string

+ Version uint64

+ func (*KeyedItem) Descriptor() ([]byte, []int)

+ func (*KeyedItem) ProtoMessage()

+ func (m *KeyedItem) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *KeyedItem) MarshalToVT(dAtA []byte) (int, error)

+ func (m *KeyedItem) MarshalVT() (dAtA []byte, err error)

+ func (m *KeyedItem) SizeVT() (n int)

+ func (m *KeyedItem) UnmarshalVT(dAtA []byte) error

+ func (v *KeyedItem) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v KeyedItem) MarshalEasyJSON(w *writer)

+ func (x *KeyedItem) GetKey() string

+ func (x *KeyedItem) GetVersion() uint64

+ func (x *KeyedItem) ProtoReflect() protoreflect.Message

+ func (x *KeyedItem) Reset()

+ func (x *KeyedItem) String() string

type Publication

+ Epoch string

+ Key string

+ PrevData Raw

+ Removed bool

+ Score int64

+ Version uint64

+ func (x *Publication) GetEpoch() string

+ func (x *Publication) GetKey() string

+ func (x *Publication) GetPrevData() []byte

+ func (x *Publication) GetRemoved() bool

+ func (x *Publication) GetScore() int64

+ func (x *Publication) GetVersion() uint64

type PublishRequest

+ Key string

+ Removed bool

+ Type int32

+ func (x *PublishRequest) GetKey() string

+ func (x *PublishRequest) GetRemoved() bool

+ func (x *PublishRequest) GetType() int32

type SubRefreshRequest

+ Items []*KeyedItem

+ Signature string

+ Type int32

+ UntrackKeys []string

+ func (x *SubRefreshRequest) GetItems() []*KeyedItem

+ func (x *SubRefreshRequest) GetSignature() string

+ func (x *SubRefreshRequest) GetType() int32

+ func (x *SubRefreshRequest) GetUntrackKeys() []string

type SubRefreshResult

+ Items []*Publication

+ func (x *SubRefreshResult) GetItems() []*Publication

type SubscribeRequest

+ Asc bool

+ Cursor string

+ Limit int32

+ Phase int32

+ Type int32

+ func (x *SubscribeRequest) GetAsc() bool

+ func (x *SubscribeRequest) GetCursor() string

+ func (x *SubscribeRequest) GetLimit() int32

+ func (x *SubscribeRequest) GetPhase() int32

+ func (x *SubscribeRequest) GetType() int32

type SubscribeResult

+ Cursor string

+ Phase int32

+ PublishDebounce uint32

+ State []*Publication

+ Type int32

+ func (x *SubscribeResult) GetCursor() string

+ func (x *SubscribeResult) GetPhase() int32

+ func (x *SubscribeResult) GetPublishDebounce() uint32

+ func (x *SubscribeResult) GetState() []*Publication

+ func (x *SubscribeResult) GetType() int32

Dec 25, 2025

Changes in this version

type DataEncoder

+ FinishNoCopy func() []byte

type JSONDataEncoder

+ func (e *JSONDataEncoder) FinishNoCopy() []byte

type ProtobufDataEncoder

+ func (e *ProtobufDataEncoder) FinishNoCopy() []byte

Oct 5, 2025

Changes in this version

type ConnectRequest

+ Flag int64

+ func (x *ConnectRequest) GetFlag() int64

+ type FilterNode struct

+ Cmp string

+ Key string

+ Nodes []*FilterNode

+ Op string

+ Val string

+ Vals []string

+ func (*FilterNode) Descriptor() ([]byte, []int)

+ func (*FilterNode) ProtoMessage()

+ func (m *FilterNode) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *FilterNode) MarshalToVT(dAtA []byte) (int, error)

+ func (m *FilterNode) MarshalVT() (dAtA []byte, err error)

+ func (m *FilterNode) SizeVT() (n int)

+ func (m *FilterNode) UnmarshalVT(dAtA []byte) error

+ func (v *FilterNode) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v FilterNode) MarshalEasyJSON(w *writer)

+ func (x *FilterNode) GetCmp() string

+ func (x *FilterNode) GetKey() string

+ func (x *FilterNode) GetNodes() []*FilterNode

+ func (x *FilterNode) GetOp() string

+ func (x *FilterNode) GetVal() string

+ func (x *FilterNode) GetVals() []string

+ func (x *FilterNode) ProtoReflect() protoreflect.Message

+ func (x *FilterNode) Reset()

+ func (x *FilterNode) String() string

type Push

+ Id int64

+ func (x *Push) GetId() int64

type SubscribeRequest

+ Flag int64

+ Tf *FilterNode

+ func (x *SubscribeRequest) GetFlag() int64

+ func (x *SubscribeRequest) GetTf() *FilterNode

type SubscribeResult

+ Id int64

+ func (x *SubscribeResult) GetId() int64

Feb 9, 2025

Changes in this version

type ConnectResult

+ func ConnectResultFromVTPool() *ConnectResult

+ func (m *ConnectResult) ResetVT()

+ func (m *ConnectResult) ReturnToVTPool()

type HistoryResult

+ func HistoryResultFromVTPool() *HistoryResult

+ func (m *HistoryResult) ResetVT()

+ func (m *HistoryResult) ReturnToVTPool()

type PresenceResult

+ func PresenceResultFromVTPool() *PresenceResult

+ func (m *PresenceResult) ResetVT()

+ func (m *PresenceResult) ReturnToVTPool()

type PresenceStatsResult

+ func PresenceStatsResultFromVTPool() *PresenceStatsResult

+ func (m *PresenceStatsResult) ResetVT()

+ func (m *PresenceStatsResult) ReturnToVTPool()

type PublishResult

+ func PublishResultFromVTPool() *PublishResult

+ func (m *PublishResult) ResetVT()

+ func (m *PublishResult) ReturnToVTPool()

type RPCResult

+ func RPCResultFromVTPool() *RPCResult

+ func (m *RPCResult) ResetVT()

+ func (m *RPCResult) ReturnToVTPool()

type RefreshResult

+ func RefreshResultFromVTPool() *RefreshResult

+ func (m *RefreshResult) ResetVT()

+ func (m *RefreshResult) ReturnToVTPool()

type SubRefreshResult

+ func SubRefreshResultFromVTPool() *SubRefreshResult

+ func (m *SubRefreshResult) ResetVT()

+ func (m *SubRefreshResult) ReturnToVTPool()

type SubscribeResult

+ func SubscribeResultFromVTPool() *SubscribeResult

+ func (m *SubscribeResult) ResetVT()

+ func (m *SubscribeResult) ReturnToVTPool()

Jan 9, 2025

Changes in this version

+ var ErrMessageTooLarge = errors.New("message size exceeds the limit")

type ConnectRequest

+ Headers map[string]string

+ func (x *ConnectRequest) GetHeaders() map[string]string

type StreamCommandDecoder

+ func GetStreamCommandDecoderLimited(protoType Type, reader io.Reader, messageSizeLimit int64) StreamCommandDecoder

Jul 2, 2024

Changes in this version

type Publication

+ Channel string

+ func (x *Publication) GetChannel() string

May 26, 2024

Changes in this version

type Publication

+ Time int64

+ func (x *Publication) GetTime() int64

May 20, 2024

Changes in this version

type Connect

+ Time int64

+ func (x *Connect) GetTime() int64

May 14, 2024

Changes in this version

type ConnectResult

+ Time int64

+ func (x *ConnectResult) GetTime() int64

type Publication

+ Delta bool

+ func (x *Publication) GetDelta() bool

type SubscribeRequest

+ Delta string

+ func (x *SubscribeRequest) GetDelta() string

type SubscribeResult

+ Delta bool

+ func (x *SubscribeResult) GetDelta() bool

Oct 22, 2023

Changes in this version

+ type FrameType uint8

+ const FrameTypeClientPong

+ const FrameTypeConnect

+ const FrameTypeHistory

+ const FrameTypePresence

+ const FrameTypePresenceStats

+ const FrameTypePublish

+ const FrameTypePushConnect

+ const FrameTypePushDisconnect

+ const FrameTypePushJoin

+ const FrameTypePushLeave

+ const FrameTypePushMessage

+ const FrameTypePushPublication

+ const FrameTypePushRefresh

+ const FrameTypePushSubscribe

+ const FrameTypePushUnsubscribe

+ const FrameTypeRPC

+ const FrameTypeRefresh

+ const FrameTypeSend

+ const FrameTypeServerPing

+ const FrameTypeSubRefresh

+ const FrameTypeSubscribe

+ const FrameTypeUnsubscribe

+ func (f FrameType) String() string

Dec 29, 2022

Changes in this version

+ var ReplyPool = &ReplyPoolCollection

+ func PutStreamCommandDecoder(protoType Type, e StreamCommandDecoder)

type JSONStreamCommandDecoder

+ func (d *JSONStreamCommandDecoder) Reset(reader io.Reader)

type ProtobufStreamCommandDecoder

+ func (d *ProtobufStreamCommandDecoder) Reset(reader io.Reader)

+ type ReplyPoolCollection struct

+ func (p *ReplyPoolCollection) AcquireConnectReply(result *ConnectResult) *Reply

+ func (p *ReplyPoolCollection) AcquireHistoryReply(result *HistoryResult) *Reply

+ func (p *ReplyPoolCollection) AcquirePresenceReply(result *PresenceResult) *Reply

+ func (p *ReplyPoolCollection) AcquirePresenceStatsReply(result *PresenceStatsResult) *Reply

+ func (p *ReplyPoolCollection) AcquirePublishReply(result *PublishResult) *Reply

+ func (p *ReplyPoolCollection) AcquireRPCReply(result *RPCResult) *Reply

+ func (p *ReplyPoolCollection) AcquireRefreshReply(result *RefreshResult) *Reply

+ func (p *ReplyPoolCollection) AcquireSubRefreshReply(result *SubRefreshResult) *Reply

+ func (p *ReplyPoolCollection) AcquireSubscribeReply(result *SubscribeResult) *Reply

+ func (p *ReplyPoolCollection) AcquireUnsubscribeReply(result *UnsubscribeResult) *Reply

+ func (p *ReplyPoolCollection) ReleaseConnectReply(r *Reply)

+ func (p *ReplyPoolCollection) ReleaseHistoryReply(r *Reply)

+ func (p *ReplyPoolCollection) ReleasePresenceReply(r *Reply)

+ func (p *ReplyPoolCollection) ReleasePresenceStatsReply(r *Reply)

+ func (p *ReplyPoolCollection) ReleasePublishReply(r *Reply)

+ func (p *ReplyPoolCollection) ReleaseRPCReply(r *Reply)

+ func (p *ReplyPoolCollection) ReleaseRefreshReply(r *Reply)

+ func (p *ReplyPoolCollection) ReleaseSubRefreshReply(r *Reply)

+ func (p *ReplyPoolCollection) ReleaseSubscribeReply(r *Reply)

+ func (p *ReplyPoolCollection) ReleaseUnsubscribeReply(r *Reply)

type StreamCommandDecoder

+ func GetStreamCommandDecoder(protoType Type, reader io.Reader) StreamCommandDecoder

+ Reset func(reader io.Reader)

Jul 13, 2022

Changes in this version

+ type JSONStreamCommandDecoder struct

+ func NewJSONStreamCommandDecoder(reader io.Reader) *JSONStreamCommandDecoder

+ func (d *JSONStreamCommandDecoder) Decode() (*Command, []byte, error)

+ type ProtobufStreamCommandDecoder struct

+ func NewProtobufStreamCommandDecoder(reader io.Reader) *ProtobufStreamCommandDecoder

+ func (d *ProtobufStreamCommandDecoder) Decode() (*Command, []byte, error)

+ type StreamCommandDecoder interface

+ Decode func() (*Command, []byte, error)

Jul 1, 2022

Changes in this version

type SubscribeRequest

+ JoinLeave bool

+ func (x *SubscribeRequest) GetJoinLeave() bool

May 4, 2022

Changes in this version

type SubscribeRequest

+ Positioned bool

+ Recoverable bool

+ func (x *SubscribeRequest) GetPositioned() bool

+ func (x *SubscribeRequest) GetRecoverable() bool

type Unsubscribe

+ Reason string

+ func (x *Unsubscribe) GetReason() string

Apr 22, 2022

Changes in this version

type Connect

+ Node string

+ func (x *Connect) GetNode() string

type ConnectResult

+ Node string

+ func (x *ConnectResult) GetNode() string

+ type EmulationRequest struct

+ Data Raw

+ Node string

+ Session string

+ func (*EmulationRequest) Descriptor() ([]byte, []int)

+ func (*EmulationRequest) ProtoMessage()

+ func (m *EmulationRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *EmulationRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *EmulationRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *EmulationRequest) SizeVT() (n int)

+ func (m *EmulationRequest) UnmarshalVT(dAtA []byte) error

+ func (v *EmulationRequest) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v EmulationRequest) MarshalEasyJSON(w *writer)

+ func (x *EmulationRequest) GetData() []byte

+ func (x *EmulationRequest) GetNode() string

+ func (x *EmulationRequest) GetSession() string

+ func (x *EmulationRequest) ProtoReflect() protoreflect.Message

+ func (x *EmulationRequest) Reset()

+ func (x *EmulationRequest) String() string

type Error

+ Temporary bool

+ func (x *Error) GetTemporary() bool

type SubscribeResult

+ WasRecovering bool

+ func (x *SubscribeResult) GetWasRecovering() bool

type Unsubscribe

+ Code uint32

+ func (x *Unsubscribe) GetCode() uint32

Feb 13, 2022

Changes in this version

type Connect

+ Session string

+ func (x *Connect) GetSession() string

type ConnectResult

+ Session string

+ func (x *ConnectResult) GetSession() string

Feb 7, 2022

Changes in this version

type Connect

+ Pong bool

+ func (x *Connect) GetPong() bool

type ConnectResult

+ Pong bool

+ func (x *ConnectResult) GetPong() bool

Feb 6, 2022

Changes in this version

type Connect

+ Ping uint32

+ func (x *Connect) GetPing() uint32

type ConnectResult

+ Ping uint32

+ func (x *ConnectResult) GetPing() uint32

Jan 24, 2022

Changes in this version

type Publication

+ Tags map[string]string

+ func (x *Publication) GetTags() map[string]string

Jan 9, 2022

Changes in this version

+ var DefaultJsonPushEncoder = NewJSONPushEncoder()

+ var DefaultJsonReplyEncoder = NewJSONReplyEncoder()

+ var DefaultProtobufPushEncoder = NewProtobufPushEncoder()

+ var DefaultProtobufReplyEncoder = NewProtobufReplyEncoder()

type Command

+ Connect *ConnectRequest

+ History *HistoryRequest

+ Ping *PingRequest

+ Presence *PresenceRequest

+ PresenceStats *PresenceStatsRequest

+ Publish *PublishRequest

+ Refresh *RefreshRequest

+ Rpc *RPCRequest

+ Send *SendRequest

+ SubRefresh *SubRefreshRequest

+ Subscribe *SubscribeRequest

+ Unsubscribe *UnsubscribeRequest

+ func (x *Command) GetConnect() *ConnectRequest

+ func (x *Command) GetHistory() *HistoryRequest

+ func (x *Command) GetPing() *PingRequest

+ func (x *Command) GetPresence() *PresenceRequest

+ func (x *Command) GetPresenceStats() *PresenceStatsRequest

+ func (x *Command) GetPublish() *PublishRequest

+ func (x *Command) GetRefresh() *RefreshRequest

+ func (x *Command) GetRpc() *RPCRequest

+ func (x *Command) GetSend() *SendRequest

+ func (x *Command) GetSubRefresh() *SubRefreshRequest

+ func (x *Command) GetSubscribe() *SubscribeRequest

+ func (x *Command) GetUnsubscribe() *UnsubscribeRequest

type Publication

+ Meta map[string]string

+ func (x *Publication) GetMeta() map[string]string

type Push

+ Connect *Connect

+ Disconnect *Disconnect

+ Join *Join

+ Leave *Leave

+ Message *Message

+ Pub *Publication

+ Refresh *Refresh

+ Subscribe *Subscribe

+ Unsubscribe *Unsubscribe

+ func (x *Push) GetConnect() *Connect

+ func (x *Push) GetDisconnect() *Disconnect

+ func (x *Push) GetJoin() *Join

+ func (x *Push) GetLeave() *Leave

+ func (x *Push) GetMessage() *Message

+ func (x *Push) GetPub() *Publication

+ func (x *Push) GetRefresh() *Refresh

+ func (x *Push) GetSubscribe() *Subscribe

+ func (x *Push) GetUnsubscribe() *Unsubscribe

type Reply

+ Connect *ConnectResult

+ History *HistoryResult

+ Ping *PingResult

+ Presence *PresenceResult

+ PresenceStats *PresenceStatsResult

+ Publish *PublishResult

+ Push *Push

+ Refresh *RefreshResult

+ Rpc *RPCResult

+ SubRefresh *SubRefreshResult

+ Subscribe *SubscribeResult

+ Unsubscribe *UnsubscribeResult

+ func (x *Reply) GetConnect() *ConnectResult

+ func (x *Reply) GetHistory() *HistoryResult

+ func (x *Reply) GetPing() *PingResult

+ func (x *Reply) GetPresence() *PresenceResult

+ func (x *Reply) GetPresenceStats() *PresenceStatsResult

+ func (x *Reply) GetPublish() *PublishResult

+ func (x *Reply) GetPush() *Push

+ func (x *Reply) GetRefresh() *RefreshResult

+ func (x *Reply) GetRpc() *RPCResult

+ func (x *Reply) GetSubRefresh() *SubRefreshResult

+ func (x *Reply) GetSubscribe() *SubscribeResult

+ func (x *Reply) GetUnsubscribe() *UnsubscribeResult

Dec 2, 2021

Changes in this version

type SubscribeRequest

+ Data Raw

+ func (x *SubscribeRequest) GetData() []byte

Sep 9, 2021

Changes in this version

+ const MaxJSONPushFieldsSize

+ func EncodeConnectPush(protoType Type, message *Connect) ([]byte, error)

+ func EncodeDisconnectPush(protoType Type, message *Disconnect) ([]byte, error)

+ func EncodeJoinPush(protoType Type, channel string, message *Join) ([]byte, error)

+ func EncodeLeavePush(protoType Type, channel string, message *Leave) ([]byte, error)

+ func EncodeMessagePush(protoType Type, message *Message) ([]byte, error)

+ func EncodePublicationPush(protoType Type, channel string, message *Publication) ([]byte, error)

+ func EncodeRefreshPush(protoType Type, message *Refresh) ([]byte, error)

+ func EncodeSubscribePush(protoType Type, channel string, message *Subscribe) ([]byte, error)

+ func EncodeUnsubscribePush(protoType Type, channel string, message *Unsubscribe) ([]byte, error)

+ type ByteBuffer struct

+ B []byte

+ func (bb *ByteBuffer) Reset()

+ func (bb *ByteBuffer) Write(p []byte) (int, error)

Aug 28, 2021

Changes in this version

type HistoryRequest

+ Reverse bool

+ func (x *HistoryRequest) GetReverse() bool

Aug 23, 2021

Changes in this version

+ var ErrIntOverflow = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLength = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")

+ var File_client_proto protoreflect.FileDescriptor

type ClientInfo

+ func (m *ClientInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ClientInfo) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ClientInfo) MarshalVT() (dAtA []byte, err error)

+ func (m *ClientInfo) SizeVT() (n int)

+ func (m *ClientInfo) UnmarshalVT(dAtA []byte) error

+ func (x *ClientInfo) GetChanInfo() []byte

+ func (x *ClientInfo) GetConnInfo() []byte

+ func (x *ClientInfo) ProtoReflect() protoreflect.Message

type Command

+ func (m *Command) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Command) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Command) MarshalVT() (dAtA []byte, err error)

+ func (m *Command) SizeVT() (n int)

+ func (m *Command) UnmarshalVT(dAtA []byte) error

+ func (x *Command) GetParams() []byte

+ func (x *Command) ProtoReflect() protoreflect.Message

type Command_MethodType

+ func (Command_MethodType) Descriptor() protoreflect.EnumDescriptor

+ func (Command_MethodType) Type() protoreflect.EnumType

+ func (x Command_MethodType) Enum() *Command_MethodType

+ func (x Command_MethodType) Number() protoreflect.EnumNumber

type Connect

+ func (m *Connect) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Connect) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Connect) MarshalVT() (dAtA []byte, err error)

+ func (m *Connect) SizeVT() (n int)

+ func (m *Connect) UnmarshalVT(dAtA []byte) error

+ func (x *Connect) GetData() []byte

+ func (x *Connect) ProtoReflect() protoreflect.Message

type ConnectRequest

+ func (m *ConnectRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ConnectRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ConnectRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *ConnectRequest) SizeVT() (n int)

+ func (m *ConnectRequest) UnmarshalVT(dAtA []byte) error

+ func (x *ConnectRequest) GetData() []byte

+ func (x *ConnectRequest) ProtoReflect() protoreflect.Message

type ConnectResult

+ func (m *ConnectResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *ConnectResult) MarshalToVT(dAtA []byte) (int, error)

+ func (m *ConnectResult) MarshalVT() (dAtA []byte, err error)

+ func (m *ConnectResult) SizeVT() (n int)

+ func (m *ConnectResult) UnmarshalVT(dAtA []byte) error

+ func (x *ConnectResult) GetData() []byte

+ func (x *ConnectResult) ProtoReflect() protoreflect.Message

type Disconnect

+ func (m *Disconnect) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Disconnect) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Disconnect) MarshalVT() (dAtA []byte, err error)

+ func (m *Disconnect) SizeVT() (n int)

+ func (m *Disconnect) UnmarshalVT(dAtA []byte) error

+ func (x *Disconnect) ProtoReflect() protoreflect.Message

type Error

+ func (m *Error) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Error) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Error) MarshalVT() (dAtA []byte, err error)

+ func (m *Error) SizeVT() (n int)

+ func (m *Error) UnmarshalVT(dAtA []byte) error

+ func (x *Error) ProtoReflect() protoreflect.Message

type HistoryRequest

+ func (m *HistoryRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *HistoryRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *HistoryRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *HistoryRequest) SizeVT() (n int)

+ func (m *HistoryRequest) UnmarshalVT(dAtA []byte) error

+ func (x *HistoryRequest) ProtoReflect() protoreflect.Message

type HistoryResult

+ func (m *HistoryResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *HistoryResult) MarshalToVT(dAtA []byte) (int, error)

+ func (m *HistoryResult) MarshalVT() (dAtA []byte, err error)

+ func (m *HistoryResult) SizeVT() (n int)

+ func (m *HistoryResult) UnmarshalVT(dAtA []byte) error

+ func (x *HistoryResult) ProtoReflect() protoreflect.Message

type Join

+ func (m *Join) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Join) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Join) MarshalVT() (dAtA []byte, err error)

+ func (m *Join) SizeVT() (n int)

+ func (m *Join) UnmarshalVT(dAtA []byte) error

+ func (x *Join) ProtoReflect() protoreflect.Message

type Leave

+ func (m *Leave) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Leave) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Leave) MarshalVT() (dAtA []byte, err error)

+ func (m *Leave) SizeVT() (n int)

+ func (m *Leave) UnmarshalVT(dAtA []byte) error

+ func (x *Leave) ProtoReflect() protoreflect.Message

type Message

+ func (m *Message) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Message) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Message) MarshalVT() (dAtA []byte, err error)

+ func (m *Message) SizeVT() (n int)

+ func (m *Message) UnmarshalVT(dAtA []byte) error

+ func (x *Message) GetData() []byte

+ func (x *Message) ProtoReflect() protoreflect.Message

type PingRequest

+ func (m *PingRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *PingRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *PingRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *PingRequest) SizeVT() (n int)

+ func (m *PingRequest) UnmarshalVT(dAtA []byte) error

+ func (x *PingRequest) ProtoReflect() protoreflect.Message

type PingResult

+ func (m *PingResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *PingResult) MarshalToVT(dAtA []byte) (int, error)

+ func (m *PingResult) MarshalVT() (dAtA []byte, err error)

+ func (m *PingResult) SizeVT() (n int)

+ func (m *PingResult) UnmarshalVT(dAtA []byte) error

+ func (x *PingResult) ProtoReflect() protoreflect.Message

type PresenceRequest

+ func (m *PresenceRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *PresenceRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *PresenceRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *PresenceRequest) SizeVT() (n int)

+ func (m *PresenceRequest) UnmarshalVT(dAtA []byte) error

+ func (x *PresenceRequest) ProtoReflect() protoreflect.Message

type PresenceResult

+ func (m *PresenceResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *PresenceResult) MarshalToVT(dAtA []byte) (int, error)

+ func (m *PresenceResult) MarshalVT() (dAtA []byte, err error)

+ func (m *PresenceResult) SizeVT() (n int)

+ func (m *PresenceResult) UnmarshalVT(dAtA []byte) error

+ func (x *PresenceResult) ProtoReflect() protoreflect.Message

type PresenceStatsRequest

+ func (m *PresenceStatsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *PresenceStatsRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *PresenceStatsRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *PresenceStatsRequest) SizeVT() (n int)

+ func (m *PresenceStatsRequest) UnmarshalVT(dAtA []byte) error

+ func (x *PresenceStatsRequest) ProtoReflect() protoreflect.Message

type PresenceStatsResult

+ func (m *PresenceStatsResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *PresenceStatsResult) MarshalToVT(dAtA []byte) (int, error)

+ func (m *PresenceStatsResult) MarshalVT() (dAtA []byte, err error)

+ func (m *PresenceStatsResult) SizeVT() (n int)

+ func (m *PresenceStatsResult) UnmarshalVT(dAtA []byte) error

+ func (x *PresenceStatsResult) ProtoReflect() protoreflect.Message

type Publication

+ func (m *Publication) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Publication) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Publication) MarshalVT() (dAtA []byte, err error)

+ func (m *Publication) SizeVT() (n int)

+ func (m *Publication) UnmarshalVT(dAtA []byte) error

+ func (x *Publication) GetData() []byte

+ func (x *Publication) ProtoReflect() protoreflect.Message

type PublishRequest

+ func (m *PublishRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *PublishRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *PublishRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *PublishRequest) SizeVT() (n int)

+ func (m *PublishRequest) UnmarshalVT(dAtA []byte) error

+ func (x *PublishRequest) GetData() []byte

+ func (x *PublishRequest) ProtoReflect() protoreflect.Message

type PublishResult

+ func (m *PublishResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *PublishResult) MarshalToVT(dAtA []byte) (int, error)

+ func (m *PublishResult) MarshalVT() (dAtA []byte, err error)

+ func (m *PublishResult) SizeVT() (n int)

+ func (m *PublishResult) UnmarshalVT(dAtA []byte) error

+ func (x *PublishResult) ProtoReflect() protoreflect.Message

type Push

+ func (m *Push) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Push) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Push) MarshalVT() (dAtA []byte, err error)

+ func (m *Push) SizeVT() (n int)

+ func (m *Push) UnmarshalVT(dAtA []byte) error

+ func (x *Push) GetData() []byte

+ func (x *Push) ProtoReflect() protoreflect.Message

type Push_PushType

+ func (Push_PushType) Descriptor() protoreflect.EnumDescriptor

+ func (Push_PushType) Type() protoreflect.EnumType

+ func (x Push_PushType) Enum() *Push_PushType

+ func (x Push_PushType) Number() protoreflect.EnumNumber

type RPCRequest

+ func (m *RPCRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *RPCRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *RPCRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *RPCRequest) SizeVT() (n int)

+ func (m *RPCRequest) UnmarshalVT(dAtA []byte) error

+ func (x *RPCRequest) GetData() []byte

+ func (x *RPCRequest) ProtoReflect() protoreflect.Message

type RPCResult

+ func (m *RPCResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *RPCResult) MarshalToVT(dAtA []byte) (int, error)

+ func (m *RPCResult) MarshalVT() (dAtA []byte, err error)

+ func (m *RPCResult) SizeVT() (n int)

+ func (m *RPCResult) UnmarshalVT(dAtA []byte) error

+ func (x *RPCResult) GetData() []byte

+ func (x *RPCResult) ProtoReflect() protoreflect.Message

type Refresh

+ func (m *Refresh) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Refresh) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Refresh) MarshalVT() (dAtA []byte, err error)

+ func (m *Refresh) SizeVT() (n int)

+ func (m *Refresh) UnmarshalVT(dAtA []byte) error

+ func (x *Refresh) ProtoReflect() protoreflect.Message

type RefreshRequest

+ func (m *RefreshRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *RefreshRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *RefreshRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *RefreshRequest) SizeVT() (n int)

+ func (m *RefreshRequest) UnmarshalVT(dAtA []byte) error

+ func (x *RefreshRequest) ProtoReflect() protoreflect.Message

type RefreshResult

+ func (m *RefreshResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *RefreshResult) MarshalToVT(dAtA []byte) (int, error)

+ func (m *RefreshResult) MarshalVT() (dAtA []byte, err error)

+ func (m *RefreshResult) SizeVT() (n int)

+ func (m *RefreshResult) UnmarshalVT(dAtA []byte) error

+ func (x *RefreshResult) ProtoReflect() protoreflect.Message

type Reply

+ func (m *Reply) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Reply) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Reply) MarshalVT() (dAtA []byte, err error)

+ func (m *Reply) SizeVT() (n int)

+ func (m *Reply) UnmarshalVT(dAtA []byte) error

+ func (x *Reply) GetResult() []byte

+ func (x *Reply) ProtoReflect() protoreflect.Message

type SendRequest

+ func (m *SendRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *SendRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *SendRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *SendRequest) SizeVT() (n int)

+ func (m *SendRequest) UnmarshalVT(dAtA []byte) error

+ func (x *SendRequest) GetData() []byte

+ func (x *SendRequest) ProtoReflect() protoreflect.Message

type StreamPosition

+ func (m *StreamPosition) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *StreamPosition) MarshalToVT(dAtA []byte) (int, error)

+ func (m *StreamPosition) MarshalVT() (dAtA []byte, err error)

+ func (m *StreamPosition) SizeVT() (n int)

+ func (m *StreamPosition) UnmarshalVT(dAtA []byte) error

+ func (x *StreamPosition) ProtoReflect() protoreflect.Message

type SubRefreshRequest

+ func (m *SubRefreshRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *SubRefreshRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *SubRefreshRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *SubRefreshRequest) SizeVT() (n int)

+ func (m *SubRefreshRequest) UnmarshalVT(dAtA []byte) error

+ func (x *SubRefreshRequest) ProtoReflect() protoreflect.Message

type SubRefreshResult

+ func (m *SubRefreshResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *SubRefreshResult) MarshalToVT(dAtA []byte) (int, error)

+ func (m *SubRefreshResult) MarshalVT() (dAtA []byte, err error)

+ func (m *SubRefreshResult) SizeVT() (n int)

+ func (m *SubRefreshResult) UnmarshalVT(dAtA []byte) error

+ func (x *SubRefreshResult) ProtoReflect() protoreflect.Message

type Subscribe

+ func (m *Subscribe) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Subscribe) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Subscribe) MarshalVT() (dAtA []byte, err error)

+ func (m *Subscribe) SizeVT() (n int)

+ func (m *Subscribe) UnmarshalVT(dAtA []byte) error

+ func (x *Subscribe) GetData() []byte

+ func (x *Subscribe) ProtoReflect() protoreflect.Message

type SubscribeRequest

+ func (m *SubscribeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *SubscribeRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *SubscribeRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *SubscribeRequest) SizeVT() (n int)

+ func (m *SubscribeRequest) UnmarshalVT(dAtA []byte) error

+ func (x *SubscribeRequest) ProtoReflect() protoreflect.Message

type SubscribeResult

+ func (m *SubscribeResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *SubscribeResult) MarshalToVT(dAtA []byte) (int, error)

+ func (m *SubscribeResult) MarshalVT() (dAtA []byte, err error)

+ func (m *SubscribeResult) SizeVT() (n int)

+ func (m *SubscribeResult) UnmarshalVT(dAtA []byte) error

+ func (x *SubscribeResult) GetData() []byte

+ func (x *SubscribeResult) ProtoReflect() protoreflect.Message

type Unsubscribe

+ func (m *Unsubscribe) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *Unsubscribe) MarshalToVT(dAtA []byte) (int, error)

+ func (m *Unsubscribe) MarshalVT() (dAtA []byte, err error)

+ func (m *Unsubscribe) SizeVT() (n int)

+ func (m *Unsubscribe) UnmarshalVT(dAtA []byte) error

+ func (x *Unsubscribe) ProtoReflect() protoreflect.Message

type UnsubscribeRequest

+ func (m *UnsubscribeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *UnsubscribeRequest) MarshalToVT(dAtA []byte) (int, error)

+ func (m *UnsubscribeRequest) MarshalVT() (dAtA []byte, err error)

+ func (m *UnsubscribeRequest) SizeVT() (n int)

+ func (m *UnsubscribeRequest) UnmarshalVT(dAtA []byte) error

+ func (x *UnsubscribeRequest) ProtoReflect() protoreflect.Message

type UnsubscribeResult

+ func (m *UnsubscribeResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

+ func (m *UnsubscribeResult) MarshalToVT(dAtA []byte) (int, error)

+ func (m *UnsubscribeResult) MarshalVT() (dAtA []byte, err error)

+ func (m *UnsubscribeResult) SizeVT() (n int)

+ func (m *UnsubscribeResult) UnmarshalVT(dAtA []byte) error

+ func (x *UnsubscribeResult) ProtoReflect() protoreflect.Message

Aug 21, 2021

Changes in this version

type ClientInfo

+ func (v *ClientInfo) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v ClientInfo) MarshalEasyJSON(w *writer)

type Command

+ func (v *Command) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v Command) MarshalEasyJSON(w *writer)

type Connect

+ Expires bool

+ Ttl uint32

+ func (m *Connect) GetExpires() bool

+ func (m *Connect) GetTtl() uint32

+ func (v *Connect) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v Connect) MarshalEasyJSON(w *writer)

type ConnectRequest

+ func (v *ConnectRequest) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v ConnectRequest) MarshalEasyJSON(w *writer)

type ConnectResult

+ func (v *ConnectResult) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v ConnectResult) MarshalEasyJSON(w *writer)

type Disconnect

+ func (v *Disconnect) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v Disconnect) MarshalEasyJSON(w *writer)

type Error

+ func (v *Error) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v Error) MarshalEasyJSON(w *writer)

type HistoryRequest

+ Since *StreamPosition

+ func (m *HistoryRequest) GetSince() *StreamPosition

+ func (v *HistoryRequest) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v HistoryRequest) MarshalEasyJSON(w *writer)

type HistoryResult

+ func (v *HistoryResult) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v HistoryResult) MarshalEasyJSON(w *writer)

type JSONPushEncoder

+ func (e *JSONPushEncoder) EncodeRefresh(message *Refresh) ([]byte, error)

type Join

+ func (v *Join) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v Join) MarshalEasyJSON(w *writer)

type Leave

+ func (v *Leave) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v Leave) MarshalEasyJSON(w *writer)

type Message

+ func (v *Message) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v Message) MarshalEasyJSON(w *writer)

type PingRequest

+ func (v *PingRequest) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v PingRequest) MarshalEasyJSON(w *writer)

type PingResult

+ func (v *PingResult) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v PingResult) MarshalEasyJSON(w *writer)

type PresenceRequest

+ func (v *PresenceRequest) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v PresenceRequest) MarshalEasyJSON(w *writer)

type PresenceResult

+ func (v *PresenceResult) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v PresenceResult) MarshalEasyJSON(w *writer)

type PresenceStatsRequest

+ func (v *PresenceStatsRequest) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v PresenceStatsRequest) MarshalEasyJSON(w *writer)

type PresenceStatsResult

+ func (v *PresenceStatsResult) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v PresenceStatsResult) MarshalEasyJSON(w *writer)

type ProtobufPushEncoder

+ func (e *ProtobufPushEncoder) EncodeRefresh(message *Refresh) ([]byte, error)

type Publication

+ func (v *Publication) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v Publication) MarshalEasyJSON(w *writer)

type PublishRequest

+ func (v *PublishRequest) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v PublishRequest) MarshalEasyJSON(w *writer)

type PublishResult

+ func (v *PublishResult) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v PublishResult) MarshalEasyJSON(w *writer)

type Push

+ func (v *Push) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v Push) MarshalEasyJSON(w *writer)

type PushEncoder

+ EncodeRefresh func(*Refresh) ([]byte, error)

type Push_PushType

+ const Push_REFRESH

type RPCRequest

+ func (v *RPCRequest) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v RPCRequest) MarshalEasyJSON(w *writer)

type RPCResult

+ func (v *RPCResult) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v RPCResult) MarshalEasyJSON(w *writer)

+ type Refresh struct

+ Expires bool

+ Ttl uint32

+ func NewPopulatedRefresh(r randyClient, easy bool) *Refresh

+ func (*Refresh) Descriptor() ([]byte, []int)

+ func (*Refresh) ProtoMessage()

+ func (m *Refresh) GetExpires() bool

+ func (m *Refresh) GetTtl() uint32

+ func (m *Refresh) Marshal() (dAtA []byte, err error)

+ func (m *Refresh) MarshalTo(dAtA []byte) (int, error)

+ func (m *Refresh) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Refresh) Reset()

+ func (m *Refresh) Size() (n int)

+ func (m *Refresh) String() string

+ func (m *Refresh) Unmarshal(dAtA []byte) error

+ func (m *Refresh) XXX_DiscardUnknown()

+ func (m *Refresh) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Refresh) XXX_Merge(src proto.Message)

+ func (m *Refresh) XXX_Size() int

+ func (m *Refresh) XXX_Unmarshal(b []byte) error

+ func (this *Refresh) Equal(that interface{}) bool

+ func (v *Refresh) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v Refresh) MarshalEasyJSON(w *writer)

type RefreshRequest

+ func (v *RefreshRequest) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v RefreshRequest) MarshalEasyJSON(w *writer)

type RefreshResult

+ func (v *RefreshResult) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v RefreshResult) MarshalEasyJSON(w *writer)

type Reply

+ func (v *Reply) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v Reply) MarshalEasyJSON(w *writer)

type SendRequest

+ func (v *SendRequest) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v SendRequest) MarshalEasyJSON(w *writer)

+ type StreamPosition struct

+ Epoch string

+ Offset uint64

+ func NewPopulatedStreamPosition(r randyClient, easy bool) *StreamPosition

+ func (*StreamPosition) Descriptor() ([]byte, []int)

+ func (*StreamPosition) ProtoMessage()

+ func (m *StreamPosition) GetEpoch() string

+ func (m *StreamPosition) GetOffset() uint64

+ func (m *StreamPosition) Marshal() (dAtA []byte, err error)

+ func (m *StreamPosition) MarshalTo(dAtA []byte) (int, error)

+ func (m *StreamPosition) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *StreamPosition) Reset()

+ func (m *StreamPosition) Size() (n int)

+ func (m *StreamPosition) String() string

+ func (m *StreamPosition) Unmarshal(dAtA []byte) error

+ func (m *StreamPosition) XXX_DiscardUnknown()

+ func (m *StreamPosition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *StreamPosition) XXX_Merge(src proto.Message)

+ func (m *StreamPosition) XXX_Size() int

+ func (m *StreamPosition) XXX_Unmarshal(b []byte) error

+ func (this *StreamPosition) Equal(that interface{}) bool

+ func (v *StreamPosition) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v StreamPosition) MarshalEasyJSON(w *writer)

type SubRefreshRequest

+ func (v *SubRefreshRequest) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v SubRefreshRequest) MarshalEasyJSON(w *writer)

type SubRefreshResult

+ func (v *SubRefreshResult) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v SubRefreshResult) MarshalEasyJSON(w *writer)

type Subscribe

+ func (v *Subscribe) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v Subscribe) MarshalEasyJSON(w *writer)

type SubscribeRequest

+ func (v *SubscribeRequest) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v SubscribeRequest) MarshalEasyJSON(w *writer)

type SubscribeResult

+ func (v *SubscribeResult) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v SubscribeResult) MarshalEasyJSON(w *writer)

type Unsubscribe

+ func (v *Unsubscribe) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v Unsubscribe) MarshalEasyJSON(w *writer)

type UnsubscribeRequest

+ func (v *UnsubscribeRequest) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v UnsubscribeRequest) MarshalEasyJSON(w *writer)

type UnsubscribeResult

+ func (v *UnsubscribeResult) UnmarshalEasyJSON(l *jlexer.Lexer)

+ func (v UnsubscribeResult) MarshalEasyJSON(w *writer)

Apr 9, 2021

Changes in this version

+ var Command_MethodType_name = map[int32]string

+ var Command_MethodType_value = map[string]int32

+ var Push_PushType_name = map[int32]string

+ var Push_PushType_value = map[string]int32

+ type Command_MethodType int32

+ const Command_CONNECT

+ const Command_HISTORY

+ const Command_PING

+ const Command_PRESENCE

+ const Command_PRESENCE_STATS

+ const Command_PUBLISH

+ const Command_REFRESH

+ const Command_RPC

+ const Command_SEND

+ const Command_SUBSCRIBE

+ const Command_SUB_REFRESH

+ const Command_UNSUBSCRIBE

+ func (Command_MethodType) EnumDescriptor() ([]byte, []int)

+ func (x Command_MethodType) String() string

+ type Push_PushType int32

+ const Push_CONNECT

+ const Push_DISCONNECT

+ const Push_JOIN

+ const Push_LEAVE

+ const Push_MESSAGE

+ const Push_PUBLICATION

+ const Push_SUBSCRIBE

+ const Push_UNSUBSCRIBE

+ func (Push_PushType) EnumDescriptor() ([]byte, []int)

+ func (x Push_PushType) String() string

Mar 19, 2021

Changes in this version

type Command

+ Id uint32

+ func (m *Command) GetId() uint32

type ConnectResult

+ Ttl uint32

+ func (m *ConnectResult) GetTtl() uint32

type Publication

+ Uid string

+ func (m *Publication) GetUid() string

type RefreshResult

+ Ttl uint32

+ func (m *RefreshResult) GetTtl() uint32

type Reply

+ Id uint32

+ func (m *Reply) GetId() uint32

type SubRefreshResult

+ Ttl uint32

+ func (m *SubRefreshResult) GetTtl() uint32

type SubscribeResult

+ Ttl uint32

+ func (m *SubscribeResult) GetTtl() uint32

Mar 19, 2021

Changes in this version

+ func PutDataEncoder(protoType Type, e DataEncoder)

+ type Connect struct

+ Client string

+ Data Raw

+ Subs map[string]*SubscribeResult

+ Version string

+ func NewPopulatedConnect(r randyClient, easy bool) *Connect

+ func (*Connect) Descriptor() ([]byte, []int)

+ func (*Connect) ProtoMessage()

+ func (m *Connect) GetClient() string

+ func (m *Connect) GetSubs() map[string]*SubscribeResult

+ func (m *Connect) GetVersion() string

+ func (m *Connect) Marshal() (dAtA []byte, err error)

+ func (m *Connect) MarshalTo(dAtA []byte) (int, error)

+ func (m *Connect) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Connect) Reset()

+ func (m *Connect) Size() (n int)

+ func (m *Connect) String() string

+ func (m *Connect) Unmarshal(dAtA []byte) error

+ func (m *Connect) XXX_DiscardUnknown()

+ func (m *Connect) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Connect) XXX_Merge(src proto.Message)

+ func (m *Connect) XXX_Size() int

+ func (m *Connect) XXX_Unmarshal(b []byte) error

+ func (this *Connect) Equal(that interface{}) bool

+ type DataEncoder interface

+ Encode func([]byte) error

+ Finish func() []byte

+ Reset func()

+ func GetDataEncoder(protoType Type) DataEncoder

+ type Disconnect struct

+ Code uint32

+ Reason string

+ Reconnect bool

+ func NewPopulatedDisconnect(r randyClient, easy bool) *Disconnect

+ func (*Disconnect) Descriptor() ([]byte, []int)

+ func (*Disconnect) ProtoMessage()

+ func (m *Disconnect) GetCode() uint32

+ func (m *Disconnect) GetReason() string

+ func (m *Disconnect) GetReconnect() bool

+ func (m *Disconnect) Marshal() (dAtA []byte, err error)

+ func (m *Disconnect) MarshalTo(dAtA []byte) (int, error)

+ func (m *Disconnect) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Disconnect) Reset()

+ func (m *Disconnect) Size() (n int)

+ func (m *Disconnect) String() string

+ func (m *Disconnect) Unmarshal(dAtA []byte) error

+ func (m *Disconnect) XXX_DiscardUnknown()

+ func (m *Disconnect) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Disconnect) XXX_Merge(src proto.Message)

+ func (m *Disconnect) XXX_Size() int

+ func (m *Disconnect) XXX_Unmarshal(b []byte) error

+ func (this *Disconnect) Equal(that interface{}) bool

+ type JSONDataEncoder struct

+ func NewJSONDataEncoder() *JSONDataEncoder

+ func (e *JSONDataEncoder) Encode(data []byte) error

+ func (e *JSONDataEncoder) Finish() []byte

+ func (e *JSONDataEncoder) Reset()

type JSONPushDecoder

+ func (e *JSONPushDecoder) DecodeConnect(data []byte) (*Connect, error)

+ func (e *JSONPushDecoder) DecodeDisconnect(data []byte) (*Disconnect, error)

+ func (e *JSONPushDecoder) DecodeSubscribe(data []byte) (*Subscribe, error)

+ func (e *JSONPushDecoder) DecodeUnsubscribe(data []byte) (*Unsubscribe, error)

type JSONPushEncoder

+ func (e *JSONPushEncoder) EncodeConnect(message *Connect) ([]byte, error)

+ func (e *JSONPushEncoder) EncodeDisconnect(message *Disconnect) ([]byte, error)

+ func (e *JSONPushEncoder) EncodeSubscribe(message *Subscribe) ([]byte, error)

+ func (e *JSONPushEncoder) EncodeUnsubscribe(message *Unsubscribe) ([]byte, error)

type MethodType

+ const MethodType_METHOD_TYPE_CONNECT

+ const MethodType_METHOD_TYPE_HISTORY

+ const MethodType_METHOD_TYPE_PING

+ const MethodType_METHOD_TYPE_PRESENCE

+ const MethodType_METHOD_TYPE_PRESENCE_STATS

+ const MethodType_METHOD_TYPE_PUBLISH

+ const MethodType_METHOD_TYPE_REFRESH

+ const MethodType_METHOD_TYPE_RPC

+ const MethodType_METHOD_TYPE_SEND

+ const MethodType_METHOD_TYPE_SUBSCRIBE

+ const MethodType_METHOD_TYPE_SUB_REFRESH

+ const MethodType_METHOD_TYPE_UNSUBSCRIBE

+ type ProtobufDataEncoder struct

+ func NewProtobufDataEncoder() *ProtobufDataEncoder

+ func (e *ProtobufDataEncoder) Encode(data []byte) error

+ func (e *ProtobufDataEncoder) Finish() []byte

+ func (e *ProtobufDataEncoder) Reset()

type ProtobufPushDecoder

+ func (e *ProtobufPushDecoder) DecodeConnect(data []byte) (*Connect, error)

+ func (e *ProtobufPushDecoder) DecodeDisconnect(data []byte) (*Disconnect, error)

+ func (e *ProtobufPushDecoder) DecodeSubscribe(data []byte) (*Subscribe, error)

+ func (e *ProtobufPushDecoder) DecodeUnsubscribe(data []byte) (*Unsubscribe, error)

type ProtobufPushEncoder

+ func (e *ProtobufPushEncoder) EncodeConnect(message *Connect) ([]byte, error)

+ func (e *ProtobufPushEncoder) EncodeDisconnect(message *Disconnect) ([]byte, error)

+ func (e *ProtobufPushEncoder) EncodeSubscribe(message *Subscribe) ([]byte, error)

+ func (e *ProtobufPushEncoder) EncodeUnsubscribe(message *Unsubscribe) ([]byte, error)

type PushDecoder

+ DecodeConnect func([]byte) (*Connect, error)

+ DecodeDisconnect func([]byte) (*Disconnect, error)

+ DecodeSubscribe func([]byte) (*Subscribe, error)

+ DecodeUnsubscribe func([]byte) (*Unsubscribe, error)

type PushEncoder

+ EncodeConnect func(*Connect) ([]byte, error)

+ EncodeDisconnect func(*Disconnect) ([]byte, error)

+ EncodeSubscribe func(*Subscribe) ([]byte, error)

+ EncodeUnsubscribe func(*Unsubscribe) ([]byte, error)

type PushType

+ const PushType_PUSH_TYPE_CONNECT

+ const PushType_PUSH_TYPE_DISCONNECT

+ const PushType_PUSH_TYPE_JOIN

+ const PushType_PUSH_TYPE_LEAVE

+ const PushType_PUSH_TYPE_MESSAGE

+ const PushType_PUSH_TYPE_PUBLICATION

+ const PushType_PUSH_TYPE_SUBSCRIBE

+ const PushType_PUSH_TYPE_UNSUBSCRIBE

+ type Subscribe struct

+ Data Raw

+ Epoch string

+ Gen uint32

+ Offset uint64

+ Positioned bool

+ Recoverable bool

+ Seq uint32

+ func NewPopulatedSubscribe(r randyClient, easy bool) *Subscribe

+ func (*Subscribe) Descriptor() ([]byte, []int)

+ func (*Subscribe) ProtoMessage()

+ func (m *Subscribe) GetEpoch() string

+ func (m *Subscribe) GetGen() uint32

+ func (m *Subscribe) GetOffset() uint64

+ func (m *Subscribe) GetPositioned() bool

+ func (m *Subscribe) GetRecoverable() bool

+ func (m *Subscribe) GetSeq() uint32

+ func (m *Subscribe) Marshal() (dAtA []byte, err error)

+ func (m *Subscribe) MarshalTo(dAtA []byte) (int, error)

+ func (m *Subscribe) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Subscribe) Reset()

+ func (m *Subscribe) Size() (n int)

+ func (m *Subscribe) String() string

+ func (m *Subscribe) Unmarshal(dAtA []byte) error

+ func (m *Subscribe) XXX_DiscardUnknown()

+ func (m *Subscribe) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Subscribe) XXX_Merge(src proto.Message)

+ func (m *Subscribe) XXX_Size() int

+ func (m *Subscribe) XXX_Unmarshal(b []byte) error

+ func (this *Subscribe) Equal(that interface{}) bool

type SubscribeResult

+ Data Raw

+ type Unsubscribe struct

+ Resubscribe bool

+ func NewPopulatedUnsubscribe(r randyClient, easy bool) *Unsubscribe

+ func (*Unsubscribe) Descriptor() ([]byte, []int)

+ func (*Unsubscribe) ProtoMessage()

+ func (m *Unsubscribe) GetResubscribe() bool

+ func (m *Unsubscribe) Marshal() (dAtA []byte, err error)

+ func (m *Unsubscribe) MarshalTo(dAtA []byte) (int, error)

+ func (m *Unsubscribe) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Unsubscribe) Reset()

+ func (m *Unsubscribe) Size() (n int)

+ func (m *Unsubscribe) String() string

+ func (m *Unsubscribe) Unmarshal(dAtA []byte) error

+ func (m *Unsubscribe) XXX_DiscardUnknown()

+ func (m *Unsubscribe) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Unsubscribe) XXX_Merge(src proto.Message)

+ func (m *Unsubscribe) XXX_Size() int

+ func (m *Unsubscribe) XXX_Unmarshal(b []byte) error

+ func (this *Unsubscribe) Equal(that interface{}) bool

Jan 10, 2021

Changes in this version

+ var ErrUnexpectedEndOfGroupClient = fmt.Errorf("proto: unexpected end of group")

type ClientInfo

+ func (m *ClientInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ClientInfo) XXX_DiscardUnknown()

+ func (m *ClientInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ClientInfo) XXX_Merge(src proto.Message)

+ func (m *ClientInfo) XXX_Size() int

+ func (m *ClientInfo) XXX_Unmarshal(b []byte) error

type Command

+ func (m *Command) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Command) XXX_DiscardUnknown()

+ func (m *Command) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Command) XXX_Merge(src proto.Message)

+ func (m *Command) XXX_Size() int

+ func (m *Command) XXX_Unmarshal(b []byte) error

type ConnectRequest

+ func (m *ConnectRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ConnectRequest) XXX_DiscardUnknown()

+ func (m *ConnectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ConnectRequest) XXX_Merge(src proto.Message)

+ func (m *ConnectRequest) XXX_Size() int

+ func (m *ConnectRequest) XXX_Unmarshal(b []byte) error

type ConnectResult

+ func (m *ConnectResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ConnectResult) XXX_DiscardUnknown()

+ func (m *ConnectResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ConnectResult) XXX_Merge(src proto.Message)

+ func (m *ConnectResult) XXX_Size() int

+ func (m *ConnectResult) XXX_Unmarshal(b []byte) error

type Error

+ func (m *Error) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Error) XXX_DiscardUnknown()

+ func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Error) XXX_Merge(src proto.Message)

+ func (m *Error) XXX_Size() int

+ func (m *Error) XXX_Unmarshal(b []byte) error

type HistoryRequest

+ Epoch string

+ Limit int32

+ Offset uint64

+ UseLimit bool

+ UseSince bool

+ func (m *HistoryRequest) GetEpoch() string

+ func (m *HistoryRequest) GetLimit() int32

+ func (m *HistoryRequest) GetOffset() uint64

+ func (m *HistoryRequest) GetUseLimit() bool

+ func (m *HistoryRequest) GetUseSince() bool

+ func (m *HistoryRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *HistoryRequest) XXX_DiscardUnknown()

+ func (m *HistoryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *HistoryRequest) XXX_Merge(src proto.Message)

+ func (m *HistoryRequest) XXX_Size() int

+ func (m *HistoryRequest) XXX_Unmarshal(b []byte) error

type HistoryResult

+ Epoch string

+ Offset uint64

+ func (m *HistoryResult) GetEpoch() string

+ func (m *HistoryResult) GetOffset() uint64

+ func (m *HistoryResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *HistoryResult) XXX_DiscardUnknown()

+ func (m *HistoryResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *HistoryResult) XXX_Merge(src proto.Message)

+ func (m *HistoryResult) XXX_Size() int

+ func (m *HistoryResult) XXX_Unmarshal(b []byte) error

type Join

+ func (m *Join) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Join) XXX_DiscardUnknown()

+ func (m *Join) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Join) XXX_Merge(src proto.Message)

+ func (m *Join) XXX_Size() int

+ func (m *Join) XXX_Unmarshal(b []byte) error

type Leave

+ func (m *Leave) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Leave) XXX_DiscardUnknown()

+ func (m *Leave) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Leave) XXX_Merge(src proto.Message)

+ func (m *Leave) XXX_Size() int

+ func (m *Leave) XXX_Unmarshal(b []byte) error

type Message

+ func (m *Message) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Message) XXX_DiscardUnknown()

+ func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Message) XXX_Merge(src proto.Message)

+ func (m *Message) XXX_Size() int

+ func (m *Message) XXX_Unmarshal(b []byte) error

type PingRequest

+ func (m *PingRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PingRequest) XXX_DiscardUnknown()

+ func (m *PingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PingRequest) XXX_Merge(src proto.Message)

+ func (m *PingRequest) XXX_Size() int

+ func (m *PingRequest) XXX_Unmarshal(b []byte) error

type PingResult

+ func (m *PingResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PingResult) XXX_DiscardUnknown()

+ func (m *PingResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PingResult) XXX_Merge(src proto.Message)

+ func (m *PingResult) XXX_Size() int

+ func (m *PingResult) XXX_Unmarshal(b []byte) error

type PresenceRequest

+ func (m *PresenceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PresenceRequest) XXX_DiscardUnknown()

+ func (m *PresenceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PresenceRequest) XXX_Merge(src proto.Message)

+ func (m *PresenceRequest) XXX_Size() int

+ func (m *PresenceRequest) XXX_Unmarshal(b []byte) error

type PresenceResult

+ func (m *PresenceResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PresenceResult) XXX_DiscardUnknown()

+ func (m *PresenceResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PresenceResult) XXX_Merge(src proto.Message)

+ func (m *PresenceResult) XXX_Size() int

+ func (m *PresenceResult) XXX_Unmarshal(b []byte) error

type PresenceStatsRequest

+ func (m *PresenceStatsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PresenceStatsRequest) XXX_DiscardUnknown()

+ func (m *PresenceStatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PresenceStatsRequest) XXX_Merge(src proto.Message)

+ func (m *PresenceStatsRequest) XXX_Size() int

+ func (m *PresenceStatsRequest) XXX_Unmarshal(b []byte) error

type PresenceStatsResult

+ func (m *PresenceStatsResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PresenceStatsResult) XXX_DiscardUnknown()

+ func (m *PresenceStatsResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PresenceStatsResult) XXX_Merge(src proto.Message)

+ func (m *PresenceStatsResult) XXX_Size() int

+ func (m *PresenceStatsResult) XXX_Unmarshal(b []byte) error

type Publication

+ func (m *Publication) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Publication) XXX_DiscardUnknown()

+ func (m *Publication) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Publication) XXX_Merge(src proto.Message)

+ func (m *Publication) XXX_Size() int

+ func (m *Publication) XXX_Unmarshal(b []byte) error

type PublishRequest

+ func (m *PublishRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PublishRequest) XXX_DiscardUnknown()

+ func (m *PublishRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PublishRequest) XXX_Merge(src proto.Message)

+ func (m *PublishRequest) XXX_Size() int

+ func (m *PublishRequest) XXX_Unmarshal(b []byte) error

type PublishResult

+ func (m *PublishResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *PublishResult) XXX_DiscardUnknown()

+ func (m *PublishResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PublishResult) XXX_Merge(src proto.Message)

+ func (m *PublishResult) XXX_Size() int

+ func (m *PublishResult) XXX_Unmarshal(b []byte) error

type Push

+ func (m *Push) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Push) XXX_DiscardUnknown()

+ func (m *Push) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Push) XXX_Merge(src proto.Message)

+ func (m *Push) XXX_Size() int

+ func (m *Push) XXX_Unmarshal(b []byte) error

type RPCRequest

+ func (m *RPCRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RPCRequest) XXX_DiscardUnknown()

+ func (m *RPCRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RPCRequest) XXX_Merge(src proto.Message)

+ func (m *RPCRequest) XXX_Size() int

+ func (m *RPCRequest) XXX_Unmarshal(b []byte) error

type RPCResult

+ func (m *RPCResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RPCResult) XXX_DiscardUnknown()

+ func (m *RPCResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RPCResult) XXX_Merge(src proto.Message)

+ func (m *RPCResult) XXX_Size() int

+ func (m *RPCResult) XXX_Unmarshal(b []byte) error

type RefreshRequest

+ func (m *RefreshRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RefreshRequest) XXX_DiscardUnknown()

+ func (m *RefreshRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RefreshRequest) XXX_Merge(src proto.Message)

+ func (m *RefreshRequest) XXX_Size() int

+ func (m *RefreshRequest) XXX_Unmarshal(b []byte) error

type RefreshResult

+ func (m *RefreshResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *RefreshResult) XXX_DiscardUnknown()

+ func (m *RefreshResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RefreshResult) XXX_Merge(src proto.Message)

+ func (m *RefreshResult) XXX_Size() int

+ func (m *RefreshResult) XXX_Unmarshal(b []byte) error

type Reply

+ func (m *Reply) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Reply) XXX_DiscardUnknown()

+ func (m *Reply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Reply) XXX_Merge(src proto.Message)

+ func (m *Reply) XXX_Size() int

+ func (m *Reply) XXX_Unmarshal(b []byte) error

type SendRequest

+ func (m *SendRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SendRequest) XXX_DiscardUnknown()

+ func (m *SendRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SendRequest) XXX_Merge(src proto.Message)

+ func (m *SendRequest) XXX_Size() int

+ func (m *SendRequest) XXX_Unmarshal(b []byte) error

type Sub

+ Positioned bool

+ func (m *Sub) GetPositioned() bool

+ func (m *Sub) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Sub) XXX_DiscardUnknown()

+ func (m *Sub) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Sub) XXX_Merge(src proto.Message)

+ func (m *Sub) XXX_Size() int

+ func (m *Sub) XXX_Unmarshal(b []byte) error

type SubRefreshRequest

+ func (m *SubRefreshRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SubRefreshRequest) XXX_DiscardUnknown()

+ func (m *SubRefreshRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SubRefreshRequest) XXX_Merge(src proto.Message)

+ func (m *SubRefreshRequest) XXX_Size() int

+ func (m *SubRefreshRequest) XXX_Unmarshal(b []byte) error

type SubRefreshResult

+ func (m *SubRefreshResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SubRefreshResult) XXX_DiscardUnknown()

+ func (m *SubRefreshResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SubRefreshResult) XXX_Merge(src proto.Message)

+ func (m *SubRefreshResult) XXX_Size() int

+ func (m *SubRefreshResult) XXX_Unmarshal(b []byte) error

type SubscribeRequest

+ func (m *SubscribeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SubscribeRequest) XXX_DiscardUnknown()

+ func (m *SubscribeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SubscribeRequest) XXX_Merge(src proto.Message)

+ func (m *SubscribeRequest) XXX_Size() int

+ func (m *SubscribeRequest) XXX_Unmarshal(b []byte) error

type SubscribeResult

+ Positioned bool

+ func (m *SubscribeResult) GetPositioned() bool

+ func (m *SubscribeResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *SubscribeResult) XXX_DiscardUnknown()

+ func (m *SubscribeResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SubscribeResult) XXX_Merge(src proto.Message)

+ func (m *SubscribeResult) XXX_Size() int

+ func (m *SubscribeResult) XXX_Unmarshal(b []byte) error

type Unsub

+ func (m *Unsub) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *Unsub) XXX_DiscardUnknown()

+ func (m *Unsub) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Unsub) XXX_Merge(src proto.Message)

+ func (m *Unsub) XXX_Size() int

+ func (m *Unsub) XXX_Unmarshal(b []byte) error

type UnsubscribeRequest

+ func (m *UnsubscribeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *UnsubscribeRequest) XXX_DiscardUnknown()

+ func (m *UnsubscribeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *UnsubscribeRequest) XXX_Merge(src proto.Message)

+ func (m *UnsubscribeRequest) XXX_Size() int

+ func (m *UnsubscribeRequest) XXX_Unmarshal(b []byte) error

type UnsubscribeResult

+ func (m *UnsubscribeResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *UnsubscribeResult) XXX_DiscardUnknown()

+ func (m *UnsubscribeResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *UnsubscribeResult) XXX_Merge(src proto.Message)

+ func (m *UnsubscribeResult) XXX_Size() int

+ func (m *UnsubscribeResult) XXX_Unmarshal(b []byte) error

Aug 13, 2020

Changes in this version

type ConnectRequest

+ Name string

+ Version string

+ func (m *ConnectRequest) GetName() string

+ func (m *ConnectRequest) GetVersion() string

May 4, 2020

Changes in this version

type RPCRequest

+ Method string

+ func (m *RPCRequest) GetMethod() string

Apr 29, 2020

Changes in this version

+ var ErrIntOverflowClient = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthClient = fmt.Errorf("proto: negative length found during unmarshaling")

+ var MethodType_name = map[int32]string

+ var MethodType_value = map[string]int32

+ var PushType_name = map[int32]string

+ var PushType_value = map[string]int32

+ func PutCommandDecoder(protoType Type, e CommandDecoder)

+ func PutParamsDecoder(protoType Type, e ParamsDecoder)

+ func PutReplyEncoder(protoType Type, e ReplyEncoder)

+ func PutResultEncoder(protoType Type, e ReplyEncoder)

+ type ClientInfo struct

+ ChanInfo Raw

+ Client string

+ ConnInfo Raw

+ User string

+ func NewPopulatedClientInfo(r randyClient, easy bool) *ClientInfo

+ func (*ClientInfo) Descriptor() ([]byte, []int)

+ func (*ClientInfo) ProtoMessage()

+ func (m *ClientInfo) GetClient() string

+ func (m *ClientInfo) GetUser() string

+ func (m *ClientInfo) Marshal() (dAtA []byte, err error)

+ func (m *ClientInfo) MarshalTo(dAtA []byte) (int, error)

+ func (m *ClientInfo) Reset()

+ func (m *ClientInfo) Size() (n int)

+ func (m *ClientInfo) String() string

+ func (m *ClientInfo) Unmarshal(dAtA []byte) error

+ func (this *ClientInfo) Equal(that interface{}) bool

+ type Command struct

+ ID uint32

+ Method MethodType

+ Params Raw

+ func NewPopulatedCommand(r randyClient, easy bool) *Command

+ func (*Command) Descriptor() ([]byte, []int)

+ func (*Command) ProtoMessage()

+ func (m *Command) GetID() uint32

+ func (m *Command) GetMethod() MethodType

+ func (m *Command) Marshal() (dAtA []byte, err error)

+ func (m *Command) MarshalTo(dAtA []byte) (int, error)

+ func (m *Command) Reset()

+ func (m *Command) Size() (n int)

+ func (m *Command) String() string

+ func (m *Command) Unmarshal(dAtA []byte) error

+ func (this *Command) Equal(that interface{}) bool

+ type CommandDecoder interface

+ Decode func() (*Command, error)

+ Reset func([]byte) error

+ func GetCommandDecoder(protoType Type, data []byte) CommandDecoder

+ type CommandEncoder interface

+ Encode func(cmd *Command) ([]byte, error)

+ type ConnectRequest struct

+ Data Raw

+ Subs map[string]*SubscribeRequest

+ Token string

+ func NewPopulatedConnectRequest(r randyClient, easy bool) *ConnectRequest

+ func (*ConnectRequest) Descriptor() ([]byte, []int)

+ func (*ConnectRequest) ProtoMessage()

+ func (m *ConnectRequest) GetSubs() map[string]*SubscribeRequest

+ func (m *ConnectRequest) GetToken() string

+ func (m *ConnectRequest) Marshal() (dAtA []byte, err error)

+ func (m *ConnectRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *ConnectRequest) Reset()

+ func (m *ConnectRequest) Size() (n int)

+ func (m *ConnectRequest) String() string

+ func (m *ConnectRequest) Unmarshal(dAtA []byte) error

+ func (this *ConnectRequest) Equal(that interface{}) bool

+ type ConnectResult struct

+ Client string

+ Data Raw

+ Expires bool

+ Subs map[string]*SubscribeResult

+ TTL uint32

+ Version string

+ func NewPopulatedConnectResult(r randyClient, easy bool) *ConnectResult

+ func (*ConnectResult) Descriptor() ([]byte, []int)

+ func (*ConnectResult) ProtoMessage()

+ func (m *ConnectResult) GetClient() string

+ func (m *ConnectResult) GetExpires() bool

+ func (m *ConnectResult) GetSubs() map[string]*SubscribeResult

+ func (m *ConnectResult) GetTTL() uint32

+ func (m *ConnectResult) GetVersion() string

+ func (m *ConnectResult) Marshal() (dAtA []byte, err error)

+ func (m *ConnectResult) MarshalTo(dAtA []byte) (int, error)

+ func (m *ConnectResult) Reset()

+ func (m *ConnectResult) Size() (n int)

+ func (m *ConnectResult) String() string

+ func (m *ConnectResult) Unmarshal(dAtA []byte) error

+ func (this *ConnectResult) Equal(that interface{}) bool

+ type EncodingType string

+ const EncodingTypeBinary

+ const EncodingTypeJSON

+ type Error struct

+ Code uint32

+ Message string

+ func NewPopulatedError(r randyClient, easy bool) *Error

+ func (*Error) Descriptor() ([]byte, []int)

+ func (*Error) ProtoMessage()

+ func (e Error) Error() string

+ func (m *Error) GetCode() uint32

+ func (m *Error) GetMessage() string

+ func (m *Error) Marshal() (dAtA []byte, err error)

+ func (m *Error) MarshalTo(dAtA []byte) (int, error)

+ func (m *Error) Reset()

+ func (m *Error) Size() (n int)

+ func (m *Error) String() string

+ func (m *Error) Unmarshal(dAtA []byte) error

+ func (this *Error) Equal(that interface{}) bool

+ type HistoryRequest struct

+ Channel string

+ func NewPopulatedHistoryRequest(r randyClient, easy bool) *HistoryRequest

+ func (*HistoryRequest) Descriptor() ([]byte, []int)

+ func (*HistoryRequest) ProtoMessage()

+ func (m *HistoryRequest) GetChannel() string

+ func (m *HistoryRequest) Marshal() (dAtA []byte, err error)

+ func (m *HistoryRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *HistoryRequest) Reset()

+ func (m *HistoryRequest) Size() (n int)

+ func (m *HistoryRequest) String() string

+ func (m *HistoryRequest) Unmarshal(dAtA []byte) error

+ func (this *HistoryRequest) Equal(that interface{}) bool

+ type HistoryResult struct

+ Publications []*Publication

+ func NewPopulatedHistoryResult(r randyClient, easy bool) *HistoryResult

+ func (*HistoryResult) Descriptor() ([]byte, []int)

+ func (*HistoryResult) ProtoMessage()

+ func (m *HistoryResult) GetPublications() []*Publication

+ func (m *HistoryResult) Marshal() (dAtA []byte, err error)

+ func (m *HistoryResult) MarshalTo(dAtA []byte) (int, error)

+ func (m *HistoryResult) Reset()

+ func (m *HistoryResult) Size() (n int)

+ func (m *HistoryResult) String() string

+ func (m *HistoryResult) Unmarshal(dAtA []byte) error

+ func (this *HistoryResult) Equal(that interface{}) bool

+ type JSONCommandDecoder struct

+ func NewJSONCommandDecoder(data []byte) *JSONCommandDecoder

+ func (d *JSONCommandDecoder) Decode() (*Command, error)

+ func (d *JSONCommandDecoder) Reset(data []byte) error

+ type JSONCommandEncoder struct

+ func NewJSONCommandEncoder() *JSONCommandEncoder

+ func (e *JSONCommandEncoder) Encode(cmd *Command) ([]byte, error)

+ type JSONParamsDecoder struct

+ func NewJSONParamsDecoder() *JSONParamsDecoder

+ func (d *JSONParamsDecoder) DecodeConnect(data []byte) (*ConnectRequest, error)

+ func (d *JSONParamsDecoder) DecodeHistory(data []byte) (*HistoryRequest, error)

+ func (d *JSONParamsDecoder) DecodePing(data []byte) (*PingRequest, error)

+ func (d *JSONParamsDecoder) DecodePresence(data []byte) (*PresenceRequest, error)

+ func (d *JSONParamsDecoder) DecodePresenceStats(data []byte) (*PresenceStatsRequest, error)

+ func (d *JSONParamsDecoder) DecodePublish(data []byte) (*PublishRequest, error)

+ func (d *JSONParamsDecoder) DecodeRPC(data []byte) (*RPCRequest, error)

+ func (d *JSONParamsDecoder) DecodeRefresh(data []byte) (*RefreshRequest, error)

+ func (d *JSONParamsDecoder) DecodeSend(data []byte) (*SendRequest, error)

+ func (d *JSONParamsDecoder) DecodeSubRefresh(data []byte) (*SubRefreshRequest, error)

+ func (d *JSONParamsDecoder) DecodeSubscribe(data []byte) (*SubscribeRequest, error)

+ func (d *JSONParamsDecoder) DecodeUnsubscribe(data []byte) (*UnsubscribeRequest, error)

+ type JSONParamsEncoder struct

+ func NewJSONParamsEncoder() *JSONParamsEncoder

+ func (d *JSONParamsEncoder) Encode(r interface{}) ([]byte, error)

+ type JSONPushDecoder struct

+ func NewJSONPushDecoder() *JSONPushDecoder

+ func (e *JSONPushDecoder) Decode(data []byte) (*Push, error)

+ func (e *JSONPushDecoder) DecodeJoin(data []byte) (*Join, error)

+ func (e *JSONPushDecoder) DecodeLeave(data []byte) (*Leave, error)

+ func (e *JSONPushDecoder) DecodeMessage(data []byte) (*Message, error)

+ func (e *JSONPushDecoder) DecodePublication(data []byte) (*Publication, error)

+ func (e *JSONPushDecoder) DecodeSub(data []byte) (*Sub, error)

+ func (e *JSONPushDecoder) DecodeUnsub(data []byte) (*Unsub, error)

+ type JSONPushEncoder struct

+ func NewJSONPushEncoder() *JSONPushEncoder

+ func (e *JSONPushEncoder) Encode(message *Push) ([]byte, error)

+ func (e *JSONPushEncoder) EncodeJoin(message *Join) ([]byte, error)

+ func (e *JSONPushEncoder) EncodeLeave(message *Leave) ([]byte, error)

+ func (e *JSONPushEncoder) EncodeMessage(message *Message) ([]byte, error)

+ func (e *JSONPushEncoder) EncodePublication(message *Publication) ([]byte, error)

+ func (e *JSONPushEncoder) EncodeSub(message *Sub) ([]byte, error)

+ func (e *JSONPushEncoder) EncodeUnsub(message *Unsub) ([]byte, error)

+ type JSONReplyDecoder struct

+ func NewJSONReplyDecoder(data []byte) *JSONReplyDecoder

+ func (d *JSONReplyDecoder) Decode() (*Reply, error)

+ func (d *JSONReplyDecoder) Reset(data []byte) error

+ type JSONReplyEncoder struct

+ func NewJSONReplyEncoder() *JSONReplyEncoder

+ func (e *JSONReplyEncoder) Encode(r *Reply) error

+ func (e *JSONReplyEncoder) Finish() []byte

+ func (e *JSONReplyEncoder) Reset()

+ type JSONResultDecoder struct

+ func NewJSONResultDecoder() *JSONResultDecoder

+ func (e *JSONResultDecoder) Decode(data []byte, dest interface{}) error

+ type JSONResultEncoder struct

+ func NewJSONResultEncoder() *JSONResultEncoder

+ func (e *JSONResultEncoder) EncodeConnectResult(res *ConnectResult) ([]byte, error)

+ func (e *JSONResultEncoder) EncodeHistoryResult(res *HistoryResult) ([]byte, error)

+ func (e *JSONResultEncoder) EncodePingResult(res *PingResult) ([]byte, error)

+ func (e *JSONResultEncoder) EncodePresenceResult(res *PresenceResult) ([]byte, error)

+ func (e *JSONResultEncoder) EncodePresenceStatsResult(res *PresenceStatsResult) ([]byte, error)

+ func (e *JSONResultEncoder) EncodePublishResult(res *PublishResult) ([]byte, error)

+ func (e *JSONResultEncoder) EncodeRPCResult(res *RPCResult) ([]byte, error)

+ func (e *JSONResultEncoder) EncodeRefreshResult(res *RefreshResult) ([]byte, error)

+ func (e *JSONResultEncoder) EncodeSubRefreshResult(res *SubRefreshResult) ([]byte, error)

+ func (e *JSONResultEncoder) EncodeSubscribeResult(res *SubscribeResult) ([]byte, error)

+ func (e *JSONResultEncoder) EncodeUnsubscribeResult(res *UnsubscribeResult) ([]byte, error)

+ type Join struct

+ Info ClientInfo

+ func NewPopulatedJoin(r randyClient, easy bool) *Join

+ func (*Join) Descriptor() ([]byte, []int)

+ func (*Join) ProtoMessage()

+ func (m *Join) GetInfo() ClientInfo

+ func (m *Join) Marshal() (dAtA []byte, err error)

+ func (m *Join) MarshalTo(dAtA []byte) (int, error)

+ func (m *Join) Reset()

+ func (m *Join) Size() (n int)

+ func (m *Join) String() string

+ func (m *Join) Unmarshal(dAtA []byte) error

+ func (this *Join) Equal(that interface{}) bool

+ type Leave struct

+ Info ClientInfo

+ func NewPopulatedLeave(r randyClient, easy bool) *Leave

+ func (*Leave) Descriptor() ([]byte, []int)

+ func (*Leave) ProtoMessage()

+ func (m *Leave) GetInfo() ClientInfo

+ func (m *Leave) Marshal() (dAtA []byte, err error)

+ func (m *Leave) MarshalTo(dAtA []byte) (int, error)

+ func (m *Leave) Reset()

+ func (m *Leave) Size() (n int)

+ func (m *Leave) String() string

+ func (m *Leave) Unmarshal(dAtA []byte) error

+ func (this *Leave) Equal(that interface{}) bool

+ type Message struct

+ Data Raw

+ func NewPopulatedMessage(r randyClient, easy bool) *Message

+ func (*Message) Descriptor() ([]byte, []int)

+ func (*Message) ProtoMessage()

+ func (m *Message) Marshal() (dAtA []byte, err error)

+ func (m *Message) MarshalTo(dAtA []byte) (int, error)

+ func (m *Message) Reset()

+ func (m *Message) Size() (n int)

+ func (m *Message) String() string

+ func (m *Message) Unmarshal(dAtA []byte) error

+ func (this *Message) Equal(that interface{}) bool

+ type MethodType int32

+ const MethodTypeConnect

+ const MethodTypeHistory

+ const MethodTypePing

+ const MethodTypePresence

+ const MethodTypePresenceStats

+ const MethodTypePublish

+ const MethodTypeRPC

+ const MethodTypeRefresh

+ const MethodTypeSend

+ const MethodTypeSubRefresh

+ const MethodTypeSubscribe

+ const MethodTypeUnsubscribe

+ func (MethodType) EnumDescriptor() ([]byte, []int)

+ func (m *MethodType) UnmarshalJSON(data []byte) error

+ func (x MethodType) String() string

+ type ParamsDecoder interface

+ DecodeConnect func([]byte) (*ConnectRequest, error)

+ DecodeHistory func([]byte) (*HistoryRequest, error)

+ DecodePing func([]byte) (*PingRequest, error)

+ DecodePresence func([]byte) (*PresenceRequest, error)

+ DecodePresenceStats func([]byte) (*PresenceStatsRequest, error)

+ DecodePublish func([]byte) (*PublishRequest, error)

+ DecodeRPC func([]byte) (*RPCRequest, error)

+ DecodeRefresh func([]byte) (*RefreshRequest, error)

+ DecodeSend func([]byte) (*SendRequest, error)

+ DecodeSubRefresh func([]byte) (*SubRefreshRequest, error)

+ DecodeSubscribe func([]byte) (*SubscribeRequest, error)

+ DecodeUnsubscribe func([]byte) (*UnsubscribeRequest, error)

+ func GetParamsDecoder(protoType Type) ParamsDecoder

+ type ParamsEncoder interface

+ Encode func(request interface{}) ([]byte, error)

+ type PingRequest struct

+ func NewPopulatedPingRequest(r randyClient, easy bool) *PingRequest

+ func (*PingRequest) Descriptor() ([]byte, []int)

+ func (*PingRequest) ProtoMessage()

+ func (m *PingRequest) Marshal() (dAtA []byte, err error)

+ func (m *PingRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *PingRequest) Reset()

+ func (m *PingRequest) Size() (n int)

+ func (m *PingRequest) String() string

+ func (m *PingRequest) Unmarshal(dAtA []byte) error

+ func (this *PingRequest) Equal(that interface{}) bool

+ type PingResult struct

+ func NewPopulatedPingResult(r randyClient, easy bool) *PingResult

+ func (*PingResult) Descriptor() ([]byte, []int)

+ func (*PingResult) ProtoMessage()

+ func (m *PingResult) Marshal() (dAtA []byte, err error)

+ func (m *PingResult) MarshalTo(dAtA []byte) (int, error)

+ func (m *PingResult) Reset()

+ func (m *PingResult) Size() (n int)

+ func (m *PingResult) String() string

+ func (m *PingResult) Unmarshal(dAtA []byte) error

+ func (this *PingResult) Equal(that interface{}) bool

+ type PresenceRequest struct

+ Channel string

+ func NewPopulatedPresenceRequest(r randyClient, easy bool) *PresenceRequest

+ func (*PresenceRequest) Descriptor() ([]byte, []int)

+ func (*PresenceRequest) ProtoMessage()

+ func (m *PresenceRequest) GetChannel() string

+ func (m *PresenceRequest) Marshal() (dAtA []byte, err error)

+ func (m *PresenceRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *PresenceRequest) Reset()

+ func (m *PresenceRequest) Size() (n int)

+ func (m *PresenceRequest) String() string

+ func (m *PresenceRequest) Unmarshal(dAtA []byte) error

+ func (this *PresenceRequest) Equal(that interface{}) bool

+ type PresenceResult struct

+ Presence map[string]*ClientInfo

+ func NewPopulatedPresenceResult(r randyClient, easy bool) *PresenceResult

+ func (*PresenceResult) Descriptor() ([]byte, []int)

+ func (*PresenceResult) ProtoMessage()

+ func (m *PresenceResult) GetPresence() map[string]*ClientInfo

+ func (m *PresenceResult) Marshal() (dAtA []byte, err error)

+ func (m *PresenceResult) MarshalTo(dAtA []byte) (int, error)

+ func (m *PresenceResult) Reset()

+ func (m *PresenceResult) Size() (n int)

+ func (m *PresenceResult) String() string

+ func (m *PresenceResult) Unmarshal(dAtA []byte) error

+ func (this *PresenceResult) Equal(that interface{}) bool

+ type PresenceStatsRequest struct

+ Channel string

+ func NewPopulatedPresenceStatsRequest(r randyClient, easy bool) *PresenceStatsRequest

+ func (*PresenceStatsRequest) Descriptor() ([]byte, []int)

+ func (*PresenceStatsRequest) ProtoMessage()

+ func (m *PresenceStatsRequest) GetChannel() string

+ func (m *PresenceStatsRequest) Marshal() (dAtA []byte, err error)

+ func (m *PresenceStatsRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *PresenceStatsRequest) Reset()

+ func (m *PresenceStatsRequest) Size() (n int)

+ func (m *PresenceStatsRequest) String() string

+ func (m *PresenceStatsRequest) Unmarshal(dAtA []byte) error

+ func (this *PresenceStatsRequest) Equal(that interface{}) bool

+ type PresenceStatsResult struct

+ NumClients uint32

+ NumUsers uint32

+ func NewPopulatedPresenceStatsResult(r randyClient, easy bool) *PresenceStatsResult

+ func (*PresenceStatsResult) Descriptor() ([]byte, []int)

+ func (*PresenceStatsResult) ProtoMessage()

+ func (m *PresenceStatsResult) GetNumClients() uint32

+ func (m *PresenceStatsResult) GetNumUsers() uint32

+ func (m *PresenceStatsResult) Marshal() (dAtA []byte, err error)

+ func (m *PresenceStatsResult) MarshalTo(dAtA []byte) (int, error)

+ func (m *PresenceStatsResult) Reset()

+ func (m *PresenceStatsResult) Size() (n int)

+ func (m *PresenceStatsResult) String() string

+ func (m *PresenceStatsResult) Unmarshal(dAtA []byte) error

+ func (this *PresenceStatsResult) Equal(that interface{}) bool

+ type ProtobufCommandDecoder struct

+ func NewProtobufCommandDecoder(data []byte) *ProtobufCommandDecoder

+ func (d *ProtobufCommandDecoder) Decode() (*Command, error)

+ func (d *ProtobufCommandDecoder) Reset(data []byte) error

+ type ProtobufCommandEncoder struct

+ func NewProtobufCommandEncoder() *ProtobufCommandEncoder

+ func (e *ProtobufCommandEncoder) Encode(cmd *Command) ([]byte, error)

+ type ProtobufParamsDecoder struct

+ func NewProtobufParamsDecoder() *ProtobufParamsDecoder

+ func (d *ProtobufParamsDecoder) DecodeConnect(data []byte) (*ConnectRequest, error)

+ func (d *ProtobufParamsDecoder) DecodeHistory(data []byte) (*HistoryRequest, error)

+ func (d *ProtobufParamsDecoder) DecodePing(data []byte) (*PingRequest, error)

+ func (d *ProtobufParamsDecoder) DecodePresence(data []byte) (*PresenceRequest, error)

+ func (d *ProtobufParamsDecoder) DecodePresenceStats(data []byte) (*PresenceStatsRequest, error)

+ func (d *ProtobufParamsDecoder) DecodePublish(data []byte) (*PublishRequest, error)

+ func (d *ProtobufParamsDecoder) DecodeRPC(data []byte) (*RPCRequest, error)

+ func (d *ProtobufParamsDecoder) DecodeRefresh(data []byte) (*RefreshRequest, error)

+ func (d *ProtobufParamsDecoder) DecodeSend(data []byte) (*SendRequest, error)

+ func (d *ProtobufParamsDecoder) DecodeSubRefresh(data []byte) (*SubRefreshRequest, error)

+ func (d *ProtobufParamsDecoder) DecodeSubscribe(data []byte) (*SubscribeRequest, error)

+ func (d *ProtobufParamsDecoder) DecodeUnsubscribe(data []byte) (*UnsubscribeRequest, error)

+ type ProtobufParamsEncoder struct

+ func NewProtobufParamsEncoder() *ProtobufParamsEncoder

+ func (d *ProtobufParamsEncoder) Encode(r interface{}) ([]byte, error)

+ type ProtobufPushDecoder struct

+ func NewProtobufPushDecoder() *ProtobufPushDecoder

+ func (e *ProtobufPushDecoder) Decode(data []byte) (*Push, error)

+ func (e *ProtobufPushDecoder) DecodeJoin(data []byte) (*Join, error)

+ func (e *ProtobufPushDecoder) DecodeLeave(data []byte) (*Leave, error)

+ func (e *ProtobufPushDecoder) DecodeMessage(data []byte) (*Message, error)

+ func (e *ProtobufPushDecoder) DecodePublication(data []byte) (*Publication, error)

+ func (e *ProtobufPushDecoder) DecodeSub(data []byte) (*Sub, error)

+ func (e *ProtobufPushDecoder) DecodeUnsub(data []byte) (*Unsub, error)

+ type ProtobufPushEncoder struct

+ func NewProtobufPushEncoder() *ProtobufPushEncoder

+ func (e *ProtobufPushEncoder) Encode(message *Push) ([]byte, error)

+ func (e *ProtobufPushEncoder) EncodeJoin(message *Join) ([]byte, error)

+ func (e *ProtobufPushEncoder) EncodeLeave(message *Leave) ([]byte, error)

+ func (e *ProtobufPushEncoder) EncodeMessage(message *Message) ([]byte, error)

+ func (e *ProtobufPushEncoder) EncodePublication(message *Publication) ([]byte, error)

+ func (e *ProtobufPushEncoder) EncodeSub(message *Sub) ([]byte, error)

+ func (e *ProtobufPushEncoder) EncodeUnsub(message *Unsub) ([]byte, error)

+ type ProtobufReplyDecoder struct

+ func NewProtobufReplyDecoder(data []byte) *ProtobufReplyDecoder

+ func (d *ProtobufReplyDecoder) Decode() (*Reply, error)

+ func (d *ProtobufReplyDecoder) Reset(data []byte) error

+ type ProtobufReplyEncoder struct

+ func NewProtobufReplyEncoder() *ProtobufReplyEncoder

+ func (e *ProtobufReplyEncoder) Encode(r *Reply) error

+ func (e *ProtobufReplyEncoder) Finish() []byte

+ func (e *ProtobufReplyEncoder) Reset()

+ type ProtobufResultDecoder struct

+ func NewProtobufResultDecoder() *ProtobufResultDecoder

+ func (e *ProtobufResultDecoder) Decode(data []byte, dest interface{}) error

+ type ProtobufResultEncoder struct

+ func NewProtobufResultEncoder() *ProtobufResultEncoder

+ func (e *ProtobufResultEncoder) EncodeConnectResult(res *ConnectResult) ([]byte, error)

+ func (e *ProtobufResultEncoder) EncodeHistoryResult(res *HistoryResult) ([]byte, error)

+ func (e *ProtobufResultEncoder) EncodePingResult(res *PingResult) ([]byte, error)

+ func (e *ProtobufResultEncoder) EncodePresenceResult(res *PresenceResult) ([]byte, error)

+ func (e *ProtobufResultEncoder) EncodePresenceStatsResult(res *PresenceStatsResult) ([]byte, error)

+ func (e *ProtobufResultEncoder) EncodePublishResult(res *PublishResult) ([]byte, error)

+ func (e *ProtobufResultEncoder) EncodeRPCResult(res *RPCResult) ([]byte, error)

+ func (e *ProtobufResultEncoder) EncodeRefreshResult(res *RefreshResult) ([]byte, error)

+ func (e *ProtobufResultEncoder) EncodeSubRefreshResult(res *SubRefreshResult) ([]byte, error)

+ func (e *ProtobufResultEncoder) EncodeSubscribeResult(res *SubscribeResult) ([]byte, error)

+ func (e *ProtobufResultEncoder) EncodeUnsubscribeResult(res *UnsubscribeResult) ([]byte, error)

+ type Publication struct

+ Data Raw

+ Gen uint32

+ Info *ClientInfo

+ Offset uint64

+ Seq uint32

+ UID string

+ func NewPopulatedPublication(r randyClient, easy bool) *Publication

+ func (*Publication) Descriptor() ([]byte, []int)

+ func (*Publication) ProtoMessage()

+ func (m *Publication) GetGen() uint32

+ func (m *Publication) GetInfo() *ClientInfo

+ func (m *Publication) GetOffset() uint64

+ func (m *Publication) GetSeq() uint32

+ func (m *Publication) GetUID() string

+ func (m *Publication) Marshal() (dAtA []byte, err error)

+ func (m *Publication) MarshalTo(dAtA []byte) (int, error)

+ func (m *Publication) Reset()

+ func (m *Publication) Size() (n int)

+ func (m *Publication) String() string

+ func (m *Publication) Unmarshal(dAtA []byte) error

+ func (this *Publication) Equal(that interface{}) bool

+ type PublishRequest struct

+ Channel string

+ Data Raw

+ func NewPopulatedPublishRequest(r randyClient, easy bool) *PublishRequest

+ func (*PublishRequest) Descriptor() ([]byte, []int)

+ func (*PublishRequest) ProtoMessage()

+ func (m *PublishRequest) GetChannel() string

+ func (m *PublishRequest) Marshal() (dAtA []byte, err error)

+ func (m *PublishRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *PublishRequest) Reset()

+ func (m *PublishRequest) Size() (n int)

+ func (m *PublishRequest) String() string

+ func (m *PublishRequest) Unmarshal(dAtA []byte) error

+ func (this *PublishRequest) Equal(that interface{}) bool

+ type PublishResult struct

+ func NewPopulatedPublishResult(r randyClient, easy bool) *PublishResult

+ func (*PublishResult) Descriptor() ([]byte, []int)

+ func (*PublishResult) ProtoMessage()

+ func (m *PublishResult) Marshal() (dAtA []byte, err error)

+ func (m *PublishResult) MarshalTo(dAtA []byte) (int, error)

+ func (m *PublishResult) Reset()

+ func (m *PublishResult) Size() (n int)

+ func (m *PublishResult) String() string

+ func (m *PublishResult) Unmarshal(dAtA []byte) error

+ func (this *PublishResult) Equal(that interface{}) bool

+ type Push struct

+ Channel string

+ Data Raw

+ Type PushType

+ func NewPopulatedPush(r randyClient, easy bool) *Push

+ func (*Push) Descriptor() ([]byte, []int)

+ func (*Push) ProtoMessage()

+ func (m *Push) GetChannel() string

+ func (m *Push) GetType() PushType

+ func (m *Push) Marshal() (dAtA []byte, err error)

+ func (m *Push) MarshalTo(dAtA []byte) (int, error)

+ func (m *Push) Reset()

+ func (m *Push) Size() (n int)

+ func (m *Push) String() string

+ func (m *Push) Unmarshal(dAtA []byte) error

+ func (this *Push) Equal(that interface{}) bool

+ type PushDecoder interface

+ Decode func([]byte) (*Push, error)

+ DecodeJoin func([]byte) (*Join, error)

+ DecodeLeave func([]byte) (*Leave, error)

+ DecodeMessage func([]byte) (*Message, error)

+ DecodePublication func([]byte) (*Publication, error)

+ DecodeSub func([]byte) (*Sub, error)

+ DecodeUnsub func([]byte) (*Unsub, error)

+ type PushEncoder interface

+ Encode func(*Push) ([]byte, error)

+ EncodeJoin func(*Join) ([]byte, error)

+ EncodeLeave func(*Leave) ([]byte, error)

+ EncodeMessage func(*Message) ([]byte, error)

+ EncodePublication func(*Publication) ([]byte, error)

+ EncodeSub func(*Sub) ([]byte, error)

+ EncodeUnsub func(*Unsub) ([]byte, error)

+ func GetPushEncoder(protoType Type) PushEncoder

+ type PushType int32

+ const PushTypeJoin

+ const PushTypeLeave

+ const PushTypeMessage

+ const PushTypePublication

+ const PushTypeSub

+ const PushTypeUnsub

+ func (PushType) EnumDescriptor() ([]byte, []int)

+ func (x PushType) String() string

+ type RPCRequest struct

+ Data Raw

+ func NewPopulatedRPCRequest(r randyClient, easy bool) *RPCRequest

+ func (*RPCRequest) Descriptor() ([]byte, []int)

+ func (*RPCRequest) ProtoMessage()

+ func (m *RPCRequest) Marshal() (dAtA []byte, err error)

+ func (m *RPCRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *RPCRequest) Reset()

+ func (m *RPCRequest) Size() (n int)

+ func (m *RPCRequest) String() string

+ func (m *RPCRequest) Unmarshal(dAtA []byte) error

+ func (this *RPCRequest) Equal(that interface{}) bool

+ type RPCResult struct

+ Data Raw

+ func NewPopulatedRPCResult(r randyClient, easy bool) *RPCResult

+ func (*RPCResult) Descriptor() ([]byte, []int)

+ func (*RPCResult) ProtoMessage()

+ func (m *RPCResult) Marshal() (dAtA []byte, err error)

+ func (m *RPCResult) MarshalTo(dAtA []byte) (int, error)

+ func (m *RPCResult) Reset()

+ func (m *RPCResult) Size() (n int)

+ func (m *RPCResult) String() string

+ func (m *RPCResult) Unmarshal(dAtA []byte) error

+ func (this *RPCResult) Equal(that interface{}) bool

+ type Raw []byte

+ func NewPopulatedRaw(r intn) *Raw

+ func (r *Raw) Size() int

+ func (r *Raw) Unmarshal(data []byte) error

+ func (r *Raw) UnmarshalJSON(data []byte) error

+ func (r Raw) Compare(other Raw) int

+ func (r Raw) Equal(other Raw) bool

+ func (r Raw) Marshal() ([]byte, error)

+ func (r Raw) MarshalJSON() ([]byte, error)

+ func (r Raw) MarshalTo(data []byte) (n int, err error)

+ type RefreshRequest struct

+ Token string

+ func NewPopulatedRefreshRequest(r randyClient, easy bool) *RefreshRequest

+ func (*RefreshRequest) Descriptor() ([]byte, []int)

+ func (*RefreshRequest) ProtoMessage()

+ func (m *RefreshRequest) GetToken() string

+ func (m *RefreshRequest) Marshal() (dAtA []byte, err error)

+ func (m *RefreshRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *RefreshRequest) Reset()

+ func (m *RefreshRequest) Size() (n int)

+ func (m *RefreshRequest) String() string

+ func (m *RefreshRequest) Unmarshal(dAtA []byte) error

+ func (this *RefreshRequest) Equal(that interface{}) bool

+ type RefreshResult struct

+ Client string

+ Expires bool

+ TTL uint32

+ Version string

+ func NewPopulatedRefreshResult(r randyClient, easy bool) *RefreshResult

+ func (*RefreshResult) Descriptor() ([]byte, []int)

+ func (*RefreshResult) ProtoMessage()

+ func (m *RefreshResult) GetClient() string

+ func (m *RefreshResult) GetExpires() bool

+ func (m *RefreshResult) GetTTL() uint32

+ func (m *RefreshResult) GetVersion() string

+ func (m *RefreshResult) Marshal() (dAtA []byte, err error)

+ func (m *RefreshResult) MarshalTo(dAtA []byte) (int, error)

+ func (m *RefreshResult) Reset()

+ func (m *RefreshResult) Size() (n int)

+ func (m *RefreshResult) String() string

+ func (m *RefreshResult) Unmarshal(dAtA []byte) error

+ func (this *RefreshResult) Equal(that interface{}) bool

+ type Reply struct

+ Error *Error

+ ID uint32

+ Result Raw

+ func NewPopulatedReply(r randyClient, easy bool) *Reply

+ func (*Reply) Descriptor() ([]byte, []int)

+ func (*Reply) ProtoMessage()

+ func (m *Reply) GetError() *Error

+ func (m *Reply) GetID() uint32

+ func (m *Reply) Marshal() (dAtA []byte, err error)

+ func (m *Reply) MarshalTo(dAtA []byte) (int, error)

+ func (m *Reply) Reset()

+ func (m *Reply) Size() (n int)

+ func (m *Reply) String() string

+ func (m *Reply) Unmarshal(dAtA []byte) error

+ func (this *Reply) Equal(that interface{}) bool

+ type ReplyDecoder interface

+ Decode func() (*Reply, error)

+ Reset func([]byte) error

+ type ReplyEncoder interface

+ Encode func(*Reply) error

+ Finish func() []byte

+ Reset func()

+ func GetReplyEncoder(protoType Type) ReplyEncoder

+ type ResultDecoder interface

+ Decode func([]byte, interface{}) error

+ type ResultEncoder interface

+ EncodeConnectResult func(*ConnectResult) ([]byte, error)

+ EncodeHistoryResult func(*HistoryResult) ([]byte, error)

+ EncodePingResult func(*PingResult) ([]byte, error)

+ EncodePresenceResult func(*PresenceResult) ([]byte, error)

+ EncodePresenceStatsResult func(*PresenceStatsResult) ([]byte, error)

+ EncodePublishResult func(*PublishResult) ([]byte, error)

+ EncodeRPCResult func(*RPCResult) ([]byte, error)

+ EncodeRefreshResult func(*RefreshResult) ([]byte, error)

+ EncodeSubRefreshResult func(*SubRefreshResult) ([]byte, error)

+ EncodeSubscribeResult func(*SubscribeResult) ([]byte, error)

+ EncodeUnsubscribeResult func(*UnsubscribeResult) ([]byte, error)

+ func GetResultEncoder(protoType Type) ResultEncoder

+ type SendRequest struct

+ Data Raw

+ func NewPopulatedSendRequest(r randyClient, easy bool) *SendRequest

+ func (*SendRequest) Descriptor() ([]byte, []int)

+ func (*SendRequest) ProtoMessage()

+ func (m *SendRequest) Marshal() (dAtA []byte, err error)

+ func (m *SendRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *SendRequest) Reset()

+ func (m *SendRequest) Size() (n int)

+ func (m *SendRequest) String() string

+ func (m *SendRequest) Unmarshal(dAtA []byte) error

+ func (this *SendRequest) Equal(that interface{}) bool

+ type Sub struct

+ Epoch string

+ Gen uint32

+ Offset uint64

+ Recoverable bool

+ Seq uint32

+ func NewPopulatedSub(r randyClient, easy bool) *Sub

+ func (*Sub) Descriptor() ([]byte, []int)

+ func (*Sub) ProtoMessage()

+ func (m *Sub) GetEpoch() string

+ func (m *Sub) GetGen() uint32

+ func (m *Sub) GetOffset() uint64

+ func (m *Sub) GetRecoverable() bool

+ func (m *Sub) GetSeq() uint32

+ func (m *Sub) Marshal() (dAtA []byte, err error)

+ func (m *Sub) MarshalTo(dAtA []byte) (int, error)

+ func (m *Sub) Reset()

+ func (m *Sub) Size() (n int)

+ func (m *Sub) String() string

+ func (m *Sub) Unmarshal(dAtA []byte) error

+ func (this *Sub) Equal(that interface{}) bool

+ type SubRefreshRequest struct

+ Channel string

+ Token string

+ func NewPopulatedSubRefreshRequest(r randyClient, easy bool) *SubRefreshRequest

+ func (*SubRefreshRequest) Descriptor() ([]byte, []int)

+ func (*SubRefreshRequest) ProtoMessage()

+ func (m *SubRefreshRequest) GetChannel() string

+ func (m *SubRefreshRequest) GetToken() string

+ func (m *SubRefreshRequest) Marshal() (dAtA []byte, err error)

+ func (m *SubRefreshRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *SubRefreshRequest) Reset()

+ func (m *SubRefreshRequest) Size() (n int)

+ func (m *SubRefreshRequest) String() string

+ func (m *SubRefreshRequest) Unmarshal(dAtA []byte) error

+ func (this *SubRefreshRequest) Equal(that interface{}) bool

+ type SubRefreshResult struct

+ Expires bool

+ TTL uint32

+ func NewPopulatedSubRefreshResult(r randyClient, easy bool) *SubRefreshResult

+ func (*SubRefreshResult) Descriptor() ([]byte, []int)

+ func (*SubRefreshResult) ProtoMessage()

+ func (m *SubRefreshResult) GetExpires() bool

+ func (m *SubRefreshResult) GetTTL() uint32

+ func (m *SubRefreshResult) Marshal() (dAtA []byte, err error)

+ func (m *SubRefreshResult) MarshalTo(dAtA []byte) (int, error)

+ func (m *SubRefreshResult) Reset()

+ func (m *SubRefreshResult) Size() (n int)

+ func (m *SubRefreshResult) String() string

+ func (m *SubRefreshResult) Unmarshal(dAtA []byte) error

+ func (this *SubRefreshResult) Equal(that interface{}) bool

+ type SubscribeRequest struct

+ Channel string

+ Epoch string

+ Gen uint32

+ Offset uint64

+ Recover bool

+ Seq uint32

+ Token string

+ func NewPopulatedSubscribeRequest(r randyClient, easy bool) *SubscribeRequest

+ func (*SubscribeRequest) Descriptor() ([]byte, []int)

+ func (*SubscribeRequest) ProtoMessage()

+ func (m *SubscribeRequest) GetChannel() string

+ func (m *SubscribeRequest) GetEpoch() string

+ func (m *SubscribeRequest) GetGen() uint32

+ func (m *SubscribeRequest) GetOffset() uint64

+ func (m *SubscribeRequest) GetRecover() bool

+ func (m *SubscribeRequest) GetSeq() uint32

+ func (m *SubscribeRequest) GetToken() string

+ func (m *SubscribeRequest) Marshal() (dAtA []byte, err error)

+ func (m *SubscribeRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *SubscribeRequest) Reset()

+ func (m *SubscribeRequest) Size() (n int)

+ func (m *SubscribeRequest) String() string

+ func (m *SubscribeRequest) Unmarshal(dAtA []byte) error

+ func (this *SubscribeRequest) Equal(that interface{}) bool

+ type SubscribeResult struct

+ Epoch string

+ Expires bool

+ Gen uint32

+ Offset uint64

+ Publications []*Publication

+ Recoverable bool

+ Recovered bool

+ Seq uint32

+ TTL uint32

+ func NewPopulatedSubscribeResult(r randyClient, easy bool) *SubscribeResult

+ func (*SubscribeResult) Descriptor() ([]byte, []int)

+ func (*SubscribeResult) ProtoMessage()

+ func (m *SubscribeResult) GetEpoch() string

+ func (m *SubscribeResult) GetExpires() bool

+ func (m *SubscribeResult) GetGen() uint32

+ func (m *SubscribeResult) GetOffset() uint64

+ func (m *SubscribeResult) GetPublications() []*Publication

+ func (m *SubscribeResult) GetRecoverable() bool

+ func (m *SubscribeResult) GetRecovered() bool

+ func (m *SubscribeResult) GetSeq() uint32

+ func (m *SubscribeResult) GetTTL() uint32

+ func (m *SubscribeResult) Marshal() (dAtA []byte, err error)

+ func (m *SubscribeResult) MarshalTo(dAtA []byte) (int, error)

+ func (m *SubscribeResult) Reset()

+ func (m *SubscribeResult) Size() (n int)

+ func (m *SubscribeResult) String() string

+ func (m *SubscribeResult) Unmarshal(dAtA []byte) error

+ func (this *SubscribeResult) Equal(that interface{}) bool

+ type Type string

+ const TypeJSON

+ const TypeProtobuf

+ type Unsub struct

+ Resubscribe bool

+ func NewPopulatedUnsub(r randyClient, easy bool) *Unsub

+ func (*Unsub) Descriptor() ([]byte, []int)

+ func (*Unsub) ProtoMessage()

+ func (m *Unsub) GetResubscribe() bool

+ func (m *Unsub) Marshal() (dAtA []byte, err error)

+ func (m *Unsub) MarshalTo(dAtA []byte) (int, error)

+ func (m *Unsub) Reset()

+ func (m *Unsub) Size() (n int)

+ func (m *Unsub) String() string

+ func (m *Unsub) Unmarshal(dAtA []byte) error

+ func (this *Unsub) Equal(that interface{}) bool

+ type UnsubscribeRequest struct

+ Channel string

+ func NewPopulatedUnsubscribeRequest(r randyClient, easy bool) *UnsubscribeRequest

+ func (*UnsubscribeRequest) Descriptor() ([]byte, []int)

+ func (*UnsubscribeRequest) ProtoMessage()

+ func (m *UnsubscribeRequest) GetChannel() string

+ func (m *UnsubscribeRequest) Marshal() (dAtA []byte, err error)

+ func (m *UnsubscribeRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *UnsubscribeRequest) Reset()

+ func (m *UnsubscribeRequest) Size() (n int)

+ func (m *UnsubscribeRequest) String() string

+ func (m *UnsubscribeRequest) Unmarshal(dAtA []byte) error

+ func (this *UnsubscribeRequest) Equal(that interface{}) bool

+ type UnsubscribeResult struct

+ func NewPopulatedUnsubscribeResult(r randyClient, easy bool) *UnsubscribeResult

+ func (*UnsubscribeResult) Descriptor() ([]byte, []int)

+ func (*UnsubscribeResult) ProtoMessage()

+ func (m *UnsubscribeResult) Marshal() (dAtA []byte, err error)

+ func (m *UnsubscribeResult) MarshalTo(dAtA []byte) (int, error)

+ func (m *UnsubscribeResult) Reset()

+ func (m *UnsubscribeResult) Size() (n int)

+ func (m *UnsubscribeResult) String() string

+ func (m *UnsubscribeResult) Unmarshal(dAtA []byte) error

+ func (this *UnsubscribeResult) Equal(that interface{}) bool