Versions in this module Expand all Collapse all v0 v0.0.1 Jan 5, 2026 Changes in this version + var DefaultJsonPushEncoder = NewJSONPushEncoder() + var DefaultJsonReplyEncoder = NewJSONReplyEncoder() + var DefaultProtobufPushEncoder = NewProtobufPushEncoder() + var DefaultProtobufReplyEncoder = NewProtobufReplyEncoder() + var ErrMessageTooLarge = errors.New("message size exceeds the limit") + var File_client_proto protoreflect.FileDescriptor + var ReplyPool = &ReplyPoolCollection + func PutCommandDecoder(protoType Type, e CommandDecoder) + func PutDataEncoder(protoType Type, e DataEncoder) + func PutResultEncoder(_ Type, _ ReplyEncoder) + func PutStreamCommandDecoder(protoType Type, e StreamCommandDecoder) + type ByteBuffer struct + B []byte + func (bb *ByteBuffer) Reset() + func (bb *ByteBuffer) Write(p []byte) (int, error) + type ClientInfo struct + ChanInfo Raw + Client string + ConnInfo Raw + User string + func (*ClientInfo) Descriptor() ([]byte, []int) + func (*ClientInfo) ProtoMessage() + 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 (v *ClientInfo) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v ClientInfo) MarshalEasyJSON(w *writer) + func (x *ClientInfo) GetChanInfo() []byte + func (x *ClientInfo) GetClient() string + func (x *ClientInfo) GetConnInfo() []byte + func (x *ClientInfo) GetUser() string + func (x *ClientInfo) ProtoReflect() protoreflect.Message + func (x *ClientInfo) Reset() + func (x *ClientInfo) String() string + type Command struct + Connect *ConnectRequest + History *HistoryRequest + Id uint32 + Ping *PingRequest + Presence *PresenceRequest + PresenceStats *PresenceStatsRequest + Publish *PublishRequest + Refresh *RefreshRequest + Rpc *RPCRequest + Send *SendRequest + SubRefresh *SubRefreshRequest + Subscribe *SubscribeRequest + Unsubscribe *UnsubscribeRequest + func (*Command) Descriptor() ([]byte, []int) + func (*Command) ProtoMessage() + 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 (v *Command) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v Command) MarshalEasyJSON(w *writer) + func (x *Command) GetConnect() *ConnectRequest + func (x *Command) GetHistory() *HistoryRequest + func (x *Command) GetId() uint32 + 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 + func (x *Command) ProtoReflect() protoreflect.Message + func (x *Command) Reset() + func (x *Command) String() string + 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 Connect struct + Client string + Data Raw + Expires bool + Node string + Ping uint32 + Pong bool + Session string + Subs map[string]*SubscribeResult + Time int64 + Ttl uint32 + Version string + func (*Connect) Descriptor() ([]byte, []int) + func (*Connect) ProtoMessage() + 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 (v *Connect) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v Connect) MarshalEasyJSON(w *writer) + func (x *Connect) GetClient() string + func (x *Connect) GetData() []byte + func (x *Connect) GetExpires() bool + func (x *Connect) GetNode() string + func (x *Connect) GetPing() uint32 + func (x *Connect) GetPong() bool + func (x *Connect) GetSession() string + func (x *Connect) GetSubs() map[string]*SubscribeResult + func (x *Connect) GetTime() int64 + func (x *Connect) GetTtl() uint32 + func (x *Connect) GetVersion() string + func (x *Connect) ProtoReflect() protoreflect.Message + func (x *Connect) Reset() + func (x *Connect) String() string + type ConnectRequest struct + Data Raw + Headers map[string]string + Name string + Subs map[string]*SubscribeRequest + Token string + Version string + func (*ConnectRequest) Descriptor() ([]byte, []int) + func (*ConnectRequest) ProtoMessage() + 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 (v *ConnectRequest) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v ConnectRequest) MarshalEasyJSON(w *writer) + func (x *ConnectRequest) GetData() []byte + func (x *ConnectRequest) GetHeaders() map[string]string + func (x *ConnectRequest) GetName() string + func (x *ConnectRequest) GetSubs() map[string]*SubscribeRequest + func (x *ConnectRequest) GetToken() string + func (x *ConnectRequest) GetVersion() string + func (x *ConnectRequest) ProtoReflect() protoreflect.Message + func (x *ConnectRequest) Reset() + func (x *ConnectRequest) String() string + type ConnectResult struct + Client string + Data Raw + Expires bool + Node string + Ping uint32 + Pong bool + Session string + Subs map[string]*SubscribeResult + Time int64 + Ttl uint32 + Version string + func (*ConnectResult) Descriptor() ([]byte, []int) + func (*ConnectResult) ProtoMessage() + 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 (v *ConnectResult) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v ConnectResult) MarshalEasyJSON(w *writer) + func (x *ConnectResult) GetClient() string + func (x *ConnectResult) GetData() []byte + func (x *ConnectResult) GetExpires() bool + func (x *ConnectResult) GetNode() string + func (x *ConnectResult) GetPing() uint32 + func (x *ConnectResult) GetPong() bool + func (x *ConnectResult) GetSession() string + func (x *ConnectResult) GetSubs() map[string]*SubscribeResult + func (x *ConnectResult) GetTime() int64 + func (x *ConnectResult) GetTtl() uint32 + func (x *ConnectResult) GetVersion() string + func (x *ConnectResult) ProtoReflect() protoreflect.Message + func (x *ConnectResult) Reset() + func (x *ConnectResult) String() string + 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 (*Disconnect) Descriptor() ([]byte, []int) + func (*Disconnect) ProtoMessage() + 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 (v *Disconnect) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v Disconnect) MarshalEasyJSON(w *writer) + func (x *Disconnect) GetCode() uint32 + func (x *Disconnect) GetReason() string + func (x *Disconnect) GetReconnect() bool + func (x *Disconnect) ProtoReflect() protoreflect.Message + func (x *Disconnect) Reset() + func (x *Disconnect) String() 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 struct + Code uint32 + Message string + Temporary bool + func (*Error) Descriptor() ([]byte, []int) + func (*Error) ProtoMessage() + 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 (v *Error) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v Error) MarshalEasyJSON(w *writer) + func (x *Error) GetCode() uint32 + func (x *Error) GetMessage() string + func (x *Error) GetTemporary() bool + func (x *Error) ProtoReflect() protoreflect.Message + func (x *Error) Reset() + func (x *Error) String() string + 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 + type HistoryRequest struct + Channel string + Limit int32 + Reverse bool + Since *StreamPosition + func (*HistoryRequest) Descriptor() ([]byte, []int) + func (*HistoryRequest) ProtoMessage() + 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 (v *HistoryRequest) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v HistoryRequest) MarshalEasyJSON(w *writer) + func (x *HistoryRequest) GetChannel() string + func (x *HistoryRequest) GetLimit() int32 + func (x *HistoryRequest) GetReverse() bool + func (x *HistoryRequest) GetSince() *StreamPosition + func (x *HistoryRequest) ProtoReflect() protoreflect.Message + func (x *HistoryRequest) Reset() + func (x *HistoryRequest) String() string + type HistoryResult struct + Epoch string + Offset uint64 + Publications []*Publication + func (*HistoryResult) Descriptor() ([]byte, []int) + func (*HistoryResult) ProtoMessage() + 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 (v *HistoryResult) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v HistoryResult) MarshalEasyJSON(w *writer) + func (x *HistoryResult) GetEpoch() string + func (x *HistoryResult) GetOffset() uint64 + func (x *HistoryResult) GetPublications() []*Publication + func (x *HistoryResult) ProtoReflect() protoreflect.Message + func (x *HistoryResult) Reset() + func (x *HistoryResult) String() string + 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 JSONDataEncoder struct + func NewJSONDataEncoder() *JSONDataEncoder + func (e *JSONDataEncoder) Encode(data []byte) error + func (e *JSONDataEncoder) Finish() []byte + func (e *JSONDataEncoder) Reset() + type JSONPushEncoder struct + func NewJSONPushEncoder() *JSONPushEncoder + func (e *JSONPushEncoder) Encode(message *Push) ([]byte, error) + func (e *JSONPushEncoder) EncodeConnect(message *Connect, reuse ...[]byte) ([]byte, error) + func (e *JSONPushEncoder) EncodeDisconnect(message *Disconnect, reuse ...[]byte) ([]byte, error) + func (e *JSONPushEncoder) EncodeJoin(message *Join, reuse ...[]byte) ([]byte, error) + func (e *JSONPushEncoder) EncodeLeave(message *Leave, reuse ...[]byte) ([]byte, error) + func (e *JSONPushEncoder) EncodeMessage(message *Message, reuse ...[]byte) ([]byte, error) + func (e *JSONPushEncoder) EncodePublication(message *Publication, reuse ...[]byte) ([]byte, error) + func (e *JSONPushEncoder) EncodeRefresh(message *Refresh, reuse ...[]byte) ([]byte, error) + func (e *JSONPushEncoder) EncodeSubscribe(message *Subscribe, reuse ...[]byte) ([]byte, error) + func (e *JSONPushEncoder) EncodeUnsubscribe(message *Unsubscribe, reuse ...[]byte) ([]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) ([]byte, 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 JSONStreamCommandDecoder struct + func NewJSONStreamCommandDecoder(reader io.Reader, messageSizeLimit int64) *JSONStreamCommandDecoder + func (d *JSONStreamCommandDecoder) Decode() (*Command, int, error) + func (d *JSONStreamCommandDecoder) Reset(reader io.Reader, messageSizeLimit int64) + type Join struct + Info *ClientInfo + func (*Join) Descriptor() ([]byte, []int) + func (*Join) ProtoMessage() + 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 (v *Join) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v Join) MarshalEasyJSON(w *writer) + func (x *Join) GetInfo() *ClientInfo + func (x *Join) ProtoReflect() protoreflect.Message + func (x *Join) Reset() + func (x *Join) String() string + type Leave struct + Info *ClientInfo + func (*Leave) Descriptor() ([]byte, []int) + func (*Leave) ProtoMessage() + 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 (v *Leave) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v Leave) MarshalEasyJSON(w *writer) + func (x *Leave) GetInfo() *ClientInfo + func (x *Leave) ProtoReflect() protoreflect.Message + func (x *Leave) Reset() + func (x *Leave) String() string + type Message struct + Data Raw + func (*Message) Descriptor() ([]byte, []int) + func (*Message) ProtoMessage() + 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 (v *Message) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v Message) MarshalEasyJSON(w *writer) + func (x *Message) GetData() []byte + func (x *Message) ProtoReflect() protoreflect.Message + func (x *Message) Reset() + func (x *Message) String() string + type PingRequest struct + func (*PingRequest) Descriptor() ([]byte, []int) + func (*PingRequest) ProtoMessage() + 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 (v *PingRequest) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v PingRequest) MarshalEasyJSON(w *writer) + func (x *PingRequest) ProtoReflect() protoreflect.Message + func (x *PingRequest) Reset() + func (x *PingRequest) String() string + type PingResult struct + func (*PingResult) Descriptor() ([]byte, []int) + func (*PingResult) ProtoMessage() + 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 (v *PingResult) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v PingResult) MarshalEasyJSON(w *writer) + func (x *PingResult) ProtoReflect() protoreflect.Message + func (x *PingResult) Reset() + func (x *PingResult) String() string + type PresenceRequest struct + Channel string + func (*PresenceRequest) Descriptor() ([]byte, []int) + func (*PresenceRequest) ProtoMessage() + 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 (v *PresenceRequest) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v PresenceRequest) MarshalEasyJSON(w *writer) + func (x *PresenceRequest) GetChannel() string + func (x *PresenceRequest) ProtoReflect() protoreflect.Message + func (x *PresenceRequest) Reset() + func (x *PresenceRequest) String() string + type PresenceResult struct + Presence map[string]*ClientInfo + func (*PresenceResult) Descriptor() ([]byte, []int) + func (*PresenceResult) ProtoMessage() + 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 (v *PresenceResult) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v PresenceResult) MarshalEasyJSON(w *writer) + func (x *PresenceResult) GetPresence() map[string]*ClientInfo + func (x *PresenceResult) ProtoReflect() protoreflect.Message + func (x *PresenceResult) Reset() + func (x *PresenceResult) String() string + type PresenceStatsRequest struct + Channel string + func (*PresenceStatsRequest) Descriptor() ([]byte, []int) + func (*PresenceStatsRequest) ProtoMessage() + 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 (v *PresenceStatsRequest) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v PresenceStatsRequest) MarshalEasyJSON(w *writer) + func (x *PresenceStatsRequest) GetChannel() string + func (x *PresenceStatsRequest) ProtoReflect() protoreflect.Message + func (x *PresenceStatsRequest) Reset() + func (x *PresenceStatsRequest) String() string + type PresenceStatsResult struct + NumClients uint32 + NumUsers uint32 + func (*PresenceStatsResult) Descriptor() ([]byte, []int) + func (*PresenceStatsResult) ProtoMessage() + 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 (v *PresenceStatsResult) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v PresenceStatsResult) MarshalEasyJSON(w *writer) + func (x *PresenceStatsResult) GetNumClients() uint32 + func (x *PresenceStatsResult) GetNumUsers() uint32 + func (x *PresenceStatsResult) ProtoReflect() protoreflect.Message + func (x *PresenceStatsResult) Reset() + func (x *PresenceStatsResult) String() string + 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 ProtobufDataEncoder struct + func NewProtobufDataEncoder() *ProtobufDataEncoder + func (e *ProtobufDataEncoder) Encode(data []byte) error + func (e *ProtobufDataEncoder) Finish() []byte + func (e *ProtobufDataEncoder) Reset() + type ProtobufPushEncoder struct + func NewProtobufPushEncoder() *ProtobufPushEncoder + func (e *ProtobufPushEncoder) Encode(message *Push) ([]byte, error) + func (e *ProtobufPushEncoder) EncodeConnect(message *Connect, reuse ...[]byte) ([]byte, error) + func (e *ProtobufPushEncoder) EncodeDisconnect(message *Disconnect, reuse ...[]byte) ([]byte, error) + func (e *ProtobufPushEncoder) EncodeJoin(message *Join, reuse ...[]byte) ([]byte, error) + func (e *ProtobufPushEncoder) EncodeLeave(message *Leave, reuse ...[]byte) ([]byte, error) + func (e *ProtobufPushEncoder) EncodeMessage(message *Message, reuse ...[]byte) ([]byte, error) + func (e *ProtobufPushEncoder) EncodePublication(message *Publication, reuse ...[]byte) ([]byte, error) + func (e *ProtobufPushEncoder) EncodeRefresh(message *Refresh, reuse ...[]byte) ([]byte, error) + func (e *ProtobufPushEncoder) EncodeSubscribe(message *Subscribe, reuse ...[]byte) ([]byte, error) + func (e *ProtobufPushEncoder) EncodeUnsubscribe(message *Unsubscribe, reuse ...[]byte) ([]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) ([]byte, 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 ProtobufStreamCommandDecoder struct + func NewProtobufStreamCommandDecoder(reader io.Reader, messageSizeLimit int64) *ProtobufStreamCommandDecoder + func (d *ProtobufStreamCommandDecoder) Decode() (*Command, int, error) + func (d *ProtobufStreamCommandDecoder) Reset(reader io.Reader, messageSizeLimit int64) + type Publication struct + Channel string + Data Raw + Delta bool + Info *ClientInfo + Meta Raw + Offset uint64 + Tags map[string]string + Time int64 + func (*Publication) Descriptor() ([]byte, []int) + func (*Publication) ProtoMessage() + 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 (v *Publication) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v Publication) MarshalEasyJSON(w *writer) + func (x *Publication) GetChannel() string + func (x *Publication) GetData() []byte + func (x *Publication) GetDelta() bool + func (x *Publication) GetInfo() *ClientInfo + func (x *Publication) GetMeta() []byte + func (x *Publication) GetOffset() uint64 + func (x *Publication) GetTags() map[string]string + func (x *Publication) GetTime() int64 + func (x *Publication) ProtoReflect() protoreflect.Message + func (x *Publication) Reset() + func (x *Publication) String() string + type PublishRequest struct + Channel string + Data Raw + Meta Raw + func (*PublishRequest) Descriptor() ([]byte, []int) + func (*PublishRequest) ProtoMessage() + 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 (v *PublishRequest) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v PublishRequest) MarshalEasyJSON(w *writer) + func (x *PublishRequest) GetChannel() string + func (x *PublishRequest) GetData() []byte + func (x *PublishRequest) GetMeta() []byte + func (x *PublishRequest) ProtoReflect() protoreflect.Message + func (x *PublishRequest) Reset() + func (x *PublishRequest) String() string + type PublishResult struct + func (*PublishResult) Descriptor() ([]byte, []int) + func (*PublishResult) ProtoMessage() + 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 (v *PublishResult) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v PublishResult) MarshalEasyJSON(w *writer) + func (x *PublishResult) ProtoReflect() protoreflect.Message + func (x *PublishResult) Reset() + func (x *PublishResult) String() string + type Push struct + Channel string + Connect *Connect + Disconnect *Disconnect + Join *Join + Leave *Leave + Message *Message + Pub *Publication + Refresh *Refresh + Subscribe *Subscribe + Unsubscribe *Unsubscribe + func (*Push) Descriptor() ([]byte, []int) + func (*Push) ProtoMessage() + 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 (v *Push) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v Push) MarshalEasyJSON(w *writer) + func (x *Push) GetChannel() string + 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 + func (x *Push) ProtoReflect() protoreflect.Message + func (x *Push) Reset() + func (x *Push) String() string + type PushEncoder interface + Encode func(*Push) ([]byte, error) + EncodeConnect func(*Connect, ...[]byte) ([]byte, error) + EncodeDisconnect func(*Disconnect, ...[]byte) ([]byte, error) + EncodeJoin func(*Join, ...[]byte) ([]byte, error) + EncodeLeave func(*Leave, ...[]byte) ([]byte, error) + EncodeMessage func(*Message, ...[]byte) ([]byte, error) + EncodePublication func(*Publication, ...[]byte) ([]byte, error) + EncodeRefresh func(*Refresh, ...[]byte) ([]byte, error) + EncodeSubscribe func(*Subscribe, ...[]byte) ([]byte, error) + EncodeUnsubscribe func(*Unsubscribe, ...[]byte) ([]byte, error) + func GetPushEncoder(protoType Type) PushEncoder + type RPCRequest struct + Data Raw + Method string + func (*RPCRequest) Descriptor() ([]byte, []int) + func (*RPCRequest) ProtoMessage() + 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 (v *RPCRequest) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v RPCRequest) MarshalEasyJSON(w *writer) + func (x *RPCRequest) GetData() []byte + func (x *RPCRequest) GetMethod() string + func (x *RPCRequest) ProtoReflect() protoreflect.Message + func (x *RPCRequest) Reset() + func (x *RPCRequest) String() string + type RPCResult struct + Data Raw + func (*RPCResult) Descriptor() ([]byte, []int) + func (*RPCResult) ProtoMessage() + 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 (v *RPCResult) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v RPCResult) MarshalEasyJSON(w *writer) + func (x *RPCResult) GetData() []byte + func (x *RPCResult) ProtoReflect() protoreflect.Message + func (x *RPCResult) Reset() + func (x *RPCResult) String() string + type Raw []byte + func (r *Raw) UnmarshalJSON(data []byte) error + func (r Raw) MarshalJSON() ([]byte, error) + type Refresh struct + Expires bool + Ttl uint32 + func (*Refresh) Descriptor() ([]byte, []int) + func (*Refresh) ProtoMessage() + 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 (v *Refresh) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v Refresh) MarshalEasyJSON(w *writer) + func (x *Refresh) GetExpires() bool + func (x *Refresh) GetTtl() uint32 + func (x *Refresh) ProtoReflect() protoreflect.Message + func (x *Refresh) Reset() + func (x *Refresh) String() string + type RefreshRequest struct + Token string + func (*RefreshRequest) Descriptor() ([]byte, []int) + func (*RefreshRequest) ProtoMessage() + 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 (v *RefreshRequest) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v RefreshRequest) MarshalEasyJSON(w *writer) + func (x *RefreshRequest) GetToken() string + func (x *RefreshRequest) ProtoReflect() protoreflect.Message + func (x *RefreshRequest) Reset() + func (x *RefreshRequest) String() string + type RefreshResult struct + Client string + Expires bool + Ttl uint32 + Version string + func (*RefreshResult) Descriptor() ([]byte, []int) + func (*RefreshResult) ProtoMessage() + 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 (v *RefreshResult) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v RefreshResult) MarshalEasyJSON(w *writer) + func (x *RefreshResult) GetClient() string + func (x *RefreshResult) GetExpires() bool + func (x *RefreshResult) GetTtl() uint32 + func (x *RefreshResult) GetVersion() string + func (x *RefreshResult) ProtoReflect() protoreflect.Message + func (x *RefreshResult) Reset() + func (x *RefreshResult) String() string + type Reply struct + Connect *ConnectResult + Error *Error + History *HistoryResult + Id uint32 + Ping *PingResult + Presence *PresenceResult + PresenceStats *PresenceStatsResult + Publish *PublishResult + Push *Push + Refresh *RefreshResult + Rpc *RPCResult + SubRefresh *SubRefreshResult + Subscribe *SubscribeResult + Unsubscribe *UnsubscribeResult + func (*Reply) Descriptor() ([]byte, []int) + func (*Reply) ProtoMessage() + 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 (v *Reply) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v Reply) MarshalEasyJSON(w *writer) + func (x *Reply) GetConnect() *ConnectResult + func (x *Reply) GetError() *Error + func (x *Reply) GetHistory() *HistoryResult + func (x *Reply) GetId() uint32 + 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 + func (x *Reply) ProtoReflect() protoreflect.Message + func (x *Reply) Reset() + func (x *Reply) String() string + type ReplyDecoder interface + Decode func() (*Reply, error) + Reset func([]byte) error + type ReplyEncoder interface + Encode func(*Reply) ([]byte, error) + func GetReplyEncoder(protoType Type) ReplyEncoder + 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 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 (*SendRequest) Descriptor() ([]byte, []int) + func (*SendRequest) ProtoMessage() + 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 (v *SendRequest) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v SendRequest) MarshalEasyJSON(w *writer) + func (x *SendRequest) GetData() []byte + func (x *SendRequest) ProtoReflect() protoreflect.Message + func (x *SendRequest) Reset() + func (x *SendRequest) String() string + type StreamCommandDecoder interface + Decode func() (*Command, int, error) + Reset func(reader io.Reader, messageSizeLimit int64) + func GetStreamCommandDecoder(protoType Type, reader io.Reader) StreamCommandDecoder + func GetStreamCommandDecoderLimited(protoType Type, reader io.Reader, messageSizeLimit int64) StreamCommandDecoder + type StreamPosition struct + Epoch string + Offset uint64 + func (*StreamPosition) Descriptor() ([]byte, []int) + func (*StreamPosition) ProtoMessage() + 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 (v *StreamPosition) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v StreamPosition) MarshalEasyJSON(w *writer) + func (x *StreamPosition) GetEpoch() string + func (x *StreamPosition) GetOffset() uint64 + func (x *StreamPosition) ProtoReflect() protoreflect.Message + func (x *StreamPosition) Reset() + func (x *StreamPosition) String() string + type SubRefreshRequest struct + Channel string + Token string + func (*SubRefreshRequest) Descriptor() ([]byte, []int) + func (*SubRefreshRequest) ProtoMessage() + 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 (v *SubRefreshRequest) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v SubRefreshRequest) MarshalEasyJSON(w *writer) + func (x *SubRefreshRequest) GetChannel() string + func (x *SubRefreshRequest) GetToken() string + func (x *SubRefreshRequest) ProtoReflect() protoreflect.Message + func (x *SubRefreshRequest) Reset() + func (x *SubRefreshRequest) String() string + type SubRefreshResult struct + Expires bool + Ttl uint32 + func (*SubRefreshResult) Descriptor() ([]byte, []int) + func (*SubRefreshResult) ProtoMessage() + 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 (v *SubRefreshResult) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v SubRefreshResult) MarshalEasyJSON(w *writer) + func (x *SubRefreshResult) GetExpires() bool + func (x *SubRefreshResult) GetTtl() uint32 + func (x *SubRefreshResult) ProtoReflect() protoreflect.Message + func (x *SubRefreshResult) Reset() + func (x *SubRefreshResult) String() string + type Subscribe struct + Data Raw + Epoch string + Offset uint64 + Positioned bool + Recoverable bool + func (*Subscribe) Descriptor() ([]byte, []int) + func (*Subscribe) ProtoMessage() + 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 (v *Subscribe) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v Subscribe) MarshalEasyJSON(w *writer) + func (x *Subscribe) GetData() []byte + func (x *Subscribe) GetEpoch() string + func (x *Subscribe) GetOffset() uint64 + func (x *Subscribe) GetPositioned() bool + func (x *Subscribe) GetRecoverable() bool + func (x *Subscribe) ProtoReflect() protoreflect.Message + func (x *Subscribe) Reset() + func (x *Subscribe) String() string + type SubscribeRequest struct + Channel string + Data Raw + Delta string + Epoch string + Filter string + JoinLeave bool + Offset uint64 + Positioned bool + Recover bool + Recoverable bool + Token string + func (*SubscribeRequest) Descriptor() ([]byte, []int) + func (*SubscribeRequest) ProtoMessage() + 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 (v *SubscribeRequest) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v SubscribeRequest) MarshalEasyJSON(w *writer) + func (x *SubscribeRequest) GetChannel() string + func (x *SubscribeRequest) GetData() []byte + func (x *SubscribeRequest) GetDelta() string + func (x *SubscribeRequest) GetEpoch() string + func (x *SubscribeRequest) GetFilter() string + func (x *SubscribeRequest) GetJoinLeave() bool + func (x *SubscribeRequest) GetOffset() uint64 + func (x *SubscribeRequest) GetPositioned() bool + func (x *SubscribeRequest) GetRecover() bool + func (x *SubscribeRequest) GetRecoverable() bool + func (x *SubscribeRequest) GetToken() string + func (x *SubscribeRequest) ProtoReflect() protoreflect.Message + func (x *SubscribeRequest) Reset() + func (x *SubscribeRequest) String() string + type SubscribeResult struct + Data Raw + Delta bool + Epoch string + Expires bool + Offset uint64 + Positioned bool + Publications []*Publication + Recoverable bool + Recovered bool + Ttl uint32 + WasRecovering bool + func (*SubscribeResult) Descriptor() ([]byte, []int) + func (*SubscribeResult) ProtoMessage() + 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 (v *SubscribeResult) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v SubscribeResult) MarshalEasyJSON(w *writer) + func (x *SubscribeResult) GetData() []byte + func (x *SubscribeResult) GetDelta() bool + func (x *SubscribeResult) GetEpoch() string + func (x *SubscribeResult) GetExpires() bool + func (x *SubscribeResult) GetOffset() uint64 + func (x *SubscribeResult) GetPositioned() bool + func (x *SubscribeResult) GetPublications() []*Publication + func (x *SubscribeResult) GetRecoverable() bool + func (x *SubscribeResult) GetRecovered() bool + func (x *SubscribeResult) GetTtl() uint32 + func (x *SubscribeResult) GetWasRecovering() bool + func (x *SubscribeResult) ProtoReflect() protoreflect.Message + func (x *SubscribeResult) Reset() + func (x *SubscribeResult) String() string + type Type string + const TypeJSON + const TypeProtobuf + type Unsubscribe struct + Code uint32 + Reason string + func (*Unsubscribe) Descriptor() ([]byte, []int) + func (*Unsubscribe) ProtoMessage() + 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 (v *Unsubscribe) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v Unsubscribe) MarshalEasyJSON(w *writer) + func (x *Unsubscribe) GetCode() uint32 + func (x *Unsubscribe) GetReason() string + func (x *Unsubscribe) ProtoReflect() protoreflect.Message + func (x *Unsubscribe) Reset() + func (x *Unsubscribe) String() string + type UnsubscribeRequest struct + Channel string + func (*UnsubscribeRequest) Descriptor() ([]byte, []int) + func (*UnsubscribeRequest) ProtoMessage() + 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 (v *UnsubscribeRequest) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v UnsubscribeRequest) MarshalEasyJSON(w *writer) + func (x *UnsubscribeRequest) GetChannel() string + func (x *UnsubscribeRequest) ProtoReflect() protoreflect.Message + func (x *UnsubscribeRequest) Reset() + func (x *UnsubscribeRequest) String() string + type UnsubscribeResult struct + func (*UnsubscribeResult) Descriptor() ([]byte, []int) + func (*UnsubscribeResult) ProtoMessage() + 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 (v *UnsubscribeResult) UnmarshalEasyJSON(l *jlexer.Lexer) + func (v UnsubscribeResult) MarshalEasyJSON(w *writer) + func (x *UnsubscribeResult) ProtoReflect() protoreflect.Message + func (x *UnsubscribeResult) Reset() + func (x *UnsubscribeResult) String() string
Go to main page