Documentation ¶
Index ¶
- Variables
- type BoolValue
- type ChannelsCapability
- func (*ChannelsCapability) Descriptor() ([]byte, []int)deprecated
- func (x *ChannelsCapability) GetAllow() []string
- func (x *ChannelsCapability) GetChannels() []string
- func (x *ChannelsCapability) GetMatch() string
- func (*ChannelsCapability) ProtoMessage()
- func (x *ChannelsCapability) ProtoReflect() protoreflect.Message
- func (x *ChannelsCapability) Reset()
- func (x *ChannelsCapability) String() string
- type ConnectRequest
- func (*ConnectRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectRequest) GetB64Data() string
- func (x *ConnectRequest) GetChannels() []string
- func (x *ConnectRequest) GetClient() string
- func (x *ConnectRequest) GetData() []byte
- func (x *ConnectRequest) GetEncoding() string
- func (x *ConnectRequest) GetName() string
- func (x *ConnectRequest) GetProtocol() string
- func (x *ConnectRequest) GetTransport() string
- func (x *ConnectRequest) GetVersion() string
- func (*ConnectRequest) ProtoMessage()
- func (x *ConnectRequest) ProtoReflect() protoreflect.Message
- func (x *ConnectRequest) Reset()
- func (x *ConnectRequest) String() string
- type ConnectResponse
- func (*ConnectResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectResponse) GetDisconnect() *Disconnect
- func (x *ConnectResponse) GetError() *Error
- func (x *ConnectResponse) GetResult() *ConnectResult
- func (*ConnectResponse) ProtoMessage()
- func (x *ConnectResponse) ProtoReflect() protoreflect.Message
- func (x *ConnectResponse) Reset()
- func (x *ConnectResponse) String() string
- type ConnectResult
- func (*ConnectResult) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectResult) GetB64Data() string
- func (x *ConnectResult) GetB64Info() string
- func (x *ConnectResult) GetCaps() []*ChannelsCapability
- func (x *ConnectResult) GetChannels() []string
- func (x *ConnectResult) GetData() []byte
- func (x *ConnectResult) GetExpireAt() int64
- func (x *ConnectResult) GetInfo() []byte
- func (x *ConnectResult) GetMeta() []byte
- func (x *ConnectResult) GetSubs() map[string]*SubscribeOptions
- func (x *ConnectResult) GetUser() string
- func (*ConnectResult) ProtoMessage()
- func (x *ConnectResult) ProtoReflect() protoreflect.Message
- func (x *ConnectResult) Reset()
- func (x *ConnectResult) String() string
- type Disconnect
- func (*Disconnect) Descriptor() ([]byte, []int)deprecated
- func (x *Disconnect) GetCode() uint32
- func (x *Disconnect) GetReason() string
- func (x *Disconnect) GetReconnect() bool
- func (*Disconnect) ProtoMessage()
- func (x *Disconnect) ProtoReflect() protoreflect.Message
- func (x *Disconnect) Reset()
- func (x *Disconnect) String() string
- type Error
- type Int32Value
- type PublishRequest
- func (*PublishRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PublishRequest) GetB64Data() string
- func (x *PublishRequest) GetChannel() string
- func (x *PublishRequest) GetClient() string
- func (x *PublishRequest) GetData() []byte
- func (x *PublishRequest) GetEncoding() string
- func (x *PublishRequest) GetMeta() []byte
- func (x *PublishRequest) GetProtocol() string
- func (x *PublishRequest) GetTransport() string
- func (x *PublishRequest) GetUser() string
- func (*PublishRequest) ProtoMessage()
- func (x *PublishRequest) ProtoReflect() protoreflect.Message
- func (x *PublishRequest) Reset()
- func (x *PublishRequest) String() string
- type PublishResponse
- func (*PublishResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PublishResponse) GetDisconnect() *Disconnect
- func (x *PublishResponse) GetError() *Error
- func (x *PublishResponse) GetResult() *PublishResult
- func (*PublishResponse) ProtoMessage()
- func (x *PublishResponse) ProtoReflect() protoreflect.Message
- func (x *PublishResponse) Reset()
- func (x *PublishResponse) String() string
- type PublishResult
- func (*PublishResult) Descriptor() ([]byte, []int)deprecated
- func (x *PublishResult) GetB64Data() string
- func (x *PublishResult) GetData() []byte
- func (x *PublishResult) GetSkipHistory() bool
- func (*PublishResult) ProtoMessage()
- func (x *PublishResult) ProtoReflect() protoreflect.Message
- func (x *PublishResult) Reset()
- func (x *PublishResult) String() string
- type RPCRequest
- func (*RPCRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RPCRequest) GetB64Data() string
- func (x *RPCRequest) GetClient() string
- func (x *RPCRequest) GetData() []byte
- func (x *RPCRequest) GetEncoding() string
- func (x *RPCRequest) GetMeta() []byte
- func (x *RPCRequest) GetMethod() string
- func (x *RPCRequest) GetProtocol() string
- func (x *RPCRequest) GetTransport() string
- func (x *RPCRequest) GetUser() string
- func (*RPCRequest) ProtoMessage()
- func (x *RPCRequest) ProtoReflect() protoreflect.Message
- func (x *RPCRequest) Reset()
- func (x *RPCRequest) String() string
- type RPCResponse
- func (*RPCResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RPCResponse) GetDisconnect() *Disconnect
- func (x *RPCResponse) GetError() *Error
- func (x *RPCResponse) GetResult() *RPCResult
- func (*RPCResponse) ProtoMessage()
- func (x *RPCResponse) ProtoReflect() protoreflect.Message
- func (x *RPCResponse) Reset()
- func (x *RPCResponse) String() string
- type RPCResult
- type RefreshRequest
- func (*RefreshRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RefreshRequest) GetClient() string
- func (x *RefreshRequest) GetEncoding() string
- func (x *RefreshRequest) GetMeta() []byte
- func (x *RefreshRequest) GetProtocol() string
- func (x *RefreshRequest) GetTransport() string
- func (x *RefreshRequest) GetUser() string
- func (*RefreshRequest) ProtoMessage()
- func (x *RefreshRequest) ProtoReflect() protoreflect.Message
- func (x *RefreshRequest) Reset()
- func (x *RefreshRequest) String() string
- type RefreshResponse
- func (*RefreshResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RefreshResponse) GetDisconnect() *Disconnect
- func (x *RefreshResponse) GetError() *Error
- func (x *RefreshResponse) GetResult() *RefreshResult
- func (*RefreshResponse) ProtoMessage()
- func (x *RefreshResponse) ProtoReflect() protoreflect.Message
- func (x *RefreshResponse) Reset()
- func (x *RefreshResponse) String() string
- type RefreshResult
- func (*RefreshResult) Descriptor() ([]byte, []int)deprecated
- func (x *RefreshResult) GetB64Info() string
- func (x *RefreshResult) GetCaps() []*ChannelsCapability
- func (x *RefreshResult) GetExpireAt() int64
- func (x *RefreshResult) GetExpired() bool
- func (x *RefreshResult) GetInfo() []byte
- func (x *RefreshResult) GetMeta() []byte
- func (*RefreshResult) ProtoMessage()
- func (x *RefreshResult) ProtoReflect() protoreflect.Message
- func (x *RefreshResult) Reset()
- func (x *RefreshResult) String() string
- type SubscribeOptionOverride
- func (*SubscribeOptionOverride) Descriptor() ([]byte, []int)deprecated
- func (x *SubscribeOptionOverride) GetForcePositioning() *BoolValue
- func (x *SubscribeOptionOverride) GetForcePushJoinLeave() *BoolValue
- func (x *SubscribeOptionOverride) GetForceRecovery() *BoolValue
- func (x *SubscribeOptionOverride) GetJoinLeave() *BoolValue
- func (x *SubscribeOptionOverride) GetPresence() *BoolValue
- func (*SubscribeOptionOverride) ProtoMessage()
- func (x *SubscribeOptionOverride) ProtoReflect() protoreflect.Message
- func (x *SubscribeOptionOverride) Reset()
- func (x *SubscribeOptionOverride) String() string
- type SubscribeOptions
- func (*SubscribeOptions) Descriptor() ([]byte, []int)deprecated
- func (x *SubscribeOptions) GetB64Data() string
- func (x *SubscribeOptions) GetB64Info() string
- func (x *SubscribeOptions) GetData() []byte
- func (x *SubscribeOptions) GetExpireAt() int64
- func (x *SubscribeOptions) GetInfo() []byte
- func (x *SubscribeOptions) GetOverride() *SubscribeOptionOverride
- func (*SubscribeOptions) ProtoMessage()
- func (x *SubscribeOptions) ProtoReflect() protoreflect.Message
- func (x *SubscribeOptions) Reset()
- func (x *SubscribeOptions) String() string
- type SubscribeRequest
- func (*SubscribeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SubscribeRequest) GetB64Data() string
- func (x *SubscribeRequest) GetChannel() string
- func (x *SubscribeRequest) GetClient() string
- func (x *SubscribeRequest) GetData() []byte
- func (x *SubscribeRequest) GetEncoding() string
- func (x *SubscribeRequest) GetMeta() []byte
- func (x *SubscribeRequest) GetProtocol() string
- func (x *SubscribeRequest) GetToken() string
- func (x *SubscribeRequest) GetTransport() string
- func (x *SubscribeRequest) GetUser() string
- func (*SubscribeRequest) ProtoMessage()
- func (x *SubscribeRequest) ProtoReflect() protoreflect.Message
- func (x *SubscribeRequest) Reset()
- func (x *SubscribeRequest) String() string
- type SubscribeResponse
- func (*SubscribeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SubscribeResponse) GetDisconnect() *Disconnect
- func (x *SubscribeResponse) GetError() *Error
- func (x *SubscribeResponse) GetResult() *SubscribeResult
- func (*SubscribeResponse) ProtoMessage()
- func (x *SubscribeResponse) ProtoReflect() protoreflect.Message
- func (x *SubscribeResponse) Reset()
- func (x *SubscribeResponse) String() string
- type SubscribeResult
- func (*SubscribeResult) Descriptor() ([]byte, []int)deprecated
- func (x *SubscribeResult) GetAllow() []string
- func (x *SubscribeResult) GetB64Data() string
- func (x *SubscribeResult) GetB64Info() string
- func (x *SubscribeResult) GetData() []byte
- func (x *SubscribeResult) GetExpireAt() int64
- func (x *SubscribeResult) GetInfo() []byte
- func (x *SubscribeResult) GetOverride() *SubscribeOptionOverride
- func (*SubscribeResult) ProtoMessage()
- func (x *SubscribeResult) ProtoReflect() protoreflect.Message
- func (x *SubscribeResult) Reset()
- func (x *SubscribeResult) String() string
Constants ¶
This section is empty.
Variables ¶
var File_proto_centrifugo_proxy_v1_proxy_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type BoolValue ¶
type BoolValue struct { Value bool `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*BoolValue) ProtoReflect ¶
func (x *BoolValue) ProtoReflect() protoreflect.Message
type ChannelsCapability ¶
type ChannelsCapability struct { Channels []string `protobuf:"bytes,1,rep,name=channels,proto3" json:"channels,omitempty"` Allow []string `protobuf:"bytes,2,rep,name=allow,proto3" json:"allow,omitempty"` Match string `protobuf:"bytes,3,opt,name=match,proto3" json:"match,omitempty"` // contains filtered or unexported fields }
func (*ChannelsCapability) Descriptor
deprecated
func (*ChannelsCapability) Descriptor() ([]byte, []int)
Deprecated: Use ChannelsCapability.ProtoReflect.Descriptor instead.
func (*ChannelsCapability) GetAllow ¶
func (x *ChannelsCapability) GetAllow() []string
func (*ChannelsCapability) GetChannels ¶
func (x *ChannelsCapability) GetChannels() []string
func (*ChannelsCapability) GetMatch ¶
func (x *ChannelsCapability) GetMatch() string
func (*ChannelsCapability) ProtoMessage ¶
func (*ChannelsCapability) ProtoMessage()
func (*ChannelsCapability) ProtoReflect ¶
func (x *ChannelsCapability) ProtoReflect() protoreflect.Message
func (*ChannelsCapability) Reset ¶
func (x *ChannelsCapability) Reset()
func (*ChannelsCapability) String ¶
func (x *ChannelsCapability) String() string
type ConnectRequest ¶
type ConnectRequest struct { Client string `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"` Transport string `protobuf:"bytes,2,opt,name=transport,proto3" json:"transport,omitempty"` Protocol string `protobuf:"bytes,3,opt,name=protocol,proto3" json:"protocol,omitempty"` Encoding string `protobuf:"bytes,4,opt,name=encoding,proto3" json:"encoding,omitempty"` Data []byte `protobuf:"bytes,10,opt,name=data,proto3" json:"data,omitempty"` B64Data string `protobuf:"bytes,11,opt,name=b64data,proto3" json:"b64data,omitempty"` Name string `protobuf:"bytes,12,opt,name=name,proto3" json:"name,omitempty"` Version string `protobuf:"bytes,13,opt,name=version,proto3" json:"version,omitempty"` Channels []string `protobuf:"bytes,14,rep,name=channels,proto3" json:"channels,omitempty"` // contains filtered or unexported fields }
func (*ConnectRequest) Descriptor
deprecated
func (*ConnectRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConnectRequest.ProtoReflect.Descriptor instead.
func (*ConnectRequest) GetB64Data ¶
func (x *ConnectRequest) GetB64Data() string
func (*ConnectRequest) GetChannels ¶
func (x *ConnectRequest) GetChannels() []string
func (*ConnectRequest) GetClient ¶
func (x *ConnectRequest) GetClient() string
func (*ConnectRequest) GetData ¶
func (x *ConnectRequest) GetData() []byte
func (*ConnectRequest) GetEncoding ¶
func (x *ConnectRequest) GetEncoding() string
func (*ConnectRequest) GetName ¶
func (x *ConnectRequest) GetName() string
func (*ConnectRequest) GetProtocol ¶
func (x *ConnectRequest) GetProtocol() string
func (*ConnectRequest) GetTransport ¶
func (x *ConnectRequest) GetTransport() string
func (*ConnectRequest) GetVersion ¶
func (x *ConnectRequest) GetVersion() string
func (*ConnectRequest) ProtoMessage ¶
func (*ConnectRequest) ProtoMessage()
func (*ConnectRequest) ProtoReflect ¶
func (x *ConnectRequest) ProtoReflect() protoreflect.Message
func (*ConnectRequest) Reset ¶
func (x *ConnectRequest) Reset()
func (*ConnectRequest) String ¶
func (x *ConnectRequest) String() string
type ConnectResponse ¶
type ConnectResponse struct { Result *ConnectResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"` Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` Disconnect *Disconnect `protobuf:"bytes,3,opt,name=disconnect,proto3" json:"disconnect,omitempty"` // contains filtered or unexported fields }
func (*ConnectResponse) Descriptor
deprecated
func (*ConnectResponse) Descriptor() ([]byte, []int)
Deprecated: Use ConnectResponse.ProtoReflect.Descriptor instead.
func (*ConnectResponse) GetDisconnect ¶
func (x *ConnectResponse) GetDisconnect() *Disconnect
func (*ConnectResponse) GetError ¶
func (x *ConnectResponse) GetError() *Error
func (*ConnectResponse) GetResult ¶
func (x *ConnectResponse) GetResult() *ConnectResult
func (*ConnectResponse) ProtoMessage ¶
func (*ConnectResponse) ProtoMessage()
func (*ConnectResponse) ProtoReflect ¶
func (x *ConnectResponse) ProtoReflect() protoreflect.Message
func (*ConnectResponse) Reset ¶
func (x *ConnectResponse) Reset()
func (*ConnectResponse) String ¶
func (x *ConnectResponse) String() string
type ConnectResult ¶
type ConnectResult struct { User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` ExpireAt int64 `protobuf:"varint,2,opt,name=expire_at,json=expireAt,proto3" json:"expire_at,omitempty"` Info []byte `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"` B64Info string `protobuf:"bytes,4,opt,name=b64info,proto3" json:"b64info,omitempty"` Data []byte `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"` B64Data string `protobuf:"bytes,6,opt,name=b64data,proto3" json:"b64data,omitempty"` Channels []string `protobuf:"bytes,7,rep,name=channels,proto3" json:"channels,omitempty"` Subs map[string]*SubscribeOptions `` /* 149-byte string literal not displayed */ Meta []byte `protobuf:"bytes,9,opt,name=meta,proto3" json:"meta,omitempty"` Caps []*ChannelsCapability `protobuf:"bytes,10,rep,name=caps,proto3" json:"caps,omitempty"` // contains filtered or unexported fields }
func (*ConnectResult) Descriptor
deprecated
func (*ConnectResult) Descriptor() ([]byte, []int)
Deprecated: Use ConnectResult.ProtoReflect.Descriptor instead.
func (*ConnectResult) GetB64Data ¶
func (x *ConnectResult) GetB64Data() string
func (*ConnectResult) GetB64Info ¶
func (x *ConnectResult) GetB64Info() string
func (*ConnectResult) GetCaps ¶
func (x *ConnectResult) GetCaps() []*ChannelsCapability
func (*ConnectResult) GetChannels ¶
func (x *ConnectResult) GetChannels() []string
func (*ConnectResult) GetData ¶
func (x *ConnectResult) GetData() []byte
func (*ConnectResult) GetExpireAt ¶
func (x *ConnectResult) GetExpireAt() int64
func (*ConnectResult) GetInfo ¶
func (x *ConnectResult) GetInfo() []byte
func (*ConnectResult) GetMeta ¶
func (x *ConnectResult) GetMeta() []byte
func (*ConnectResult) GetSubs ¶
func (x *ConnectResult) GetSubs() map[string]*SubscribeOptions
func (*ConnectResult) GetUser ¶
func (x *ConnectResult) GetUser() string
func (*ConnectResult) ProtoMessage ¶
func (*ConnectResult) ProtoMessage()
func (*ConnectResult) ProtoReflect ¶
func (x *ConnectResult) ProtoReflect() protoreflect.Message
func (*ConnectResult) Reset ¶
func (x *ConnectResult) Reset()
func (*ConnectResult) String ¶
func (x *ConnectResult) String() string
type Disconnect ¶
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
func (*Disconnect) Descriptor() ([]byte, []int)
Deprecated: Use Disconnect.ProtoReflect.Descriptor instead.
func (*Disconnect) GetCode ¶
func (x *Disconnect) GetCode() uint32
func (*Disconnect) GetReason ¶
func (x *Disconnect) GetReason() string
func (*Disconnect) GetReconnect ¶
func (x *Disconnect) GetReconnect() bool
func (*Disconnect) ProtoMessage ¶
func (*Disconnect) ProtoMessage()
func (*Disconnect) ProtoReflect ¶
func (x *Disconnect) ProtoReflect() protoreflect.Message
func (*Disconnect) Reset ¶
func (x *Disconnect) Reset()
func (*Disconnect) String ¶
func (x *Disconnect) String() string
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"` Temporary bool `protobuf:"varint,3,opt,name=temporary,proto3" json:"temporary,omitempty"` // contains filtered or unexported fields }
func (*Error) ProtoReflect ¶
func (x *Error) ProtoReflect() protoreflect.Message
type Int32Value ¶
type Int32Value struct { Value int32 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*Int32Value) Descriptor
deprecated
func (*Int32Value) Descriptor() ([]byte, []int)
Deprecated: Use Int32Value.ProtoReflect.Descriptor instead.
func (*Int32Value) GetValue ¶
func (x *Int32Value) GetValue() int32
func (*Int32Value) ProtoMessage ¶
func (*Int32Value) ProtoMessage()
func (*Int32Value) ProtoReflect ¶
func (x *Int32Value) ProtoReflect() protoreflect.Message
func (*Int32Value) Reset ¶
func (x *Int32Value) Reset()
func (*Int32Value) String ¶
func (x *Int32Value) String() string
type PublishRequest ¶
type PublishRequest struct { Client string `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"` Transport string `protobuf:"bytes,2,opt,name=transport,proto3" json:"transport,omitempty"` Protocol string `protobuf:"bytes,3,opt,name=protocol,proto3" json:"protocol,omitempty"` Encoding string `protobuf:"bytes,4,opt,name=encoding,proto3" json:"encoding,omitempty"` User string `protobuf:"bytes,10,opt,name=user,proto3" json:"user,omitempty"` Channel string `protobuf:"bytes,11,opt,name=channel,proto3" json:"channel,omitempty"` Data []byte `protobuf:"bytes,12,opt,name=data,proto3" json:"data,omitempty"` B64Data string `protobuf:"bytes,13,opt,name=b64data,proto3" json:"b64data,omitempty"` Meta []byte `protobuf:"bytes,14,opt,name=meta,proto3" json:"meta,omitempty"` // contains filtered or unexported fields }
func (*PublishRequest) Descriptor
deprecated
func (*PublishRequest) Descriptor() ([]byte, []int)
Deprecated: Use PublishRequest.ProtoReflect.Descriptor instead.
func (*PublishRequest) GetB64Data ¶
func (x *PublishRequest) GetB64Data() string
func (*PublishRequest) GetChannel ¶
func (x *PublishRequest) GetChannel() string
func (*PublishRequest) GetClient ¶
func (x *PublishRequest) GetClient() string
func (*PublishRequest) GetData ¶
func (x *PublishRequest) GetData() []byte
func (*PublishRequest) GetEncoding ¶
func (x *PublishRequest) GetEncoding() string
func (*PublishRequest) GetMeta ¶
func (x *PublishRequest) GetMeta() []byte
func (*PublishRequest) GetProtocol ¶
func (x *PublishRequest) GetProtocol() string
func (*PublishRequest) GetTransport ¶
func (x *PublishRequest) GetTransport() string
func (*PublishRequest) GetUser ¶
func (x *PublishRequest) GetUser() string
func (*PublishRequest) ProtoMessage ¶
func (*PublishRequest) ProtoMessage()
func (*PublishRequest) ProtoReflect ¶
func (x *PublishRequest) ProtoReflect() protoreflect.Message
func (*PublishRequest) Reset ¶
func (x *PublishRequest) Reset()
func (*PublishRequest) String ¶
func (x *PublishRequest) String() string
type PublishResponse ¶
type PublishResponse struct { Result *PublishResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"` Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` Disconnect *Disconnect `protobuf:"bytes,3,opt,name=disconnect,proto3" json:"disconnect,omitempty"` // contains filtered or unexported fields }
func (*PublishResponse) Descriptor
deprecated
func (*PublishResponse) Descriptor() ([]byte, []int)
Deprecated: Use PublishResponse.ProtoReflect.Descriptor instead.
func (*PublishResponse) GetDisconnect ¶
func (x *PublishResponse) GetDisconnect() *Disconnect
func (*PublishResponse) GetError ¶
func (x *PublishResponse) GetError() *Error
func (*PublishResponse) GetResult ¶
func (x *PublishResponse) GetResult() *PublishResult
func (*PublishResponse) ProtoMessage ¶
func (*PublishResponse) ProtoMessage()
func (*PublishResponse) ProtoReflect ¶
func (x *PublishResponse) ProtoReflect() protoreflect.Message
func (*PublishResponse) Reset ¶
func (x *PublishResponse) Reset()
func (*PublishResponse) String ¶
func (x *PublishResponse) String() string
type PublishResult ¶
type PublishResult struct { Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` B64Data string `protobuf:"bytes,2,opt,name=b64data,proto3" json:"b64data,omitempty"` SkipHistory bool `protobuf:"varint,3,opt,name=skip_history,json=skipHistory,proto3" json:"skip_history,omitempty"` // contains filtered or unexported fields }
func (*PublishResult) Descriptor
deprecated
func (*PublishResult) Descriptor() ([]byte, []int)
Deprecated: Use PublishResult.ProtoReflect.Descriptor instead.
func (*PublishResult) GetB64Data ¶
func (x *PublishResult) GetB64Data() string
func (*PublishResult) GetData ¶
func (x *PublishResult) GetData() []byte
func (*PublishResult) GetSkipHistory ¶
func (x *PublishResult) GetSkipHistory() bool
func (*PublishResult) ProtoMessage ¶
func (*PublishResult) ProtoMessage()
func (*PublishResult) ProtoReflect ¶
func (x *PublishResult) ProtoReflect() protoreflect.Message
func (*PublishResult) Reset ¶
func (x *PublishResult) Reset()
func (*PublishResult) String ¶
func (x *PublishResult) String() string
type RPCRequest ¶
type RPCRequest struct { Client string `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"` Transport string `protobuf:"bytes,2,opt,name=transport,proto3" json:"transport,omitempty"` Protocol string `protobuf:"bytes,3,opt,name=protocol,proto3" json:"protocol,omitempty"` Encoding string `protobuf:"bytes,4,opt,name=encoding,proto3" json:"encoding,omitempty"` User string `protobuf:"bytes,10,opt,name=user,proto3" json:"user,omitempty"` Method string `protobuf:"bytes,11,opt,name=method,proto3" json:"method,omitempty"` Data []byte `protobuf:"bytes,12,opt,name=data,proto3" json:"data,omitempty"` B64Data string `protobuf:"bytes,13,opt,name=b64data,proto3" json:"b64data,omitempty"` Meta []byte `protobuf:"bytes,14,opt,name=meta,proto3" json:"meta,omitempty"` // contains filtered or unexported fields }
func (*RPCRequest) Descriptor
deprecated
func (*RPCRequest) Descriptor() ([]byte, []int)
Deprecated: Use RPCRequest.ProtoReflect.Descriptor instead.
func (*RPCRequest) GetB64Data ¶
func (x *RPCRequest) GetB64Data() string
func (*RPCRequest) GetClient ¶
func (x *RPCRequest) GetClient() string
func (*RPCRequest) GetData ¶
func (x *RPCRequest) GetData() []byte
func (*RPCRequest) GetEncoding ¶
func (x *RPCRequest) GetEncoding() string
func (*RPCRequest) GetMeta ¶
func (x *RPCRequest) GetMeta() []byte
func (*RPCRequest) GetMethod ¶
func (x *RPCRequest) GetMethod() string
func (*RPCRequest) GetProtocol ¶
func (x *RPCRequest) GetProtocol() string
func (*RPCRequest) GetTransport ¶
func (x *RPCRequest) GetTransport() string
func (*RPCRequest) GetUser ¶
func (x *RPCRequest) GetUser() string
func (*RPCRequest) ProtoMessage ¶
func (*RPCRequest) ProtoMessage()
func (*RPCRequest) ProtoReflect ¶
func (x *RPCRequest) ProtoReflect() protoreflect.Message
func (*RPCRequest) Reset ¶
func (x *RPCRequest) Reset()
func (*RPCRequest) String ¶
func (x *RPCRequest) String() string
type RPCResponse ¶
type RPCResponse struct { Result *RPCResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"` Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` Disconnect *Disconnect `protobuf:"bytes,3,opt,name=disconnect,proto3" json:"disconnect,omitempty"` // contains filtered or unexported fields }
func (*RPCResponse) Descriptor
deprecated
func (*RPCResponse) Descriptor() ([]byte, []int)
Deprecated: Use RPCResponse.ProtoReflect.Descriptor instead.
func (*RPCResponse) GetDisconnect ¶
func (x *RPCResponse) GetDisconnect() *Disconnect
func (*RPCResponse) GetError ¶
func (x *RPCResponse) GetError() *Error
func (*RPCResponse) GetResult ¶
func (x *RPCResponse) GetResult() *RPCResult
func (*RPCResponse) ProtoMessage ¶
func (*RPCResponse) ProtoMessage()
func (*RPCResponse) ProtoReflect ¶
func (x *RPCResponse) ProtoReflect() protoreflect.Message
func (*RPCResponse) Reset ¶
func (x *RPCResponse) Reset()
func (*RPCResponse) String ¶
func (x *RPCResponse) String() string
type RPCResult ¶
type RPCResult struct { Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` B64Data string `protobuf:"bytes,2,opt,name=b64data,proto3" json:"b64data,omitempty"` // contains filtered or unexported fields }
func (*RPCResult) ProtoReflect ¶
func (x *RPCResult) ProtoReflect() protoreflect.Message
type RefreshRequest ¶
type RefreshRequest struct { Client string `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"` Transport string `protobuf:"bytes,2,opt,name=transport,proto3" json:"transport,omitempty"` Protocol string `protobuf:"bytes,3,opt,name=protocol,proto3" json:"protocol,omitempty"` Encoding string `protobuf:"bytes,4,opt,name=encoding,proto3" json:"encoding,omitempty"` User string `protobuf:"bytes,10,opt,name=user,proto3" json:"user,omitempty"` Meta []byte `protobuf:"bytes,11,opt,name=meta,proto3" json:"meta,omitempty"` // contains filtered or unexported fields }
func (*RefreshRequest) Descriptor
deprecated
func (*RefreshRequest) Descriptor() ([]byte, []int)
Deprecated: Use RefreshRequest.ProtoReflect.Descriptor instead.
func (*RefreshRequest) GetClient ¶
func (x *RefreshRequest) GetClient() string
func (*RefreshRequest) GetEncoding ¶
func (x *RefreshRequest) GetEncoding() string
func (*RefreshRequest) GetMeta ¶
func (x *RefreshRequest) GetMeta() []byte
func (*RefreshRequest) GetProtocol ¶
func (x *RefreshRequest) GetProtocol() string
func (*RefreshRequest) GetTransport ¶
func (x *RefreshRequest) GetTransport() string
func (*RefreshRequest) GetUser ¶
func (x *RefreshRequest) GetUser() string
func (*RefreshRequest) ProtoMessage ¶
func (*RefreshRequest) ProtoMessage()
func (*RefreshRequest) ProtoReflect ¶
func (x *RefreshRequest) ProtoReflect() protoreflect.Message
func (*RefreshRequest) Reset ¶
func (x *RefreshRequest) Reset()
func (*RefreshRequest) String ¶
func (x *RefreshRequest) String() string
type RefreshResponse ¶
type RefreshResponse struct { Result *RefreshResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"` Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` Disconnect *Disconnect `protobuf:"bytes,3,opt,name=disconnect,proto3" json:"disconnect,omitempty"` // contains filtered or unexported fields }
func (*RefreshResponse) Descriptor
deprecated
func (*RefreshResponse) Descriptor() ([]byte, []int)
Deprecated: Use RefreshResponse.ProtoReflect.Descriptor instead.
func (*RefreshResponse) GetDisconnect ¶
func (x *RefreshResponse) GetDisconnect() *Disconnect
func (*RefreshResponse) GetError ¶
func (x *RefreshResponse) GetError() *Error
func (*RefreshResponse) GetResult ¶
func (x *RefreshResponse) GetResult() *RefreshResult
func (*RefreshResponse) ProtoMessage ¶
func (*RefreshResponse) ProtoMessage()
func (*RefreshResponse) ProtoReflect ¶
func (x *RefreshResponse) ProtoReflect() protoreflect.Message
func (*RefreshResponse) Reset ¶
func (x *RefreshResponse) Reset()
func (*RefreshResponse) String ¶
func (x *RefreshResponse) String() string
type RefreshResult ¶
type RefreshResult struct { Expired bool `protobuf:"varint,1,opt,name=expired,proto3" json:"expired,omitempty"` ExpireAt int64 `protobuf:"varint,2,opt,name=expire_at,json=expireAt,proto3" json:"expire_at,omitempty"` Info []byte `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"` B64Info string `protobuf:"bytes,4,opt,name=b64info,proto3" json:"b64info,omitempty"` Meta []byte `protobuf:"bytes,5,opt,name=meta,proto3" json:"meta,omitempty"` Caps []*ChannelsCapability `protobuf:"bytes,6,rep,name=caps,proto3" json:"caps,omitempty"` // contains filtered or unexported fields }
func (*RefreshResult) Descriptor
deprecated
func (*RefreshResult) Descriptor() ([]byte, []int)
Deprecated: Use RefreshResult.ProtoReflect.Descriptor instead.
func (*RefreshResult) GetB64Info ¶
func (x *RefreshResult) GetB64Info() string
func (*RefreshResult) GetCaps ¶
func (x *RefreshResult) GetCaps() []*ChannelsCapability
func (*RefreshResult) GetExpireAt ¶
func (x *RefreshResult) GetExpireAt() int64
func (*RefreshResult) GetExpired ¶
func (x *RefreshResult) GetExpired() bool
func (*RefreshResult) GetInfo ¶
func (x *RefreshResult) GetInfo() []byte
func (*RefreshResult) GetMeta ¶
func (x *RefreshResult) GetMeta() []byte
func (*RefreshResult) ProtoMessage ¶
func (*RefreshResult) ProtoMessage()
func (*RefreshResult) ProtoReflect ¶
func (x *RefreshResult) ProtoReflect() protoreflect.Message
func (*RefreshResult) Reset ¶
func (x *RefreshResult) Reset()
func (*RefreshResult) String ¶
func (x *RefreshResult) String() string
type SubscribeOptionOverride ¶
type SubscribeOptionOverride struct { Presence *BoolValue `protobuf:"bytes,1,opt,name=presence,proto3" json:"presence,omitempty"` JoinLeave *BoolValue `protobuf:"bytes,2,opt,name=join_leave,json=joinLeave,proto3" json:"join_leave,omitempty"` ForceRecovery *BoolValue `protobuf:"bytes,3,opt,name=force_recovery,json=forceRecovery,proto3" json:"force_recovery,omitempty"` ForcePositioning *BoolValue `protobuf:"bytes,4,opt,name=force_positioning,json=forcePositioning,proto3" json:"force_positioning,omitempty"` ForcePushJoinLeave *BoolValue `protobuf:"bytes,5,opt,name=force_push_join_leave,json=forcePushJoinLeave,proto3" json:"force_push_join_leave,omitempty"` // contains filtered or unexported fields }
func (*SubscribeOptionOverride) Descriptor
deprecated
func (*SubscribeOptionOverride) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeOptionOverride.ProtoReflect.Descriptor instead.
func (*SubscribeOptionOverride) GetForcePositioning ¶
func (x *SubscribeOptionOverride) GetForcePositioning() *BoolValue
func (*SubscribeOptionOverride) GetForcePushJoinLeave ¶
func (x *SubscribeOptionOverride) GetForcePushJoinLeave() *BoolValue
func (*SubscribeOptionOverride) GetForceRecovery ¶
func (x *SubscribeOptionOverride) GetForceRecovery() *BoolValue
func (*SubscribeOptionOverride) GetJoinLeave ¶
func (x *SubscribeOptionOverride) GetJoinLeave() *BoolValue
func (*SubscribeOptionOverride) GetPresence ¶
func (x *SubscribeOptionOverride) GetPresence() *BoolValue
func (*SubscribeOptionOverride) ProtoMessage ¶
func (*SubscribeOptionOverride) ProtoMessage()
func (*SubscribeOptionOverride) ProtoReflect ¶
func (x *SubscribeOptionOverride) ProtoReflect() protoreflect.Message
func (*SubscribeOptionOverride) Reset ¶
func (x *SubscribeOptionOverride) Reset()
func (*SubscribeOptionOverride) String ¶
func (x *SubscribeOptionOverride) String() string
type SubscribeOptions ¶
type SubscribeOptions struct { ExpireAt int64 `protobuf:"varint,1,opt,name=expire_at,json=expireAt,proto3" json:"expire_at,omitempty"` Info []byte `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"` B64Info string `protobuf:"bytes,3,opt,name=b64info,proto3" json:"b64info,omitempty"` Data []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"` B64Data string `protobuf:"bytes,5,opt,name=b64data,proto3" json:"b64data,omitempty"` Override *SubscribeOptionOverride `protobuf:"bytes,6,opt,name=override,proto3" json:"override,omitempty"` // contains filtered or unexported fields }
func (*SubscribeOptions) Descriptor
deprecated
func (*SubscribeOptions) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeOptions.ProtoReflect.Descriptor instead.
func (*SubscribeOptions) GetB64Data ¶
func (x *SubscribeOptions) GetB64Data() string
func (*SubscribeOptions) GetB64Info ¶
func (x *SubscribeOptions) GetB64Info() string
func (*SubscribeOptions) GetData ¶
func (x *SubscribeOptions) GetData() []byte
func (*SubscribeOptions) GetExpireAt ¶
func (x *SubscribeOptions) GetExpireAt() int64
func (*SubscribeOptions) GetInfo ¶
func (x *SubscribeOptions) GetInfo() []byte
func (*SubscribeOptions) GetOverride ¶
func (x *SubscribeOptions) GetOverride() *SubscribeOptionOverride
func (*SubscribeOptions) ProtoMessage ¶
func (*SubscribeOptions) ProtoMessage()
func (*SubscribeOptions) ProtoReflect ¶
func (x *SubscribeOptions) ProtoReflect() protoreflect.Message
func (*SubscribeOptions) Reset ¶
func (x *SubscribeOptions) Reset()
func (*SubscribeOptions) String ¶
func (x *SubscribeOptions) String() string
type SubscribeRequest ¶
type SubscribeRequest struct { Client string `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"` Transport string `protobuf:"bytes,2,opt,name=transport,proto3" json:"transport,omitempty"` Protocol string `protobuf:"bytes,3,opt,name=protocol,proto3" json:"protocol,omitempty"` Encoding string `protobuf:"bytes,4,opt,name=encoding,proto3" json:"encoding,omitempty"` User string `protobuf:"bytes,10,opt,name=user,proto3" json:"user,omitempty"` Channel string `protobuf:"bytes,11,opt,name=channel,proto3" json:"channel,omitempty"` Token string `protobuf:"bytes,12,opt,name=token,proto3" json:"token,omitempty"` Meta []byte `protobuf:"bytes,13,opt,name=meta,proto3" json:"meta,omitempty"` Data []byte `protobuf:"bytes,14,opt,name=data,proto3" json:"data,omitempty"` B64Data string `protobuf:"bytes,15,opt,name=b64data,proto3" json:"b64data,omitempty"` // contains filtered or unexported fields }
func (*SubscribeRequest) Descriptor
deprecated
func (*SubscribeRequest) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.
func (*SubscribeRequest) GetB64Data ¶
func (x *SubscribeRequest) GetB64Data() string
func (*SubscribeRequest) GetChannel ¶
func (x *SubscribeRequest) GetChannel() string
func (*SubscribeRequest) GetClient ¶
func (x *SubscribeRequest) GetClient() string
func (*SubscribeRequest) GetData ¶
func (x *SubscribeRequest) GetData() []byte
func (*SubscribeRequest) GetEncoding ¶
func (x *SubscribeRequest) GetEncoding() string
func (*SubscribeRequest) GetMeta ¶
func (x *SubscribeRequest) GetMeta() []byte
func (*SubscribeRequest) GetProtocol ¶
func (x *SubscribeRequest) GetProtocol() string
func (*SubscribeRequest) GetToken ¶
func (x *SubscribeRequest) GetToken() string
func (*SubscribeRequest) GetTransport ¶
func (x *SubscribeRequest) GetTransport() string
func (*SubscribeRequest) GetUser ¶
func (x *SubscribeRequest) GetUser() string
func (*SubscribeRequest) ProtoMessage ¶
func (*SubscribeRequest) ProtoMessage()
func (*SubscribeRequest) ProtoReflect ¶
func (x *SubscribeRequest) ProtoReflect() protoreflect.Message
func (*SubscribeRequest) Reset ¶
func (x *SubscribeRequest) Reset()
func (*SubscribeRequest) String ¶
func (x *SubscribeRequest) String() string
type SubscribeResponse ¶
type SubscribeResponse struct { Result *SubscribeResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"` Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` Disconnect *Disconnect `protobuf:"bytes,3,opt,name=disconnect,proto3" json:"disconnect,omitempty"` // contains filtered or unexported fields }
func (*SubscribeResponse) Descriptor
deprecated
func (*SubscribeResponse) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeResponse.ProtoReflect.Descriptor instead.
func (*SubscribeResponse) GetDisconnect ¶
func (x *SubscribeResponse) GetDisconnect() *Disconnect
func (*SubscribeResponse) GetError ¶
func (x *SubscribeResponse) GetError() *Error
func (*SubscribeResponse) GetResult ¶
func (x *SubscribeResponse) GetResult() *SubscribeResult
func (*SubscribeResponse) ProtoMessage ¶
func (*SubscribeResponse) ProtoMessage()
func (*SubscribeResponse) ProtoReflect ¶
func (x *SubscribeResponse) ProtoReflect() protoreflect.Message
func (*SubscribeResponse) Reset ¶
func (x *SubscribeResponse) Reset()
func (*SubscribeResponse) String ¶
func (x *SubscribeResponse) String() string
type SubscribeResult ¶
type SubscribeResult struct { ExpireAt int64 `protobuf:"varint,1,opt,name=expire_at,json=expireAt,proto3" json:"expire_at,omitempty"` Info []byte `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"` B64Info string `protobuf:"bytes,3,opt,name=b64info,proto3" json:"b64info,omitempty"` Data []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"` B64Data string `protobuf:"bytes,5,opt,name=b64data,proto3" json:"b64data,omitempty"` Override *SubscribeOptionOverride `protobuf:"bytes,6,opt,name=override,proto3" json:"override,omitempty"` Allow []string `protobuf:"bytes,7,rep,name=allow,proto3" json:"allow,omitempty"` // contains filtered or unexported fields }
func (*SubscribeResult) Descriptor
deprecated
func (*SubscribeResult) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeResult.ProtoReflect.Descriptor instead.
func (*SubscribeResult) GetAllow ¶
func (x *SubscribeResult) GetAllow() []string
func (*SubscribeResult) GetB64Data ¶
func (x *SubscribeResult) GetB64Data() string
func (*SubscribeResult) GetB64Info ¶
func (x *SubscribeResult) GetB64Info() string
func (*SubscribeResult) GetData ¶
func (x *SubscribeResult) GetData() []byte
func (*SubscribeResult) GetExpireAt ¶
func (x *SubscribeResult) GetExpireAt() int64
func (*SubscribeResult) GetInfo ¶
func (x *SubscribeResult) GetInfo() []byte
func (*SubscribeResult) GetOverride ¶
func (x *SubscribeResult) GetOverride() *SubscribeOptionOverride
func (*SubscribeResult) ProtoMessage ¶
func (*SubscribeResult) ProtoMessage()
func (*SubscribeResult) ProtoReflect ¶
func (x *SubscribeResult) ProtoReflect() protoreflect.Message
func (*SubscribeResult) Reset ¶
func (x *SubscribeResult) Reset()
func (*SubscribeResult) String ¶
func (x *SubscribeResult) String() string