protocol

package module
v0.7.0 Latest Latest
Warning

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

 Go to latest Published: Aug 23, 2021 License: MIT Imports: 18 Imported by: 12

README

Centrifuge client protocol definitions. Docs on go.dev.

Documentation

Index

Constants

This section is empty.

Variables

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

Enum value maps for Command_MethodType.

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",
		8: "REFRESH",
	}
	Push_PushType_value = map[string]int32{
		"PUBLICATION": 0,
		"JOIN":        1,
		"LEAVE":       2,
		"UNSUBSCRIBE": 3,
		"MESSAGE":     4,
		"SUBSCRIBE":   5,
		"CONNECT":     6,
		"DISCONNECT":  7,
		"REFRESH":     8,
	}
)

Enum value maps for Push_PushType.

View Source 
var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var File_client_proto protoreflect.FileDescriptor

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(_ Type, _ ParamsDecoder)

PutParamsDecoder ...

func PutResultEncoder 

func PutResultEncoder(_ Type, _ 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" json:"conn_info,omitempty"`
	ChanInfo Raw    `protobuf:"bytes,4,opt,name=chan_info,json=chanInfo,proto3" json:"chan_info,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientInfo) Descriptor deprecated 

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

Deprecated: Use ClientInfo.ProtoReflect.Descriptor instead.

func (*ClientInfo) GetChanInfo added in v0.7.0 

func (x *ClientInfo) GetChanInfo() []byte

func (*ClientInfo) GetClient 

func (x *ClientInfo) GetClient() string

func (*ClientInfo) GetConnInfo added in v0.7.0 

func (x *ClientInfo) GetConnInfo() []byte

func (*ClientInfo) GetUser 

func (x *ClientInfo) GetUser() string

func (ClientInfo) MarshalEasyJSON added in v0.6.0 

func (v ClientInfo) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*ClientInfo) MarshalToSizedBufferVT added in v0.7.0 

func (m *ClientInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ClientInfo) MarshalToVT added in v0.7.0 

func (m *ClientInfo) MarshalToVT(dAtA []byte) (int, error)

func (*ClientInfo) MarshalVT added in v0.7.0 

func (m *ClientInfo) MarshalVT() (dAtA []byte, err error)

func (*ClientInfo) ProtoMessage 

func (*ClientInfo) ProtoMessage()

func (*ClientInfo) ProtoReflect added in v0.7.0 

func (x *ClientInfo) ProtoReflect() protoreflect.Message

func (*ClientInfo) Reset 

func (x *ClientInfo) Reset()

func (*ClientInfo) SizeVT added in v0.7.0 

func (m *ClientInfo) SizeVT() (n int)

func (*ClientInfo) String 

func (x *ClientInfo) String() string

func (*ClientInfo) UnmarshalEasyJSON added in v0.6.0 

func (v *ClientInfo) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*ClientInfo) UnmarshalVT added in v0.7.0 

func (m *ClientInfo) UnmarshalVT(dAtA []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=centrifugal.centrifuge.protocol.Command_MethodType" json:"method,omitempty"`
	Params Raw                `protobuf:"bytes,3,opt,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

func (*Command) Descriptor deprecated 

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

Deprecated: Use Command.ProtoReflect.Descriptor instead.

func (*Command) GetId added in v0.4.1 

func (x *Command) GetId() uint32

func (*Command) GetMethod 

func (x *Command) GetMethod() Command_MethodType

func (*Command) GetParams added in v0.7.0 

func (x *Command) GetParams() []byte

func (Command) MarshalEasyJSON added in v0.6.0 

func (v Command) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*Command) MarshalToSizedBufferVT added in v0.7.0 

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

func (*Command) MarshalToVT added in v0.7.0 

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

func (*Command) MarshalVT added in v0.7.0 

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

func (*Command) ProtoMessage 

func (*Command) ProtoMessage()

func (*Command) ProtoReflect added in v0.7.0 

func (x *Command) ProtoReflect() protoreflect.Message

func (*Command) Reset 

func (x *Command) Reset()

func (*Command) SizeVT added in v0.7.0 

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

func (*Command) String 

func (x *Command) String() string

func (*Command) UnmarshalEasyJSON added in v0.6.0 

func (v *Command) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*Command) UnmarshalVT added in v0.7.0 

func (m *Command) UnmarshalVT(dAtA []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) Descriptor added in v0.7.0 

func (Command_MethodType) Descriptor() protoreflect.EnumDescriptor

func (Command_MethodType) Enum added in v0.7.0 

func (x Command_MethodType) Enum() *Command_MethodType

func (Command_MethodType) EnumDescriptor deprecated added in v0.5.0 

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

Deprecated: Use Command_MethodType.Descriptor instead.

func (Command_MethodType) Number added in v0.7.0 

func (x Command_MethodType) Number() protoreflect.EnumNumber

func (Command_MethodType) String added in v0.5.0 

func (x Command_MethodType) String() string

func (Command_MethodType) Type added in v0.7.0 

func (Command_MethodType) Type() protoreflect.EnumType

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" json:"data,omitempty"`
	Subs    map[string]*SubscribeResult `` /* 149-byte string literal not displayed */
	Expires bool                        `protobuf:"varint,5,opt,name=expires,proto3" json:"expires,omitempty"`
	Ttl     uint32                      `protobuf:"varint,6,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

func (*Connect) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use Connect.ProtoReflect.Descriptor instead.

func (*Connect) GetClient added in v0.4.0 

func (x *Connect) GetClient() string

func (*Connect) GetData added in v0.7.0 

func (x *Connect) GetData() []byte

func (*Connect) GetExpires added in v0.6.0 

func (x *Connect) GetExpires() bool

func (*Connect) GetSubs added in v0.4.0 

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

func (*Connect) GetTtl added in v0.6.0 

func (x *Connect) GetTtl() uint32

func (*Connect) GetVersion added in v0.4.0 

func (x *Connect) GetVersion() string

func (Connect) MarshalEasyJSON added in v0.6.0 

func (v Connect) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*Connect) MarshalToSizedBufferVT added in v0.7.0 

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

func (*Connect) MarshalToVT added in v0.7.0 

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

func (*Connect) MarshalVT added in v0.7.0 

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

func (*Connect) ProtoMessage added in v0.4.0 

func (*Connect) ProtoMessage()

func (*Connect) ProtoReflect added in v0.7.0 

func (x *Connect) ProtoReflect() protoreflect.Message

func (*Connect) Reset added in v0.4.0 

func (x *Connect) Reset()

func (*Connect) SizeVT added in v0.7.0 

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

func (*Connect) String added in v0.4.0 

func (x *Connect) String() string

func (*Connect) UnmarshalEasyJSON added in v0.6.0 

func (v *Connect) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*Connect) UnmarshalVT added in v0.7.0 

func (m *Connect) UnmarshalVT(dAtA []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" 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"`
	// contains filtered or unexported fields
}

func (*ConnectRequest) Descriptor deprecated 

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

Deprecated: Use ConnectRequest.ProtoReflect.Descriptor instead.

func (*ConnectRequest) GetData added in v0.7.0 

func (x *ConnectRequest) GetData() []byte

func (*ConnectRequest) GetName added in v0.3.4 

func (x *ConnectRequest) GetName() string

func (*ConnectRequest) GetSubs 

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

func (*ConnectRequest) GetToken 

func (x *ConnectRequest) GetToken() string

func (*ConnectRequest) GetVersion added in v0.3.4 

func (x *ConnectRequest) GetVersion() string

func (ConnectRequest) MarshalEasyJSON added in v0.6.0 

func (v ConnectRequest) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*ConnectRequest) MarshalToSizedBufferVT added in v0.7.0 

func (m *ConnectRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ConnectRequest) MarshalToVT added in v0.7.0 

func (m *ConnectRequest) MarshalToVT(dAtA []byte) (int, error)

func (*ConnectRequest) MarshalVT added in v0.7.0 

func (m *ConnectRequest) MarshalVT() (dAtA []byte, err error)

func (*ConnectRequest) ProtoMessage 

func (*ConnectRequest) ProtoMessage()

func (*ConnectRequest) ProtoReflect added in v0.7.0 

func (x *ConnectRequest) ProtoReflect() protoreflect.Message

func (*ConnectRequest) Reset 

func (x *ConnectRequest) Reset()

func (*ConnectRequest) SizeVT added in v0.7.0 

func (m *ConnectRequest) SizeVT() (n int)

func (*ConnectRequest) String 

func (x *ConnectRequest) String() string

func (*ConnectRequest) UnmarshalEasyJSON added in v0.6.0 

func (v *ConnectRequest) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*ConnectRequest) UnmarshalVT added in v0.7.0 

func (m *ConnectRequest) UnmarshalVT(dAtA []byte) error

type ConnectResult 

type ConnectResult 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"`
	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" json:"data,omitempty"`
	Subs    map[string]*SubscribeResult `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ConnectResult) Descriptor deprecated 

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

Deprecated: Use ConnectResult.ProtoReflect.Descriptor instead.

func (*ConnectResult) GetClient 

func (x *ConnectResult) GetClient() string

func (*ConnectResult) GetData added in v0.7.0 

func (x *ConnectResult) GetData() []byte

func (*ConnectResult) GetExpires 

func (x *ConnectResult) GetExpires() bool

func (*ConnectResult) GetSubs 

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

func (*ConnectResult) GetTtl added in v0.4.1 

func (x *ConnectResult) GetTtl() uint32

func (*ConnectResult) GetVersion 

func (x *ConnectResult) GetVersion() string

func (ConnectResult) MarshalEasyJSON added in v0.6.0 

func (v ConnectResult) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*ConnectResult) MarshalToSizedBufferVT added in v0.7.0 

func (m *ConnectResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ConnectResult) MarshalToVT added in v0.7.0 

func (m *ConnectResult) MarshalToVT(dAtA []byte) (int, error)

func (*ConnectResult) MarshalVT added in v0.7.0 

func (m *ConnectResult) MarshalVT() (dAtA []byte, err error)

func (*ConnectResult) ProtoMessage 

func (*ConnectResult) ProtoMessage()

func (*ConnectResult) ProtoReflect added in v0.7.0 

func (x *ConnectResult) ProtoReflect() protoreflect.Message

func (*ConnectResult) Reset 

func (x *ConnectResult) Reset()

func (*ConnectResult) SizeVT added in v0.7.0 

func (m *ConnectResult) SizeVT() (n int)

func (*ConnectResult) String 

func (x *ConnectResult) String() string

func (*ConnectResult) UnmarshalEasyJSON added in v0.6.0 

func (v *ConnectResult) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*ConnectResult) UnmarshalVT added in v0.7.0 

func (m *ConnectResult) UnmarshalVT(dAtA []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"`
	// contains filtered or unexported fields
}

func (*Disconnect) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use Disconnect.ProtoReflect.Descriptor instead.

func (*Disconnect) GetCode added in v0.4.0 

func (x *Disconnect) GetCode() uint32

func (*Disconnect) GetReason added in v0.4.0 

func (x *Disconnect) GetReason() string

func (*Disconnect) GetReconnect added in v0.4.0 

func (x *Disconnect) GetReconnect() bool

func (Disconnect) MarshalEasyJSON added in v0.6.0 

func (v Disconnect) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*Disconnect) MarshalToSizedBufferVT added in v0.7.0 

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

func (*Disconnect) MarshalToVT added in v0.7.0 

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

func (*Disconnect) MarshalVT added in v0.7.0 

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

func (*Disconnect) ProtoMessage added in v0.4.0 

func (*Disconnect) ProtoMessage()

func (*Disconnect) ProtoReflect added in v0.7.0 

func (x *Disconnect) ProtoReflect() protoreflect.Message

func (*Disconnect) Reset added in v0.4.0 

func (x *Disconnect) Reset()

func (*Disconnect) SizeVT added in v0.7.0 

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

func (*Disconnect) String added in v0.4.0 

func (x *Disconnect) String() string

func (*Disconnect) UnmarshalEasyJSON added in v0.6.0 

func (v *Disconnect) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*Disconnect) UnmarshalVT added in v0.7.0 

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

type Error 

type Error struct {
	Code    uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Error) Descriptor deprecated 

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

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetCode 

func (x *Error) GetCode() uint32

func (*Error) GetMessage 

func (x *Error) GetMessage() string

func (Error) MarshalEasyJSON added in v0.6.0 

func (v Error) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*Error) MarshalToSizedBufferVT added in v0.7.0 

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

func (*Error) MarshalToVT added in v0.7.0 

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

func (*Error) MarshalVT added in v0.7.0 

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

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect added in v0.7.0 

func (x *Error) ProtoReflect() protoreflect.Message

func (*Error) Reset 

func (x *Error) Reset()

func (*Error) SizeVT added in v0.7.0 

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

func (*Error) String 

func (x *Error) String() string

func (*Error) UnmarshalEasyJSON added in v0.6.0 

func (v *Error) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*Error) UnmarshalVT added in v0.7.0 

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

type HistoryRequest 

type HistoryRequest struct {
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	// 2-6 skipped here for backwards compatibility.
	Limit int32           `protobuf:"varint,7,opt,name=limit,proto3" json:"limit,omitempty"`
	Since *StreamPosition `protobuf:"bytes,8,opt,name=since,proto3" json:"since,omitempty"`
	// contains filtered or unexported fields
}

func (*HistoryRequest) Descriptor deprecated 

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

Deprecated: Use HistoryRequest.ProtoReflect.Descriptor instead.

func (*HistoryRequest) GetChannel 

func (x *HistoryRequest) GetChannel() string

func (*HistoryRequest) GetLimit added in v0.3.5 

func (x *HistoryRequest) GetLimit() int32

func (*HistoryRequest) GetSince added in v0.6.0 

func (x *HistoryRequest) GetSince() *StreamPosition

func (HistoryRequest) MarshalEasyJSON added in v0.6.0 

func (v HistoryRequest) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*HistoryRequest) MarshalToSizedBufferVT added in v0.7.0 

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

func (*HistoryRequest) MarshalToVT added in v0.7.0 

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

func (*HistoryRequest) MarshalVT added in v0.7.0 

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

func (*HistoryRequest) ProtoMessage 

func (*HistoryRequest) ProtoMessage()

func (*HistoryRequest) ProtoReflect added in v0.7.0 

func (x *HistoryRequest) ProtoReflect() protoreflect.Message

func (*HistoryRequest) Reset 

func (x *HistoryRequest) Reset()

func (*HistoryRequest) SizeVT added in v0.7.0 

func (m *HistoryRequest) SizeVT() (n int)

func (*HistoryRequest) String 

func (x *HistoryRequest) String() string

func (*HistoryRequest) UnmarshalEasyJSON added in v0.6.0 

func (v *HistoryRequest) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*HistoryRequest) UnmarshalVT added in v0.7.0 

func (m *HistoryRequest) UnmarshalVT(dAtA []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"`
	// contains filtered or unexported fields
}

func (*HistoryResult) Descriptor deprecated 

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

Deprecated: Use HistoryResult.ProtoReflect.Descriptor instead.

func (*HistoryResult) GetEpoch added in v0.3.5 

func (x *HistoryResult) GetEpoch() string

func (*HistoryResult) GetOffset added in v0.3.5 

func (x *HistoryResult) GetOffset() uint64

func (*HistoryResult) GetPublications 

func (x *HistoryResult) GetPublications() []*Publication

func (HistoryResult) MarshalEasyJSON added in v0.6.0 

func (v HistoryResult) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*HistoryResult) MarshalToSizedBufferVT added in v0.7.0 

func (m *HistoryResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*HistoryResult) MarshalToVT added in v0.7.0 

func (m *HistoryResult) MarshalToVT(dAtA []byte) (int, error)

func (*HistoryResult) MarshalVT added in v0.7.0 

func (m *HistoryResult) MarshalVT() (dAtA []byte, err error)

func (*HistoryResult) ProtoMessage 

func (*HistoryResult) ProtoMessage()

func (*HistoryResult) ProtoReflect added in v0.7.0 

func (x *HistoryResult) ProtoReflect() protoreflect.Message

func (*HistoryResult) Reset 

func (x *HistoryResult) Reset()

func (*HistoryResult) SizeVT added in v0.7.0 

func (m *HistoryResult) SizeVT() (n int)

func (*HistoryResult) String 

func (x *HistoryResult) String() string

func (*HistoryResult) UnmarshalEasyJSON added in v0.6.0 

func (v *HistoryResult) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*HistoryResult) UnmarshalVT added in v0.7.0 

func (m *HistoryResult) UnmarshalVT(dAtA []byte) error

type JSONCommandDecoder 

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

JSONCommandDecoder ...

func NewJSONCommandDecoder 

func NewJSONCommandDecoder(data []byte) *JSONCommandDecoder

NewJSONCommandDecoder ...

func (*JSONCommandDecoder) Decode 

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

Decode ...

func (*JSONCommandDecoder) Reset 

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

Reset ...

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

DecodeSubscribe ...

func (*JSONPushDecoder) DecodeUnsubscribe added in v0.4.0 

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

DecodeUnsubscribe ...

type JSONPushEncoder 

type JSONPushEncoder struct {
}

JSONPushEncoder ...

func NewJSONPushEncoder 

func NewJSONPushEncoder() *JSONPushEncoder

NewJSONPushEncoder ...

func (*JSONPushEncoder) Encode 

func (e *JSONPushEncoder) Encode(message *Push) ([]byte, error)

Encode Push to bytes.

func (*JSONPushEncoder) EncodeConnect added in v0.4.0 

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

EncodeConnect to bytes.

func (*JSONPushEncoder) EncodeDisconnect added in v0.4.0 

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

EncodeDisconnect to bytes.

func (*JSONPushEncoder) EncodeJoin 

func (e *JSONPushEncoder) EncodeJoin(message *Join) ([]byte, error)

EncodeJoin to bytes.

func (*JSONPushEncoder) EncodeLeave 

func (e *JSONPushEncoder) EncodeLeave(message *Leave) ([]byte, error)

EncodeLeave to bytes.

func (*JSONPushEncoder) EncodeMessage 

func (e *JSONPushEncoder) EncodeMessage(message *Message) ([]byte, error)

EncodeMessage to bytes.

func (*JSONPushEncoder) EncodePublication 

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

EncodePublication to bytes.

func (*JSONPushEncoder) EncodeRefresh added in v0.6.0 

func (e *JSONPushEncoder) EncodeRefresh(message *Refresh) ([]byte, error)

EncodeRefresh to bytes.

func (*JSONPushEncoder) EncodeSubscribe added in v0.4.0 

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

EncodeSubscribe to bytes.

func (*JSONPushEncoder) EncodeUnsubscribe added in v0.4.0 

func (e *JSONPushEncoder) EncodeUnsubscribe(message *Unsubscribe) ([]byte, error)

EncodeUnsubscribe to bytes.

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 Reply to bytes.

type JSONResultDecoder 

type JSONResultDecoder struct{}

JSONResultDecoder ...

func NewJSONResultDecoder 

func NewJSONResultDecoder() *JSONResultDecoder

NewJSONResultDecoder ...

func (*JSONResultDecoder) Decode 

func (e *JSONResultDecoder) Decode(data []byte, dst 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,omitempty"`
	// contains filtered or unexported fields
}

func (*Join) Descriptor deprecated 

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

Deprecated: Use Join.ProtoReflect.Descriptor instead.

func (*Join) GetInfo 

func (x *Join) GetInfo() *ClientInfo

func (Join) MarshalEasyJSON added in v0.6.0 

func (v Join) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*Join) MarshalToSizedBufferVT added in v0.7.0 

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

func (*Join) MarshalToVT added in v0.7.0 

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

func (*Join) MarshalVT added in v0.7.0 

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

func (*Join) ProtoMessage 

func (*Join) ProtoMessage()

func (*Join) ProtoReflect added in v0.7.0 

func (x *Join) ProtoReflect() protoreflect.Message

func (*Join) Reset 

func (x *Join) Reset()

func (*Join) SizeVT added in v0.7.0 

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

func (*Join) String 

func (x *Join) String() string

func (*Join) UnmarshalEasyJSON added in v0.6.0 

func (v *Join) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*Join) UnmarshalVT added in v0.7.0 

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

type Leave 

type Leave struct {
	Info *ClientInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

func (*Leave) Descriptor deprecated 

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

Deprecated: Use Leave.ProtoReflect.Descriptor instead.

func (*Leave) GetInfo 

func (x *Leave) GetInfo() *ClientInfo

func (Leave) MarshalEasyJSON added in v0.6.0 

func (v Leave) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*Leave) MarshalToSizedBufferVT added in v0.7.0 

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

func (*Leave) MarshalToVT added in v0.7.0 

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

func (*Leave) MarshalVT added in v0.7.0 

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

func (*Leave) ProtoMessage 

func (*Leave) ProtoMessage()

func (*Leave) ProtoReflect added in v0.7.0 

func (x *Leave) ProtoReflect() protoreflect.Message

func (*Leave) Reset 

func (x *Leave) Reset()

func (*Leave) SizeVT added in v0.7.0 

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

func (*Leave) String 

func (x *Leave) String() string

func (*Leave) UnmarshalEasyJSON added in v0.6.0 

func (v *Leave) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*Leave) UnmarshalVT added in v0.7.0 

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

type Message 

type Message struct {
	Data Raw `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Message) Descriptor deprecated 

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetData added in v0.7.0 

func (x *Message) GetData() []byte

func (Message) MarshalEasyJSON added in v0.6.0 

func (v Message) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*Message) MarshalToSizedBufferVT added in v0.7.0 

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

func (*Message) MarshalToVT added in v0.7.0 

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

func (*Message) MarshalVT added in v0.7.0 

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

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect added in v0.7.0 

func (x *Message) ProtoReflect() protoreflect.Message

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) SizeVT added in v0.7.0 

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

func (*Message) String 

func (x *Message) String() string

func (*Message) UnmarshalEasyJSON added in v0.6.0 

func (v *Message) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*Message) UnmarshalVT added in v0.7.0 

func (m *Message) UnmarshalVT(dAtA []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 {
	// contains filtered or unexported fields
}

func (*PingRequest) Descriptor deprecated 

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

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (PingRequest) MarshalEasyJSON added in v0.6.0 

func (v PingRequest) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*PingRequest) MarshalToSizedBufferVT added in v0.7.0 

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

func (*PingRequest) MarshalToVT added in v0.7.0 

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

func (*PingRequest) MarshalVT added in v0.7.0 

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

func (*PingRequest) ProtoMessage 

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect added in v0.7.0 

func (x *PingRequest) ProtoReflect() protoreflect.Message

func (*PingRequest) Reset 

func (x *PingRequest) Reset()

func (*PingRequest) SizeVT added in v0.7.0 

func (m *PingRequest) SizeVT() (n int)

func (*PingRequest) String 

func (x *PingRequest) String() string

func (*PingRequest) UnmarshalEasyJSON added in v0.6.0 

func (v *PingRequest) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*PingRequest) UnmarshalVT added in v0.7.0 

func (m *PingRequest) UnmarshalVT(dAtA []byte) error

type PingResult 

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

func (*PingResult) Descriptor deprecated 

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

Deprecated: Use PingResult.ProtoReflect.Descriptor instead.

func (PingResult) MarshalEasyJSON added in v0.6.0 

func (v PingResult) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*PingResult) MarshalToSizedBufferVT added in v0.7.0 

func (m *PingResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PingResult) MarshalToVT added in v0.7.0 

func (m *PingResult) MarshalToVT(dAtA []byte) (int, error)

func (*PingResult) MarshalVT added in v0.7.0 

func (m *PingResult) MarshalVT() (dAtA []byte, err error)

func (*PingResult) ProtoMessage 

func (*PingResult) ProtoMessage()

func (*PingResult) ProtoReflect added in v0.7.0 

func (x *PingResult) ProtoReflect() protoreflect.Message

func (*PingResult) Reset 

func (x *PingResult) Reset()

func (*PingResult) SizeVT added in v0.7.0 

func (m *PingResult) SizeVT() (n int)

func (*PingResult) String 

func (x *PingResult) String() string

func (*PingResult) UnmarshalEasyJSON added in v0.6.0 

func (v *PingResult) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*PingResult) UnmarshalVT added in v0.7.0 

func (m *PingResult) UnmarshalVT(dAtA []byte) error

type PresenceRequest 

type PresenceRequest struct {
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	// contains filtered or unexported fields
}

func (*PresenceRequest) Descriptor deprecated 

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

Deprecated: Use PresenceRequest.ProtoReflect.Descriptor instead.

func (*PresenceRequest) GetChannel 

func (x *PresenceRequest) GetChannel() string

func (PresenceRequest) MarshalEasyJSON added in v0.6.0 

func (v PresenceRequest) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*PresenceRequest) MarshalToSizedBufferVT added in v0.7.0 

func (m *PresenceRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PresenceRequest) MarshalToVT added in v0.7.0 

func (m *PresenceRequest) MarshalToVT(dAtA []byte) (int, error)

func (*PresenceRequest) MarshalVT added in v0.7.0 

func (m *PresenceRequest) MarshalVT() (dAtA []byte, err error)

func (*PresenceRequest) ProtoMessage 

func (*PresenceRequest) ProtoMessage()

func (*PresenceRequest) ProtoReflect added in v0.7.0 

func (x *PresenceRequest) ProtoReflect() protoreflect.Message

func (*PresenceRequest) Reset 

func (x *PresenceRequest) Reset()

func (*PresenceRequest) SizeVT added in v0.7.0 

func (m *PresenceRequest) SizeVT() (n int)

func (*PresenceRequest) String 

func (x *PresenceRequest) String() string

func (*PresenceRequest) UnmarshalEasyJSON added in v0.6.0 

func (v *PresenceRequest) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*PresenceRequest) UnmarshalVT added in v0.7.0 

func (m *PresenceRequest) UnmarshalVT(dAtA []byte) error

type PresenceResult 

type PresenceResult struct {
	Presence map[string]*ClientInfo `` /* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PresenceResult) Descriptor deprecated 

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

Deprecated: Use PresenceResult.ProtoReflect.Descriptor instead.

func (*PresenceResult) GetPresence 

func (x *PresenceResult) GetPresence() map[string]*ClientInfo

func (PresenceResult) MarshalEasyJSON added in v0.6.0 

func (v PresenceResult) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*PresenceResult) MarshalToSizedBufferVT added in v0.7.0 

func (m *PresenceResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PresenceResult) MarshalToVT added in v0.7.0 

func (m *PresenceResult) MarshalToVT(dAtA []byte) (int, error)

func (*PresenceResult) MarshalVT added in v0.7.0 

func (m *PresenceResult) MarshalVT() (dAtA []byte, err error)

func (*PresenceResult) ProtoMessage 

func (*PresenceResult) ProtoMessage()

func (*PresenceResult) ProtoReflect added in v0.7.0 

func (x *PresenceResult) ProtoReflect() protoreflect.Message

func (*PresenceResult) Reset 

func (x *PresenceResult) Reset()

func (*PresenceResult) SizeVT added in v0.7.0 

func (m *PresenceResult) SizeVT() (n int)

func (*PresenceResult) String 

func (x *PresenceResult) String() string

func (*PresenceResult) UnmarshalEasyJSON added in v0.6.0 

func (v *PresenceResult) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*PresenceResult) UnmarshalVT added in v0.7.0 

func (m *PresenceResult) UnmarshalVT(dAtA []byte) error

type PresenceStatsRequest 

type PresenceStatsRequest struct {
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	// contains filtered or unexported fields
}

func (*PresenceStatsRequest) Descriptor deprecated 

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

Deprecated: Use PresenceStatsRequest.ProtoReflect.Descriptor instead.

func (*PresenceStatsRequest) GetChannel 

func (x *PresenceStatsRequest) GetChannel() string

func (PresenceStatsRequest) MarshalEasyJSON added in v0.6.0 

func (v PresenceStatsRequest) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*PresenceStatsRequest) MarshalToSizedBufferVT added in v0.7.0 

func (m *PresenceStatsRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PresenceStatsRequest) MarshalToVT added in v0.7.0 

func (m *PresenceStatsRequest) MarshalToVT(dAtA []byte) (int, error)

func (*PresenceStatsRequest) MarshalVT added in v0.7.0 

func (m *PresenceStatsRequest) MarshalVT() (dAtA []byte, err error)

func (*PresenceStatsRequest) ProtoMessage 

func (*PresenceStatsRequest) ProtoMessage()

func (*PresenceStatsRequest) ProtoReflect added in v0.7.0 

func (x *PresenceStatsRequest) ProtoReflect() protoreflect.Message

func (*PresenceStatsRequest) Reset 

func (x *PresenceStatsRequest) Reset()

func (*PresenceStatsRequest) SizeVT added in v0.7.0 

func (m *PresenceStatsRequest) SizeVT() (n int)

func (*PresenceStatsRequest) String 

func (x *PresenceStatsRequest) String() string

func (*PresenceStatsRequest) UnmarshalEasyJSON added in v0.6.0 

func (v *PresenceStatsRequest) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*PresenceStatsRequest) UnmarshalVT added in v0.7.0 

func (m *PresenceStatsRequest) UnmarshalVT(dAtA []byte) error

type PresenceStatsResult 

type PresenceStatsResult struct {
	NumClients uint32 `protobuf:"varint,1,opt,name=num_clients,json=numClients,proto3" json:"num_clients"`
	NumUsers   uint32 `protobuf:"varint,2,opt,name=num_users,json=numUsers,proto3" json:"num_users"`
	// contains filtered or unexported fields
}

func (*PresenceStatsResult) Descriptor deprecated 

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

Deprecated: Use PresenceStatsResult.ProtoReflect.Descriptor instead.

func (*PresenceStatsResult) GetNumClients 

func (x *PresenceStatsResult) GetNumClients() uint32

func (*PresenceStatsResult) GetNumUsers 

func (x *PresenceStatsResult) GetNumUsers() uint32

func (PresenceStatsResult) MarshalEasyJSON added in v0.6.0 

func (v PresenceStatsResult) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*PresenceStatsResult) MarshalToSizedBufferVT added in v0.7.0 

func (m *PresenceStatsResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PresenceStatsResult) MarshalToVT added in v0.7.0 

func (m *PresenceStatsResult) MarshalToVT(dAtA []byte) (int, error)

func (*PresenceStatsResult) MarshalVT added in v0.7.0 

func (m *PresenceStatsResult) MarshalVT() (dAtA []byte, err error)

func (*PresenceStatsResult) ProtoMessage 

func (*PresenceStatsResult) ProtoMessage()

func (*PresenceStatsResult) ProtoReflect added in v0.7.0 

func (x *PresenceStatsResult) ProtoReflect() protoreflect.Message

func (*PresenceStatsResult) Reset 

func (x *PresenceStatsResult) Reset()

func (*PresenceStatsResult) SizeVT added in v0.7.0 

func (m *PresenceStatsResult) SizeVT() (n int)

func (*PresenceStatsResult) String 

func (x *PresenceStatsResult) String() string

func (*PresenceStatsResult) UnmarshalEasyJSON added in v0.6.0 

func (v *PresenceStatsResult) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*PresenceStatsResult) UnmarshalVT added in v0.7.0 

func (m *PresenceStatsResult) UnmarshalVT(dAtA []byte) error

type ProtobufCommandDecoder 

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

ProtobufCommandDecoder ...

func NewProtobufCommandDecoder 

func NewProtobufCommandDecoder(data []byte) *ProtobufCommandDecoder

NewProtobufCommandDecoder ...

func (*ProtobufCommandDecoder) Decode 

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

Decode ...

func (*ProtobufCommandDecoder) Reset 

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

Reset ...

type 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 Push to bytes.

func (*ProtobufPushEncoder) EncodeConnect added in v0.4.0 

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

EncodeConnect to bytes.

func (*ProtobufPushEncoder) EncodeDisconnect added in v0.4.0 

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

EncodeDisconnect to bytes.

func (*ProtobufPushEncoder) EncodeJoin 

func (e *ProtobufPushEncoder) EncodeJoin(message *Join) ([]byte, error)

EncodeJoin to bytes.

func (*ProtobufPushEncoder) EncodeLeave 

func (e *ProtobufPushEncoder) EncodeLeave(message *Leave) ([]byte, error)

EncodeLeave to bytes.

func (*ProtobufPushEncoder) EncodeMessage 

func (e *ProtobufPushEncoder) EncodeMessage(message *Message) ([]byte, error)

EncodeMessage to bytes.

func (*ProtobufPushEncoder) EncodePublication 

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

EncodePublication to bytes.

func (*ProtobufPushEncoder) EncodeRefresh added in v0.6.0 

func (e *ProtobufPushEncoder) EncodeRefresh(message *Refresh) ([]byte, error)

EncodeRefresh to bytes.

func (*ProtobufPushEncoder) EncodeSubscribe added in v0.4.0 

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

EncodeSubscribe to bytes.

func (*ProtobufPushEncoder) EncodeUnsubscribe added in v0.4.0 

func (e *ProtobufPushEncoder) EncodeUnsubscribe(message *Unsubscribe) ([]byte, error)

EncodeUnsubscribe to bytes.

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 Reply to bytes.

type ProtobufResultDecoder 

type ProtobufResultDecoder struct{}

ProtobufResultDecoder ...

func NewProtobufResultDecoder 

func NewProtobufResultDecoder() *ProtobufResultDecoder

NewProtobufResultDecoder ...

func (*ProtobufResultDecoder) Decode 

func (e *ProtobufResultDecoder) Decode(data []byte, dst 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 {

	// 1-3 skipped here for backwards compatibility.
	Data   Raw         `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	Info   *ClientInfo `protobuf:"bytes,5,opt,name=info,proto3" json:"info,omitempty"`
	Offset uint64      `protobuf:"varint,6,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*Publication) Descriptor deprecated 

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

Deprecated: Use Publication.ProtoReflect.Descriptor instead.

func (*Publication) GetData added in v0.7.0 

func (x *Publication) GetData() []byte

func (*Publication) GetInfo 

func (x *Publication) GetInfo() *ClientInfo

func (*Publication) GetOffset 

func (x *Publication) GetOffset() uint64

func (Publication) MarshalEasyJSON added in v0.6.0 

func (v Publication) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*Publication) MarshalToSizedBufferVT added in v0.7.0 

func (m *Publication) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Publication) MarshalToVT added in v0.7.0 

func (m *Publication) MarshalToVT(dAtA []byte) (int, error)

func (*Publication) MarshalVT added in v0.7.0 

func (m *Publication) MarshalVT() (dAtA []byte, err error)

func (*Publication) ProtoMessage 

func (*Publication) ProtoMessage()

func (*Publication) ProtoReflect added in v0.7.0 

func (x *Publication) ProtoReflect() protoreflect.Message

func (*Publication) Reset 

func (x *Publication) Reset()

func (*Publication) SizeVT added in v0.7.0 

func (m *Publication) SizeVT() (n int)

func (*Publication) String 

func (x *Publication) String() string

func (*Publication) UnmarshalEasyJSON added in v0.6.0 

func (v *Publication) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*Publication) UnmarshalVT added in v0.7.0 

func (m *Publication) UnmarshalVT(dAtA []byte) error

type PublishRequest 

type PublishRequest struct {
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	Data    Raw    `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishRequest) Descriptor deprecated 

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

Deprecated: Use PublishRequest.ProtoReflect.Descriptor instead.

func (*PublishRequest) GetChannel 

func (x *PublishRequest) GetChannel() string

func (*PublishRequest) GetData added in v0.7.0 

func (x *PublishRequest) GetData() []byte

func (PublishRequest) MarshalEasyJSON added in v0.6.0 

func (v PublishRequest) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*PublishRequest) MarshalToSizedBufferVT added in v0.7.0 

func (m *PublishRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PublishRequest) MarshalToVT added in v0.7.0 

func (m *PublishRequest) MarshalToVT(dAtA []byte) (int, error)

func (*PublishRequest) MarshalVT added in v0.7.0 

func (m *PublishRequest) MarshalVT() (dAtA []byte, err error)

func (*PublishRequest) ProtoMessage 

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) ProtoReflect added in v0.7.0 

func (x *PublishRequest) ProtoReflect() protoreflect.Message

func (*PublishRequest) Reset 

func (x *PublishRequest) Reset()

func (*PublishRequest) SizeVT added in v0.7.0 

func (m *PublishRequest) SizeVT() (n int)

func (*PublishRequest) String 

func (x *PublishRequest) String() string

func (*PublishRequest) UnmarshalEasyJSON added in v0.6.0 

func (v *PublishRequest) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*PublishRequest) UnmarshalVT added in v0.7.0 

func (m *PublishRequest) UnmarshalVT(dAtA []byte) error

type PublishResult 

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

func (*PublishResult) Descriptor deprecated 

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

Deprecated: Use PublishResult.ProtoReflect.Descriptor instead.

func (PublishResult) MarshalEasyJSON added in v0.6.0 

func (v PublishResult) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*PublishResult) MarshalToSizedBufferVT added in v0.7.0 

func (m *PublishResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PublishResult) MarshalToVT added in v0.7.0 

func (m *PublishResult) MarshalToVT(dAtA []byte) (int, error)

func (*PublishResult) MarshalVT added in v0.7.0 

func (m *PublishResult) MarshalVT() (dAtA []byte, err error)

func (*PublishResult) ProtoMessage 

func (*PublishResult) ProtoMessage()

func (*PublishResult) ProtoReflect added in v0.7.0 

func (x *PublishResult) ProtoReflect() protoreflect.Message

func (*PublishResult) Reset 

func (x *PublishResult) Reset()

func (*PublishResult) SizeVT added in v0.7.0 

func (m *PublishResult) SizeVT() (n int)

func (*PublishResult) String 

func (x *PublishResult) String() string

func (*PublishResult) UnmarshalEasyJSON added in v0.6.0 

func (v *PublishResult) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*PublishResult) UnmarshalVT added in v0.7.0 

func (m *PublishResult) UnmarshalVT(dAtA []byte) error

type Push 

type Push struct {
	Type    Push_PushType `protobuf:"varint,1,opt,name=type,proto3,enum=centrifugal.centrifuge.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" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Push) Descriptor deprecated 

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

Deprecated: Use Push.ProtoReflect.Descriptor instead.

func (*Push) GetChannel 

func (x *Push) GetChannel() string

func (*Push) GetData added in v0.7.0 

func (x *Push) GetData() []byte

func (*Push) GetType 

func (x *Push) GetType() Push_PushType

func (Push) MarshalEasyJSON added in v0.6.0 

func (v Push) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*Push) MarshalToSizedBufferVT added in v0.7.0 

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

func (*Push) MarshalToVT added in v0.7.0 

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

func (*Push) MarshalVT added in v0.7.0 

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

func (*Push) ProtoMessage 

func (*Push) ProtoMessage()

func (*Push) ProtoReflect added in v0.7.0 

func (x *Push) ProtoReflect() protoreflect.Message

func (*Push) Reset 

func (x *Push) Reset()

func (*Push) SizeVT added in v0.7.0 

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

func (*Push) String 

func (x *Push) String() string

func (*Push) UnmarshalEasyJSON added in v0.6.0 

func (v *Push) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*Push) UnmarshalVT added in v0.7.0 

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

type PushDecoder 

type PushDecoder interface {
	Decode([]byte) (*Push, error)
	DecodePublication([]byte) (*Publication, error)
	DecodeJoin([]byte) (*Join, error)
	DecodeLeave([]byte) (*Leave, error)
	DecodeMessage([]byte) (*Message, error)
	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)
	EncodeRefresh(*Refresh) ([]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
	Push_REFRESH     Push_PushType = 8
)

func (Push_PushType) Descriptor added in v0.7.0 

func (Push_PushType) Descriptor() protoreflect.EnumDescriptor

func (Push_PushType) Enum added in v0.7.0 

func (x Push_PushType) Enum() *Push_PushType

func (Push_PushType) EnumDescriptor deprecated added in v0.5.0 

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

Deprecated: Use Push_PushType.Descriptor instead.

func (Push_PushType) Number added in v0.7.0 

func (x Push_PushType) Number() protoreflect.EnumNumber

func (Push_PushType) String added in v0.5.0 

func (x Push_PushType) String() string

func (Push_PushType) Type added in v0.7.0 

func (Push_PushType) Type() protoreflect.EnumType

type RPCRequest 

type RPCRequest struct {
	Data   Raw    `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Method string `protobuf:"bytes,2,opt,name=method,proto3" json:"method,omitempty"`
	// contains filtered or unexported fields
}

func (*RPCRequest) Descriptor deprecated 

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

Deprecated: Use RPCRequest.ProtoReflect.Descriptor instead.

func (*RPCRequest) GetData added in v0.7.0 

func (x *RPCRequest) GetData() []byte

func (*RPCRequest) GetMethod added in v0.3.3 

func (x *RPCRequest) GetMethod() string

func (RPCRequest) MarshalEasyJSON added in v0.6.0 

func (v RPCRequest) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*RPCRequest) MarshalToSizedBufferVT added in v0.7.0 

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

func (*RPCRequest) MarshalToVT added in v0.7.0 

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

func (*RPCRequest) MarshalVT added in v0.7.0 

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

func (*RPCRequest) ProtoMessage 

func (*RPCRequest) ProtoMessage()

func (*RPCRequest) ProtoReflect added in v0.7.0 

func (x *RPCRequest) ProtoReflect() protoreflect.Message

func (*RPCRequest) Reset 

func (x *RPCRequest) Reset()

func (*RPCRequest) SizeVT added in v0.7.0 

func (m *RPCRequest) SizeVT() (n int)

func (*RPCRequest) String 

func (x *RPCRequest) String() string

func (*RPCRequest) UnmarshalEasyJSON added in v0.6.0 

func (v *RPCRequest) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*RPCRequest) UnmarshalVT added in v0.7.0 

func (m *RPCRequest) UnmarshalVT(dAtA []byte) error

type RPCResult 

type RPCResult struct {
	Data Raw `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*RPCResult) Descriptor deprecated 

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

Deprecated: Use RPCResult.ProtoReflect.Descriptor instead.

func (*RPCResult) GetData added in v0.7.0 

func (x *RPCResult) GetData() []byte

func (RPCResult) MarshalEasyJSON added in v0.6.0 

func (v RPCResult) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*RPCResult) MarshalToSizedBufferVT added in v0.7.0 

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

func (*RPCResult) MarshalToVT added in v0.7.0 

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

func (*RPCResult) MarshalVT added in v0.7.0 

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

func (*RPCResult) ProtoMessage 

func (*RPCResult) ProtoMessage()

func (*RPCResult) ProtoReflect added in v0.7.0 

func (x *RPCResult) ProtoReflect() protoreflect.Message

func (*RPCResult) Reset 

func (x *RPCResult) Reset()

func (*RPCResult) SizeVT added in v0.7.0 

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

func (*RPCResult) String 

func (x *RPCResult) String() string

func (*RPCResult) UnmarshalEasyJSON added in v0.6.0 

func (v *RPCResult) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*RPCResult) UnmarshalVT added in v0.7.0 

func (m *RPCResult) UnmarshalVT(dAtA []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 (Raw) MarshalJSON 

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

MarshalJSON returns *r as the JSON encoding of r.

func (*Raw) UnmarshalJSON 

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

UnmarshalJSON sets *r to a copy of data.

type Refresh added in v0.6.0 

type Refresh 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"`
	// contains filtered or unexported fields
}

func (*Refresh) Descriptor deprecated added in v0.6.0 

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

Deprecated: Use Refresh.ProtoReflect.Descriptor instead.

func (*Refresh) GetExpires added in v0.6.0 

func (x *Refresh) GetExpires() bool

func (*Refresh) GetTtl added in v0.6.0 

func (x *Refresh) GetTtl() uint32

func (Refresh) MarshalEasyJSON added in v0.6.0 

func (v Refresh) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*Refresh) MarshalToSizedBufferVT added in v0.7.0 

func (m *Refresh) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Refresh) MarshalToVT added in v0.7.0 

func (m *Refresh) MarshalToVT(dAtA []byte) (int, error)

func (*Refresh) MarshalVT added in v0.7.0 

func (m *Refresh) MarshalVT() (dAtA []byte, err error)

func (*Refresh) ProtoMessage added in v0.6.0 

func (*Refresh) ProtoMessage()

func (*Refresh) ProtoReflect added in v0.7.0 

func (x *Refresh) ProtoReflect() protoreflect.Message

func (*Refresh) Reset added in v0.6.0 

func (x *Refresh) Reset()

func (*Refresh) SizeVT added in v0.7.0 

func (m *Refresh) SizeVT() (n int)

func (*Refresh) String added in v0.6.0 

func (x *Refresh) String() string

func (*Refresh) UnmarshalEasyJSON added in v0.6.0 

func (v *Refresh) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*Refresh) UnmarshalVT added in v0.7.0 

func (m *Refresh) UnmarshalVT(dAtA []byte) error

type RefreshRequest 

type RefreshRequest struct {
	Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*RefreshRequest) Descriptor deprecated 

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

Deprecated: Use RefreshRequest.ProtoReflect.Descriptor instead.

func (*RefreshRequest) GetToken 

func (x *RefreshRequest) GetToken() string

func (RefreshRequest) MarshalEasyJSON added in v0.6.0 

func (v RefreshRequest) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*RefreshRequest) MarshalToSizedBufferVT added in v0.7.0 

func (m *RefreshRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RefreshRequest) MarshalToVT added in v0.7.0 

func (m *RefreshRequest) MarshalToVT(dAtA []byte) (int, error)

func (*RefreshRequest) MarshalVT added in v0.7.0 

func (m *RefreshRequest) MarshalVT() (dAtA []byte, err error)

func (*RefreshRequest) ProtoMessage 

func (*RefreshRequest) ProtoMessage()

func (*RefreshRequest) ProtoReflect added in v0.7.0 

func (x *RefreshRequest) ProtoReflect() protoreflect.Message

func (*RefreshRequest) Reset 

func (x *RefreshRequest) Reset()

func (*RefreshRequest) SizeVT added in v0.7.0 

func (m *RefreshRequest) SizeVT() (n int)

func (*RefreshRequest) String 

func (x *RefreshRequest) String() string

func (*RefreshRequest) UnmarshalEasyJSON added in v0.6.0 

func (v *RefreshRequest) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*RefreshRequest) UnmarshalVT added in v0.7.0 

func (m *RefreshRequest) UnmarshalVT(dAtA []byte) error

type RefreshResult 

type RefreshResult 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"`
	Expires bool   `protobuf:"varint,3,opt,name=expires,proto3" json:"expires,omitempty"`
	Ttl     uint32 `protobuf:"varint,4,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

func (*RefreshResult) Descriptor deprecated 

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

Deprecated: Use RefreshResult.ProtoReflect.Descriptor instead.

func (*RefreshResult) GetClient 

func (x *RefreshResult) GetClient() string

func (*RefreshResult) GetExpires 

func (x *RefreshResult) GetExpires() bool

func (*RefreshResult) GetTtl added in v0.4.1 

func (x *RefreshResult) GetTtl() uint32

func (*RefreshResult) GetVersion 

func (x *RefreshResult) GetVersion() string

func (RefreshResult) MarshalEasyJSON added in v0.6.0 

func (v RefreshResult) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*RefreshResult) MarshalToSizedBufferVT added in v0.7.0 

func (m *RefreshResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*RefreshResult) MarshalToVT added in v0.7.0 

func (m *RefreshResult) MarshalToVT(dAtA []byte) (int, error)

func (*RefreshResult) MarshalVT added in v0.7.0 

func (m *RefreshResult) MarshalVT() (dAtA []byte, err error)

func (*RefreshResult) ProtoMessage 

func (*RefreshResult) ProtoMessage()

func (*RefreshResult) ProtoReflect added in v0.7.0 

func (x *RefreshResult) ProtoReflect() protoreflect.Message

func (*RefreshResult) Reset 

func (x *RefreshResult) Reset()

func (*RefreshResult) SizeVT added in v0.7.0 

func (m *RefreshResult) SizeVT() (n int)

func (*RefreshResult) String 

func (x *RefreshResult) String() string

func (*RefreshResult) UnmarshalEasyJSON added in v0.6.0 

func (v *RefreshResult) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*RefreshResult) UnmarshalVT added in v0.7.0 

func (m *RefreshResult) UnmarshalVT(dAtA []byte) error

type Reply 

type Reply struct {
	Id     uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Error  *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Result Raw    `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*Reply) Descriptor deprecated 

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

Deprecated: Use Reply.ProtoReflect.Descriptor instead.

func (*Reply) GetError 

func (x *Reply) GetError() *Error

func (*Reply) GetId added in v0.4.1 

func (x *Reply) GetId() uint32

func (*Reply) GetResult added in v0.7.0 

func (x *Reply) GetResult() []byte

func (Reply) MarshalEasyJSON added in v0.6.0 

func (v Reply) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*Reply) MarshalToSizedBufferVT added in v0.7.0 

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

func (*Reply) MarshalToVT added in v0.7.0 

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

func (*Reply) MarshalVT added in v0.7.0 

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

func (*Reply) ProtoMessage 

func (*Reply) ProtoMessage()

func (*Reply) ProtoReflect added in v0.7.0 

func (x *Reply) ProtoReflect() protoreflect.Message

func (*Reply) Reset 

func (x *Reply) Reset()

func (*Reply) SizeVT added in v0.7.0 

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

func (*Reply) String 

func (x *Reply) String() string

func (*Reply) UnmarshalEasyJSON added in v0.6.0 

func (v *Reply) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*Reply) UnmarshalVT added in v0.7.0 

func (m *Reply) UnmarshalVT(dAtA []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" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*SendRequest) Descriptor deprecated 

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

Deprecated: Use SendRequest.ProtoReflect.Descriptor instead.

func (*SendRequest) GetData added in v0.7.0 

func (x *SendRequest) GetData() []byte

func (SendRequest) MarshalEasyJSON added in v0.6.0 

func (v SendRequest) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*SendRequest) MarshalToSizedBufferVT added in v0.7.0 

func (m *SendRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SendRequest) MarshalToVT added in v0.7.0 

func (m *SendRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SendRequest) MarshalVT added in v0.7.0 

func (m *SendRequest) MarshalVT() (dAtA []byte, err error)

func (*SendRequest) ProtoMessage 

func (*SendRequest) ProtoMessage()

func (*SendRequest) ProtoReflect added in v0.7.0 

func (x *SendRequest) ProtoReflect() protoreflect.Message

func (*SendRequest) Reset 

func (x *SendRequest) Reset()

func (*SendRequest) SizeVT added in v0.7.0 

func (m *SendRequest) SizeVT() (n int)

func (*SendRequest) String 

func (x *SendRequest) String() string

func (*SendRequest) UnmarshalEasyJSON added in v0.6.0 

func (v *SendRequest) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*SendRequest) UnmarshalVT added in v0.7.0 

func (m *SendRequest) UnmarshalVT(dAtA []byte) error

type StreamPosition added in v0.6.0 

type StreamPosition struct {
	Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	Epoch  string `protobuf:"bytes,2,opt,name=epoch,proto3" json:"epoch,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamPosition) Descriptor deprecated added in v0.6.0 

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

Deprecated: Use StreamPosition.ProtoReflect.Descriptor instead.

func (*StreamPosition) GetEpoch added in v0.6.0 

func (x *StreamPosition) GetEpoch() string

func (*StreamPosition) GetOffset added in v0.6.0 

func (x *StreamPosition) GetOffset() uint64

func (StreamPosition) MarshalEasyJSON added in v0.6.0 

func (v StreamPosition) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*StreamPosition) MarshalToSizedBufferVT added in v0.7.0 

func (m *StreamPosition) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StreamPosition) MarshalToVT added in v0.7.0 

func (m *StreamPosition) MarshalToVT(dAtA []byte) (int, error)

func (*StreamPosition) MarshalVT added in v0.7.0 

func (m *StreamPosition) MarshalVT() (dAtA []byte, err error)

func (*StreamPosition) ProtoMessage added in v0.6.0 

func (*StreamPosition) ProtoMessage()

func (*StreamPosition) ProtoReflect added in v0.7.0 

func (x *StreamPosition) ProtoReflect() protoreflect.Message

func (*StreamPosition) Reset added in v0.6.0 

func (x *StreamPosition) Reset()

func (*StreamPosition) SizeVT added in v0.7.0 

func (m *StreamPosition) SizeVT() (n int)

func (*StreamPosition) String added in v0.6.0 

func (x *StreamPosition) String() string

func (*StreamPosition) UnmarshalEasyJSON added in v0.6.0 

func (v *StreamPosition) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*StreamPosition) UnmarshalVT added in v0.7.0 

func (m *StreamPosition) UnmarshalVT(dAtA []byte) error

type SubRefreshRequest 

type SubRefreshRequest 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"`
	// contains filtered or unexported fields
}

func (*SubRefreshRequest) Descriptor deprecated 

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

Deprecated: Use SubRefreshRequest.ProtoReflect.Descriptor instead.

func (*SubRefreshRequest) GetChannel 

func (x *SubRefreshRequest) GetChannel() string

func (*SubRefreshRequest) GetToken 

func (x *SubRefreshRequest) GetToken() string

func (SubRefreshRequest) MarshalEasyJSON added in v0.6.0 

func (v SubRefreshRequest) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*SubRefreshRequest) MarshalToSizedBufferVT added in v0.7.0 

func (m *SubRefreshRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SubRefreshRequest) MarshalToVT added in v0.7.0 

func (m *SubRefreshRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SubRefreshRequest) MarshalVT added in v0.7.0 

func (m *SubRefreshRequest) MarshalVT() (dAtA []byte, err error)

func (*SubRefreshRequest) ProtoMessage 

func (*SubRefreshRequest) ProtoMessage()

func (*SubRefreshRequest) ProtoReflect added in v0.7.0 

func (x *SubRefreshRequest) ProtoReflect() protoreflect.Message

func (*SubRefreshRequest) Reset 

func (x *SubRefreshRequest) Reset()

func (*SubRefreshRequest) SizeVT added in v0.7.0 

func (m *SubRefreshRequest) SizeVT() (n int)

func (*SubRefreshRequest) String 

func (x *SubRefreshRequest) String() string

func (*SubRefreshRequest) UnmarshalEasyJSON added in v0.6.0 

func (v *SubRefreshRequest) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*SubRefreshRequest) UnmarshalVT added in v0.7.0 

func (m *SubRefreshRequest) UnmarshalVT(dAtA []byte) error

type SubRefreshResult 

type SubRefreshResult struct {
	Expires bool   `protobuf:"varint,1,opt,name=expires,proto3" json:"expires,omitempty"`
	Ttl     uint32 `protobuf:"varint,2,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

func (*SubRefreshResult) Descriptor deprecated 

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

Deprecated: Use SubRefreshResult.ProtoReflect.Descriptor instead.

func (*SubRefreshResult) GetExpires 

func (x *SubRefreshResult) GetExpires() bool

func (*SubRefreshResult) GetTtl added in v0.4.1 

func (x *SubRefreshResult) GetTtl() uint32

func (SubRefreshResult) MarshalEasyJSON added in v0.6.0 

func (v SubRefreshResult) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*SubRefreshResult) MarshalToSizedBufferVT added in v0.7.0 

func (m *SubRefreshResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SubRefreshResult) MarshalToVT added in v0.7.0 

func (m *SubRefreshResult) MarshalToVT(dAtA []byte) (int, error)

func (*SubRefreshResult) MarshalVT added in v0.7.0 

func (m *SubRefreshResult) MarshalVT() (dAtA []byte, err error)

func (*SubRefreshResult) ProtoMessage 

func (*SubRefreshResult) ProtoMessage()

func (*SubRefreshResult) ProtoReflect added in v0.7.0 

func (x *SubRefreshResult) ProtoReflect() protoreflect.Message

func (*SubRefreshResult) Reset 

func (x *SubRefreshResult) Reset()

func (*SubRefreshResult) SizeVT added in v0.7.0 

func (m *SubRefreshResult) SizeVT() (n int)

func (*SubRefreshResult) String 

func (x *SubRefreshResult) String() string

func (*SubRefreshResult) UnmarshalEasyJSON added in v0.6.0 

func (v *SubRefreshResult) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*SubRefreshResult) UnmarshalVT added in v0.7.0 

func (m *SubRefreshResult) UnmarshalVT(dAtA []byte) error

type Subscribe added in v0.4.0 

type Subscribe struct {
	Recoverable bool `protobuf:"varint,1,opt,name=recoverable,proto3" json:"recoverable,omitempty"`
	// 2-3 skipped here for backwards compatibility.
	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" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*Subscribe) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use Subscribe.ProtoReflect.Descriptor instead.

func (*Subscribe) GetData added in v0.7.0 

func (x *Subscribe) GetData() []byte

func (*Subscribe) GetEpoch added in v0.4.0 

func (x *Subscribe) GetEpoch() string

func (*Subscribe) GetOffset added in v0.4.0 

func (x *Subscribe) GetOffset() uint64

func (*Subscribe) GetPositioned added in v0.4.0 

func (x *Subscribe) GetPositioned() bool

func (*Subscribe) GetRecoverable added in v0.4.0 

func (x *Subscribe) GetRecoverable() bool

func (Subscribe) MarshalEasyJSON added in v0.6.0 

func (v Subscribe) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*Subscribe) MarshalToSizedBufferVT added in v0.7.0 

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

func (*Subscribe) MarshalToVT added in v0.7.0 

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

func (*Subscribe) MarshalVT added in v0.7.0 

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

func (*Subscribe) ProtoMessage added in v0.4.0 

func (*Subscribe) ProtoMessage()

func (*Subscribe) ProtoReflect added in v0.7.0 

func (x *Subscribe) ProtoReflect() protoreflect.Message

func (*Subscribe) Reset added in v0.4.0 

func (x *Subscribe) Reset()

func (*Subscribe) SizeVT added in v0.7.0 

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

func (*Subscribe) String added in v0.4.0 

func (x *Subscribe) String() string

func (*Subscribe) UnmarshalEasyJSON added in v0.6.0 

func (v *Subscribe) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*Subscribe) UnmarshalVT added in v0.7.0 

func (m *Subscribe) UnmarshalVT(dAtA []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"`
	// 4-5 skipped here for backwards compatibility.
	Epoch  string `protobuf:"bytes,6,opt,name=epoch,proto3" json:"epoch,omitempty"`
	Offset uint64 `protobuf:"varint,7,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.

func (*SubscribeRequest) GetChannel 

func (x *SubscribeRequest) GetChannel() string

func (*SubscribeRequest) GetEpoch 

func (x *SubscribeRequest) GetEpoch() string

func (*SubscribeRequest) GetOffset 

func (x *SubscribeRequest) GetOffset() uint64

func (*SubscribeRequest) GetRecover 

func (x *SubscribeRequest) GetRecover() bool

func (*SubscribeRequest) GetToken 

func (x *SubscribeRequest) GetToken() string

func (SubscribeRequest) MarshalEasyJSON added in v0.6.0 

func (v SubscribeRequest) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*SubscribeRequest) MarshalToSizedBufferVT added in v0.7.0 

func (m *SubscribeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SubscribeRequest) MarshalToVT added in v0.7.0 

func (m *SubscribeRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SubscribeRequest) MarshalVT added in v0.7.0 

func (m *SubscribeRequest) MarshalVT() (dAtA []byte, err error)

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) ProtoReflect added in v0.7.0 

func (x *SubscribeRequest) ProtoReflect() protoreflect.Message

func (*SubscribeRequest) Reset 

func (x *SubscribeRequest) Reset()

func (*SubscribeRequest) SizeVT added in v0.7.0 

func (m *SubscribeRequest) SizeVT() (n int)

func (*SubscribeRequest) String 

func (x *SubscribeRequest) String() string

func (*SubscribeRequest) UnmarshalEasyJSON added in v0.6.0 

func (v *SubscribeRequest) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*SubscribeRequest) UnmarshalVT added in v0.7.0 

func (m *SubscribeRequest) UnmarshalVT(dAtA []byte) error

type SubscribeResult 

type SubscribeResult struct {
	Expires     bool   `protobuf:"varint,1,opt,name=expires,proto3" json:"expires,omitempty"`
	Ttl         uint32 `protobuf:"varint,2,opt,name=ttl,proto3" json:"ttl,omitempty"`
	Recoverable bool   `protobuf:"varint,3,opt,name=recoverable,proto3" json:"recoverable,omitempty"`
	// 4-5 skipped here for backwards compatibility.
	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" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeResult) Descriptor deprecated 

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

Deprecated: Use SubscribeResult.ProtoReflect.Descriptor instead.

func (*SubscribeResult) GetData added in v0.7.0 

func (x *SubscribeResult) GetData() []byte

func (*SubscribeResult) GetEpoch 

func (x *SubscribeResult) GetEpoch() string

func (*SubscribeResult) GetExpires 

func (x *SubscribeResult) GetExpires() bool

func (*SubscribeResult) GetOffset 

func (x *SubscribeResult) GetOffset() uint64

func (*SubscribeResult) GetPositioned added in v0.3.5 

func (x *SubscribeResult) GetPositioned() bool

func (*SubscribeResult) GetPublications 

func (x *SubscribeResult) GetPublications() []*Publication

func (*SubscribeResult) GetRecoverable 

func (x *SubscribeResult) GetRecoverable() bool

func (*SubscribeResult) GetRecovered 

func (x *SubscribeResult) GetRecovered() bool

func (*SubscribeResult) GetTtl added in v0.4.1 

func (x *SubscribeResult) GetTtl() uint32

func (SubscribeResult) MarshalEasyJSON added in v0.6.0 

func (v SubscribeResult) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*SubscribeResult) MarshalToSizedBufferVT added in v0.7.0 

func (m *SubscribeResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SubscribeResult) MarshalToVT added in v0.7.0 

func (m *SubscribeResult) MarshalToVT(dAtA []byte) (int, error)

func (*SubscribeResult) MarshalVT added in v0.7.0 

func (m *SubscribeResult) MarshalVT() (dAtA []byte, err error)

func (*SubscribeResult) ProtoMessage 

func (*SubscribeResult) ProtoMessage()

func (*SubscribeResult) ProtoReflect added in v0.7.0 

func (x *SubscribeResult) ProtoReflect() protoreflect.Message

func (*SubscribeResult) Reset 

func (x *SubscribeResult) Reset()

func (*SubscribeResult) SizeVT added in v0.7.0 

func (m *SubscribeResult) SizeVT() (n int)

func (*SubscribeResult) String 

func (x *SubscribeResult) String() string

func (*SubscribeResult) UnmarshalEasyJSON added in v0.6.0 

func (v *SubscribeResult) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*SubscribeResult) UnmarshalVT added in v0.7.0 

func (m *SubscribeResult) UnmarshalVT(dAtA []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 {
	// contains filtered or unexported fields
}

func (*Unsubscribe) Descriptor deprecated added in v0.4.0 

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

Deprecated: Use Unsubscribe.ProtoReflect.Descriptor instead.

func (Unsubscribe) MarshalEasyJSON added in v0.6.0 

func (v Unsubscribe) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*Unsubscribe) MarshalToSizedBufferVT added in v0.7.0 

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

func (*Unsubscribe) MarshalToVT added in v0.7.0 

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

func (*Unsubscribe) MarshalVT added in v0.7.0 

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

func (*Unsubscribe) ProtoMessage added in v0.4.0 

func (*Unsubscribe) ProtoMessage()

func (*Unsubscribe) ProtoReflect added in v0.7.0 

func (x *Unsubscribe) ProtoReflect() protoreflect.Message

func (*Unsubscribe) Reset added in v0.4.0 

func (x *Unsubscribe) Reset()

func (*Unsubscribe) SizeVT added in v0.7.0 

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

func (*Unsubscribe) String added in v0.4.0 

func (x *Unsubscribe) String() string

func (*Unsubscribe) UnmarshalEasyJSON added in v0.6.0 

func (v *Unsubscribe) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*Unsubscribe) UnmarshalVT added in v0.7.0 

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

type UnsubscribeRequest 

type UnsubscribeRequest struct {
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	// contains filtered or unexported fields
}

func (*UnsubscribeRequest) Descriptor deprecated 

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

Deprecated: Use UnsubscribeRequest.ProtoReflect.Descriptor instead.

func (*UnsubscribeRequest) GetChannel 

func (x *UnsubscribeRequest) GetChannel() string

func (UnsubscribeRequest) MarshalEasyJSON added in v0.6.0 

func (v UnsubscribeRequest) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*UnsubscribeRequest) MarshalToSizedBufferVT added in v0.7.0 

func (m *UnsubscribeRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*UnsubscribeRequest) MarshalToVT added in v0.7.0 

func (m *UnsubscribeRequest) MarshalToVT(dAtA []byte) (int, error)

func (*UnsubscribeRequest) MarshalVT added in v0.7.0 

func (m *UnsubscribeRequest) MarshalVT() (dAtA []byte, err error)

func (*UnsubscribeRequest) ProtoMessage 

func (*UnsubscribeRequest) ProtoMessage()

func (*UnsubscribeRequest) ProtoReflect added in v0.7.0 

func (x *UnsubscribeRequest) ProtoReflect() protoreflect.Message

func (*UnsubscribeRequest) Reset 

func (x *UnsubscribeRequest) Reset()

func (*UnsubscribeRequest) SizeVT added in v0.7.0 

func (m *UnsubscribeRequest) SizeVT() (n int)

func (*UnsubscribeRequest) String 

func (x *UnsubscribeRequest) String() string

func (*UnsubscribeRequest) UnmarshalEasyJSON added in v0.6.0 

func (v *UnsubscribeRequest) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*UnsubscribeRequest) UnmarshalVT added in v0.7.0 

func (m *UnsubscribeRequest) UnmarshalVT(dAtA []byte) error

type UnsubscribeResult 

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

func (*UnsubscribeResult) Descriptor deprecated 

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

Deprecated: Use UnsubscribeResult.ProtoReflect.Descriptor instead.

func (UnsubscribeResult) MarshalEasyJSON added in v0.6.0 

func (v UnsubscribeResult) MarshalEasyJSON(w *writer)

MarshalEasyJSON supports easyjson.Marshaler interface

func (*UnsubscribeResult) MarshalToSizedBufferVT added in v0.7.0 

func (m *UnsubscribeResult) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*UnsubscribeResult) MarshalToVT added in v0.7.0 

func (m *UnsubscribeResult) MarshalToVT(dAtA []byte) (int, error)

func (*UnsubscribeResult) MarshalVT added in v0.7.0 

func (m *UnsubscribeResult) MarshalVT() (dAtA []byte, err error)

func (*UnsubscribeResult) ProtoMessage 

func (*UnsubscribeResult) ProtoMessage()

func (*UnsubscribeResult) ProtoReflect added in v0.7.0 

func (x *UnsubscribeResult) ProtoReflect() protoreflect.Message

func (*UnsubscribeResult) Reset 

func (x *UnsubscribeResult) Reset()

func (*UnsubscribeResult) SizeVT added in v0.7.0 

func (m *UnsubscribeResult) SizeVT() (n int)

func (*UnsubscribeResult) String 

func (x *UnsubscribeResult) String() string

func (*UnsubscribeResult) UnmarshalEasyJSON added in v0.6.0 

func (v *UnsubscribeResult) UnmarshalEasyJSON(l *jlexer.Lexer)

UnmarshalEasyJSON supports easyjson.Unmarshaler interface

func (*UnsubscribeResult) UnmarshalVT added in v0.7.0 

func (m *UnsubscribeResult) UnmarshalVT(dAtA []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

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