protocol

package module
v0.3.6 Latest Latest
Warning

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

 Go to latest Published: Feb 23, 2021 License: MIT Imports: 13 Imported by: 12

README

Centrifuge client protocol definitions. Docs on go.dev.

To make changes in proto first install protoc.

Make required changes in client.template file.

Then run:

make install
make

Documentation

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")
	ErrUnexpectedEndOfGroupClient = fmt.Errorf("proto: unexpected end of group")
)
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",
	5: "SUB",
}
View Source 
var PushType_value = map[string]int32{
	"PUBLICATION": 0,
	"JOIN":        1,
	"LEAVE":       2,
	"UNSUB":       3,
	"MESSAGE":     4,
	"SUB":         5,
}

Functions

func PutCommandDecoder 

func PutCommandDecoder(protoType Type, e CommandDecoder)

PutCommandDecoder ...

func PutParamsDecoder 

func PutParamsDecoder(protoType Type, e ParamsDecoder)

PutParamsDecoder ...

func PutReplyEncoder 

func PutReplyEncoder(protoType Type, e ReplyEncoder)

PutReplyEncoder ...

func PutResultEncoder 

func PutResultEncoder(protoType Type, 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) MarshalToSizedBuffer added in v0.3.5 

func (m *ClientInfo) MarshalToSizedBuffer(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

func (*ClientInfo) XXX_DiscardUnknown added in v0.3.5 

func (m *ClientInfo) XXX_DiscardUnknown()

func (*ClientInfo) XXX_Marshal added in v0.3.5 

func (m *ClientInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientInfo) XXX_Merge added in v0.3.5 

func (m *ClientInfo) XXX_Merge(src proto.Message)

func (*ClientInfo) XXX_Size added in v0.3.5 

func (m *ClientInfo) XXX_Size() int

func (*ClientInfo) XXX_Unmarshal added in v0.3.5 

func (m *ClientInfo) XXX_Unmarshal(b []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=protocol.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) MarshalToSizedBuffer added in v0.3.5 

func (m *Command) MarshalToSizedBuffer(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

func (*Command) XXX_DiscardUnknown added in v0.3.5 

func (m *Command) XXX_DiscardUnknown()

func (*Command) XXX_Marshal added in v0.3.5 

func (m *Command) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Command) XXX_Merge added in v0.3.5 

func (m *Command) XXX_Merge(src proto.Message)

func (*Command) XXX_Size added in v0.3.5 

func (m *Command) XXX_Size() int

func (*Command) XXX_Unmarshal added in v0.3.5 

func (m *Command) XXX_Unmarshal(b []byte) error

type CommandDecoder 

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

CommandDecoder ...

func GetCommandDecoder 

func GetCommandDecoder(protoType Type, data []byte) CommandDecoder

GetCommandDecoder ...

type CommandEncoder 

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

CommandEncoder ...

type ConnectRequest 

type ConnectRequest struct {
	Token   string                       `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	Data    Raw                          `protobuf:"bytes,2,opt,name=data,proto3,customtype=Raw" json:"data,omitempty"`
	Subs    map[string]*SubscribeRequest `` /* 149-byte string literal not displayed */
	Name    string                       `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Version string                       `protobuf:"bytes,5,opt,name=version,proto3" json:"version,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) GetName added in v0.3.4 

func (m *ConnectRequest) GetName() string

func (*ConnectRequest) GetSubs 

func (m *ConnectRequest) GetSubs() map[string]*SubscribeRequest

func (*ConnectRequest) GetToken 

func (m *ConnectRequest) GetToken() string

func (*ConnectRequest) GetVersion added in v0.3.4 

func (m *ConnectRequest) GetVersion() 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) MarshalToSizedBuffer added in v0.3.5 

func (m *ConnectRequest) MarshalToSizedBuffer(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

func (*ConnectRequest) XXX_DiscardUnknown added in v0.3.5 

func (m *ConnectRequest) XXX_DiscardUnknown()

func (*ConnectRequest) XXX_Marshal added in v0.3.5 

func (m *ConnectRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConnectRequest) XXX_Merge added in v0.3.5 

func (m *ConnectRequest) XXX_Merge(src proto.Message)

func (*ConnectRequest) XXX_Size added in v0.3.5 

func (m *ConnectRequest) XXX_Size() int

func (*ConnectRequest) XXX_Unmarshal added in v0.3.5 

func (m *ConnectRequest) XXX_Unmarshal(b []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"`
	Subs    map[string]*SubscribeResult `` /* 149-byte string literal not displayed */
}

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

func (m *ConnectResult) GetSubs() map[string]*SubscribeResult

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) MarshalToSizedBuffer added in v0.3.5 

func (m *ConnectResult) MarshalToSizedBuffer(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

func (*ConnectResult) XXX_DiscardUnknown added in v0.3.5 

func (m *ConnectResult) XXX_DiscardUnknown()

func (*ConnectResult) XXX_Marshal added in v0.3.5 

func (m *ConnectResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConnectResult) XXX_Merge added in v0.3.5 

func (m *ConnectResult) XXX_Merge(src proto.Message)

func (*ConnectResult) XXX_Size added in v0.3.5 

func (m *ConnectResult) XXX_Size() int

func (*ConnectResult) XXX_Unmarshal added in v0.3.5 

func (m *ConnectResult) XXX_Unmarshal(b []byte) error

type EncodingType 

type EncodingType string

EncodingType determines connection payload encoding type. 

const (
	// EncodingTypeJSON means JSON payload.
	EncodingTypeJSON EncodingType = "json"
	// EncodingTypeBinary means binary payload.
	EncodingTypeBinary EncodingType = "binary"
)

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) 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) MarshalToSizedBuffer added in v0.3.5 

func (m *Error) MarshalToSizedBuffer(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

func (*Error) XXX_DiscardUnknown added in v0.3.5 

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal added in v0.3.5 

func (m *Error) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Error) XXX_Merge added in v0.3.5 

func (m *Error) XXX_Merge(src proto.Message)

func (*Error) XXX_Size added in v0.3.5 

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal added in v0.3.5 

func (m *Error) XXX_Unmarshal(b []byte) error

type HistoryRequest 

type HistoryRequest struct {
	Channel  string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel"`
	UseSince bool   `protobuf:"varint,2,opt,name=use_since,json=useSince,proto3" json:"use_since,omitempty"`
	Offset   uint64 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	Epoch    string `protobuf:"bytes,4,opt,name=epoch,proto3" json:"epoch,omitempty"`
	UseLimit bool   `protobuf:"varint,5,opt,name=use_limit,json=useLimit,proto3" json:"use_limit,omitempty"`
	Limit    int32  `protobuf:"varint,6,opt,name=limit,proto3" json:"limit,omitempty"`
}

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) GetEpoch added in v0.3.5 

func (m *HistoryRequest) GetEpoch() string

func (*HistoryRequest) GetLimit added in v0.3.5 

func (m *HistoryRequest) GetLimit() int32

func (*HistoryRequest) GetOffset added in v0.3.5 

func (m *HistoryRequest) GetOffset() uint64

func (*HistoryRequest) GetUseLimit added in v0.3.5 

func (m *HistoryRequest) GetUseLimit() bool

func (*HistoryRequest) GetUseSince added in v0.3.5 

func (m *HistoryRequest) GetUseSince() bool

func (*HistoryRequest) Marshal 

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

func (*HistoryRequest) MarshalTo 

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

func (*HistoryRequest) MarshalToSizedBuffer added in v0.3.5 

func (m *HistoryRequest) MarshalToSizedBuffer(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

func (*HistoryRequest) XXX_DiscardUnknown added in v0.3.5 

func (m *HistoryRequest) XXX_DiscardUnknown()

func (*HistoryRequest) XXX_Marshal added in v0.3.5 

func (m *HistoryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HistoryRequest) XXX_Merge added in v0.3.5 

func (m *HistoryRequest) XXX_Merge(src proto.Message)

func (*HistoryRequest) XXX_Size added in v0.3.5 

func (m *HistoryRequest) XXX_Size() int

func (*HistoryRequest) XXX_Unmarshal added in v0.3.5 

func (m *HistoryRequest) XXX_Unmarshal(b []byte) error

type HistoryResult 

type HistoryResult struct {
	Publications []*Publication `protobuf:"bytes,1,rep,name=publications,proto3" json:"publications"`
	Epoch        string         `protobuf:"bytes,2,opt,name=epoch,proto3" json:"epoch"`
	Offset       uint64         `protobuf:"varint,3,opt,name=offset,proto3" json:"offset"`
}

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) GetEpoch added in v0.3.5 

func (m *HistoryResult) GetEpoch() string

func (*HistoryResult) GetOffset added in v0.3.5 

func (m *HistoryResult) GetOffset() uint64

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) MarshalToSizedBuffer added in v0.3.5 

func (m *HistoryResult) MarshalToSizedBuffer(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

func (*HistoryResult) XXX_DiscardUnknown added in v0.3.5 

func (m *HistoryResult) XXX_DiscardUnknown()

func (*HistoryResult) XXX_Marshal added in v0.3.5 

func (m *HistoryResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HistoryResult) XXX_Merge added in v0.3.5 

func (m *HistoryResult) XXX_Merge(src proto.Message)

func (*HistoryResult) XXX_Size added in v0.3.5 

func (m *HistoryResult) XXX_Size() int

func (*HistoryResult) XXX_Unmarshal added in v0.3.5 

func (m *HistoryResult) XXX_Unmarshal(b []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 JSONCommandEncoder 

type JSONCommandEncoder struct {
}

JSONCommandEncoder ...

func NewJSONCommandEncoder 

func NewJSONCommandEncoder() *JSONCommandEncoder

NewJSONCommandEncoder ...

func (*JSONCommandEncoder) Encode 

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

Encode ...

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

func (e *JSONPushDecoder) DecodeSub(data []byte) (*Sub, error)

DecodeSub ...

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

func (e *JSONPushEncoder) EncodeSub(message *Sub) ([]byte, error)

EncodeSub ...

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 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,proto3" 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) MarshalToSizedBuffer added in v0.3.5 

func (m *Join) MarshalToSizedBuffer(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

func (*Join) XXX_DiscardUnknown added in v0.3.5 

func (m *Join) XXX_DiscardUnknown()

func (*Join) XXX_Marshal added in v0.3.5 

func (m *Join) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Join) XXX_Merge added in v0.3.5 

func (m *Join) XXX_Merge(src proto.Message)

func (*Join) XXX_Size added in v0.3.5 

func (m *Join) XXX_Size() int

func (*Join) XXX_Unmarshal added in v0.3.5 

func (m *Join) XXX_Unmarshal(b []byte) error

type Leave 

type Leave struct {
	Info ClientInfo `protobuf:"bytes,1,opt,name=info,proto3" 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) MarshalToSizedBuffer added in v0.3.5 

func (m *Leave) MarshalToSizedBuffer(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

func (*Leave) XXX_DiscardUnknown added in v0.3.5 

func (m *Leave) XXX_DiscardUnknown()

func (*Leave) XXX_Marshal added in v0.3.5 

func (m *Leave) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Leave) XXX_Merge added in v0.3.5 

func (m *Leave) XXX_Merge(src proto.Message)

func (*Leave) XXX_Size added in v0.3.5 

func (m *Leave) XXX_Size() int

func (*Leave) XXX_Unmarshal added in v0.3.5 

func (m *Leave) XXX_Unmarshal(b []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) MarshalToSizedBuffer added in v0.3.5 

func (m *Message) MarshalToSizedBuffer(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

func (*Message) XXX_DiscardUnknown added in v0.3.5 

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal added in v0.3.5 

func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Message) XXX_Merge added in v0.3.5 

func (m *Message) XXX_Merge(src proto.Message)

func (*Message) XXX_Size added in v0.3.5 

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal added in v0.3.5 

func (m *Message) XXX_Unmarshal(b []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 (x *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(protoType Type) ParamsDecoder

GetParamsDecoder ...

type ParamsEncoder 

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

ParamsEncoder ...

type PingRequest 

type PingRequest struct {
}

func NewPopulatedPingRequest 

func NewPopulatedPingRequest(r randyClient, easy bool) *PingRequest

func (*PingRequest) Descriptor 

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

func (*PingRequest) Equal 

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

func (*PingRequest) Marshal 

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

func (*PingRequest) MarshalTo 

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

func (*PingRequest) MarshalToSizedBuffer added in v0.3.5 

func (m *PingRequest) MarshalToSizedBuffer(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

func (*PingRequest) XXX_DiscardUnknown added in v0.3.5 

func (m *PingRequest) XXX_DiscardUnknown()

func (*PingRequest) XXX_Marshal added in v0.3.5 

func (m *PingRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PingRequest) XXX_Merge added in v0.3.5 

func (m *PingRequest) XXX_Merge(src proto.Message)

func (*PingRequest) XXX_Size added in v0.3.5 

func (m *PingRequest) XXX_Size() int

func (*PingRequest) XXX_Unmarshal added in v0.3.5 

func (m *PingRequest) XXX_Unmarshal(b []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) MarshalToSizedBuffer added in v0.3.5 

func (m *PingResult) MarshalToSizedBuffer(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

func (*PingResult) XXX_DiscardUnknown added in v0.3.5 

func (m *PingResult) XXX_DiscardUnknown()

func (*PingResult) XXX_Marshal added in v0.3.5 

func (m *PingResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PingResult) XXX_Merge added in v0.3.5 

func (m *PingResult) XXX_Merge(src proto.Message)

func (*PingResult) XXX_Size added in v0.3.5 

func (m *PingResult) XXX_Size() int

func (*PingResult) XXX_Unmarshal added in v0.3.5 

func (m *PingResult) XXX_Unmarshal(b []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) MarshalToSizedBuffer added in v0.3.5 

func (m *PresenceRequest) MarshalToSizedBuffer(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

func (*PresenceRequest) XXX_DiscardUnknown added in v0.3.5 

func (m *PresenceRequest) XXX_DiscardUnknown()

func (*PresenceRequest) XXX_Marshal added in v0.3.5 

func (m *PresenceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PresenceRequest) XXX_Merge added in v0.3.5 

func (m *PresenceRequest) XXX_Merge(src proto.Message)

func (*PresenceRequest) XXX_Size added in v0.3.5 

func (m *PresenceRequest) XXX_Size() int

func (*PresenceRequest) XXX_Unmarshal added in v0.3.5 

func (m *PresenceRequest) XXX_Unmarshal(b []byte) error

type PresenceResult 

type PresenceResult struct {
	Presence map[string]*ClientInfo `` /* 147-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) MarshalToSizedBuffer added in v0.3.5 

func (m *PresenceResult) MarshalToSizedBuffer(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

func (*PresenceResult) XXX_DiscardUnknown added in v0.3.5 

func (m *PresenceResult) XXX_DiscardUnknown()

func (*PresenceResult) XXX_Marshal added in v0.3.5 

func (m *PresenceResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PresenceResult) XXX_Merge added in v0.3.5 

func (m *PresenceResult) XXX_Merge(src proto.Message)

func (*PresenceResult) XXX_Size added in v0.3.5 

func (m *PresenceResult) XXX_Size() int

func (*PresenceResult) XXX_Unmarshal added in v0.3.5 

func (m *PresenceResult) XXX_Unmarshal(b []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) MarshalToSizedBuffer added in v0.3.5 

func (m *PresenceStatsRequest) MarshalToSizedBuffer(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

func (*PresenceStatsRequest) XXX_DiscardUnknown added in v0.3.5 

func (m *PresenceStatsRequest) XXX_DiscardUnknown()

func (*PresenceStatsRequest) XXX_Marshal added in v0.3.5 

func (m *PresenceStatsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PresenceStatsRequest) XXX_Merge added in v0.3.5 

func (m *PresenceStatsRequest) XXX_Merge(src proto.Message)

func (*PresenceStatsRequest) XXX_Size added in v0.3.5 

func (m *PresenceStatsRequest) XXX_Size() int

func (*PresenceStatsRequest) XXX_Unmarshal added in v0.3.5 

func (m *PresenceStatsRequest) XXX_Unmarshal(b []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) MarshalToSizedBuffer added in v0.3.5 

func (m *PresenceStatsResult) MarshalToSizedBuffer(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

func (*PresenceStatsResult) XXX_DiscardUnknown added in v0.3.5 

func (m *PresenceStatsResult) XXX_DiscardUnknown()

func (*PresenceStatsResult) XXX_Marshal added in v0.3.5 

func (m *PresenceStatsResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PresenceStatsResult) XXX_Merge added in v0.3.5 

func (m *PresenceStatsResult) XXX_Merge(src proto.Message)

func (*PresenceStatsResult) XXX_Size added in v0.3.5 

func (m *PresenceStatsResult) XXX_Size() int

func (*PresenceStatsResult) XXX_Unmarshal added in v0.3.5 

func (m *PresenceStatsResult) XXX_Unmarshal(b []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 ProtobufCommandEncoder 

type ProtobufCommandEncoder struct {
}

ProtobufCommandEncoder ...

func NewProtobufCommandEncoder 

func NewProtobufCommandEncoder() *ProtobufCommandEncoder

NewProtobufCommandEncoder ...

func (*ProtobufCommandEncoder) Encode 

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

Encode ...

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

func (e *ProtobufPushDecoder) DecodeSub(data []byte) (*Sub, error)

DecodeSub ...

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)

EncodeMessage ...

func (*ProtobufPushEncoder) EncodePublication 

func (e *ProtobufPushEncoder) EncodePublication(message *Publication) ([]byte, error)

EncodePublication ...

func (*ProtobufPushEncoder) EncodeSub 

func (e *ProtobufPushEncoder) EncodeSub(message *Sub) ([]byte, error)

EncodeSub ...

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 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,proto3" json:"info,omitempty"`
	Offset uint64      `protobuf:"varint,6,opt,name=offset,proto3" json:"offset,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) GetOffset 

func (m *Publication) GetOffset() uint64

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) MarshalToSizedBuffer added in v0.3.5 

func (m *Publication) MarshalToSizedBuffer(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

func (*Publication) XXX_DiscardUnknown added in v0.3.5 

func (m *Publication) XXX_DiscardUnknown()

func (*Publication) XXX_Marshal added in v0.3.5 

func (m *Publication) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Publication) XXX_Merge added in v0.3.5 

func (m *Publication) XXX_Merge(src proto.Message)

func (*Publication) XXX_Size added in v0.3.5 

func (m *Publication) XXX_Size() int

func (*Publication) XXX_Unmarshal added in v0.3.5 

func (m *Publication) XXX_Unmarshal(b []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) MarshalToSizedBuffer added in v0.3.5 

func (m *PublishRequest) MarshalToSizedBuffer(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

func (*PublishRequest) XXX_DiscardUnknown added in v0.3.5 

func (m *PublishRequest) XXX_DiscardUnknown()

func (*PublishRequest) XXX_Marshal added in v0.3.5 

func (m *PublishRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PublishRequest) XXX_Merge added in v0.3.5 

func (m *PublishRequest) XXX_Merge(src proto.Message)

func (*PublishRequest) XXX_Size added in v0.3.5 

func (m *PublishRequest) XXX_Size() int

func (*PublishRequest) XXX_Unmarshal added in v0.3.5 

func (m *PublishRequest) XXX_Unmarshal(b []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) MarshalToSizedBuffer added in v0.3.5 

func (m *PublishResult) MarshalToSizedBuffer(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

func (*PublishResult) XXX_DiscardUnknown added in v0.3.5 

func (m *PublishResult) XXX_DiscardUnknown()

func (*PublishResult) XXX_Marshal added in v0.3.5 

func (m *PublishResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PublishResult) XXX_Merge added in v0.3.5 

func (m *PublishResult) XXX_Merge(src proto.Message)

func (*PublishResult) XXX_Size added in v0.3.5 

func (m *PublishResult) XXX_Size() int

func (*PublishResult) XXX_Unmarshal added in v0.3.5 

func (m *PublishResult) XXX_Unmarshal(b []byte) error

type Push 

type Push struct {
	Type    PushType `protobuf:"varint,1,opt,name=type,proto3,enum=protocol.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) MarshalToSizedBuffer added in v0.3.5 

func (m *Push) MarshalToSizedBuffer(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

func (*Push) XXX_DiscardUnknown added in v0.3.5 

func (m *Push) XXX_DiscardUnknown()

func (*Push) XXX_Marshal added in v0.3.5 

func (m *Push) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Push) XXX_Merge added in v0.3.5 

func (m *Push) XXX_Merge(src proto.Message)

func (*Push) XXX_Size added in v0.3.5 

func (m *Push) XXX_Size() int

func (*Push) XXX_Unmarshal added in v0.3.5 

func (m *Push) XXX_Unmarshal(b []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)
	DecodeSub([]byte) (*Sub, 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)
	EncodeSub(*Sub) ([]byte, error)
}

PushEncoder ...

func GetPushEncoder 

func GetPushEncoder(protoType Type) PushEncoder

GetPushEncoder ...

type PushType 

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

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"`
	Method string `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
}

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) GetMethod added in v0.3.3 

func (m *RPCRequest) GetMethod() string

func (*RPCRequest) Marshal 

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

func (*RPCRequest) MarshalTo 

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

func (*RPCRequest) MarshalToSizedBuffer added in v0.3.5 

func (m *RPCRequest) MarshalToSizedBuffer(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

func (*RPCRequest) XXX_DiscardUnknown added in v0.3.5 

func (m *RPCRequest) XXX_DiscardUnknown()

func (*RPCRequest) XXX_Marshal added in v0.3.5 

func (m *RPCRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RPCRequest) XXX_Merge added in v0.3.5 

func (m *RPCRequest) XXX_Merge(src proto.Message)

func (*RPCRequest) XXX_Size added in v0.3.5 

func (m *RPCRequest) XXX_Size() int

func (*RPCRequest) XXX_Unmarshal added in v0.3.5 

func (m *RPCRequest) XXX_Unmarshal(b []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) MarshalToSizedBuffer added in v0.3.5 

func (m *RPCResult) MarshalToSizedBuffer(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

func (*RPCResult) XXX_DiscardUnknown added in v0.3.5 

func (m *RPCResult) XXX_DiscardUnknown()

func (*RPCResult) XXX_Marshal added in v0.3.5 

func (m *RPCResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RPCResult) XXX_Merge added in v0.3.5 

func (m *RPCResult) XXX_Merge(src proto.Message)

func (*RPCResult) XXX_Size added in v0.3.5 

func (m *RPCResult) XXX_Size() int

func (*RPCResult) XXX_Unmarshal added in v0.3.5 

func (m *RPCResult) XXX_Unmarshal(b []byte) error

type Raw 

type Raw []byte

Raw type used by Centrifuge protocol as a type for fields in structs which value we want to stay 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 gogo/protobuf 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 gogo/protobuf custom type interface.

func (Raw) Equal 

func (r Raw) Equal(other Raw) bool

Equal exists to fit gogo/protobuf custom type interface.

func (Raw) Marshal 

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

Marshal encodes Raw to slice of bytes. Exists to fit gogo/protobuf 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 gogo/protobuf custom type interface.

func (*Raw) Size 

func (r *Raw) Size() int

Size exists to fit gogo/protobuf custom type interface.

func (*Raw) Unmarshal 

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

Unmarshal exists to fit gogo/protobuf 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) MarshalToSizedBuffer added in v0.3.5 

func (m *RefreshRequest) MarshalToSizedBuffer(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

func (*RefreshRequest) XXX_DiscardUnknown added in v0.3.5 

func (m *RefreshRequest) XXX_DiscardUnknown()

func (*RefreshRequest) XXX_Marshal added in v0.3.5 

func (m *RefreshRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RefreshRequest) XXX_Merge added in v0.3.5 

func (m *RefreshRequest) XXX_Merge(src proto.Message)

func (*RefreshRequest) XXX_Size added in v0.3.5 

func (m *RefreshRequest) XXX_Size() int

func (*RefreshRequest) XXX_Unmarshal added in v0.3.5 

func (m *RefreshRequest) XXX_Unmarshal(b []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) MarshalToSizedBuffer added in v0.3.5 

func (m *RefreshResult) MarshalToSizedBuffer(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

func (*RefreshResult) XXX_DiscardUnknown added in v0.3.5 

func (m *RefreshResult) XXX_DiscardUnknown()

func (*RefreshResult) XXX_Marshal added in v0.3.5 

func (m *RefreshResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RefreshResult) XXX_Merge added in v0.3.5 

func (m *RefreshResult) XXX_Merge(src proto.Message)

func (*RefreshResult) XXX_Size added in v0.3.5 

func (m *RefreshResult) XXX_Size() int

func (*RefreshResult) XXX_Unmarshal added in v0.3.5 

func (m *RefreshResult) XXX_Unmarshal(b []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,proto3" 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) MarshalToSizedBuffer added in v0.3.5 

func (m *Reply) MarshalToSizedBuffer(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

func (*Reply) XXX_DiscardUnknown added in v0.3.5 

func (m *Reply) XXX_DiscardUnknown()

func (*Reply) XXX_Marshal added in v0.3.5 

func (m *Reply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Reply) XXX_Merge added in v0.3.5 

func (m *Reply) XXX_Merge(src proto.Message)

func (*Reply) XXX_Size added in v0.3.5 

func (m *Reply) XXX_Size() int

func (*Reply) XXX_Unmarshal added in v0.3.5 

func (m *Reply) XXX_Unmarshal(b []byte) error

type ReplyDecoder 

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

ReplyDecoder ...

type ReplyEncoder 

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

ReplyEncoder ...

func GetReplyEncoder 

func GetReplyEncoder(protoType Type) ReplyEncoder

GetReplyEncoder ...

type ResultDecoder 

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

ResultDecoder ...

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(protoType Type) 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) MarshalToSizedBuffer added in v0.3.5 

func (m *SendRequest) MarshalToSizedBuffer(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

func (*SendRequest) XXX_DiscardUnknown added in v0.3.5 

func (m *SendRequest) XXX_DiscardUnknown()

func (*SendRequest) XXX_Marshal added in v0.3.5 

func (m *SendRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SendRequest) XXX_Merge added in v0.3.5 

func (m *SendRequest) XXX_Merge(src proto.Message)

func (*SendRequest) XXX_Size added in v0.3.5 

func (m *SendRequest) XXX_Size() int

func (*SendRequest) XXX_Unmarshal added in v0.3.5 

func (m *SendRequest) XXX_Unmarshal(b []byte) error

type Sub 

type Sub struct {
	Recoverable bool   `protobuf:"varint,1,opt,name=recoverable,proto3" json:"recoverable,omitempty"`
	Seq         uint32 `protobuf:"varint,2,opt,name=seq,proto3" json:"seq,omitempty"`
	Gen         uint32 `protobuf:"varint,3,opt,name=gen,proto3" json:"gen,omitempty"`
	Epoch       string `protobuf:"bytes,4,opt,name=epoch,proto3" json:"epoch,omitempty"`
	Offset      uint64 `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"`
	Positioned  bool   `protobuf:"varint,6,opt,name=positioned,proto3" json:"positioned,omitempty"`
}

func NewPopulatedSub 

func NewPopulatedSub(r randyClient, easy bool) *Sub

func (*Sub) Descriptor 

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

func (*Sub) Equal 

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

func (*Sub) GetEpoch 

func (m *Sub) GetEpoch() string

func (*Sub) GetGen 

func (m *Sub) GetGen() uint32

func (*Sub) GetOffset 

func (m *Sub) GetOffset() uint64

func (*Sub) GetPositioned added in v0.3.5 

func (m *Sub) GetPositioned() bool

func (*Sub) GetRecoverable 

func (m *Sub) GetRecoverable() bool

func (*Sub) GetSeq 

func (m *Sub) GetSeq() uint32

func (*Sub) Marshal 

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

func (*Sub) MarshalTo 

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

func (*Sub) MarshalToSizedBuffer added in v0.3.5 

func (m *Sub) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Sub) ProtoMessage 

func (*Sub) ProtoMessage()

func (*Sub) Reset 

func (m *Sub) Reset()

func (*Sub) Size 

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

func (*Sub) String 

func (m *Sub) String() string

func (*Sub) Unmarshal 

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

func (*Sub) XXX_DiscardUnknown added in v0.3.5 

func (m *Sub) XXX_DiscardUnknown()

func (*Sub) XXX_Marshal added in v0.3.5 

func (m *Sub) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Sub) XXX_Merge added in v0.3.5 

func (m *Sub) XXX_Merge(src proto.Message)

func (*Sub) XXX_Size added in v0.3.5 

func (m *Sub) XXX_Size() int

func (*Sub) XXX_Unmarshal added in v0.3.5 

func (m *Sub) XXX_Unmarshal(b []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) MarshalToSizedBuffer added in v0.3.5 

func (m *SubRefreshRequest) MarshalToSizedBuffer(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

func (*SubRefreshRequest) XXX_DiscardUnknown added in v0.3.5 

func (m *SubRefreshRequest) XXX_DiscardUnknown()

func (*SubRefreshRequest) XXX_Marshal added in v0.3.5 

func (m *SubRefreshRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubRefreshRequest) XXX_Merge added in v0.3.5 

func (m *SubRefreshRequest) XXX_Merge(src proto.Message)

func (*SubRefreshRequest) XXX_Size added in v0.3.5 

func (m *SubRefreshRequest) XXX_Size() int

func (*SubRefreshRequest) XXX_Unmarshal added in v0.3.5 

func (m *SubRefreshRequest) XXX_Unmarshal(b []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) MarshalToSizedBuffer added in v0.3.5 

func (m *SubRefreshResult) MarshalToSizedBuffer(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

func (*SubRefreshResult) XXX_DiscardUnknown added in v0.3.5 

func (m *SubRefreshResult) XXX_DiscardUnknown()

func (*SubRefreshResult) XXX_Marshal added in v0.3.5 

func (m *SubRefreshResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubRefreshResult) XXX_Merge added in v0.3.5 

func (m *SubRefreshResult) XXX_Merge(src proto.Message)

func (*SubRefreshResult) XXX_Size added in v0.3.5 

func (m *SubRefreshResult) XXX_Size() int

func (*SubRefreshResult) XXX_Unmarshal added in v0.3.5 

func (m *SubRefreshResult) XXX_Unmarshal(b []byte) error

type SubscribeRequest 

type SubscribeRequest struct {
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	Token   string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	Recover bool   `protobuf:"varint,3,opt,name=recover,proto3" json:"recover,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"`
	Offset  uint64 `protobuf:"varint,7,opt,name=offset,proto3" json:"offset,omitempty"`
}

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

func (m *SubscribeRequest) GetOffset() uint64

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) MarshalToSizedBuffer added in v0.3.5 

func (m *SubscribeRequest) MarshalToSizedBuffer(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

func (*SubscribeRequest) XXX_DiscardUnknown added in v0.3.5 

func (m *SubscribeRequest) XXX_DiscardUnknown()

func (*SubscribeRequest) XXX_Marshal added in v0.3.5 

func (m *SubscribeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubscribeRequest) XXX_Merge added in v0.3.5 

func (m *SubscribeRequest) XXX_Merge(src proto.Message)

func (*SubscribeRequest) XXX_Size added in v0.3.5 

func (m *SubscribeRequest) XXX_Size() int

func (*SubscribeRequest) XXX_Unmarshal added in v0.3.5 

func (m *SubscribeRequest) XXX_Unmarshal(b []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,proto3" json:"publications,omitempty"`
	Recovered    bool           `protobuf:"varint,8,opt,name=recovered,proto3" json:"recovered,omitempty"`
	Offset       uint64         `protobuf:"varint,9,opt,name=offset,proto3" json:"offset,omitempty"`
	Positioned   bool           `protobuf:"varint,10,opt,name=positioned,proto3" json:"positioned,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) GetOffset 

func (m *SubscribeResult) GetOffset() uint64

func (*SubscribeResult) GetPositioned added in v0.3.5 

func (m *SubscribeResult) GetPositioned() bool

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) MarshalToSizedBuffer added in v0.3.5 

func (m *SubscribeResult) MarshalToSizedBuffer(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

func (*SubscribeResult) XXX_DiscardUnknown added in v0.3.5 

func (m *SubscribeResult) XXX_DiscardUnknown()

func (*SubscribeResult) XXX_Marshal added in v0.3.5 

func (m *SubscribeResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubscribeResult) XXX_Merge added in v0.3.5 

func (m *SubscribeResult) XXX_Merge(src proto.Message)

func (*SubscribeResult) XXX_Size added in v0.3.5 

func (m *SubscribeResult) XXX_Size() int

func (*SubscribeResult) XXX_Unmarshal added in v0.3.5 

func (m *SubscribeResult) XXX_Unmarshal(b []byte) error

type Type 

type Type string

Type determines connection protocol type. 

const (
	// TypeJSON means JSON protocol - in this case data encoded in
	// JSON-streaming format.
	TypeJSON Type = "json"
	// TypeProtobuf means protobuf protocol - in this case data encoded
	// as length-delimited (varint) protobuf messages.
	TypeProtobuf Type = "protobuf"
)

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) MarshalToSizedBuffer added in v0.3.5 

func (m *Unsub) MarshalToSizedBuffer(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

func (*Unsub) XXX_DiscardUnknown added in v0.3.5 

func (m *Unsub) XXX_DiscardUnknown()

func (*Unsub) XXX_Marshal added in v0.3.5 

func (m *Unsub) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Unsub) XXX_Merge added in v0.3.5 

func (m *Unsub) XXX_Merge(src proto.Message)

func (*Unsub) XXX_Size added in v0.3.5 

func (m *Unsub) XXX_Size() int

func (*Unsub) XXX_Unmarshal added in v0.3.5 

func (m *Unsub) XXX_Unmarshal(b []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) MarshalToSizedBuffer added in v0.3.5 

func (m *UnsubscribeRequest) MarshalToSizedBuffer(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

func (*UnsubscribeRequest) XXX_DiscardUnknown added in v0.3.5 

func (m *UnsubscribeRequest) XXX_DiscardUnknown()

func (*UnsubscribeRequest) XXX_Marshal added in v0.3.5 

func (m *UnsubscribeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnsubscribeRequest) XXX_Merge added in v0.3.5 

func (m *UnsubscribeRequest) XXX_Merge(src proto.Message)

func (*UnsubscribeRequest) XXX_Size added in v0.3.5 

func (m *UnsubscribeRequest) XXX_Size() int

func (*UnsubscribeRequest) XXX_Unmarshal added in v0.3.5 

func (m *UnsubscribeRequest) XXX_Unmarshal(b []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) MarshalToSizedBuffer added in v0.3.5 

func (m *UnsubscribeResult) MarshalToSizedBuffer(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

func (*UnsubscribeResult) XXX_DiscardUnknown added in v0.3.5 

func (m *UnsubscribeResult) XXX_DiscardUnknown()

func (*UnsubscribeResult) XXX_Marshal added in v0.3.5 

func (m *UnsubscribeResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnsubscribeResult) XXX_Merge added in v0.3.5 

func (m *UnsubscribeResult) XXX_Merge(src proto.Message)

func (*UnsubscribeResult) XXX_Size added in v0.3.5 

func (m *UnsubscribeResult) XXX_Size() int

func (*UnsubscribeResult) XXX_Unmarshal added in v0.3.5 

func (m *UnsubscribeResult) XXX_Unmarshal(b []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.