protocol

package module
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Apr 9, 2021 License: MIT Imports: 11 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 Command_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 Command_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 Push_PushType_name = map[int32]string{
	0: "PUBLICATION",
	1: "JOIN",
	2: "LEAVE",
	3: "UNSUBSCRIBE",
	4: "MESSAGE",
	5: "SUBSCRIBE",
	6: "CONNECT",
	7: "DISCONNECT",
}
View Source 
var Push_PushType_value = map[string]int32{
	"PUBLICATION": 0,
	"JOIN":        1,
	"LEAVE":       2,
	"UNSUBSCRIBE": 3,
	"MESSAGE":     4,
	"SUBSCRIBE":   5,
	"CONNECT":     6,
	"DISCONNECT":  7,
}

Functions

func PutCommandDecoder 

func PutCommandDecoder(protoType Type, e CommandDecoder)

PutCommandDecoder ...

func PutDataEncoder added in v0.4.0 

func PutDataEncoder(protoType Type, e DataEncoder)

PutDataEncoder ...

func PutParamsDecoder 

func PutParamsDecoder(protoType Type, e ParamsDecoder)

PutParamsDecoder ...

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 Command_MethodType `protobuf:"varint,2,opt,name=method,proto3,enum=protocol.Command_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 added in v0.4.1 

func (m *Command) GetId() uint32

func (*Command) GetMethod 

func (m *Command) GetMethod() Command_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 Command_MethodType added in v0.5.0 

type Command_MethodType int32
const (
	Command_CONNECT        Command_MethodType = 0
	Command_SUBSCRIBE      Command_MethodType = 1
	Command_UNSUBSCRIBE    Command_MethodType = 2
	Command_PUBLISH        Command_MethodType = 3
	Command_PRESENCE       Command_MethodType = 4
	Command_PRESENCE_STATS Command_MethodType = 5
	Command_HISTORY        Command_MethodType = 6
	Command_PING           Command_MethodType = 7
	Command_SEND           Command_MethodType = 8
	Command_RPC            Command_MethodType = 9
	Command_REFRESH        Command_MethodType = 10
	Command_SUB_REFRESH    Command_MethodType = 11
)

func (Command_MethodType) EnumDescriptor added in v0.5.0 

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

func (Command_MethodType) String added in v0.5.0 

func (x Command_MethodType) String() string

type Connect added in v0.4.0 

type Connect struct {
	Client  string                      `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"`
	Version string                      `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Data    Raw                         `protobuf:"bytes,3,opt,name=data,proto3,customtype=Raw" json:"data,omitempty"`
	Subs    map[string]*SubscribeResult `` /* 149-byte string literal not displayed */
}

func NewPopulatedConnect added in v0.4.0 

func NewPopulatedConnect(r randyClient, easy bool) *Connect

func (*Connect) Descriptor added in v0.4.0 

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

func (*Connect) Equal added in v0.4.0 

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

func (*Connect) GetClient added in v0.4.0 

func (m *Connect) GetClient() string

func (*Connect) GetSubs added in v0.4.0 

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

func (*Connect) GetVersion added in v0.4.0 

func (m *Connect) GetVersion() string

func (*Connect) Marshal added in v0.4.0 

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

func (*Connect) MarshalTo added in v0.4.0 

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

func (*Connect) MarshalToSizedBuffer added in v0.4.0 

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

func (*Connect) ProtoMessage added in v0.4.0 

func (*Connect) ProtoMessage()

func (*Connect) Reset added in v0.4.0 

func (m *Connect) Reset()

func (*Connect) Size added in v0.4.0 

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

func (*Connect) String added in v0.4.0 

func (m *Connect) String() string

func (*Connect) Unmarshal added in v0.4.0 

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

func (*Connect) XXX_DiscardUnknown added in v0.4.0 

func (m *Connect) XXX_DiscardUnknown()

func (*Connect) XXX_Marshal added in v0.4.0 

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

func (*Connect) XXX_Merge added in v0.4.0 

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

func (*Connect) XXX_Size added in v0.4.0 

func (m *Connect) XXX_Size() int

func (*Connect) XXX_Unmarshal added in v0.4.0 

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

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,omitempty"`
	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 added in v0.4.1 

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 DataEncoder added in v0.4.0 

type DataEncoder interface {
	Reset()
	Encode([]byte) error
	Finish() []byte
}

DataEncoder ...

func GetDataEncoder added in v0.4.0 

func GetDataEncoder(protoType Type) DataEncoder

GetDataEncoder ...

type Disconnect added in v0.4.0 

type Disconnect struct {
	Code      uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Reason    string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	Reconnect bool   `protobuf:"varint,3,opt,name=reconnect,proto3" json:"reconnect,omitempty"`
}

func NewPopulatedDisconnect added in v0.4.0 

func NewPopulatedDisconnect(r randyClient, easy bool) *Disconnect

func (*Disconnect) Descriptor added in v0.4.0 

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

func (*Disconnect) Equal added in v0.4.0 

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

func (*Disconnect) GetCode added in v0.4.0 

func (m *Disconnect) GetCode() uint32

func (*Disconnect) GetReason added in v0.4.0 

func (m *Disconnect) GetReason() string

func (*Disconnect) GetReconnect added in v0.4.0 

func (m *Disconnect) GetReconnect() bool

func (*Disconnect) Marshal added in v0.4.0 

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

func (*Disconnect) MarshalTo added in v0.4.0 

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

func (*Disconnect) MarshalToSizedBuffer added in v0.4.0 

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

func (*Disconnect) ProtoMessage added in v0.4.0 

func (*Disconnect) ProtoMessage()

func (*Disconnect) Reset added in v0.4.0 

func (m *Disconnect) Reset()

func (*Disconnect) Size added in v0.4.0 

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

func (*Disconnect) String added in v0.4.0 

func (m *Disconnect) String() string

func (*Disconnect) Unmarshal added in v0.4.0 

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

func (*Disconnect) XXX_DiscardUnknown added in v0.4.0 

func (m *Disconnect) XXX_DiscardUnknown()

func (*Disconnect) XXX_Marshal added in v0.4.0 

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

func (*Disconnect) XXX_Merge added in v0.4.0 

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

func (*Disconnect) XXX_Size added in v0.4.0 

func (m *Disconnect) XXX_Size() int

func (*Disconnect) XXX_Unmarshal added in v0.4.0 

func (m *Disconnect) 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 JSONDataEncoder added in v0.4.0 

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

JSONDataEncoder ...

func NewJSONDataEncoder added in v0.4.0 

func NewJSONDataEncoder() *JSONDataEncoder

NewJSONDataEncoder ...

func (*JSONDataEncoder) Encode added in v0.4.0 

func (e *JSONDataEncoder) Encode(data []byte) error

Encode ...

func (*JSONDataEncoder) Finish added in v0.4.0 

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

Finish ...

func (*JSONDataEncoder) Reset added in v0.4.0 

func (e *JSONDataEncoder) Reset()

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 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) DecodeConnect added in v0.4.0 

func (e *JSONPushDecoder) DecodeConnect(data []byte) (*Connect, error)

DecodeConnect ...

func (*JSONPushDecoder) DecodeDisconnect added in v0.4.0 

func (e *JSONPushDecoder) DecodeDisconnect(data []byte) (*Disconnect, error)

DecodeDisconnect ...

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) DecodeSubscribe added in v0.4.0 

func (e *JSONPushDecoder) DecodeSubscribe(data []byte) (*Subscribe, error)

DecodeSub ...

func (*JSONPushDecoder) DecodeUnsubscribe added in v0.4.0 

func (e *JSONPushDecoder) DecodeUnsubscribe(data []byte) (*Unsubscribe, 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) EncodeConnect added in v0.4.0 

func (e *JSONPushEncoder) EncodeConnect(message *Connect) ([]byte, error)

EncodeConn ...

func (*JSONPushEncoder) EncodeDisconnect added in v0.4.0 

func (e *JSONPushEncoder) EncodeDisconnect(message *Disconnect) ([]byte, error)

EncodeDisconnect ...

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) EncodeSubscribe added in v0.4.0 

func (e *JSONPushEncoder) EncodeSubscribe(message *Subscribe) ([]byte, error)

EncodeSub ...

func (*JSONPushEncoder) EncodeUnsubscribe added in v0.4.0 

func (e *JSONPushEncoder) EncodeUnsubscribe(message *Unsubscribe) ([]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{}

JSONReplyEncoder ...

func NewJSONReplyEncoder 

func NewJSONReplyEncoder() *JSONReplyEncoder

NewJSONReplyEncoder ...

func (*JSONReplyEncoder) Encode 

func (e *JSONReplyEncoder) Encode(r *Reply) ([]byte, error)

Encode ...

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 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 ProtobufDataEncoder added in v0.4.0 

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

ProtobufDataEncoder ...

func NewProtobufDataEncoder added in v0.4.0 

func NewProtobufDataEncoder() *ProtobufDataEncoder

NewProtobufDataEncoder ...

func (*ProtobufDataEncoder) Encode added in v0.4.0 

func (e *ProtobufDataEncoder) Encode(data []byte) error

Encode ...

func (*ProtobufDataEncoder) Finish added in v0.4.0 

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

Finish ...

func (*ProtobufDataEncoder) Reset added in v0.4.0 

func (e *ProtobufDataEncoder) Reset()

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 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) DecodeConnect added in v0.4.0 

func (e *ProtobufPushDecoder) DecodeConnect(data []byte) (*Connect, error)

DecodeConnect ...

func (*ProtobufPushDecoder) DecodeDisconnect added in v0.4.0 

func (e *ProtobufPushDecoder) DecodeDisconnect(data []byte) (*Disconnect, error)

DecodeDisconnect ...

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) DecodeSubscribe added in v0.4.0 

func (e *ProtobufPushDecoder) DecodeSubscribe(data []byte) (*Subscribe, error)

DecodeSubscribe ...

func (*ProtobufPushDecoder) DecodeUnsubscribe added in v0.4.0 

func (e *ProtobufPushDecoder) DecodeUnsubscribe(data []byte) (*Unsubscribe, error)

DecodeUnsubscribe ...

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) EncodeConnect added in v0.4.0 

func (e *ProtobufPushEncoder) EncodeConnect(message *Connect) ([]byte, error)

EncodeConn ...

func (*ProtobufPushEncoder) EncodeDisconnect added in v0.4.0 

func (e *ProtobufPushEncoder) EncodeDisconnect(message *Disconnect) ([]byte, error)

EncodeDisconnect ...

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) EncodeSubscribe added in v0.4.0 

func (e *ProtobufPushEncoder) EncodeSubscribe(message *Subscribe) ([]byte, error)

EncodeSub ...

func (*ProtobufPushEncoder) EncodeUnsubscribe added in v0.4.0 

func (e *ProtobufPushEncoder) EncodeUnsubscribe(message *Unsubscribe) ([]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{}

ProtobufReplyEncoder ...

func NewProtobufReplyEncoder 

func NewProtobufReplyEncoder() *ProtobufReplyEncoder

NewProtobufReplyEncoder ...

func (*ProtobufReplyEncoder) Encode 

func (e *ProtobufReplyEncoder) Encode(r *Reply) ([]byte, error)

Encode ...

type ProtobufResultDecoder 

type ProtobufResultDecoder struct{}

ProtobufResultDecoder ...

func NewProtobufResultDecoder 

func NewProtobufResultDecoder() *ProtobufResultDecoder

NewProtobufResultDecoder ...

func (*ProtobufResultDecoder) Decode 

func (e *ProtobufResultDecoder) Decode(data []byte, dest interface{}) error

Decode ...

type 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 added in v0.4.1 

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    Push_PushType `protobuf:"varint,1,opt,name=type,proto3,enum=protocol.Push_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() Push_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)
	DecodeUnsubscribe([]byte) (*Unsubscribe, error)
	DecodeSubscribe([]byte) (*Subscribe, error)
	DecodeConnect([]byte) (*Connect, error)
	DecodeDisconnect([]byte) (*Disconnect, 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)
	EncodeUnsubscribe(*Unsubscribe) ([]byte, error)
	EncodeSubscribe(*Subscribe) ([]byte, error)
	EncodeConnect(*Connect) ([]byte, error)
	EncodeDisconnect(*Disconnect) ([]byte, error)
}

PushEncoder ...

func GetPushEncoder 

func GetPushEncoder(protoType Type) PushEncoder

GetPushEncoder ...

type Push_PushType added in v0.5.0 

type Push_PushType int32
const (
	Push_PUBLICATION Push_PushType = 0
	Push_JOIN        Push_PushType = 1
	Push_LEAVE       Push_PushType = 2
	Push_UNSUBSCRIBE Push_PushType = 3
	Push_MESSAGE     Push_PushType = 4
	Push_SUBSCRIBE   Push_PushType = 5
	Push_CONNECT     Push_PushType = 6
	Push_DISCONNECT  Push_PushType = 7
)

func (Push_PushType) EnumDescriptor added in v0.5.0 

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

func (Push_PushType) String added in v0.5.0 

func (x Push_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 added in v0.4.1 

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 added in v0.4.1 

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 {
	Encode(*Reply) ([]byte, error)
}

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 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 added in v0.4.1 

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 Subscribe added in v0.4.0 

type Subscribe 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"`
	Data        Raw    `protobuf:"bytes,7,opt,name=data,proto3,customtype=Raw" json:"data,omitempty"`
}

func NewPopulatedSubscribe added in v0.4.0 

func NewPopulatedSubscribe(r randyClient, easy bool) *Subscribe

func (*Subscribe) Descriptor added in v0.4.0 

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

func (*Subscribe) Equal added in v0.4.0 

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

func (*Subscribe) GetEpoch added in v0.4.0 

func (m *Subscribe) GetEpoch() string

func (*Subscribe) GetGen added in v0.4.0 

func (m *Subscribe) GetGen() uint32

func (*Subscribe) GetOffset added in v0.4.0 

func (m *Subscribe) GetOffset() uint64

func (*Subscribe) GetPositioned added in v0.4.0 

func (m *Subscribe) GetPositioned() bool

func (*Subscribe) GetRecoverable added in v0.4.0 

func (m *Subscribe) GetRecoverable() bool

func (*Subscribe) GetSeq added in v0.4.0 

func (m *Subscribe) GetSeq() uint32

func (*Subscribe) Marshal added in v0.4.0 

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

func (*Subscribe) MarshalTo added in v0.4.0 

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

func (*Subscribe) MarshalToSizedBuffer added in v0.4.0 

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

func (*Subscribe) ProtoMessage added in v0.4.0 

func (*Subscribe) ProtoMessage()

func (*Subscribe) Reset added in v0.4.0 

func (m *Subscribe) Reset()

func (*Subscribe) Size added in v0.4.0 

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

func (*Subscribe) String added in v0.4.0 

func (m *Subscribe) String() string

func (*Subscribe) Unmarshal added in v0.4.0 

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

func (*Subscribe) XXX_DiscardUnknown added in v0.4.0 

func (m *Subscribe) XXX_DiscardUnknown()

func (*Subscribe) XXX_Marshal added in v0.4.0 

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

func (*Subscribe) XXX_Merge added in v0.4.0 

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

func (*Subscribe) XXX_Size added in v0.4.0 

func (m *Subscribe) XXX_Size() int

func (*Subscribe) XXX_Unmarshal added in v0.4.0 

func (m *Subscribe) 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"`
	Data         Raw            `protobuf:"bytes,11,opt,name=data,proto3,customtype=Raw" json:"data,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 added in v0.4.1 

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.
	TypeJSON Type = "json"
	// TypeProtobuf means Protobuf protocol.
	TypeProtobuf Type = "protobuf"
)

type Unsubscribe added in v0.4.0 

type Unsubscribe struct {
	Resubscribe bool `protobuf:"varint,1,opt,name=resubscribe,proto3" json:"resubscribe,omitempty"`
}

func NewPopulatedUnsubscribe added in v0.4.0 

func NewPopulatedUnsubscribe(r randyClient, easy bool) *Unsubscribe

func (*Unsubscribe) Descriptor added in v0.4.0 

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

func (*Unsubscribe) Equal added in v0.4.0 

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

func (*Unsubscribe) GetResubscribe added in v0.4.0 

func (m *Unsubscribe) GetResubscribe() bool

func (*Unsubscribe) Marshal added in v0.4.0 

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

func (*Unsubscribe) MarshalTo added in v0.4.0 

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

func (*Unsubscribe) MarshalToSizedBuffer added in v0.4.0 

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

func (*Unsubscribe) ProtoMessage added in v0.4.0 

func (*Unsubscribe) ProtoMessage()

func (*Unsubscribe) Reset added in v0.4.0 

func (m *Unsubscribe) Reset()

func (*Unsubscribe) Size added in v0.4.0 

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

func (*Unsubscribe) String added in v0.4.0 

func (m *Unsubscribe) String() string

func (*Unsubscribe) Unmarshal added in v0.4.0 

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

func (*Unsubscribe) XXX_DiscardUnknown added in v0.4.0 

func (m *Unsubscribe) XXX_DiscardUnknown()

func (*Unsubscribe) XXX_Marshal added in v0.4.0 

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

func (*Unsubscribe) XXX_Merge added in v0.4.0 

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

func (*Unsubscribe) XXX_Size added in v0.4.0 

func (m *Unsubscribe) XXX_Size() int

func (*Unsubscribe) XXX_Unmarshal added in v0.4.0 

func (m *Unsubscribe) 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.
JackTT - Gopher 🇻🇳