proxyproto

Jun 1, 2024

Changes in this version

+ const CentrifugoProxy_NotifyCacheEmpty_FullMethodName

+ func DisconnectFromProto(s *Disconnect) *centrifuge.Disconnect

+ func ErrorFromProto(s *Error) *centrifuge.Error

type CentrifugoProxyClient

+ NotifyCacheEmpty func(ctx context.Context, in *NotifyCacheEmptyRequest, opts ...grpc.CallOption) (*NotifyCacheEmptyResponse, error)

type CentrifugoProxyServer

+ NotifyCacheEmpty func(context.Context, *NotifyCacheEmptyRequest) (*NotifyCacheEmptyResponse, error)

+ type Codec struct

+ func (Codec) Marshal(v any) ([]byte, error)

+ func (Codec) Name() string

+ func (Codec) Unmarshal(data []byte, v any) error

+ type JSONDecoder struct

+ func (e *JSONDecoder) DecodeConnectResponse(data []byte) (*ConnectResponse, error)

+ func (e *JSONDecoder) DecodeNotifyCacheEmptyResponse(data []byte) (*NotifyCacheEmptyResponse, error)

+ func (e *JSONDecoder) DecodePublishResponse(data []byte) (*PublishResponse, error)

+ func (e *JSONDecoder) DecodeRPCResponse(data []byte) (*RPCResponse, error)

+ func (e *JSONDecoder) DecodeRefreshResponse(data []byte) (*RefreshResponse, error)

+ func (e *JSONDecoder) DecodeSubRefreshResponse(data []byte) (*SubRefreshResponse, error)

+ func (e *JSONDecoder) DecodeSubscribeResponse(data []byte) (*SubscribeResponse, error)

+ type JSONEncoder struct

+ func (e *JSONEncoder) EncodeConnectRequest(req *ConnectRequest) ([]byte, error)

+ func (e *JSONEncoder) EncodeNotifyCacheEmptyRequest(req *NotifyCacheEmptyRequest) ([]byte, error)

+ func (e *JSONEncoder) EncodePublishRequest(req *PublishRequest) ([]byte, error)

+ func (e *JSONEncoder) EncodeRPCRequest(req *RPCRequest) ([]byte, error)

+ func (e *JSONEncoder) EncodeRefreshRequest(req *RefreshRequest) ([]byte, error)

+ func (e *JSONEncoder) EncodeSubRefreshRequest(req *SubRefreshRequest) ([]byte, error)

+ func (e *JSONEncoder) EncodeSubscribeRequest(req *SubscribeRequest) ([]byte, error)

+ type NotifyCacheEmptyRequest struct

+ Channel string

+ func (*NotifyCacheEmptyRequest) Descriptor() ([]byte, []int)

+ func (*NotifyCacheEmptyRequest) ProtoMessage()

+ func (x *NotifyCacheEmptyRequest) GetChannel() string

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

+ func (x *NotifyCacheEmptyRequest) Reset()

+ func (x *NotifyCacheEmptyRequest) String() string

+ type NotifyCacheEmptyResponse struct

+ Result *NotifyCacheEmptyResult

+ func (*NotifyCacheEmptyResponse) Descriptor() ([]byte, []int)

+ func (*NotifyCacheEmptyResponse) ProtoMessage()

+ func (x *NotifyCacheEmptyResponse) GetResult() *NotifyCacheEmptyResult

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

+ func (x *NotifyCacheEmptyResponse) Reset()

+ func (x *NotifyCacheEmptyResponse) String() string

+ type NotifyCacheEmptyResult struct

+ Populated bool

+ func (*NotifyCacheEmptyResult) Descriptor() ([]byte, []int)

+ func (*NotifyCacheEmptyResult) ProtoMessage()

+ func (x *NotifyCacheEmptyResult) GetPopulated() bool

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

+ func (x *NotifyCacheEmptyResult) Reset()

+ func (x *NotifyCacheEmptyResult) String() string

+ type RequestEncoder interface

+ EncodeConnectRequest func(req *ConnectRequest) ([]byte, error)

+ EncodeNotifyCacheEmptyRequest func(req *NotifyCacheEmptyRequest) ([]byte, error)

+ EncodePublishRequest func(req *PublishRequest) ([]byte, error)

+ EncodeRPCRequest func(req *RPCRequest) ([]byte, error)

+ EncodeRefreshRequest func(req *RefreshRequest) ([]byte, error)

+ EncodeSubRefreshRequest func(req *SubRefreshRequest) ([]byte, error)

+ EncodeSubscribeRequest func(req *SubscribeRequest) ([]byte, error)

+ type ResponseDecoder interface

+ DecodeConnectResponse func(data []byte) (*ConnectResponse, error)

+ DecodeNotifyCacheEmptyResponse func(data []byte) (*NotifyCacheEmptyResponse, error)

+ DecodePublishResponse func(data []byte) (*PublishResponse, error)

+ DecodeRPCResponse func(data []byte) (*RPCResponse, error)

+ DecodeRefreshResponse func(data []byte) (*RefreshResponse, error)

+ DecodeSubRefreshResponse func(data []byte) (*SubRefreshResponse, error)

+ DecodeSubscribeResponse func(data []byte) (*SubscribeResponse, error)

type UnimplementedCentrifugoProxyServer

+ func (UnimplementedCentrifugoProxyServer) NotifyCacheEmpty(context.Context, *NotifyCacheEmptyRequest) (*NotifyCacheEmptyResponse, error)

May 26, 2024

Changes in this version

+ const CentrifugoProxy_Connect_FullMethodName

+ const CentrifugoProxy_NotifyChannelState_FullMethodName

+ const CentrifugoProxy_Publish_FullMethodName

+ const CentrifugoProxy_RPC_FullMethodName

+ const CentrifugoProxy_Refresh_FullMethodName

+ const CentrifugoProxy_SubRefresh_FullMethodName

+ const CentrifugoProxy_SubscribeBidirectional_FullMethodName

+ const CentrifugoProxy_SubscribeUnidirectional_FullMethodName

+ const CentrifugoProxy_Subscribe_FullMethodName

+ var CentrifugoProxy_ServiceDesc = grpc.ServiceDesc

+ var File_proxy_proto protoreflect.FileDescriptor

+ func RegisterCentrifugoProxyServer(s grpc.ServiceRegistrar, srv CentrifugoProxyServer)

+ type BoolValue struct

+ Value bool

+ func (*BoolValue) Descriptor() ([]byte, []int)

+ func (*BoolValue) ProtoMessage()

+ func (x *BoolValue) GetValue() bool

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

+ func (x *BoolValue) Reset()

+ func (x *BoolValue) String() string

+ type CentrifugoProxyClient interface

+ Connect func(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (*ConnectResponse, error)

+ NotifyChannelState func(ctx context.Context, in *NotifyChannelStateRequest, opts ...grpc.CallOption) (*NotifyChannelStateResponse, error)

+ Publish func(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error)

+ RPC func(ctx context.Context, in *RPCRequest, opts ...grpc.CallOption) (*RPCResponse, error)

+ Refresh func(ctx context.Context, in *RefreshRequest, opts ...grpc.CallOption) (*RefreshResponse, error)

+ SubRefresh func(ctx context.Context, in *SubRefreshRequest, opts ...grpc.CallOption) (*SubRefreshResponse, error)

+ Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (*SubscribeResponse, error)

+ SubscribeBidirectional func(ctx context.Context, opts ...grpc.CallOption) (CentrifugoProxy_SubscribeBidirectionalClient, error)

+ SubscribeUnidirectional func(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (CentrifugoProxy_SubscribeUnidirectionalClient, error)

+ func NewCentrifugoProxyClient(cc grpc.ClientConnInterface) CentrifugoProxyClient

+ type CentrifugoProxyServer interface

+ Connect func(context.Context, *ConnectRequest) (*ConnectResponse, error)

+ NotifyChannelState func(context.Context, *NotifyChannelStateRequest) (*NotifyChannelStateResponse, error)

+ Publish func(context.Context, *PublishRequest) (*PublishResponse, error)

+ RPC func(context.Context, *RPCRequest) (*RPCResponse, error)

+ Refresh func(context.Context, *RefreshRequest) (*RefreshResponse, error)

+ SubRefresh func(context.Context, *SubRefreshRequest) (*SubRefreshResponse, error)

+ Subscribe func(context.Context, *SubscribeRequest) (*SubscribeResponse, error)

+ SubscribeBidirectional func(CentrifugoProxy_SubscribeBidirectionalServer) error

+ SubscribeUnidirectional func(*SubscribeRequest, CentrifugoProxy_SubscribeUnidirectionalServer) error

+ type CentrifugoProxy_SubscribeBidirectionalClient interface

+ Recv func() (*StreamSubscribeResponse, error)

+ Send func(*StreamSubscribeRequest) error

+ type CentrifugoProxy_SubscribeBidirectionalServer interface

+ Recv func() (*StreamSubscribeRequest, error)

+ Send func(*StreamSubscribeResponse) error

+ type CentrifugoProxy_SubscribeUnidirectionalClient interface

+ Recv func() (*StreamSubscribeResponse, error)

+ type CentrifugoProxy_SubscribeUnidirectionalServer interface

+ Send func(*StreamSubscribeResponse) error

+ type ChannelEvent struct

+ Channel string

+ TimeMs int64

+ Type string

+ func (*ChannelEvent) Descriptor() ([]byte, []int)

+ func (*ChannelEvent) ProtoMessage()

+ func (x *ChannelEvent) GetChannel() string

+ func (x *ChannelEvent) GetTimeMs() int64

+ func (x *ChannelEvent) GetType() string

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

+ func (x *ChannelEvent) Reset()

+ func (x *ChannelEvent) String() string

+ type ChannelsCapability struct

+ Allow []string

+ Channels []string

+ Match string

+ func (*ChannelsCapability) Descriptor() ([]byte, []int)

+ func (*ChannelsCapability) ProtoMessage()

+ func (x *ChannelsCapability) GetAllow() []string

+ func (x *ChannelsCapability) GetChannels() []string

+ func (x *ChannelsCapability) GetMatch() string

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

+ func (x *ChannelsCapability) Reset()

+ func (x *ChannelsCapability) String() string

+ type ConnectRequest struct

+ B64Data string

+ Channels []string

+ Client string

+ Data Raw

+ Encoding string

+ Name string

+ Protocol string

+ Transport string

+ Version string

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

+ func (*ConnectRequest) ProtoMessage()

+ 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 (x *ConnectRequest) ProtoReflect() protoreflect.Message

+ func (x *ConnectRequest) Reset()

+ func (x *ConnectRequest) String() string

+ type ConnectResponse struct

+ Disconnect *Disconnect

+ Error *Error

+ Result *ConnectResult

+ func (*ConnectResponse) Descriptor() ([]byte, []int)

+ func (*ConnectResponse) ProtoMessage()

+ func (x *ConnectResponse) GetDisconnect() *Disconnect

+ func (x *ConnectResponse) GetError() *Error

+ func (x *ConnectResponse) GetResult() *ConnectResult

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

+ func (x *ConnectResponse) Reset()

+ func (x *ConnectResponse) String() string

+ type ConnectResult struct

+ B64Data string

+ B64Info string

+ Caps []*ChannelsCapability

+ Channels []string

+ Data Raw

+ ExpireAt int64

+ Info Raw

+ Meta Raw

+ Subs map[string]*SubscribeOptions

+ User string

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

+ func (*ConnectResult) ProtoMessage()

+ 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 (x *ConnectResult) ProtoReflect() protoreflect.Message

+ func (x *ConnectResult) Reset()

+ func (x *ConnectResult) String() string

+ type Disconnect struct

+ Code uint32

+ Reason string

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

+ func (*Disconnect) ProtoMessage()

+ func (x *Disconnect) GetCode() uint32

+ func (x *Disconnect) GetReason() string

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

+ func (x *Disconnect) Reset()

+ func (x *Disconnect) String() string

+ type Error struct

+ Code uint32

+ Message string

+ Temporary bool

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

+ func (*Error) ProtoMessage()

+ func (x *Error) GetCode() uint32

+ func (x *Error) GetMessage() string

+ func (x *Error) GetTemporary() bool

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

+ func (x *Error) Reset()

+ func (x *Error) String() string

+ type Int32Value struct

+ Value int32

+ func (*Int32Value) Descriptor() ([]byte, []int)

+ func (*Int32Value) ProtoMessage()

+ func (x *Int32Value) GetValue() int32

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

+ func (x *Int32Value) Reset()

+ func (x *Int32Value) String() string

+ type NotifyChannelStateRequest struct

+ Events []*ChannelEvent

+ func (*NotifyChannelStateRequest) Descriptor() ([]byte, []int)

+ func (*NotifyChannelStateRequest) ProtoMessage()

+ func (x *NotifyChannelStateRequest) GetEvents() []*ChannelEvent

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

+ func (x *NotifyChannelStateRequest) Reset()

+ func (x *NotifyChannelStateRequest) String() string

+ type NotifyChannelStateResponse struct

+ Error *Error

+ Result *NotifyChannelStateResult

+ func (*NotifyChannelStateResponse) Descriptor() ([]byte, []int)

+ func (*NotifyChannelStateResponse) ProtoMessage()

+ func (x *NotifyChannelStateResponse) GetError() *Error

+ func (x *NotifyChannelStateResponse) GetResult() *NotifyChannelStateResult

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

+ func (x *NotifyChannelStateResponse) Reset()

+ func (x *NotifyChannelStateResponse) String() string

+ type NotifyChannelStateResult struct

+ func (*NotifyChannelStateResult) Descriptor() ([]byte, []int)

+ func (*NotifyChannelStateResult) ProtoMessage()

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

+ func (x *NotifyChannelStateResult) Reset()

+ func (x *NotifyChannelStateResult) String() string

+ type Publication struct

+ Data Raw

+ Tags map[string]string

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

+ func (*Publication) ProtoMessage()

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

+ func (x *Publication) GetTags() map[string]string

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

+ func (x *Publication) Reset()

+ func (x *Publication) String() string

+ type PublishRequest struct

+ B64Data string

+ Channel string

+ Client string

+ Data Raw

+ Encoding string

+ Meta Raw

+ Protocol string

+ Transport string

+ User string

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

+ func (*PublishRequest) ProtoMessage()

+ 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 (x *PublishRequest) ProtoReflect() protoreflect.Message

+ func (x *PublishRequest) Reset()

+ func (x *PublishRequest) String() string

+ type PublishResponse struct

+ Disconnect *Disconnect

+ Error *Error

+ Result *PublishResult

+ func (*PublishResponse) Descriptor() ([]byte, []int)

+ func (*PublishResponse) ProtoMessage()

+ func (x *PublishResponse) GetDisconnect() *Disconnect

+ func (x *PublishResponse) GetError() *Error

+ func (x *PublishResponse) GetResult() *PublishResult

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

+ func (x *PublishResponse) Reset()

+ func (x *PublishResponse) String() string

+ type PublishResult struct

+ B64Data string

+ Data Raw

+ SkipHistory bool

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

+ func (*PublishResult) ProtoMessage()

+ func (x *PublishResult) GetB64Data() string

+ func (x *PublishResult) GetData() []byte

+ func (x *PublishResult) GetSkipHistory() bool

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

+ func (x *PublishResult) Reset()

+ func (x *PublishResult) String() string

+ type RPCRequest struct

+ B64Data string

+ Client string

+ Data Raw

+ Encoding string

+ Meta Raw

+ Method string

+ Protocol string

+ Transport string

+ User string

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

+ func (*RPCRequest) ProtoMessage()

+ 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 (x *RPCRequest) ProtoReflect() protoreflect.Message

+ func (x *RPCRequest) Reset()

+ func (x *RPCRequest) String() string

+ type RPCResponse struct

+ Disconnect *Disconnect

+ Error *Error

+ Result *RPCResult

+ func (*RPCResponse) Descriptor() ([]byte, []int)

+ func (*RPCResponse) ProtoMessage()

+ func (x *RPCResponse) GetDisconnect() *Disconnect

+ func (x *RPCResponse) GetError() *Error

+ func (x *RPCResponse) GetResult() *RPCResult

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

+ func (x *RPCResponse) Reset()

+ func (x *RPCResponse) String() string

+ type RPCResult struct

+ B64Data string

+ Data Raw

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

+ func (*RPCResult) ProtoMessage()

+ func (x *RPCResult) GetB64Data() string

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

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

+ func (x *RPCResult) Reset()

+ func (x *RPCResult) String() string

+ type Raw []byte

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

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

+ type RefreshRequest struct

+ Client string

+ Encoding string

+ Meta Raw

+ Protocol string

+ Transport string

+ User string

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

+ func (*RefreshRequest) ProtoMessage()

+ 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 (x *RefreshRequest) ProtoReflect() protoreflect.Message

+ func (x *RefreshRequest) Reset()

+ func (x *RefreshRequest) String() string

+ type RefreshResponse struct

+ Disconnect *Disconnect

+ Error *Error

+ Result *RefreshResult

+ func (*RefreshResponse) Descriptor() ([]byte, []int)

+ func (*RefreshResponse) ProtoMessage()

+ func (x *RefreshResponse) GetDisconnect() *Disconnect

+ func (x *RefreshResponse) GetError() *Error

+ func (x *RefreshResponse) GetResult() *RefreshResult

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

+ func (x *RefreshResponse) Reset()

+ func (x *RefreshResponse) String() string

+ type RefreshResult struct

+ B64Info string

+ Caps []*ChannelsCapability

+ ExpireAt int64

+ Expired bool

+ Info Raw

+ Meta Raw

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

+ func (*RefreshResult) ProtoMessage()

+ 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 (x *RefreshResult) ProtoReflect() protoreflect.Message

+ func (x *RefreshResult) Reset()

+ func (x *RefreshResult) String() string

+ type StreamSubscribeRequest struct

+ Publication *Publication

+ SubscribeRequest *SubscribeRequest

+ func (*StreamSubscribeRequest) Descriptor() ([]byte, []int)

+ func (*StreamSubscribeRequest) ProtoMessage()

+ func (x *StreamSubscribeRequest) GetPublication() *Publication

+ func (x *StreamSubscribeRequest) GetSubscribeRequest() *SubscribeRequest

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

+ func (x *StreamSubscribeRequest) Reset()

+ func (x *StreamSubscribeRequest) String() string

+ type StreamSubscribeResponse struct

+ Publication *Publication

+ SubscribeResponse *SubscribeResponse

+ func (*StreamSubscribeResponse) Descriptor() ([]byte, []int)

+ func (*StreamSubscribeResponse) ProtoMessage()

+ func (x *StreamSubscribeResponse) GetPublication() *Publication

+ func (x *StreamSubscribeResponse) GetSubscribeResponse() *SubscribeResponse

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

+ func (x *StreamSubscribeResponse) Reset()

+ func (x *StreamSubscribeResponse) String() string

+ type SubRefreshRequest struct

+ Channel string

+ Client string

+ Encoding string

+ Meta Raw

+ Protocol string

+ Transport string

+ User string

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

+ func (*SubRefreshRequest) ProtoMessage()

+ func (x *SubRefreshRequest) GetChannel() string

+ func (x *SubRefreshRequest) GetClient() string

+ func (x *SubRefreshRequest) GetEncoding() string

+ func (x *SubRefreshRequest) GetMeta() []byte

+ func (x *SubRefreshRequest) GetProtocol() string

+ func (x *SubRefreshRequest) GetTransport() string

+ func (x *SubRefreshRequest) GetUser() string

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

+ func (x *SubRefreshRequest) Reset()

+ func (x *SubRefreshRequest) String() string

+ type SubRefreshResponse struct

+ Disconnect *Disconnect

+ Error *Error

+ Result *SubRefreshResult

+ func (*SubRefreshResponse) Descriptor() ([]byte, []int)

+ func (*SubRefreshResponse) ProtoMessage()

+ func (x *SubRefreshResponse) GetDisconnect() *Disconnect

+ func (x *SubRefreshResponse) GetError() *Error

+ func (x *SubRefreshResponse) GetResult() *SubRefreshResult

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

+ func (x *SubRefreshResponse) Reset()

+ func (x *SubRefreshResponse) String() string

+ type SubRefreshResult struct

+ B64Info string

+ ExpireAt int64

+ Expired bool

+ Info Raw

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

+ func (*SubRefreshResult) ProtoMessage()

+ func (x *SubRefreshResult) GetB64Info() string

+ func (x *SubRefreshResult) GetExpireAt() int64

+ func (x *SubRefreshResult) GetExpired() bool

+ func (x *SubRefreshResult) GetInfo() []byte

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

+ func (x *SubRefreshResult) Reset()

+ func (x *SubRefreshResult) String() string

+ type SubscribeOptionOverride struct

+ ForcePositioning *BoolValue

+ ForcePushJoinLeave *BoolValue

+ ForceRecovery *BoolValue

+ JoinLeave *BoolValue

+ Presence *BoolValue

+ func (*SubscribeOptionOverride) Descriptor() ([]byte, []int)

+ func (*SubscribeOptionOverride) ProtoMessage()

+ 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 (x *SubscribeOptionOverride) ProtoReflect() protoreflect.Message

+ func (x *SubscribeOptionOverride) Reset()

+ func (x *SubscribeOptionOverride) String() string

+ type SubscribeOptions struct

+ B64Data string

+ B64Info string

+ Data Raw

+ ExpireAt int64

+ Info Raw

+ Override *SubscribeOptionOverride

+ func (*SubscribeOptions) Descriptor() ([]byte, []int)

+ func (*SubscribeOptions) ProtoMessage()

+ 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 (x *SubscribeOptions) ProtoReflect() protoreflect.Message

+ func (x *SubscribeOptions) Reset()

+ func (x *SubscribeOptions) String() string

+ type SubscribeRequest struct

+ B64Data string

+ Channel string

+ Client string

+ Data Raw

+ Encoding string

+ Meta Raw

+ Protocol string

+ Token string

+ Transport string

+ User string

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

+ func (*SubscribeRequest) ProtoMessage()

+ 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 (x *SubscribeRequest) ProtoReflect() protoreflect.Message

+ func (x *SubscribeRequest) Reset()

+ func (x *SubscribeRequest) String() string

+ type SubscribeResponse struct

+ Disconnect *Disconnect

+ Error *Error

+ Result *SubscribeResult

+ func (*SubscribeResponse) Descriptor() ([]byte, []int)

+ func (*SubscribeResponse) ProtoMessage()

+ func (x *SubscribeResponse) GetDisconnect() *Disconnect

+ func (x *SubscribeResponse) GetError() *Error

+ func (x *SubscribeResponse) GetResult() *SubscribeResult

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

+ func (x *SubscribeResponse) Reset()

+ func (x *SubscribeResponse) String() string

+ type SubscribeResult struct

+ Allow []string

+ B64Data string

+ B64Info string

+ Data Raw

+ ExpireAt int64

+ Info Raw

+ Override *SubscribeOptionOverride

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

+ func (*SubscribeResult) ProtoMessage()

+ 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 (x *SubscribeResult) ProtoReflect() protoreflect.Message

+ func (x *SubscribeResult) Reset()

+ func (x *SubscribeResult) String() string

+ type UnimplementedCentrifugoProxyServer struct

+ func (UnimplementedCentrifugoProxyServer) Connect(context.Context, *ConnectRequest) (*ConnectResponse, error)

+ func (UnimplementedCentrifugoProxyServer) NotifyChannelState(context.Context, *NotifyChannelStateRequest) (*NotifyChannelStateResponse, error)

+ func (UnimplementedCentrifugoProxyServer) Publish(context.Context, *PublishRequest) (*PublishResponse, error)

+ func (UnimplementedCentrifugoProxyServer) RPC(context.Context, *RPCRequest) (*RPCResponse, error)

+ func (UnimplementedCentrifugoProxyServer) Refresh(context.Context, *RefreshRequest) (*RefreshResponse, error)

+ func (UnimplementedCentrifugoProxyServer) SubRefresh(context.Context, *SubRefreshRequest) (*SubRefreshResponse, error)

+ func (UnimplementedCentrifugoProxyServer) Subscribe(context.Context, *SubscribeRequest) (*SubscribeResponse, error)

+ func (UnimplementedCentrifugoProxyServer) SubscribeBidirectional(CentrifugoProxy_SubscribeBidirectionalServer) error

+ func (UnimplementedCentrifugoProxyServer) SubscribeUnidirectional(*SubscribeRequest, CentrifugoProxy_SubscribeUnidirectionalServer) error

+ type UnsafeCentrifugoProxyServer interface