proto

package
v0.2.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 4, 2019 License: MIT Imports: 12 Imported by: 0

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

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthClient = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowClient   = fmt.Errorf("proto: integer overflow")
)
View Source 
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",
}
View Source 
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,
}
View Source 
var PushType_name = map[int32]string{
	0: "PUBLICATION",
	1: "JOIN",
	2: "LEAVE",
	3: "UNSUB",
	4: "MESSAGE",
}
View Source 
var PushType_value = map[string]int32{
	"PUBLICATION": 0,
	"JOIN":        1,
	"LEAVE":       2,
	"UNSUB":       3,
	"MESSAGE":     4,
}

Functions

func PutReplyEncoder 

func PutReplyEncoder(enc Encoding, e ReplyEncoder)

PutReplyEncoder ...

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

func (m *ClientInfo) MarshalTo(dAtA []byte) (int, 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 NewPopulatedCommand(r randyClient, easy bool) *Command

func (*Command) Descriptor 

func (*Command) Descriptor() ([]byte, []int)

func (*Command) Equal 

func (this *Command) Equal(that interface{}) bool

func (*Command) GetID 

func (m *Command) GetID() uint32

func (*Command) GetMethod 

func (m *Command) GetMethod() MethodType

func (*Command) Marshal 

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

func (*Command) MarshalTo 

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

func (*Command) ProtoMessage 

func (*Command) ProtoMessage()

func (*Command) Reset 

func (m *Command) Reset()

func (*Command) Size 

func (m *Command) Size() (n int)

func (*Command) String 

func (m *Command) String() string

func (*Command) Unmarshal 

func (m *Command) Unmarshal(dAtA []byte) error

type CommandEncoder 

type CommandEncoder interface {
	Encode(cmd *Command) ([]byte, error)
}

CommandEncoder ...

func NewCommandEncoder 

func NewCommandEncoder(enc Encoding) CommandEncoder

NewCommandEncoder ...

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

func (m *ConnectRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *ConnectResult) MarshalTo(dAtA []byte) (int, 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 Encoding 

type Encoding int

Encoding determines connection protocol encoding in use. 

const (
	// EncodingJSON means JSON protocol.
	EncodingJSON Encoding = 0
	// EncodingProtobuf means protobuf protocol.
	EncodingProtobuf Encoding = 1
)

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 NewPopulatedError(r randyClient, easy bool) *Error

func (*Error) Descriptor 

func (*Error) Descriptor() ([]byte, []int)

func (*Error) Equal 

func (this *Error) Equal(that interface{}) bool

func (Error) Error 

func (e Error) Error() string

func (*Error) GetCode 

func (m *Error) GetCode() uint32

func (*Error) GetMessage 

func (m *Error) GetMessage() string

func (*Error) Marshal 

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

func (*Error) MarshalTo 

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

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) Size 

func (m *Error) Size() (n int)

func (*Error) String 

func (m *Error) String() string

func (*Error) Unmarshal 

func (m *Error) Unmarshal(dAtA []byte) error

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

func (m *HistoryRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *HistoryResult) MarshalTo(dAtA []byte) (int, 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 ...

func (*JSONCommandEncoder) Encode 

func (e *JSONCommandEncoder) Encode(cmd *Command) ([]byte, error)

Encode ...

type JSONParamsEncoder 

type JSONParamsEncoder struct{}

JSONParamsEncoder ...

func NewJSONParamsEncoder 

func NewJSONParamsEncoder() *JSONParamsEncoder

NewJSONParamsEncoder ...

func (*JSONParamsEncoder) Encode 

func (d *JSONParamsEncoder) Encode(r interface{}) ([]byte, error)

Encode ...

type JSONPushDecoder 

type JSONPushDecoder struct {
}

JSONPushDecoder ...

func NewJSONPushDecoder 

func NewJSONPushDecoder() *JSONPushDecoder

NewJSONPushDecoder ...

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 NewJSONPushEncoder 

func NewJSONPushEncoder() *JSONPushEncoder

NewJSONPushEncoder ...

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 ...

func (*JSONReplyDecoder) Decode 

func (d *JSONReplyDecoder) Decode() (*Reply, error)

Decode ...

func (*JSONReplyDecoder) Reset 

func (d *JSONReplyDecoder) Reset(data []byte) error

Reset ...

type JSONReplyEncoder 

type JSONReplyEncoder struct {
	// contains filtered or unexported fields
}

JSONReplyEncoder ...

func NewJSONReplyEncoder 

func NewJSONReplyEncoder() *JSONReplyEncoder

NewJSONReplyEncoder ...

func (*JSONReplyEncoder) Encode 

func (e *JSONReplyEncoder) Encode(r *Reply) error

Encode ...

func (*JSONReplyEncoder) Finish 

func (e *JSONReplyEncoder) Finish() []byte

Finish ...

func (*JSONReplyEncoder) Reset 

func (e *JSONReplyEncoder) Reset()

Reset ...

type JSONResultDecoder 

type JSONResultDecoder struct{}

JSONResultDecoder ...

func NewJSONResultDecoder 

func NewJSONResultDecoder() *JSONResultDecoder

NewJSONResultDecoder ...

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 NewPopulatedJoin(r randyClient, easy bool) *Join

func (*Join) Descriptor 

func (*Join) Descriptor() ([]byte, []int)

func (*Join) Equal 

func (this *Join) Equal(that interface{}) bool

func (*Join) GetInfo 

func (m *Join) GetInfo() ClientInfo

func (*Join) Marshal 

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

func (*Join) MarshalTo 

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

func (*Join) ProtoMessage 

func (*Join) ProtoMessage()

func (*Join) Reset 

func (m *Join) Reset()

func (*Join) Size 

func (m *Join) Size() (n int)

func (*Join) String 

func (m *Join) String() string

func (*Join) Unmarshal 

func (m *Join) Unmarshal(dAtA []byte) error

type Leave 

type Leave struct {
	Info ClientInfo `protobuf:"bytes,1,opt,name=info" json:"info"`
}

func NewPopulatedLeave 

func NewPopulatedLeave(r randyClient, easy bool) *Leave

func (*Leave) Descriptor 

func (*Leave) Descriptor() ([]byte, []int)

func (*Leave) Equal 

func (this *Leave) Equal(that interface{}) bool

func (*Leave) GetInfo 

func (m *Leave) GetInfo() ClientInfo

func (*Leave) Marshal 

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

func (*Leave) MarshalTo 

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

func (*Leave) ProtoMessage 

func (*Leave) ProtoMessage()

func (*Leave) Reset 

func (m *Leave) Reset()

func (*Leave) Size 

func (m *Leave) Size() (n int)

func (*Leave) String 

func (m *Leave) String() string

func (*Leave) Unmarshal 

func (m *Leave) Unmarshal(dAtA []byte) error

type Message 

type Message struct {
	Data Raw `protobuf:"bytes,1,opt,name=data,proto3,customtype=Raw" json:"data"`
}

func NewPopulatedMessage 

func NewPopulatedMessage(r randyClient, easy bool) *Message

func (*Message) Descriptor 

func (*Message) Descriptor() ([]byte, []int)

func (*Message) Equal 

func (this *Message) Equal(that interface{}) bool

func (*Message) Marshal 

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

func (*Message) MarshalTo 

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

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) Size 

func (m *Message) Size() (n int)

func (*Message) String 

func (m *Message) String() string

func (*Message) Unmarshal 

func (m *Message) Unmarshal(dAtA []byte) error

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 

type ParamsEncoder interface {
	Encode(request interface{}) ([]byte, error)
}

ParamsEncoder ...

func NewParamsEncoder 

func NewParamsEncoder(enc Encoding) ParamsEncoder

NewParamsEncoder ...

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

func (m *PingRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *PingResult) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *PresenceRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *PresenceResult) MarshalTo(dAtA []byte) (int, 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 ...

func (*ProtobufCommandEncoder) Encode 

func (e *ProtobufCommandEncoder) Encode(cmd *Command) ([]byte, error)

Encode ...

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 ...

func (*ProtobufReplyEncoder) Finish 

func (e *ProtobufReplyEncoder) Finish() []byte

Finish ...

func (*ProtobufReplyEncoder) Reset 

func (e *ProtobufReplyEncoder) Reset()

Reset ...

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

func (m *Publication) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *PublishRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *PublishResult) MarshalTo(dAtA []byte) (int, 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 NewPopulatedPush(r randyClient, easy bool) *Push

func (*Push) Descriptor 

func (*Push) Descriptor() ([]byte, []int)

func (*Push) Equal 

func (this *Push) Equal(that interface{}) bool

func (*Push) GetChannel 

func (m *Push) GetChannel() string

func (*Push) GetType 

func (m *Push) GetType() PushType

func (*Push) Marshal 

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

func (*Push) MarshalTo 

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

func (*Push) ProtoMessage 

func (*Push) ProtoMessage()

func (*Push) Reset 

func (m *Push) Reset()

func (*Push) Size 

func (m *Push) Size() (n int)

func (*Push) String 

func (m *Push) String() string

func (*Push) Unmarshal 

func (m *Push) Unmarshal(dAtA []byte) error

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 ...

func NewPushDecoder 

func NewPushDecoder(enc Encoding) PushDecoder

NewPushDecoder ...

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 ...

func NewPushEncoder 

func NewPushEncoder(enc Encoding) PushEncoder

NewPushEncoder ...

type PushType 

type PushType int32
const (
	PushTypePublication PushType = 0
	PushTypeJoin        PushType = 1
	PushTypeLeave       PushType = 2
	PushTypeUnsub       PushType = 3
	PushTypeMessage     PushType = 4
)

func (PushType) EnumDescriptor 

func (PushType) EnumDescriptor() ([]byte, []int)

func (PushType) String 

func (x PushType) String() string

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

func (m *RPCRequest) MarshalTo(dAtA []byte) (int, 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 NewPopulatedRPCResult(r randyClient, easy bool) *RPCResult

func (*RPCResult) Descriptor 

func (*RPCResult) Descriptor() ([]byte, []int)

func (*RPCResult) Equal 

func (this *RPCResult) Equal(that interface{}) bool

func (*RPCResult) Marshal 

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

func (*RPCResult) MarshalTo 

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

func (*RPCResult) ProtoMessage 

func (*RPCResult) ProtoMessage()

func (*RPCResult) Reset 

func (m *RPCResult) Reset()

func (*RPCResult) Size 

func (m *RPCResult) Size() (n int)

func (*RPCResult) String 

func (m *RPCResult) String() string

func (*RPCResult) Unmarshal 

func (m *RPCResult) Unmarshal(dAtA []byte) error

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

func (r Raw) Compare(other Raw) int

Compare exists to fit gogoprotobuf custom type interface.

func (Raw) Equal 

func (r Raw) Equal(other Raw) bool

Equal exists to fit gogoprotobuf custom type interface.

func (Raw) Marshal 

func (r Raw) Marshal() ([]byte, error)

Marshal encodes Raw to slice of bytes. Exists to fit gogoprotobuf custom type interface.

func (Raw) MarshalJSON 

func (r Raw) MarshalJSON() ([]byte, error)

MarshalJSON returns *r as the JSON encoding of r.

func (Raw) MarshalTo 

func (r Raw) MarshalTo(data []byte) (n int, err error)

MarshalTo exists to fit gogoprotobuf custom type interface.

func (*Raw) Size 

func (r *Raw) Size() int

Size exists to fit gogoprotobuf custom type interface.

func (*Raw) Unmarshal 

func (r *Raw) Unmarshal(data []byte) error

Unmarshal exists to fit gogoprotobuf custom type interface.

func (*Raw) UnmarshalJSON 

func (r *Raw) UnmarshalJSON(data []byte) error

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

func (m *RefreshRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *RefreshResult) MarshalTo(dAtA []byte) (int, 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 NewPopulatedReply(r randyClient, easy bool) *Reply

func (*Reply) Descriptor 

func (*Reply) Descriptor() ([]byte, []int)

func (*Reply) Equal 

func (this *Reply) Equal(that interface{}) bool

func (*Reply) GetError 

func (m *Reply) GetError() *Error

func (*Reply) GetID 

func (m *Reply) GetID() uint32

func (*Reply) Marshal 

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

func (*Reply) MarshalTo 

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

func (*Reply) ProtoMessage 

func (*Reply) ProtoMessage()

func (*Reply) Reset 

func (m *Reply) Reset()

func (*Reply) Size 

func (m *Reply) Size() (n int)

func (*Reply) String 

func (m *Reply) String() string

func (*Reply) Unmarshal 

func (m *Reply) Unmarshal(dAtA []byte) error

type ReplyDecoder 

type ReplyDecoder interface {
	Reset([]byte) error
	Decode() (*Reply, error)
}

ReplyDecoder ...

func NewReplyDecoder 

func NewReplyDecoder(enc Encoding, data []byte) ReplyDecoder

NewReplyDecoder ...

type ReplyEncoder 

type ReplyEncoder interface {
	Reset()
	Encode(*Reply) error
	Finish() []byte
}

ReplyEncoder ...

func GetReplyEncoder 

func GetReplyEncoder(enc Encoding) ReplyEncoder

GetReplyEncoder ...

type ResultDecoder 

type ResultDecoder interface {
	Decode([]byte, interface{}) error
}

ResultDecoder ...

func NewResultDecoder 

func NewResultDecoder(enc Encoding) ResultDecoder

NewResultDecoder ...

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

func (m *SendRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *SubRefreshResult) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *SubscribeRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *SubscribeResult) MarshalTo(dAtA []byte) (int, 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 NewPopulatedUnsub(r randyClient, easy bool) *Unsub

func (*Unsub) Descriptor 

func (*Unsub) Descriptor() ([]byte, []int)

func (*Unsub) Equal 

func (this *Unsub) Equal(that interface{}) bool

func (*Unsub) GetResubscribe 

func (m *Unsub) GetResubscribe() bool

func (*Unsub) Marshal 

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

func (*Unsub) MarshalTo 

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

func (*Unsub) ProtoMessage 

func (*Unsub) ProtoMessage()

func (*Unsub) Reset 

func (m *Unsub) Reset()

func (*Unsub) Size 

func (m *Unsub) Size() (n int)

func (*Unsub) String 

func (m *Unsub) String() string

func (*Unsub) Unmarshal 

func (m *Unsub) Unmarshal(dAtA []byte) error

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.