proto

package
v0.0.0-...-b165c23 Latest Latest
Warning

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

 Go to latest Published: Nov 16, 2018 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 PutCommandDecoder 

func PutCommandDecoder(enc Encoding, e CommandDecoder)

PutCommandDecoder ...

func PutParamsDecoder 

func PutParamsDecoder(enc Encoding, e ParamsDecoder)

PutParamsDecoder ...

func PutReplyEncoder 

func PutReplyEncoder(enc Encoding, e ReplyEncoder)

PutReplyEncoder ...

func PutResultEncoder 

func PutResultEncoder(enc Encoding, e ReplyEncoder)

PutResultEncoder ...

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 CommandDecoder 

type CommandDecoder interface {
	Reset([]byte) error
	Decode() (*Command, error)
}

CommandDecoder ...

func GetCommandDecoder 

func GetCommandDecoder(enc Encoding, data []byte) CommandDecoder

GetCommandDecoder ...

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 ConnectResponse 

type ConnectResponse struct {
	Error  *Error         `json:"error,omitempty"`
	Result *ConnectResult `json:"result,omitempty"`
}

ConnectResponse ...

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 string

Encoding determines connection protocol encoding in use. 

const (
	// EncodingJSON means JSON protocol.
	EncodingJSON Encoding = "json"
	// EncodingProtobuf means protobuf protocol.
	EncodingProtobuf Encoding = "protobuf"
)

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 HistoryResponse 

type HistoryResponse struct {
	Error  *Error         `json:"error,omitempty"`
	Result *HistoryResult `json:"result,omitempty"`
}

HistoryResponse ...

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 JSONCommandDecoder 

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

JSONCommandDecoder ...

func NewJSONCommandDecoder 

func NewJSONCommandDecoder(data []byte) *JSONCommandDecoder

NewJSONCommandDecoder ...

func (*JSONCommandDecoder) Decode 

func (d *JSONCommandDecoder) Decode() (*Command, error)

Decode ...

func (*JSONCommandDecoder) Reset 

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

Reset ...

type JSONParamsDecoder 

type JSONParamsDecoder struct{}

JSONParamsDecoder ...

func NewJSONParamsDecoder 

func NewJSONParamsDecoder() *JSONParamsDecoder

NewJSONParamsDecoder ...

func (*JSONParamsDecoder) DecodeConnect 

func (d *JSONParamsDecoder) DecodeConnect(data []byte) (*ConnectRequest, error)

DecodeConnect ...

func (*JSONParamsDecoder) DecodeHistory 

func (d *JSONParamsDecoder) DecodeHistory(data []byte) (*HistoryRequest, error)

DecodeHistory ...

func (*JSONParamsDecoder) DecodePing 

func (d *JSONParamsDecoder) DecodePing(data []byte) (*PingRequest, error)

DecodePing ...

func (*JSONParamsDecoder) DecodePresence 

func (d *JSONParamsDecoder) DecodePresence(data []byte) (*PresenceRequest, error)

DecodePresence ...

func (*JSONParamsDecoder) DecodePresenceStats 

func (d *JSONParamsDecoder) DecodePresenceStats(data []byte) (*PresenceStatsRequest, error)

DecodePresenceStats ...

func (*JSONParamsDecoder) DecodePublish 

func (d *JSONParamsDecoder) DecodePublish(data []byte) (*PublishRequest, error)

DecodePublish ...

func (*JSONParamsDecoder) DecodeRPC 

func (d *JSONParamsDecoder) DecodeRPC(data []byte) (*RPCRequest, error)

DecodeRPC ...

func (*JSONParamsDecoder) DecodeRefresh 

func (d *JSONParamsDecoder) DecodeRefresh(data []byte) (*RefreshRequest, error)

DecodeRefresh ...

func (*JSONParamsDecoder) DecodeSend 

func (d *JSONParamsDecoder) DecodeSend(data []byte) (*SendRequest, error)

DecodeSend ...

func (*JSONParamsDecoder) DecodeSubRefresh 

func (d *JSONParamsDecoder) DecodeSubRefresh(data []byte) (*SubRefreshRequest, error)

DecodeSubRefresh ...

func (*JSONParamsDecoder) DecodeSubscribe 

func (d *JSONParamsDecoder) DecodeSubscribe(data []byte) (*SubscribeRequest, error)

DecodeSubscribe ...

func (*JSONParamsDecoder) DecodeUnsubscribe 

func (d *JSONParamsDecoder) DecodeUnsubscribe(data []byte) (*UnsubscribeRequest, error)

DecodeUnsubscribe ...

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

func (e *JSONPushDecoder) DecodePublication(data []byte) (*Publication, error)

DecodePublication ...

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

type JSONResultEncoder struct{}

JSONResultEncoder ...

func NewJSONResultEncoder 

func NewJSONResultEncoder() *JSONResultEncoder

NewJSONResultEncoder ...

func (*JSONResultEncoder) EncodeConnectResult 

func (e *JSONResultEncoder) EncodeConnectResult(res *ConnectResult) ([]byte, error)

EncodeConnectResult ...

func (*JSONResultEncoder) EncodeHistoryResult 

func (e *JSONResultEncoder) EncodeHistoryResult(res *HistoryResult) ([]byte, error)

EncodeHistoryResult ...

func (*JSONResultEncoder) EncodePingResult 

func (e *JSONResultEncoder) EncodePingResult(res *PingResult) ([]byte, error)

EncodePingResult ...

func (*JSONResultEncoder) EncodePresenceResult 

func (e *JSONResultEncoder) EncodePresenceResult(res *PresenceResult) ([]byte, error)

EncodePresenceResult ...

func (*JSONResultEncoder) EncodePresenceStatsResult 

func (e *JSONResultEncoder) EncodePresenceStatsResult(res *PresenceStatsResult) ([]byte, error)

EncodePresenceStatsResult ...

func (*JSONResultEncoder) EncodePublishResult 

func (e *JSONResultEncoder) EncodePublishResult(res *PublishResult) ([]byte, error)

EncodePublishResult ...

func (*JSONResultEncoder) EncodeRPCResult 

func (e *JSONResultEncoder) EncodeRPCResult(res *RPCResult) ([]byte, error)

EncodeRPCResult ...

func (*JSONResultEncoder) EncodeRefreshResult 

func (e *JSONResultEncoder) EncodeRefreshResult(res *RefreshResult) ([]byte, error)

EncodeRefreshResult ...

func (*JSONResultEncoder) EncodeSubRefreshResult 

func (e *JSONResultEncoder) EncodeSubRefreshResult(res *SubRefreshResult) ([]byte, error)

EncodeSubRefreshResult ...

func (*JSONResultEncoder) EncodeSubscribeResult 

func (e *JSONResultEncoder) EncodeSubscribeResult(res *SubscribeResult) ([]byte, error)

EncodeSubscribeResult ...

func (*JSONResultEncoder) EncodeUnsubscribeResult 

func (e *JSONResultEncoder) EncodeUnsubscribeResult(res *UnsubscribeResult) ([]byte, error)

EncodeUnsubscribeResult ...

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 ParamsDecoder 

type ParamsDecoder interface {
	DecodeConnect([]byte) (*ConnectRequest, error)
	DecodeRefresh([]byte) (*RefreshRequest, error)
	DecodeSubscribe([]byte) (*SubscribeRequest, error)
	DecodeSubRefresh([]byte) (*SubRefreshRequest, error)
	DecodeUnsubscribe([]byte) (*UnsubscribeRequest, error)
	DecodePublish([]byte) (*PublishRequest, error)
	DecodePresence([]byte) (*PresenceRequest, error)
	DecodePresenceStats([]byte) (*PresenceStatsRequest, error)
	DecodeHistory([]byte) (*HistoryRequest, error)
	DecodePing([]byte) (*PingRequest, error)
	DecodeRPC([]byte) (*RPCRequest, error)
	DecodeSend([]byte) (*SendRequest, error)
}

ParamsDecoder ...

func GetParamsDecoder 

func GetParamsDecoder(enc Encoding) ParamsDecoder

GetParamsDecoder ...

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 PingResponse 

type PingResponse struct {
	Error  *Error      `json:"error,omitempty"`
	Result *PingResult `json:"result,omitempty"`
}

PingResponse ...

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 PresenceResponse 

type PresenceResponse struct {
	Error  *Error          `json:"error,omitempty"`
	Result *PresenceResult `json:"result,omitempty"`
}

PresenceResponse ...

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 PresenceStatsResponse 

type PresenceStatsResponse struct {
	Error  *Error               `json:"error,omitempty"`
	Result *PresenceStatsResult `json:"result,omitempty"`
}

PresenceStatsResponse ...

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 ProtobufCommandDecoder 

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

ProtobufCommandDecoder ...

func NewProtobufCommandDecoder 

func NewProtobufCommandDecoder(data []byte) *ProtobufCommandDecoder

NewProtobufCommandDecoder ...

func (*ProtobufCommandDecoder) Decode 

func (d *ProtobufCommandDecoder) Decode() (*Command, error)

Decode ...

func (*ProtobufCommandDecoder) Reset 

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

Reset ...

type ProtobufParamsDecoder 

type ProtobufParamsDecoder struct{}

ProtobufParamsDecoder ...

func NewProtobufParamsDecoder 

func NewProtobufParamsDecoder() *ProtobufParamsDecoder

NewProtobufParamsDecoder ...

func (*ProtobufParamsDecoder) DecodeConnect 

func (d *ProtobufParamsDecoder) DecodeConnect(data []byte) (*ConnectRequest, error)

DecodeConnect ...

func (*ProtobufParamsDecoder) DecodeHistory 

func (d *ProtobufParamsDecoder) DecodeHistory(data []byte) (*HistoryRequest, error)

DecodeHistory ...

func (*ProtobufParamsDecoder) DecodePing 

func (d *ProtobufParamsDecoder) DecodePing(data []byte) (*PingRequest, error)

DecodePing ...

func (*ProtobufParamsDecoder) DecodePresence 

func (d *ProtobufParamsDecoder) DecodePresence(data []byte) (*PresenceRequest, error)

DecodePresence ...

func (*ProtobufParamsDecoder) DecodePresenceStats 

func (d *ProtobufParamsDecoder) DecodePresenceStats(data []byte) (*PresenceStatsRequest, error)

DecodePresenceStats ...

func (*ProtobufParamsDecoder) DecodePublish 

func (d *ProtobufParamsDecoder) DecodePublish(data []byte) (*PublishRequest, error)

DecodePublish ...

func (*ProtobufParamsDecoder) DecodeRPC 

func (d *ProtobufParamsDecoder) DecodeRPC(data []byte) (*RPCRequest, error)

DecodeRPC ...

func (*ProtobufParamsDecoder) DecodeRefresh 

func (d *ProtobufParamsDecoder) DecodeRefresh(data []byte) (*RefreshRequest, error)

DecodeRefresh ...

func (*ProtobufParamsDecoder) DecodeSend 

func (d *ProtobufParamsDecoder) DecodeSend(data []byte) (*SendRequest, error)

DecodeSend ...

func (*ProtobufParamsDecoder) DecodeSubRefresh 

func (d *ProtobufParamsDecoder) DecodeSubRefresh(data []byte) (*SubRefreshRequest, error)

DecodeSubRefresh ...

func (*ProtobufParamsDecoder) DecodeSubscribe 

func (d *ProtobufParamsDecoder) DecodeSubscribe(data []byte) (*SubscribeRequest, error)

DecodeSubscribe ...

func (*ProtobufParamsDecoder) DecodeUnsubscribe 

func (d *ProtobufParamsDecoder) DecodeUnsubscribe(data []byte) (*UnsubscribeRequest, error)

DecodeUnsubscribe ...

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

func (e *ProtobufPushDecoder) DecodePublication(data []byte) (*Publication, error)

DecodePublication ...

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)

EncodeMessage ...

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

type ProtobufResultEncoder struct{}

ProtobufResultEncoder ...

func NewProtobufResultEncoder 

func NewProtobufResultEncoder() *ProtobufResultEncoder

NewProtobufResultEncoder ...

func (*ProtobufResultEncoder) EncodeConnectResult 

func (e *ProtobufResultEncoder) EncodeConnectResult(res *ConnectResult) ([]byte, error)

EncodeConnectResult ...

func (*ProtobufResultEncoder) EncodeHistoryResult 

func (e *ProtobufResultEncoder) EncodeHistoryResult(res *HistoryResult) ([]byte, error)

EncodeHistoryResult ...

func (*ProtobufResultEncoder) EncodePingResult 

func (e *ProtobufResultEncoder) EncodePingResult(res *PingResult) ([]byte, error)

EncodePingResult ...

func (*ProtobufResultEncoder) EncodePresenceResult 

func (e *ProtobufResultEncoder) EncodePresenceResult(res *PresenceResult) ([]byte, error)

EncodePresenceResult ...

func (*ProtobufResultEncoder) EncodePresenceStatsResult 

func (e *ProtobufResultEncoder) EncodePresenceStatsResult(res *PresenceStatsResult) ([]byte, error)

EncodePresenceStatsResult ...

func (*ProtobufResultEncoder) EncodePublishResult 

func (e *ProtobufResultEncoder) EncodePublishResult(res *PublishResult) ([]byte, error)

EncodePublishResult ...

func (*ProtobufResultEncoder) EncodeRPCResult 

func (e *ProtobufResultEncoder) EncodeRPCResult(res *RPCResult) ([]byte, error)

EncodeRPCResult ...

func (*ProtobufResultEncoder) EncodeRefreshResult 

func (e *ProtobufResultEncoder) EncodeRefreshResult(res *RefreshResult) ([]byte, error)

EncodeRefreshResult ...

func (*ProtobufResultEncoder) EncodeSubRefreshResult 

func (e *ProtobufResultEncoder) EncodeSubRefreshResult(res *SubRefreshResult) ([]byte, error)

EncodeSubRefreshResult ...

func (*ProtobufResultEncoder) EncodeSubscribeResult 

func (e *ProtobufResultEncoder) EncodeSubscribeResult(res *SubscribeResult) ([]byte, error)

EncodeSubscribeResult ...

func (*ProtobufResultEncoder) EncodeUnsubscribeResult 

func (e *ProtobufResultEncoder) EncodeUnsubscribeResult(res *UnsubscribeResult) ([]byte, error)

EncodeUnsubscribeResult ...

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 PublishResponse 

type PublishResponse struct {
	Error  *Error         `json:"error,omitempty"`
	Result *PublishResult `json:"result,omitempty"`
}

PublishResponse ...

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 NewJoinPush 

func NewJoinPush(ch string, data Raw) *Push

NewJoinPush returns initialized async join message.

func NewLeavePush 

func NewLeavePush(ch string, data Raw) *Push

NewLeavePush returns initialized async leave message.

func NewMessagePush 

func NewMessagePush(data Raw) *Push

NewMessagePush returns initialized async push message.

func NewPopulatedPush 

func NewPopulatedPush(r randyClient, easy bool) *Push

func NewPublicationPush 

func NewPublicationPush(ch string, data Raw) *Push

NewPublicationPush returns initialized async publication message.

func NewUnsubPush 

func NewUnsubPush(ch string, data Raw) *Push

NewUnsubPush returns initialized async unsubscribe message.

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

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

func GetPushEncoder 

func GetPushEncoder(enc Encoding) PushEncoder

GetPushEncoder ...

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 RPCResponse 

type RPCResponse struct {
	Error  *Error     `json:"error,omitempty"`
	Result *RPCResult `json:"result,omitempty"`
}

RPCResponse ...

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 RefreshResponse 

type RefreshResponse struct {
	Error  *Error         `json:"error,omitempty"`
	Result *RefreshResult `json:"result,omitempty"`
}

RefreshResponse ...

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 ReplyEncoder 

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

ReplyEncoder ...

func GetReplyEncoder 

func GetReplyEncoder(enc Encoding) ReplyEncoder

GetReplyEncoder ...

type ResultEncoder 

type ResultEncoder interface {
	EncodeConnectResult(*ConnectResult) ([]byte, error)
	EncodeRefreshResult(*RefreshResult) ([]byte, error)
	EncodeSubscribeResult(*SubscribeResult) ([]byte, error)
	EncodeSubRefreshResult(*SubRefreshResult) ([]byte, error)
	EncodeUnsubscribeResult(*UnsubscribeResult) ([]byte, error)
	EncodePublishResult(*PublishResult) ([]byte, error)
	EncodePresenceResult(*PresenceResult) ([]byte, error)
	EncodePresenceStatsResult(*PresenceStatsResult) ([]byte, error)
	EncodeHistoryResult(*HistoryResult) ([]byte, error)
	EncodePingResult(*PingResult) ([]byte, error)
	EncodeRPCResult(*RPCResult) ([]byte, error)
}

ResultEncoder ...

func GetResultEncoder 

func GetResultEncoder(enc Encoding) ResultEncoder

GetResultEncoder ...

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 SubRefreshResponse 

type SubRefreshResponse struct {
	Error  *Error            `json:"error,omitempty"`
	Result *SubRefreshResult `json:"result,omitempty"`
}

SubRefreshResponse ...

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 SubscribeResponse 

type SubscribeResponse struct {
	Error  *Error           `json:"error,omitempty"`
	Result *SubscribeResult `json:"result,omitempty"`
}

SubscribeResponse ...

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 UnsubscribeResponse 

type UnsubscribeResponse struct {
	Error  *Error             `json:"error,omitempty"`
	Result *UnsubscribeResult `json:"result,omitempty"`
}

UnsubscribeResponse ...

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

Directories

Path Synopsis
Package controlproto is a generated protocol buffer package.
 Package controlproto is a generated protocol buffer package.

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.