Documentation
¶
Overview ¶
Package proto is a generated protocol buffer package.
It is generated from these files:
client.proto
It has these top-level messages:
Error Command Reply Push ClientInfo Publication Join Leave Unsub Message ConnectRequest ConnectResult RefreshRequest RefreshResult SubscribeRequest SubscribeResult SubRefreshRequest SubRefreshResult UnsubscribeRequest UnsubscribeResult PublishRequest PublishResult PresenceRequest PresenceResult PresenceStatsRequest PresenceStatsResult HistoryRequest HistoryResult PingRequest PingResult RPCRequest RPCResult SendRequest
Index ¶
- Variables
- func PutReplyEncoder(enc Encoding, e ReplyEncoder)
- type ClientInfo
- func (*ClientInfo) Descriptor() ([]byte, []int)
- func (this *ClientInfo) Equal(that interface{}) bool
- 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 (*ClientInfo) ProtoMessage()
- func (m *ClientInfo) Reset()
- func (m *ClientInfo) Size() (n int)
- func (m *ClientInfo) String() string
- func (m *ClientInfo) Unmarshal(dAtA []byte) error
- type Command
- func (*Command) Descriptor() ([]byte, []int)
- func (this *Command) Equal(that interface{}) bool
- 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 (*Command) ProtoMessage()
- func (m *Command) Reset()
- func (m *Command) Size() (n int)
- func (m *Command) String() string
- func (m *Command) Unmarshal(dAtA []byte) error
- type CommandEncoder
- type ConnectRequest
- func (*ConnectRequest) Descriptor() ([]byte, []int)
- func (this *ConnectRequest) Equal(that interface{}) bool
- func (m *ConnectRequest) GetToken() string
- func (m *ConnectRequest) Marshal() (dAtA []byte, err error)
- func (m *ConnectRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ConnectRequest) ProtoMessage()
- func (m *ConnectRequest) Reset()
- func (m *ConnectRequest) Size() (n int)
- func (m *ConnectRequest) String() string
- func (m *ConnectRequest) Unmarshal(dAtA []byte) error
- type ConnectResult
- func (*ConnectResult) Descriptor() ([]byte, []int)
- func (this *ConnectResult) Equal(that interface{}) bool
- func (m *ConnectResult) GetClient() string
- func (m *ConnectResult) GetExpires() bool
- 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 (*ConnectResult) ProtoMessage()
- func (m *ConnectResult) Reset()
- func (m *ConnectResult) Size() (n int)
- func (m *ConnectResult) String() string
- func (m *ConnectResult) Unmarshal(dAtA []byte) error
- type Encoding
- type Error
- func (*Error) Descriptor() ([]byte, []int)
- func (this *Error) Equal(that interface{}) bool
- 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 (*Error) ProtoMessage()
- func (m *Error) Reset()
- func (m *Error) Size() (n int)
- func (m *Error) String() string
- func (m *Error) Unmarshal(dAtA []byte) error
- type HistoryRequest
- func (*HistoryRequest) Descriptor() ([]byte, []int)
- func (this *HistoryRequest) Equal(that interface{}) bool
- func (m *HistoryRequest) GetChannel() string
- func (m *HistoryRequest) Marshal() (dAtA []byte, err error)
- func (m *HistoryRequest) MarshalTo(dAtA []byte) (int, error)
- func (*HistoryRequest) ProtoMessage()
- func (m *HistoryRequest) Reset()
- func (m *HistoryRequest) Size() (n int)
- func (m *HistoryRequest) String() string
- func (m *HistoryRequest) Unmarshal(dAtA []byte) error
- type HistoryResult
- func (*HistoryResult) Descriptor() ([]byte, []int)
- func (this *HistoryResult) Equal(that interface{}) bool
- func (m *HistoryResult) GetPublications() []*Publication
- func (m *HistoryResult) Marshal() (dAtA []byte, err error)
- func (m *HistoryResult) MarshalTo(dAtA []byte) (int, error)
- func (*HistoryResult) ProtoMessage()
- func (m *HistoryResult) Reset()
- func (m *HistoryResult) Size() (n int)
- func (m *HistoryResult) String() string
- func (m *HistoryResult) Unmarshal(dAtA []byte) error
- type JSONCommandEncoder
- type JSONParamsEncoder
- type 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) DecodeUnsub(data []byte) (*Unsub, error)
- type 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) EncodeUnsub(message *Unsub) ([]byte, error)
- type JSONReplyDecoder
- type JSONReplyEncoder
- type JSONResultDecoder
- type Join
- func (*Join) Descriptor() ([]byte, []int)
- func (this *Join) Equal(that interface{}) bool
- func (m *Join) GetInfo() ClientInfo
- func (m *Join) Marshal() (dAtA []byte, err error)
- func (m *Join) MarshalTo(dAtA []byte) (int, error)
- func (*Join) ProtoMessage()
- func (m *Join) Reset()
- func (m *Join) Size() (n int)
- func (m *Join) String() string
- func (m *Join) Unmarshal(dAtA []byte) error
- type Leave
- func (*Leave) Descriptor() ([]byte, []int)
- func (this *Leave) Equal(that interface{}) bool
- func (m *Leave) GetInfo() ClientInfo
- func (m *Leave) Marshal() (dAtA []byte, err error)
- func (m *Leave) MarshalTo(dAtA []byte) (int, error)
- func (*Leave) ProtoMessage()
- func (m *Leave) Reset()
- func (m *Leave) Size() (n int)
- func (m *Leave) String() string
- func (m *Leave) Unmarshal(dAtA []byte) error
- type Message
- func (*Message) Descriptor() ([]byte, []int)
- func (this *Message) Equal(that interface{}) bool
- func (m *Message) Marshal() (dAtA []byte, err error)
- func (m *Message) MarshalTo(dAtA []byte) (int, error)
- func (*Message) ProtoMessage()
- func (m *Message) Reset()
- func (m *Message) Size() (n int)
- func (m *Message) String() string
- func (m *Message) Unmarshal(dAtA []byte) error
- type MethodType
- type ParamsEncoder
- type PingRequest
- func (*PingRequest) Descriptor() ([]byte, []int)
- func (this *PingRequest) Equal(that interface{}) bool
- func (m *PingRequest) Marshal() (dAtA []byte, err error)
- func (m *PingRequest) MarshalTo(dAtA []byte) (int, error)
- func (*PingRequest) ProtoMessage()
- func (m *PingRequest) Reset()
- func (m *PingRequest) Size() (n int)
- func (m *PingRequest) String() string
- func (m *PingRequest) Unmarshal(dAtA []byte) error
- type PingResult
- func (*PingResult) Descriptor() ([]byte, []int)
- func (this *PingResult) Equal(that interface{}) bool
- func (m *PingResult) Marshal() (dAtA []byte, err error)
- func (m *PingResult) MarshalTo(dAtA []byte) (int, error)
- func (*PingResult) ProtoMessage()
- func (m *PingResult) Reset()
- func (m *PingResult) Size() (n int)
- func (m *PingResult) String() string
- func (m *PingResult) Unmarshal(dAtA []byte) error
- type PresenceRequest
- func (*PresenceRequest) Descriptor() ([]byte, []int)
- func (this *PresenceRequest) Equal(that interface{}) bool
- func (m *PresenceRequest) GetChannel() string
- func (m *PresenceRequest) Marshal() (dAtA []byte, err error)
- func (m *PresenceRequest) MarshalTo(dAtA []byte) (int, error)
- func (*PresenceRequest) ProtoMessage()
- func (m *PresenceRequest) Reset()
- func (m *PresenceRequest) Size() (n int)
- func (m *PresenceRequest) String() string
- func (m *PresenceRequest) Unmarshal(dAtA []byte) error
- type PresenceResult
- func (*PresenceResult) Descriptor() ([]byte, []int)
- func (this *PresenceResult) Equal(that interface{}) bool
- func (m *PresenceResult) GetPresence() map[string]*ClientInfo
- func (m *PresenceResult) Marshal() (dAtA []byte, err error)
- func (m *PresenceResult) MarshalTo(dAtA []byte) (int, error)
- func (*PresenceResult) ProtoMessage()
- func (m *PresenceResult) Reset()
- func (m *PresenceResult) Size() (n int)
- func (m *PresenceResult) String() string
- func (m *PresenceResult) Unmarshal(dAtA []byte) error
- type PresenceStatsRequest
- func (*PresenceStatsRequest) Descriptor() ([]byte, []int)
- func (this *PresenceStatsRequest) Equal(that interface{}) bool
- func (m *PresenceStatsRequest) GetChannel() string
- func (m *PresenceStatsRequest) Marshal() (dAtA []byte, err error)
- func (m *PresenceStatsRequest) MarshalTo(dAtA []byte) (int, error)
- func (*PresenceStatsRequest) ProtoMessage()
- func (m *PresenceStatsRequest) Reset()
- func (m *PresenceStatsRequest) Size() (n int)
- func (m *PresenceStatsRequest) String() string
- func (m *PresenceStatsRequest) Unmarshal(dAtA []byte) error
- type PresenceStatsResult
- func (*PresenceStatsResult) Descriptor() ([]byte, []int)
- func (this *PresenceStatsResult) Equal(that interface{}) bool
- 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 (*PresenceStatsResult) ProtoMessage()
- func (m *PresenceStatsResult) Reset()
- func (m *PresenceStatsResult) Size() (n int)
- func (m *PresenceStatsResult) String() string
- func (m *PresenceStatsResult) Unmarshal(dAtA []byte) error
- type ProtobufCommandEncoder
- type ProtobufParamsEncoder
- type 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) DecodeUnsub(data []byte) (*Unsub, error)
- type 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) EncodeUnsub(message *Unsub) ([]byte, error)
- type ProtobufReplyDecoder
- type ProtobufReplyEncoder
- type ProtobufResultDecoder
- type Publication
- func (*Publication) Descriptor() ([]byte, []int)
- func (this *Publication) Equal(that interface{}) bool
- func (m *Publication) GetGen() uint32
- func (m *Publication) GetInfo() *ClientInfo
- 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 (*Publication) ProtoMessage()
- func (m *Publication) Reset()
- func (m *Publication) Size() (n int)
- func (m *Publication) String() string
- func (m *Publication) Unmarshal(dAtA []byte) error
- type PublishRequest
- func (*PublishRequest) Descriptor() ([]byte, []int)
- func (this *PublishRequest) Equal(that interface{}) bool
- func (m *PublishRequest) GetChannel() string
- func (m *PublishRequest) Marshal() (dAtA []byte, err error)
- func (m *PublishRequest) MarshalTo(dAtA []byte) (int, error)
- func (*PublishRequest) ProtoMessage()
- func (m *PublishRequest) Reset()
- func (m *PublishRequest) Size() (n int)
- func (m *PublishRequest) String() string
- func (m *PublishRequest) Unmarshal(dAtA []byte) error
- type PublishResult
- func (*PublishResult) Descriptor() ([]byte, []int)
- func (this *PublishResult) Equal(that interface{}) bool
- func (m *PublishResult) Marshal() (dAtA []byte, err error)
- func (m *PublishResult) MarshalTo(dAtA []byte) (int, error)
- func (*PublishResult) ProtoMessage()
- func (m *PublishResult) Reset()
- func (m *PublishResult) Size() (n int)
- func (m *PublishResult) String() string
- func (m *PublishResult) Unmarshal(dAtA []byte) error
- type Push
- func (*Push) Descriptor() ([]byte, []int)
- func (this *Push) Equal(that interface{}) bool
- 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 (*Push) ProtoMessage()
- func (m *Push) Reset()
- func (m *Push) Size() (n int)
- func (m *Push) String() string
- func (m *Push) Unmarshal(dAtA []byte) error
- type PushDecoder
- type PushEncoder
- type PushType
- type RPCRequest
- func (*RPCRequest) Descriptor() ([]byte, []int)
- func (this *RPCRequest) Equal(that interface{}) bool
- func (m *RPCRequest) Marshal() (dAtA []byte, err error)
- func (m *RPCRequest) MarshalTo(dAtA []byte) (int, error)
- func (*RPCRequest) ProtoMessage()
- func (m *RPCRequest) Reset()
- func (m *RPCRequest) Size() (n int)
- func (m *RPCRequest) String() string
- func (m *RPCRequest) Unmarshal(dAtA []byte) error
- type RPCResult
- func (*RPCResult) Descriptor() ([]byte, []int)
- func (this *RPCResult) Equal(that interface{}) bool
- func (m *RPCResult) Marshal() (dAtA []byte, err error)
- func (m *RPCResult) MarshalTo(dAtA []byte) (int, error)
- func (*RPCResult) ProtoMessage()
- func (m *RPCResult) Reset()
- func (m *RPCResult) Size() (n int)
- func (m *RPCResult) String() string
- func (m *RPCResult) Unmarshal(dAtA []byte) error
- type Raw
- 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)
- func (r *Raw) Size() int
- func (r *Raw) Unmarshal(data []byte) error
- func (r *Raw) UnmarshalJSON(data []byte) error
- type RefreshRequest
- func (*RefreshRequest) Descriptor() ([]byte, []int)
- func (this *RefreshRequest) Equal(that interface{}) bool
- func (m *RefreshRequest) GetToken() string
- func (m *RefreshRequest) Marshal() (dAtA []byte, err error)
- func (m *RefreshRequest) MarshalTo(dAtA []byte) (int, error)
- func (*RefreshRequest) ProtoMessage()
- func (m *RefreshRequest) Reset()
- func (m *RefreshRequest) Size() (n int)
- func (m *RefreshRequest) String() string
- func (m *RefreshRequest) Unmarshal(dAtA []byte) error
- type RefreshResult
- func (*RefreshResult) Descriptor() ([]byte, []int)
- func (this *RefreshResult) Equal(that interface{}) bool
- 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 (*RefreshResult) ProtoMessage()
- func (m *RefreshResult) Reset()
- func (m *RefreshResult) Size() (n int)
- func (m *RefreshResult) String() string
- func (m *RefreshResult) Unmarshal(dAtA []byte) error
- type Reply
- func (*Reply) Descriptor() ([]byte, []int)
- func (this *Reply) Equal(that interface{}) bool
- 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 (*Reply) ProtoMessage()
- func (m *Reply) Reset()
- func (m *Reply) Size() (n int)
- func (m *Reply) String() string
- func (m *Reply) Unmarshal(dAtA []byte) error
- type ReplyDecoder
- type ReplyEncoder
- type ResultDecoder
- type SendRequest
- func (*SendRequest) Descriptor() ([]byte, []int)
- func (this *SendRequest) Equal(that interface{}) bool
- func (m *SendRequest) Marshal() (dAtA []byte, err error)
- func (m *SendRequest) MarshalTo(dAtA []byte) (int, error)
- func (*SendRequest) ProtoMessage()
- func (m *SendRequest) Reset()
- func (m *SendRequest) Size() (n int)
- func (m *SendRequest) String() string
- func (m *SendRequest) Unmarshal(dAtA []byte) error
- type SubRefreshRequest
- func (*SubRefreshRequest) Descriptor() ([]byte, []int)
- func (this *SubRefreshRequest) Equal(that interface{}) bool
- 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 (*SubRefreshRequest) ProtoMessage()
- func (m *SubRefreshRequest) Reset()
- func (m *SubRefreshRequest) Size() (n int)
- func (m *SubRefreshRequest) String() string
- func (m *SubRefreshRequest) Unmarshal(dAtA []byte) error
- type SubRefreshResult
- func (*SubRefreshResult) Descriptor() ([]byte, []int)
- func (this *SubRefreshResult) Equal(that interface{}) bool
- 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 (*SubRefreshResult) ProtoMessage()
- func (m *SubRefreshResult) Reset()
- func (m *SubRefreshResult) Size() (n int)
- func (m *SubRefreshResult) String() string
- func (m *SubRefreshResult) Unmarshal(dAtA []byte) error
- type SubscribeRequest
- func (*SubscribeRequest) Descriptor() ([]byte, []int)
- func (this *SubscribeRequest) Equal(that interface{}) bool
- func (m *SubscribeRequest) GetChannel() string
- func (m *SubscribeRequest) GetEpoch() string
- func (m *SubscribeRequest) GetGen() uint32
- 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 (*SubscribeRequest) ProtoMessage()
- func (m *SubscribeRequest) Reset()
- func (m *SubscribeRequest) Size() (n int)
- func (m *SubscribeRequest) String() string
- func (m *SubscribeRequest) Unmarshal(dAtA []byte) error
- type SubscribeResult
- func (*SubscribeResult) Descriptor() ([]byte, []int)
- func (this *SubscribeResult) Equal(that interface{}) bool
- func (m *SubscribeResult) GetEpoch() string
- func (m *SubscribeResult) GetExpires() bool
- func (m *SubscribeResult) GetGen() uint32
- 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 (*SubscribeResult) ProtoMessage()
- func (m *SubscribeResult) Reset()
- func (m *SubscribeResult) Size() (n int)
- func (m *SubscribeResult) String() string
- func (m *SubscribeResult) Unmarshal(dAtA []byte) error
- type Unsub
- func (*Unsub) Descriptor() ([]byte, []int)
- func (this *Unsub) Equal(that interface{}) bool
- func (m *Unsub) GetResubscribe() bool
- func (m *Unsub) Marshal() (dAtA []byte, err error)
- func (m *Unsub) MarshalTo(dAtA []byte) (int, error)
- func (*Unsub) ProtoMessage()
- func (m *Unsub) Reset()
- func (m *Unsub) Size() (n int)
- func (m *Unsub) String() string
- func (m *Unsub) Unmarshal(dAtA []byte) error
- type UnsubscribeRequest
- func (*UnsubscribeRequest) Descriptor() ([]byte, []int)
- func (this *UnsubscribeRequest) Equal(that interface{}) bool
- func (m *UnsubscribeRequest) GetChannel() string
- func (m *UnsubscribeRequest) Marshal() (dAtA []byte, err error)
- func (m *UnsubscribeRequest) MarshalTo(dAtA []byte) (int, error)
- func (*UnsubscribeRequest) ProtoMessage()
- func (m *UnsubscribeRequest) Reset()
- func (m *UnsubscribeRequest) Size() (n int)
- func (m *UnsubscribeRequest) String() string
- func (m *UnsubscribeRequest) Unmarshal(dAtA []byte) error
- type UnsubscribeResult
- func (*UnsubscribeResult) Descriptor() ([]byte, []int)
- func (this *UnsubscribeResult) Equal(that interface{}) bool
- func (m *UnsubscribeResult) Marshal() (dAtA []byte, err error)
- func (m *UnsubscribeResult) MarshalTo(dAtA []byte) (int, error)
- func (*UnsubscribeResult) ProtoMessage()
- func (m *UnsubscribeResult) Reset()
- func (m *UnsubscribeResult) Size() (n int)
- func (m *UnsubscribeResult) String() string
- func (m *UnsubscribeResult) Unmarshal(dAtA []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthClient = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowClient = fmt.Errorf("proto: integer overflow") )
var MethodType_name = map[int32]string{
0: "CONNECT",
1: "SUBSCRIBE",
2: "UNSUBSCRIBE",
3: "PUBLISH",
4: "PRESENCE",
5: "PRESENCE_STATS",
6: "HISTORY",
7: "PING",
8: "SEND",
9: "RPC",
10: "REFRESH",
11: "SUB_REFRESH",
}
var MethodType_value = map[string]int32{
"CONNECT": 0,
"SUBSCRIBE": 1,
"UNSUBSCRIBE": 2,
"PUBLISH": 3,
"PRESENCE": 4,
"PRESENCE_STATS": 5,
"HISTORY": 6,
"PING": 7,
"SEND": 8,
"RPC": 9,
"REFRESH": 10,
"SUB_REFRESH": 11,
}
var PushType_name = map[int32]string{
0: "PUBLICATION",
1: "JOIN",
2: "LEAVE",
3: "UNSUB",
4: "MESSAGE",
}
var PushType_value = map[string]int32{
"PUBLICATION": 0,
"JOIN": 1,
"LEAVE": 2,
"UNSUB": 3,
"MESSAGE": 4,
}
Functions ¶
Types ¶
type ClientInfo ¶
type ClientInfo struct { User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user"` Client string `protobuf:"bytes,2,opt,name=client,proto3" json:"client"` ConnInfo Raw `protobuf:"bytes,3,opt,name=conn_info,json=connInfo,proto3,customtype=Raw" json:"conn_info,omitempty"` ChanInfo Raw `protobuf:"bytes,4,opt,name=chan_info,json=chanInfo,proto3,customtype=Raw" json:"chan_info,omitempty"` }
func NewPopulatedClientInfo ¶
func NewPopulatedClientInfo(r randyClient, easy bool) *ClientInfo
func (*ClientInfo) Descriptor ¶
func (*ClientInfo) Descriptor() ([]byte, []int)
func (*ClientInfo) Equal ¶
func (this *ClientInfo) Equal(that interface{}) bool
func (*ClientInfo) GetClient ¶
func (m *ClientInfo) GetClient() string
func (*ClientInfo) GetUser ¶
func (m *ClientInfo) GetUser() string
func (*ClientInfo) Marshal ¶
func (m *ClientInfo) Marshal() (dAtA []byte, err error)
func (*ClientInfo) ProtoMessage ¶
func (*ClientInfo) ProtoMessage()
func (*ClientInfo) Reset ¶
func (m *ClientInfo) Reset()
func (*ClientInfo) Size ¶
func (m *ClientInfo) Size() (n int)
func (*ClientInfo) String ¶
func (m *ClientInfo) String() string
func (*ClientInfo) Unmarshal ¶
func (m *ClientInfo) Unmarshal(dAtA []byte) error
type Command ¶
type Command struct { ID uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Method MethodType `protobuf:"varint,2,opt,name=method,proto3,enum=proto.MethodType" json:"method,omitempty"` Params Raw `protobuf:"bytes,3,opt,name=params,proto3,customtype=Raw" json:"params,omitempty"` }
func NewPopulatedCommand ¶
func (*Command) Descriptor ¶
func (*Command) GetMethod ¶
func (m *Command) GetMethod() MethodType
func (*Command) ProtoMessage ¶
func (*Command) ProtoMessage()
type CommandEncoder ¶
CommandEncoder ...
type ConnectRequest ¶
type ConnectRequest struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token"` Data Raw `protobuf:"bytes,2,opt,name=data,proto3,customtype=Raw" json:"data,omitempty"` }
func NewPopulatedConnectRequest ¶
func NewPopulatedConnectRequest(r randyClient, easy bool) *ConnectRequest
func (*ConnectRequest) Descriptor ¶
func (*ConnectRequest) Descriptor() ([]byte, []int)
func (*ConnectRequest) Equal ¶
func (this *ConnectRequest) Equal(that interface{}) bool
func (*ConnectRequest) GetToken ¶
func (m *ConnectRequest) GetToken() string
func (*ConnectRequest) Marshal ¶
func (m *ConnectRequest) Marshal() (dAtA []byte, err error)
func (*ConnectRequest) ProtoMessage ¶
func (*ConnectRequest) ProtoMessage()
func (*ConnectRequest) Reset ¶
func (m *ConnectRequest) Reset()
func (*ConnectRequest) Size ¶
func (m *ConnectRequest) Size() (n int)
func (*ConnectRequest) String ¶
func (m *ConnectRequest) String() string
func (*ConnectRequest) Unmarshal ¶
func (m *ConnectRequest) Unmarshal(dAtA []byte) error
type ConnectResult ¶
type ConnectResult struct { Client string `protobuf:"bytes,1,opt,name=client,proto3" json:"client"` Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version"` Expires bool `protobuf:"varint,3,opt,name=expires,proto3" json:"expires,omitempty"` TTL uint32 `protobuf:"varint,4,opt,name=ttl,proto3" json:"ttl,omitempty"` Data Raw `protobuf:"bytes,5,opt,name=data,proto3,customtype=Raw" json:"data,omitempty"` }
func NewPopulatedConnectResult ¶
func NewPopulatedConnectResult(r randyClient, easy bool) *ConnectResult
func (*ConnectResult) Descriptor ¶
func (*ConnectResult) Descriptor() ([]byte, []int)
func (*ConnectResult) Equal ¶
func (this *ConnectResult) Equal(that interface{}) bool
func (*ConnectResult) GetClient ¶
func (m *ConnectResult) GetClient() string
func (*ConnectResult) GetExpires ¶
func (m *ConnectResult) GetExpires() bool
func (*ConnectResult) GetTTL ¶
func (m *ConnectResult) GetTTL() uint32
func (*ConnectResult) GetVersion ¶
func (m *ConnectResult) GetVersion() string
func (*ConnectResult) Marshal ¶
func (m *ConnectResult) Marshal() (dAtA []byte, err error)
func (*ConnectResult) ProtoMessage ¶
func (*ConnectResult) ProtoMessage()
func (*ConnectResult) Reset ¶
func (m *ConnectResult) Reset()
func (*ConnectResult) Size ¶
func (m *ConnectResult) Size() (n int)
func (*ConnectResult) String ¶
func (m *ConnectResult) String() string
func (*ConnectResult) Unmarshal ¶
func (m *ConnectResult) Unmarshal(dAtA []byte) error
type Error ¶
type Error struct { Code uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message"` }
func NewPopulatedError ¶
func (*Error) Descriptor ¶
func (*Error) GetMessage ¶
func (*Error) ProtoMessage ¶
func (*Error) ProtoMessage()
type HistoryRequest ¶
type HistoryRequest struct {
Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel"`
}
func NewPopulatedHistoryRequest ¶
func NewPopulatedHistoryRequest(r randyClient, easy bool) *HistoryRequest
func (*HistoryRequest) Descriptor ¶
func (*HistoryRequest) Descriptor() ([]byte, []int)
func (*HistoryRequest) Equal ¶
func (this *HistoryRequest) Equal(that interface{}) bool
func (*HistoryRequest) GetChannel ¶
func (m *HistoryRequest) GetChannel() string
func (*HistoryRequest) Marshal ¶
func (m *HistoryRequest) Marshal() (dAtA []byte, err error)
func (*HistoryRequest) ProtoMessage ¶
func (*HistoryRequest) ProtoMessage()
func (*HistoryRequest) Reset ¶
func (m *HistoryRequest) Reset()
func (*HistoryRequest) Size ¶
func (m *HistoryRequest) Size() (n int)
func (*HistoryRequest) String ¶
func (m *HistoryRequest) String() string
func (*HistoryRequest) Unmarshal ¶
func (m *HistoryRequest) Unmarshal(dAtA []byte) error
type HistoryResult ¶
type HistoryResult struct {
Publications []*Publication `protobuf:"bytes,1,rep,name=publications" json:"publications"`
}
func NewPopulatedHistoryResult ¶
func NewPopulatedHistoryResult(r randyClient, easy bool) *HistoryResult
func (*HistoryResult) Descriptor ¶
func (*HistoryResult) Descriptor() ([]byte, []int)
func (*HistoryResult) Equal ¶
func (this *HistoryResult) Equal(that interface{}) bool
func (*HistoryResult) GetPublications ¶
func (m *HistoryResult) GetPublications() []*Publication
func (*HistoryResult) Marshal ¶
func (m *HistoryResult) Marshal() (dAtA []byte, err error)
func (*HistoryResult) ProtoMessage ¶
func (*HistoryResult) ProtoMessage()
func (*HistoryResult) Reset ¶
func (m *HistoryResult) Reset()
func (*HistoryResult) Size ¶
func (m *HistoryResult) Size() (n int)
func (*HistoryResult) String ¶
func (m *HistoryResult) String() string
func (*HistoryResult) Unmarshal ¶
func (m *HistoryResult) Unmarshal(dAtA []byte) error
type JSONCommandEncoder ¶
type JSONCommandEncoder struct { }
JSONCommandEncoder ...
func NewJSONCommandEncoder ¶
func NewJSONCommandEncoder() *JSONCommandEncoder
NewJSONCommandEncoder ...
type JSONParamsEncoder ¶
type JSONParamsEncoder struct{}
JSONParamsEncoder ...
func (*JSONParamsEncoder) Encode ¶
func (d *JSONParamsEncoder) Encode(r interface{}) ([]byte, error)
Encode ...
type JSONPushDecoder ¶
type JSONPushDecoder struct { }
JSONPushDecoder ...
func (*JSONPushDecoder) Decode ¶
func (e *JSONPushDecoder) Decode(data []byte) (*Push, error)
Decode ...
func (*JSONPushDecoder) DecodeJoin ¶
func (e *JSONPushDecoder) DecodeJoin(data []byte) (*Join, error)
DecodeJoin ...
func (*JSONPushDecoder) DecodeLeave ¶
func (e *JSONPushDecoder) DecodeLeave(data []byte) (*Leave, error)
DecodeLeave ...
func (*JSONPushDecoder) DecodeMessage ¶
func (e *JSONPushDecoder) DecodeMessage(data []byte) (*Message, error)
DecodeMessage ...
func (*JSONPushDecoder) DecodePublication ¶
func (e *JSONPushDecoder) DecodePublication(data []byte) (*Publication, error)
DecodePublication ...
func (*JSONPushDecoder) DecodeUnsub ¶
func (e *JSONPushDecoder) DecodeUnsub(data []byte) (*Unsub, error)
DecodeUnsub ...
type JSONPushEncoder ¶
type JSONPushEncoder struct { }
JSONPushEncoder ...
func (*JSONPushEncoder) Encode ¶
func (e *JSONPushEncoder) Encode(message *Push) ([]byte, error)
Encode ...
func (*JSONPushEncoder) EncodeJoin ¶
func (e *JSONPushEncoder) EncodeJoin(message *Join) ([]byte, error)
EncodeJoin ...
func (*JSONPushEncoder) EncodeLeave ¶
func (e *JSONPushEncoder) EncodeLeave(message *Leave) ([]byte, error)
EncodeLeave ...
func (*JSONPushEncoder) EncodeMessage ¶
func (e *JSONPushEncoder) EncodeMessage(message *Message) ([]byte, error)
EncodeMessage ...
func (*JSONPushEncoder) EncodePublication ¶
func (e *JSONPushEncoder) EncodePublication(message *Publication) ([]byte, error)
EncodePublication ...
func (*JSONPushEncoder) EncodeUnsub ¶
func (e *JSONPushEncoder) EncodeUnsub(message *Unsub) ([]byte, error)
EncodeUnsub ...
type JSONReplyDecoder ¶
type JSONReplyDecoder struct {
// contains filtered or unexported fields
}
JSONReplyDecoder ...
func NewJSONReplyDecoder ¶
func NewJSONReplyDecoder(data []byte) *JSONReplyDecoder
NewJSONReplyDecoder ...
type JSONReplyEncoder ¶
type JSONReplyEncoder struct {
// contains filtered or unexported fields
}
JSONReplyEncoder ...
type JSONResultDecoder ¶
type JSONResultDecoder struct{}
JSONResultDecoder ...
func (*JSONResultDecoder) Decode ¶
func (e *JSONResultDecoder) Decode(data []byte, dest interface{}) error
Decode ...
type Join ¶
type Join struct {
Info ClientInfo `protobuf:"bytes,1,opt,name=info" json:"info"`
}
func NewPopulatedJoin ¶
func (*Join) Descriptor ¶
func (*Join) GetInfo ¶
func (m *Join) GetInfo() ClientInfo
func (*Join) ProtoMessage ¶
func (*Join) ProtoMessage()
type Leave ¶
type Leave struct {
Info ClientInfo `protobuf:"bytes,1,opt,name=info" json:"info"`
}
func NewPopulatedLeave ¶
func (*Leave) Descriptor ¶
func (*Leave) GetInfo ¶
func (m *Leave) GetInfo() ClientInfo
func (*Leave) ProtoMessage ¶
func (*Leave) ProtoMessage()
type Message ¶
type Message struct {
Data Raw `protobuf:"bytes,1,opt,name=data,proto3,customtype=Raw" json:"data"`
}
func NewPopulatedMessage ¶
func (*Message) Descriptor ¶
func (*Message) ProtoMessage ¶
func (*Message) ProtoMessage()
type MethodType ¶
type MethodType int32
const ( MethodTypeConnect MethodType = 0 MethodTypeSubscribe MethodType = 1 MethodTypeUnsubscribe MethodType = 2 MethodTypePublish MethodType = 3 MethodTypePresence MethodType = 4 MethodTypePresenceStats MethodType = 5 MethodTypeHistory MethodType = 6 MethodTypePing MethodType = 7 MethodTypeSend MethodType = 8 MethodTypeRPC MethodType = 9 MethodTypeRefresh MethodType = 10 MethodTypeSubRefresh MethodType = 11 )
func (MethodType) EnumDescriptor ¶
func (MethodType) EnumDescriptor() ([]byte, []int)
func (MethodType) String ¶
func (x MethodType) String() string
func (*MethodType) UnmarshalJSON ¶
func (m *MethodType) UnmarshalJSON(data []byte) error
UnmarshalJSON helps to unmarshal comamnd method when set as string.
type ParamsEncoder ¶
ParamsEncoder ...
type PingRequest ¶
type PingRequest struct { }
func NewPopulatedPingRequest ¶
func NewPopulatedPingRequest(r randyClient, easy bool) *PingRequest
func (*PingRequest) Descriptor ¶
func (*PingRequest) Descriptor() ([]byte, []int)
func (*PingRequest) Equal ¶
func (this *PingRequest) Equal(that interface{}) bool
func (*PingRequest) Marshal ¶
func (m *PingRequest) Marshal() (dAtA []byte, err error)
func (*PingRequest) ProtoMessage ¶
func (*PingRequest) ProtoMessage()
func (*PingRequest) Reset ¶
func (m *PingRequest) Reset()
func (*PingRequest) Size ¶
func (m *PingRequest) Size() (n int)
func (*PingRequest) String ¶
func (m *PingRequest) String() string
func (*PingRequest) Unmarshal ¶
func (m *PingRequest) Unmarshal(dAtA []byte) error
type PingResult ¶
type PingResult struct { }
func NewPopulatedPingResult ¶
func NewPopulatedPingResult(r randyClient, easy bool) *PingResult
func (*PingResult) Descriptor ¶
func (*PingResult) Descriptor() ([]byte, []int)
func (*PingResult) Equal ¶
func (this *PingResult) Equal(that interface{}) bool
func (*PingResult) Marshal ¶
func (m *PingResult) Marshal() (dAtA []byte, err error)
func (*PingResult) ProtoMessage ¶
func (*PingResult) ProtoMessage()
func (*PingResult) Reset ¶
func (m *PingResult) Reset()
func (*PingResult) Size ¶
func (m *PingResult) Size() (n int)
func (*PingResult) String ¶
func (m *PingResult) String() string
func (*PingResult) Unmarshal ¶
func (m *PingResult) Unmarshal(dAtA []byte) error
type PresenceRequest ¶
type PresenceRequest struct {
Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel"`
}
func NewPopulatedPresenceRequest ¶
func NewPopulatedPresenceRequest(r randyClient, easy bool) *PresenceRequest
func (*PresenceRequest) Descriptor ¶
func (*PresenceRequest) Descriptor() ([]byte, []int)
func (*PresenceRequest) Equal ¶
func (this *PresenceRequest) Equal(that interface{}) bool
func (*PresenceRequest) GetChannel ¶
func (m *PresenceRequest) GetChannel() string
func (*PresenceRequest) Marshal ¶
func (m *PresenceRequest) Marshal() (dAtA []byte, err error)
func (*PresenceRequest) ProtoMessage ¶
func (*PresenceRequest) ProtoMessage()
func (*PresenceRequest) Reset ¶
func (m *PresenceRequest) Reset()
func (*PresenceRequest) Size ¶
func (m *PresenceRequest) Size() (n int)
func (*PresenceRequest) String ¶
func (m *PresenceRequest) String() string
func (*PresenceRequest) Unmarshal ¶
func (m *PresenceRequest) Unmarshal(dAtA []byte) error
type PresenceResult ¶
type PresenceResult struct {
Presence map[string]*ClientInfo `` /* 133-byte string literal not displayed */
}
func NewPopulatedPresenceResult ¶
func NewPopulatedPresenceResult(r randyClient, easy bool) *PresenceResult
func (*PresenceResult) Descriptor ¶
func (*PresenceResult) Descriptor() ([]byte, []int)
func (*PresenceResult) Equal ¶
func (this *PresenceResult) Equal(that interface{}) bool
func (*PresenceResult) GetPresence ¶
func (m *PresenceResult) GetPresence() map[string]*ClientInfo
func (*PresenceResult) Marshal ¶
func (m *PresenceResult) Marshal() (dAtA []byte, err error)
func (*PresenceResult) ProtoMessage ¶
func (*PresenceResult) ProtoMessage()
func (*PresenceResult) Reset ¶
func (m *PresenceResult) Reset()
func (*PresenceResult) Size ¶
func (m *PresenceResult) Size() (n int)
func (*PresenceResult) String ¶
func (m *PresenceResult) String() string
func (*PresenceResult) Unmarshal ¶
func (m *PresenceResult) Unmarshal(dAtA []byte) error
type PresenceStatsRequest ¶
type PresenceStatsRequest struct {
Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel"`
}
func NewPopulatedPresenceStatsRequest ¶
func NewPopulatedPresenceStatsRequest(r randyClient, easy bool) *PresenceStatsRequest
func (*PresenceStatsRequest) Descriptor ¶
func (*PresenceStatsRequest) Descriptor() ([]byte, []int)
func (*PresenceStatsRequest) Equal ¶
func (this *PresenceStatsRequest) Equal(that interface{}) bool
func (*PresenceStatsRequest) GetChannel ¶
func (m *PresenceStatsRequest) GetChannel() string
func (*PresenceStatsRequest) Marshal ¶
func (m *PresenceStatsRequest) Marshal() (dAtA []byte, err error)
func (*PresenceStatsRequest) MarshalTo ¶
func (m *PresenceStatsRequest) MarshalTo(dAtA []byte) (int, error)
func (*PresenceStatsRequest) ProtoMessage ¶
func (*PresenceStatsRequest) ProtoMessage()
func (*PresenceStatsRequest) Reset ¶
func (m *PresenceStatsRequest) Reset()
func (*PresenceStatsRequest) Size ¶
func (m *PresenceStatsRequest) Size() (n int)
func (*PresenceStatsRequest) String ¶
func (m *PresenceStatsRequest) String() string
func (*PresenceStatsRequest) Unmarshal ¶
func (m *PresenceStatsRequest) Unmarshal(dAtA []byte) error
type PresenceStatsResult ¶
type PresenceStatsResult struct { NumClients uint32 `protobuf:"varint,1,opt,name=num_clients,json=numClients,proto3" json:"num_clients"` NumUsers uint32 `protobuf:"varint,2,opt,name=num_users,json=numUsers,proto3" json:"num_users"` }
func NewPopulatedPresenceStatsResult ¶
func NewPopulatedPresenceStatsResult(r randyClient, easy bool) *PresenceStatsResult
func (*PresenceStatsResult) Descriptor ¶
func (*PresenceStatsResult) Descriptor() ([]byte, []int)
func (*PresenceStatsResult) Equal ¶
func (this *PresenceStatsResult) Equal(that interface{}) bool
func (*PresenceStatsResult) GetNumClients ¶
func (m *PresenceStatsResult) GetNumClients() uint32
func (*PresenceStatsResult) GetNumUsers ¶
func (m *PresenceStatsResult) GetNumUsers() uint32
func (*PresenceStatsResult) Marshal ¶
func (m *PresenceStatsResult) Marshal() (dAtA []byte, err error)
func (*PresenceStatsResult) MarshalTo ¶
func (m *PresenceStatsResult) MarshalTo(dAtA []byte) (int, error)
func (*PresenceStatsResult) ProtoMessage ¶
func (*PresenceStatsResult) ProtoMessage()
func (*PresenceStatsResult) Reset ¶
func (m *PresenceStatsResult) Reset()
func (*PresenceStatsResult) Size ¶
func (m *PresenceStatsResult) Size() (n int)
func (*PresenceStatsResult) String ¶
func (m *PresenceStatsResult) String() string
func (*PresenceStatsResult) Unmarshal ¶
func (m *PresenceStatsResult) Unmarshal(dAtA []byte) error
type ProtobufCommandEncoder ¶
type ProtobufCommandEncoder struct { }
ProtobufCommandEncoder ...
func NewProtobufCommandEncoder ¶
func NewProtobufCommandEncoder() *ProtobufCommandEncoder
NewProtobufCommandEncoder ...
type ProtobufParamsEncoder ¶
type ProtobufParamsEncoder struct{}
ProtobufParamsEncoder ...
func NewProtobufParamsEncoder ¶
func NewProtobufParamsEncoder() *ProtobufParamsEncoder
NewProtobufParamsEncoder ...
func (*ProtobufParamsEncoder) Encode ¶
func (d *ProtobufParamsEncoder) Encode(r interface{}) ([]byte, error)
Encode ...
type ProtobufPushDecoder ¶
type ProtobufPushDecoder struct { }
ProtobufPushDecoder ...
func NewProtobufPushDecoder ¶
func NewProtobufPushDecoder() *ProtobufPushDecoder
NewProtobufPushDecoder ...
func (*ProtobufPushDecoder) Decode ¶
func (e *ProtobufPushDecoder) Decode(data []byte) (*Push, error)
Decode ...
func (*ProtobufPushDecoder) DecodeJoin ¶
func (e *ProtobufPushDecoder) DecodeJoin(data []byte) (*Join, error)
DecodeJoin ...
func (*ProtobufPushDecoder) DecodeLeave ¶
func (e *ProtobufPushDecoder) DecodeLeave(data []byte) (*Leave, error)
DecodeLeave ...
func (*ProtobufPushDecoder) DecodeMessage ¶
func (e *ProtobufPushDecoder) DecodeMessage(data []byte) (*Message, error)
DecodeMessage ...
func (*ProtobufPushDecoder) DecodePublication ¶
func (e *ProtobufPushDecoder) DecodePublication(data []byte) (*Publication, error)
DecodePublication ...
func (*ProtobufPushDecoder) DecodeUnsub ¶
func (e *ProtobufPushDecoder) DecodeUnsub(data []byte) (*Unsub, error)
DecodeUnsub ...
type ProtobufPushEncoder ¶
type ProtobufPushEncoder struct { }
ProtobufPushEncoder ...
func NewProtobufPushEncoder ¶
func NewProtobufPushEncoder() *ProtobufPushEncoder
NewProtobufPushEncoder ...
func (*ProtobufPushEncoder) Encode ¶
func (e *ProtobufPushEncoder) Encode(message *Push) ([]byte, error)
Encode ...
func (*ProtobufPushEncoder) EncodeJoin ¶
func (e *ProtobufPushEncoder) EncodeJoin(message *Join) ([]byte, error)
EncodeJoin ...
func (*ProtobufPushEncoder) EncodeLeave ¶
func (e *ProtobufPushEncoder) EncodeLeave(message *Leave) ([]byte, error)
EncodeLeave ...
func (*ProtobufPushEncoder) EncodeMessage ¶
func (e *ProtobufPushEncoder) EncodeMessage(message *Message) ([]byte, error)
EncodePush ...
func (*ProtobufPushEncoder) EncodePublication ¶
func (e *ProtobufPushEncoder) EncodePublication(message *Publication) ([]byte, error)
EncodePublication ...
func (*ProtobufPushEncoder) EncodeUnsub ¶
func (e *ProtobufPushEncoder) EncodeUnsub(message *Unsub) ([]byte, error)
EncodeUnsub ...
type ProtobufReplyDecoder ¶
type ProtobufReplyDecoder struct {
// contains filtered or unexported fields
}
ProtobufReplyDecoder ...
func NewProtobufReplyDecoder ¶
func NewProtobufReplyDecoder(data []byte) *ProtobufReplyDecoder
NewProtobufReplyDecoder ...
func (*ProtobufReplyDecoder) Decode ¶
func (d *ProtobufReplyDecoder) Decode() (*Reply, error)
Decode ...
func (*ProtobufReplyDecoder) Reset ¶
func (d *ProtobufReplyDecoder) Reset(data []byte) error
Reset ...
type ProtobufReplyEncoder ¶
type ProtobufReplyEncoder struct {
// contains filtered or unexported fields
}
ProtobufReplyEncoder ...
func NewProtobufReplyEncoder ¶
func NewProtobufReplyEncoder() *ProtobufReplyEncoder
NewProtobufReplyEncoder ...
func (*ProtobufReplyEncoder) Encode ¶
func (e *ProtobufReplyEncoder) Encode(r *Reply) error
Encode ...
type ProtobufResultDecoder ¶
type ProtobufResultDecoder struct{}
ProtobufResultDecoder ...
func NewProtobufResultDecoder ¶
func NewProtobufResultDecoder() *ProtobufResultDecoder
NewProtobufResultDecoder ...
func (*ProtobufResultDecoder) Decode ¶
func (e *ProtobufResultDecoder) Decode(data []byte, dest interface{}) error
Decode ...
type Publication ¶
type Publication struct { Seq uint32 `protobuf:"varint,1,opt,name=seq,proto3" json:"seq,omitempty"` Gen uint32 `protobuf:"varint,2,opt,name=gen,proto3" json:"gen,omitempty"` UID string `protobuf:"bytes,3,opt,name=uid,proto3" json:"uid,omitempty"` Data Raw `protobuf:"bytes,4,opt,name=data,proto3,customtype=Raw" json:"data"` Info *ClientInfo `protobuf:"bytes,5,opt,name=info" json:"info,omitempty"` }
func NewPopulatedPublication ¶
func NewPopulatedPublication(r randyClient, easy bool) *Publication
func (*Publication) Descriptor ¶
func (*Publication) Descriptor() ([]byte, []int)
func (*Publication) Equal ¶
func (this *Publication) Equal(that interface{}) bool
func (*Publication) GetGen ¶
func (m *Publication) GetGen() uint32
func (*Publication) GetInfo ¶
func (m *Publication) GetInfo() *ClientInfo
func (*Publication) GetSeq ¶
func (m *Publication) GetSeq() uint32
func (*Publication) GetUID ¶
func (m *Publication) GetUID() string
func (*Publication) Marshal ¶
func (m *Publication) Marshal() (dAtA []byte, err error)
func (*Publication) ProtoMessage ¶
func (*Publication) ProtoMessage()
func (*Publication) Reset ¶
func (m *Publication) Reset()
func (*Publication) Size ¶
func (m *Publication) Size() (n int)
func (*Publication) String ¶
func (m *Publication) String() string
func (*Publication) Unmarshal ¶
func (m *Publication) Unmarshal(dAtA []byte) error
type PublishRequest ¶
type PublishRequest struct { Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel"` Data Raw `protobuf:"bytes,2,opt,name=data,proto3,customtype=Raw" json:"data"` }
func NewPopulatedPublishRequest ¶
func NewPopulatedPublishRequest(r randyClient, easy bool) *PublishRequest
func (*PublishRequest) Descriptor ¶
func (*PublishRequest) Descriptor() ([]byte, []int)
func (*PublishRequest) Equal ¶
func (this *PublishRequest) Equal(that interface{}) bool
func (*PublishRequest) GetChannel ¶
func (m *PublishRequest) GetChannel() string
func (*PublishRequest) Marshal ¶
func (m *PublishRequest) Marshal() (dAtA []byte, err error)
func (*PublishRequest) ProtoMessage ¶
func (*PublishRequest) ProtoMessage()
func (*PublishRequest) Reset ¶
func (m *PublishRequest) Reset()
func (*PublishRequest) Size ¶
func (m *PublishRequest) Size() (n int)
func (*PublishRequest) String ¶
func (m *PublishRequest) String() string
func (*PublishRequest) Unmarshal ¶
func (m *PublishRequest) Unmarshal(dAtA []byte) error
type PublishResult ¶
type PublishResult struct { }
func NewPopulatedPublishResult ¶
func NewPopulatedPublishResult(r randyClient, easy bool) *PublishResult
func (*PublishResult) Descriptor ¶
func (*PublishResult) Descriptor() ([]byte, []int)
func (*PublishResult) Equal ¶
func (this *PublishResult) Equal(that interface{}) bool
func (*PublishResult) Marshal ¶
func (m *PublishResult) Marshal() (dAtA []byte, err error)
func (*PublishResult) ProtoMessage ¶
func (*PublishResult) ProtoMessage()
func (*PublishResult) Reset ¶
func (m *PublishResult) Reset()
func (*PublishResult) Size ¶
func (m *PublishResult) Size() (n int)
func (*PublishResult) String ¶
func (m *PublishResult) String() string
func (*PublishResult) Unmarshal ¶
func (m *PublishResult) Unmarshal(dAtA []byte) error
type Push ¶
type Push struct { Type PushType `protobuf:"varint,1,opt,name=type,proto3,enum=proto.PushType" json:"type,omitempty"` Channel string `protobuf:"bytes,2,opt,name=channel,proto3" json:"channel,omitempty"` Data Raw `protobuf:"bytes,3,opt,name=data,proto3,customtype=Raw" json:"data"` }
func NewPopulatedPush ¶
func (*Push) Descriptor ¶
func (*Push) GetChannel ¶
func (*Push) ProtoMessage ¶
func (*Push) ProtoMessage()
type PushDecoder ¶
type PushDecoder interface { Decode([]byte) (*Push, error) DecodePublication([]byte) (*Publication, error) DecodeJoin([]byte) (*Join, error) DecodeLeave([]byte) (*Leave, error) DecodeMessage([]byte) (*Message, error) DecodeUnsub([]byte) (*Unsub, error) }
PushDecoder ...
type PushEncoder ¶
type PushEncoder interface { Encode(*Push) ([]byte, error) EncodeMessage(*Message) ([]byte, error) EncodePublication(*Publication) ([]byte, error) EncodeJoin(*Join) ([]byte, error) EncodeLeave(*Leave) ([]byte, error) EncodeUnsub(*Unsub) ([]byte, error) }
PushEncoder ...
type RPCRequest ¶
type RPCRequest struct {
Data Raw `protobuf:"bytes,1,opt,name=data,proto3,customtype=Raw" json:"data"`
}
func NewPopulatedRPCRequest ¶
func NewPopulatedRPCRequest(r randyClient, easy bool) *RPCRequest
func (*RPCRequest) Descriptor ¶
func (*RPCRequest) Descriptor() ([]byte, []int)
func (*RPCRequest) Equal ¶
func (this *RPCRequest) Equal(that interface{}) bool
func (*RPCRequest) Marshal ¶
func (m *RPCRequest) Marshal() (dAtA []byte, err error)
func (*RPCRequest) ProtoMessage ¶
func (*RPCRequest) ProtoMessage()
func (*RPCRequest) Reset ¶
func (m *RPCRequest) Reset()
func (*RPCRequest) Size ¶
func (m *RPCRequest) Size() (n int)
func (*RPCRequest) String ¶
func (m *RPCRequest) String() string
func (*RPCRequest) Unmarshal ¶
func (m *RPCRequest) Unmarshal(dAtA []byte) error
type RPCResult ¶
type RPCResult struct {
Data Raw `protobuf:"bytes,1,opt,name=data,proto3,customtype=Raw" json:"data,omitempty"`
}
func NewPopulatedRPCResult ¶
func (*RPCResult) Descriptor ¶
func (*RPCResult) ProtoMessage ¶
func (*RPCResult) ProtoMessage()
type Raw ¶
type Raw []byte
Raw type used by Centrifugo as type for fields in structs which value we want to left untouched. For example custom application specific JSON payload data in published message. This is very similar to json.RawMessage type but have some extra methods to fit gogoprotobuf custom type interface.
func NewPopulatedRaw ¶
func NewPopulatedRaw(r intn) *Raw
NewPopulatedRaw required for gogoprotobuf custom type.
func (Raw) Marshal ¶
Marshal encodes Raw to slice of bytes. Exists to fit gogoprotobuf custom type interface.
func (Raw) MarshalJSON ¶
MarshalJSON returns *r as the JSON encoding of r.
func (*Raw) UnmarshalJSON ¶
UnmarshalJSON sets *r to a copy of data.
type RefreshRequest ¶
type RefreshRequest struct {
Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token"`
}
func NewPopulatedRefreshRequest ¶
func NewPopulatedRefreshRequest(r randyClient, easy bool) *RefreshRequest
func (*RefreshRequest) Descriptor ¶
func (*RefreshRequest) Descriptor() ([]byte, []int)
func (*RefreshRequest) Equal ¶
func (this *RefreshRequest) Equal(that interface{}) bool
func (*RefreshRequest) GetToken ¶
func (m *RefreshRequest) GetToken() string
func (*RefreshRequest) Marshal ¶
func (m *RefreshRequest) Marshal() (dAtA []byte, err error)
func (*RefreshRequest) ProtoMessage ¶
func (*RefreshRequest) ProtoMessage()
func (*RefreshRequest) Reset ¶
func (m *RefreshRequest) Reset()
func (*RefreshRequest) Size ¶
func (m *RefreshRequest) Size() (n int)
func (*RefreshRequest) String ¶
func (m *RefreshRequest) String() string
func (*RefreshRequest) Unmarshal ¶
func (m *RefreshRequest) Unmarshal(dAtA []byte) error
type RefreshResult ¶
type RefreshResult struct { Client string `protobuf:"bytes,1,opt,name=client,proto3" json:"client"` Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version"` Expires bool `protobuf:"varint,3,opt,name=expires,proto3" json:"expires,omitempty"` TTL uint32 `protobuf:"varint,4,opt,name=ttl,proto3" json:"ttl,omitempty"` }
func NewPopulatedRefreshResult ¶
func NewPopulatedRefreshResult(r randyClient, easy bool) *RefreshResult
func (*RefreshResult) Descriptor ¶
func (*RefreshResult) Descriptor() ([]byte, []int)
func (*RefreshResult) Equal ¶
func (this *RefreshResult) Equal(that interface{}) bool
func (*RefreshResult) GetClient ¶
func (m *RefreshResult) GetClient() string
func (*RefreshResult) GetExpires ¶
func (m *RefreshResult) GetExpires() bool
func (*RefreshResult) GetTTL ¶
func (m *RefreshResult) GetTTL() uint32
func (*RefreshResult) GetVersion ¶
func (m *RefreshResult) GetVersion() string
func (*RefreshResult) Marshal ¶
func (m *RefreshResult) Marshal() (dAtA []byte, err error)
func (*RefreshResult) ProtoMessage ¶
func (*RefreshResult) ProtoMessage()
func (*RefreshResult) Reset ¶
func (m *RefreshResult) Reset()
func (*RefreshResult) Size ¶
func (m *RefreshResult) Size() (n int)
func (*RefreshResult) String ¶
func (m *RefreshResult) String() string
func (*RefreshResult) Unmarshal ¶
func (m *RefreshResult) Unmarshal(dAtA []byte) error
type Reply ¶
type Reply struct { ID uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Error *Error `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"` Result Raw `protobuf:"bytes,3,opt,name=result,proto3,customtype=Raw" json:"result,omitempty"` }
func NewPopulatedReply ¶
func (*Reply) Descriptor ¶
func (*Reply) ProtoMessage ¶
func (*Reply) ProtoMessage()
type ReplyDecoder ¶
ReplyDecoder ...
func NewReplyDecoder ¶
func NewReplyDecoder(enc Encoding, data []byte) ReplyDecoder
NewReplyDecoder ...
type ReplyEncoder ¶
ReplyEncoder ...
type ResultDecoder ¶
ResultDecoder ...
type SendRequest ¶
type SendRequest struct {
Data Raw `protobuf:"bytes,1,opt,name=data,proto3,customtype=Raw" json:"data"`
}
func NewPopulatedSendRequest ¶
func NewPopulatedSendRequest(r randyClient, easy bool) *SendRequest
func (*SendRequest) Descriptor ¶
func (*SendRequest) Descriptor() ([]byte, []int)
func (*SendRequest) Equal ¶
func (this *SendRequest) Equal(that interface{}) bool
func (*SendRequest) Marshal ¶
func (m *SendRequest) Marshal() (dAtA []byte, err error)
func (*SendRequest) ProtoMessage ¶
func (*SendRequest) ProtoMessage()
func (*SendRequest) Reset ¶
func (m *SendRequest) Reset()
func (*SendRequest) Size ¶
func (m *SendRequest) Size() (n int)
func (*SendRequest) String ¶
func (m *SendRequest) String() string
func (*SendRequest) Unmarshal ¶
func (m *SendRequest) Unmarshal(dAtA []byte) error
type SubRefreshRequest ¶
type SubRefreshRequest struct { Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel"` Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token"` }
func NewPopulatedSubRefreshRequest ¶
func NewPopulatedSubRefreshRequest(r randyClient, easy bool) *SubRefreshRequest
func (*SubRefreshRequest) Descriptor ¶
func (*SubRefreshRequest) Descriptor() ([]byte, []int)
func (*SubRefreshRequest) Equal ¶
func (this *SubRefreshRequest) Equal(that interface{}) bool
func (*SubRefreshRequest) GetChannel ¶
func (m *SubRefreshRequest) GetChannel() string
func (*SubRefreshRequest) GetToken ¶
func (m *SubRefreshRequest) GetToken() string
func (*SubRefreshRequest) Marshal ¶
func (m *SubRefreshRequest) Marshal() (dAtA []byte, err error)
func (*SubRefreshRequest) MarshalTo ¶
func (m *SubRefreshRequest) MarshalTo(dAtA []byte) (int, error)
func (*SubRefreshRequest) ProtoMessage ¶
func (*SubRefreshRequest) ProtoMessage()
func (*SubRefreshRequest) Reset ¶
func (m *SubRefreshRequest) Reset()
func (*SubRefreshRequest) Size ¶
func (m *SubRefreshRequest) Size() (n int)
func (*SubRefreshRequest) String ¶
func (m *SubRefreshRequest) String() string
func (*SubRefreshRequest) Unmarshal ¶
func (m *SubRefreshRequest) Unmarshal(dAtA []byte) error
type SubRefreshResult ¶
type SubRefreshResult struct { Expires bool `protobuf:"varint,1,opt,name=expires,proto3" json:"expires,omitempty"` TTL uint32 `protobuf:"varint,2,opt,name=ttl,proto3" json:"ttl,omitempty"` }
func NewPopulatedSubRefreshResult ¶
func NewPopulatedSubRefreshResult(r randyClient, easy bool) *SubRefreshResult
func (*SubRefreshResult) Descriptor ¶
func (*SubRefreshResult) Descriptor() ([]byte, []int)
func (*SubRefreshResult) Equal ¶
func (this *SubRefreshResult) Equal(that interface{}) bool
func (*SubRefreshResult) GetExpires ¶
func (m *SubRefreshResult) GetExpires() bool
func (*SubRefreshResult) GetTTL ¶
func (m *SubRefreshResult) GetTTL() uint32
func (*SubRefreshResult) Marshal ¶
func (m *SubRefreshResult) Marshal() (dAtA []byte, err error)
func (*SubRefreshResult) ProtoMessage ¶
func (*SubRefreshResult) ProtoMessage()
func (*SubRefreshResult) Reset ¶
func (m *SubRefreshResult) Reset()
func (*SubRefreshResult) Size ¶
func (m *SubRefreshResult) Size() (n int)
func (*SubRefreshResult) String ¶
func (m *SubRefreshResult) String() string
func (*SubRefreshResult) Unmarshal ¶
func (m *SubRefreshResult) Unmarshal(dAtA []byte) error
type SubscribeRequest ¶
type SubscribeRequest struct { Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel"` Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token"` Recover bool `protobuf:"varint,3,opt,name=recover,proto3" json:"recover"` Seq uint32 `protobuf:"varint,4,opt,name=seq,proto3" json:"seq"` Gen uint32 `protobuf:"varint,5,opt,name=gen,proto3" json:"gen"` Epoch string `protobuf:"bytes,6,opt,name=epoch,proto3" json:"epoch"` }
func NewPopulatedSubscribeRequest ¶
func NewPopulatedSubscribeRequest(r randyClient, easy bool) *SubscribeRequest
func (*SubscribeRequest) Descriptor ¶
func (*SubscribeRequest) Descriptor() ([]byte, []int)
func (*SubscribeRequest) Equal ¶
func (this *SubscribeRequest) Equal(that interface{}) bool
func (*SubscribeRequest) GetChannel ¶
func (m *SubscribeRequest) GetChannel() string
func (*SubscribeRequest) GetEpoch ¶
func (m *SubscribeRequest) GetEpoch() string
func (*SubscribeRequest) GetGen ¶
func (m *SubscribeRequest) GetGen() uint32
func (*SubscribeRequest) GetRecover ¶
func (m *SubscribeRequest) GetRecover() bool
func (*SubscribeRequest) GetSeq ¶
func (m *SubscribeRequest) GetSeq() uint32
func (*SubscribeRequest) GetToken ¶
func (m *SubscribeRequest) GetToken() string
func (*SubscribeRequest) Marshal ¶
func (m *SubscribeRequest) Marshal() (dAtA []byte, err error)
func (*SubscribeRequest) ProtoMessage ¶
func (*SubscribeRequest) ProtoMessage()
func (*SubscribeRequest) Reset ¶
func (m *SubscribeRequest) Reset()
func (*SubscribeRequest) Size ¶
func (m *SubscribeRequest) Size() (n int)
func (*SubscribeRequest) String ¶
func (m *SubscribeRequest) String() string
func (*SubscribeRequest) Unmarshal ¶
func (m *SubscribeRequest) Unmarshal(dAtA []byte) error
type SubscribeResult ¶
type SubscribeResult struct { Expires bool `protobuf:"varint,1,opt,name=expires,proto3" json:"expires,omitempty"` TTL uint32 `protobuf:"varint,2,opt,name=ttl,proto3" json:"ttl,omitempty"` Recoverable bool `protobuf:"varint,3,opt,name=recoverable,proto3" json:"recoverable,omitempty"` Seq uint32 `protobuf:"varint,4,opt,name=seq,proto3" json:"seq,omitempty"` Gen uint32 `protobuf:"varint,5,opt,name=gen,proto3" json:"gen,omitempty"` Epoch string `protobuf:"bytes,6,opt,name=epoch,proto3" json:"epoch,omitempty"` Publications []*Publication `protobuf:"bytes,7,rep,name=publications" json:"publications,omitempty"` Recovered bool `protobuf:"varint,8,opt,name=recovered,proto3" json:"recovered,omitempty"` }
func NewPopulatedSubscribeResult ¶
func NewPopulatedSubscribeResult(r randyClient, easy bool) *SubscribeResult
func (*SubscribeResult) Descriptor ¶
func (*SubscribeResult) Descriptor() ([]byte, []int)
func (*SubscribeResult) Equal ¶
func (this *SubscribeResult) Equal(that interface{}) bool
func (*SubscribeResult) GetEpoch ¶
func (m *SubscribeResult) GetEpoch() string
func (*SubscribeResult) GetExpires ¶
func (m *SubscribeResult) GetExpires() bool
func (*SubscribeResult) GetGen ¶
func (m *SubscribeResult) GetGen() uint32
func (*SubscribeResult) GetPublications ¶
func (m *SubscribeResult) GetPublications() []*Publication
func (*SubscribeResult) GetRecoverable ¶
func (m *SubscribeResult) GetRecoverable() bool
func (*SubscribeResult) GetRecovered ¶
func (m *SubscribeResult) GetRecovered() bool
func (*SubscribeResult) GetSeq ¶
func (m *SubscribeResult) GetSeq() uint32
func (*SubscribeResult) GetTTL ¶
func (m *SubscribeResult) GetTTL() uint32
func (*SubscribeResult) Marshal ¶
func (m *SubscribeResult) Marshal() (dAtA []byte, err error)
func (*SubscribeResult) ProtoMessage ¶
func (*SubscribeResult) ProtoMessage()
func (*SubscribeResult) Reset ¶
func (m *SubscribeResult) Reset()
func (*SubscribeResult) Size ¶
func (m *SubscribeResult) Size() (n int)
func (*SubscribeResult) String ¶
func (m *SubscribeResult) String() string
func (*SubscribeResult) Unmarshal ¶
func (m *SubscribeResult) Unmarshal(dAtA []byte) error
type Unsub ¶
type Unsub struct {
Resubscribe bool `protobuf:"varint,1,opt,name=resubscribe,proto3" json:"resubscribe,omitempty"`
}
func NewPopulatedUnsub ¶
func (*Unsub) Descriptor ¶
func (*Unsub) GetResubscribe ¶
func (*Unsub) ProtoMessage ¶
func (*Unsub) ProtoMessage()
type UnsubscribeRequest ¶
type UnsubscribeRequest struct {
Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel"`
}
func NewPopulatedUnsubscribeRequest ¶
func NewPopulatedUnsubscribeRequest(r randyClient, easy bool) *UnsubscribeRequest
func (*UnsubscribeRequest) Descriptor ¶
func (*UnsubscribeRequest) Descriptor() ([]byte, []int)
func (*UnsubscribeRequest) Equal ¶
func (this *UnsubscribeRequest) Equal(that interface{}) bool
func (*UnsubscribeRequest) GetChannel ¶
func (m *UnsubscribeRequest) GetChannel() string
func (*UnsubscribeRequest) Marshal ¶
func (m *UnsubscribeRequest) Marshal() (dAtA []byte, err error)
func (*UnsubscribeRequest) MarshalTo ¶
func (m *UnsubscribeRequest) MarshalTo(dAtA []byte) (int, error)
func (*UnsubscribeRequest) ProtoMessage ¶
func (*UnsubscribeRequest) ProtoMessage()
func (*UnsubscribeRequest) Reset ¶
func (m *UnsubscribeRequest) Reset()
func (*UnsubscribeRequest) Size ¶
func (m *UnsubscribeRequest) Size() (n int)
func (*UnsubscribeRequest) String ¶
func (m *UnsubscribeRequest) String() string
func (*UnsubscribeRequest) Unmarshal ¶
func (m *UnsubscribeRequest) Unmarshal(dAtA []byte) error
type UnsubscribeResult ¶
type UnsubscribeResult struct { }
func NewPopulatedUnsubscribeResult ¶
func NewPopulatedUnsubscribeResult(r randyClient, easy bool) *UnsubscribeResult
func (*UnsubscribeResult) Descriptor ¶
func (*UnsubscribeResult) Descriptor() ([]byte, []int)
func (*UnsubscribeResult) Equal ¶
func (this *UnsubscribeResult) Equal(that interface{}) bool
func (*UnsubscribeResult) Marshal ¶
func (m *UnsubscribeResult) Marshal() (dAtA []byte, err error)
func (*UnsubscribeResult) MarshalTo ¶
func (m *UnsubscribeResult) MarshalTo(dAtA []byte) (int, error)
func (*UnsubscribeResult) ProtoMessage ¶
func (*UnsubscribeResult) ProtoMessage()
func (*UnsubscribeResult) Reset ¶
func (m *UnsubscribeResult) Reset()
func (*UnsubscribeResult) Size ¶
func (m *UnsubscribeResult) Size() (n int)
func (*UnsubscribeResult) String ¶
func (m *UnsubscribeResult) String() string
func (*UnsubscribeResult) Unmarshal ¶
func (m *UnsubscribeResult) Unmarshal(dAtA []byte) error