protocol

package module

Go to main page

Versions in this module

v0

v0.16.0

Feb 9, 2025

v0.15.0

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()

v0.14.0

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

v0.13.4

Jul 2, 2024

Changes in this version

type Publication

+ Channel string

+ func (x *Publication) GetChannel() string

v0.13.3

May 26, 2024

Changes in this version

type Publication

+ Time int64

+ func (x *Publication) GetTime() int64

v0.13.2

May 20, 2024

v0.13.1

May 20, 2024

Changes in this version

type Connect

+ Time int64

+ func (x *Connect) GetTime() int64

v0.13.0

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

v0.12.1

Apr 1, 2024

v0.12.0

Feb 3, 2024

v0.11.0

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

v0.10.0

Mar 25, 2023

v0.9.1

Jan 11, 2023

v0.9.0

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)

v0.8.11

Sep 1, 2022

v0.8.10

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)

v0.8.9

Jul 1, 2022

Changes in this version

type SubscribeRequest

+ JoinLeave bool

+ func (x *SubscribeRequest) GetJoinLeave() bool

v0.8.8

Jun 27, 2022

v0.8.7

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

v0.8.6

Apr 25, 2022

v0.8.5

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

v0.8.4

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

v0.8.3

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

v0.8.2

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

v0.8.1

Jan 24, 2022

Changes in this version

type Publication

+ Tags map[string]string

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

v0.8.0

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

v0.7.6

Dec 2, 2021

Changes in this version

type SubscribeRequest

+ Data Raw

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

v0.7.5

Dec 1, 2021

v0.7.4

Dec 1, 2021

v0.7.3

Sep 11, 2021

v0.7.2

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)

v0.7.1

Aug 28, 2021

Changes in this version

type HistoryRequest

+ Reverse bool

+ func (x *HistoryRequest) GetReverse() bool

v0.7.0

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

v0.6.0

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)

v0.5.0

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

v0.4.2

Mar 19, 2021

v0.4.1

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

v0.4.0

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

v0.3.6

Feb 23, 2021

v0.3.5

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

v0.3.4

Aug 13, 2020

Changes in this version

type ConnectRequest

+ Name string

+ Version string

+ func (m *ConnectRequest) GetName() string

+ func (m *ConnectRequest) GetVersion() string

v0.3.3

May 4, 2020

Changes in this version

type RPCRequest

+ Method string

+ func (m *RPCRequest) GetMethod() string

v0.3.2

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

v0.3.1

Apr 26, 2020

v0.3.0

Apr 21, 2020

v0.2.0

Feb 17, 2020

v0.1.0

Dec 10, 2019

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