Documentation
¶
Index ¶
- Constants
- Variables
- func DisconnectFromProto(s *Disconnect) *centrifuge.Disconnect
- func ErrorFromProto(s *Error) *centrifuge.Error
- func RegisterCentrifugoProxyServer(s grpc.ServiceRegistrar, srv CentrifugoProxyServer)
- type BoolValue
- type CentrifugoProxyClient
- type CentrifugoProxyServer
- type CentrifugoProxy_SubscribeBidirectionalClient
- type CentrifugoProxy_SubscribeBidirectionalServer
- type CentrifugoProxy_SubscribeUnidirectionalClient
- type CentrifugoProxy_SubscribeUnidirectionalServer
- type ChannelEvent
- func (*ChannelEvent) Descriptor() ([]byte, []int)deprecated
- func (x *ChannelEvent) GetChannel() string
- func (x *ChannelEvent) GetTimeMs() int64
- func (x *ChannelEvent) GetType() string
- func (*ChannelEvent) ProtoMessage()
- func (x *ChannelEvent) ProtoReflect() protoreflect.Message
- func (x *ChannelEvent) Reset()
- func (x *ChannelEvent) String() string
- 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 Codec
- 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
- type Error
- type Int32Value
- type JSONDecoder
- 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
- 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
- func (*NotifyCacheEmptyRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NotifyCacheEmptyRequest) GetChannel() string
- func (*NotifyCacheEmptyRequest) ProtoMessage()
- func (x *NotifyCacheEmptyRequest) ProtoReflect() protoreflect.Message
- func (x *NotifyCacheEmptyRequest) Reset()
- func (x *NotifyCacheEmptyRequest) String() string
- type NotifyCacheEmptyResponse
- func (*NotifyCacheEmptyResponse) Descriptor() ([]byte, []int)deprecated
- func (x *NotifyCacheEmptyResponse) GetResult() *NotifyCacheEmptyResult
- func (*NotifyCacheEmptyResponse) ProtoMessage()
- func (x *NotifyCacheEmptyResponse) ProtoReflect() protoreflect.Message
- func (x *NotifyCacheEmptyResponse) Reset()
- func (x *NotifyCacheEmptyResponse) String() string
- type NotifyCacheEmptyResult
- func (*NotifyCacheEmptyResult) Descriptor() ([]byte, []int)deprecated
- func (x *NotifyCacheEmptyResult) GetPopulated() bool
- func (*NotifyCacheEmptyResult) ProtoMessage()
- func (x *NotifyCacheEmptyResult) ProtoReflect() protoreflect.Message
- func (x *NotifyCacheEmptyResult) Reset()
- func (x *NotifyCacheEmptyResult) String() string
- type NotifyChannelStateRequest
- func (*NotifyChannelStateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NotifyChannelStateRequest) GetEvents() []*ChannelEvent
- func (*NotifyChannelStateRequest) ProtoMessage()
- func (x *NotifyChannelStateRequest) ProtoReflect() protoreflect.Message
- func (x *NotifyChannelStateRequest) Reset()
- func (x *NotifyChannelStateRequest) String() string
- type NotifyChannelStateResponse
- func (*NotifyChannelStateResponse) Descriptor() ([]byte, []int)deprecated
- func (x *NotifyChannelStateResponse) GetError() *Error
- func (x *NotifyChannelStateResponse) GetResult() *NotifyChannelStateResult
- func (*NotifyChannelStateResponse) ProtoMessage()
- func (x *NotifyChannelStateResponse) ProtoReflect() protoreflect.Message
- func (x *NotifyChannelStateResponse) Reset()
- func (x *NotifyChannelStateResponse) String() string
- type NotifyChannelStateResult
- type Publication
- func (*Publication) Descriptor() ([]byte, []int)deprecated
- func (x *Publication) GetData() []byte
- func (x *Publication) GetTags() map[string]string
- func (*Publication) ProtoMessage()
- func (x *Publication) ProtoReflect() protoreflect.Message
- func (x *Publication) Reset()
- func (x *Publication) String() string
- 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 Raw
- 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 RequestEncoder
- type ResponseDecoder
- type StreamSubscribeRequest
- func (*StreamSubscribeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StreamSubscribeRequest) GetPublication() *Publication
- func (x *StreamSubscribeRequest) GetSubscribeRequest() *SubscribeRequest
- func (*StreamSubscribeRequest) ProtoMessage()
- func (x *StreamSubscribeRequest) ProtoReflect() protoreflect.Message
- func (x *StreamSubscribeRequest) Reset()
- func (x *StreamSubscribeRequest) String() string
- type StreamSubscribeResponse
- func (*StreamSubscribeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StreamSubscribeResponse) GetPublication() *Publication
- func (x *StreamSubscribeResponse) GetSubscribeResponse() *SubscribeResponse
- func (*StreamSubscribeResponse) ProtoMessage()
- func (x *StreamSubscribeResponse) ProtoReflect() protoreflect.Message
- func (x *StreamSubscribeResponse) Reset()
- func (x *StreamSubscribeResponse) String() string
- type SubRefreshRequest
- func (*SubRefreshRequest) Descriptor() ([]byte, []int)deprecated
- 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 (*SubRefreshRequest) ProtoMessage()
- func (x *SubRefreshRequest) ProtoReflect() protoreflect.Message
- func (x *SubRefreshRequest) Reset()
- func (x *SubRefreshRequest) String() string
- type SubRefreshResponse
- func (*SubRefreshResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SubRefreshResponse) GetDisconnect() *Disconnect
- func (x *SubRefreshResponse) GetError() *Error
- func (x *SubRefreshResponse) GetResult() *SubRefreshResult
- func (*SubRefreshResponse) ProtoMessage()
- func (x *SubRefreshResponse) ProtoReflect() protoreflect.Message
- func (x *SubRefreshResponse) Reset()
- func (x *SubRefreshResponse) String() string
- type SubRefreshResult
- func (*SubRefreshResult) Descriptor() ([]byte, []int)deprecated
- func (x *SubRefreshResult) GetB64Info() string
- func (x *SubRefreshResult) GetExpireAt() int64
- func (x *SubRefreshResult) GetExpired() bool
- func (x *SubRefreshResult) GetInfo() []byte
- func (*SubRefreshResult) ProtoMessage()
- func (x *SubRefreshResult) ProtoReflect() protoreflect.Message
- func (x *SubRefreshResult) Reset()
- func (x *SubRefreshResult) 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
- type UnimplementedCentrifugoProxyServer
- func (UnimplementedCentrifugoProxyServer) Connect(context.Context, *ConnectRequest) (*ConnectResponse, error)
- func (UnimplementedCentrifugoProxyServer) NotifyCacheEmpty(context.Context, *NotifyCacheEmptyRequest) (*NotifyCacheEmptyResponse, 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
Constants ¶
const ( CentrifugoProxy_Connect_FullMethodName = "/centrifugal.centrifugo.proxy.CentrifugoProxy/Connect" CentrifugoProxy_Refresh_FullMethodName = "/centrifugal.centrifugo.proxy.CentrifugoProxy/Refresh" CentrifugoProxy_Subscribe_FullMethodName = "/centrifugal.centrifugo.proxy.CentrifugoProxy/Subscribe" CentrifugoProxy_Publish_FullMethodName = "/centrifugal.centrifugo.proxy.CentrifugoProxy/Publish" CentrifugoProxy_RPC_FullMethodName = "/centrifugal.centrifugo.proxy.CentrifugoProxy/RPC" CentrifugoProxy_SubRefresh_FullMethodName = "/centrifugal.centrifugo.proxy.CentrifugoProxy/SubRefresh" CentrifugoProxy_SubscribeUnidirectional_FullMethodName = "/centrifugal.centrifugo.proxy.CentrifugoProxy/SubscribeUnidirectional" CentrifugoProxy_SubscribeBidirectional_FullMethodName = "/centrifugal.centrifugo.proxy.CentrifugoProxy/SubscribeBidirectional" CentrifugoProxy_NotifyCacheEmpty_FullMethodName = "/centrifugal.centrifugo.proxy.CentrifugoProxy/NotifyCacheEmpty" CentrifugoProxy_NotifyChannelState_FullMethodName = "/centrifugal.centrifugo.proxy.CentrifugoProxy/NotifyChannelState" )
Variables ¶
var CentrifugoProxy_ServiceDesc = grpc.ServiceDesc{ ServiceName: "centrifugal.centrifugo.proxy.CentrifugoProxy", HandlerType: (*CentrifugoProxyServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Connect", Handler: _CentrifugoProxy_Connect_Handler, }, { MethodName: "Refresh", Handler: _CentrifugoProxy_Refresh_Handler, }, { MethodName: "Subscribe", Handler: _CentrifugoProxy_Subscribe_Handler, }, { MethodName: "Publish", Handler: _CentrifugoProxy_Publish_Handler, }, { MethodName: "RPC", Handler: _CentrifugoProxy_RPC_Handler, }, { MethodName: "SubRefresh", Handler: _CentrifugoProxy_SubRefresh_Handler, }, { MethodName: "NotifyCacheEmpty", Handler: _CentrifugoProxy_NotifyCacheEmpty_Handler, }, { MethodName: "NotifyChannelState", Handler: _CentrifugoProxy_NotifyChannelState_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "SubscribeUnidirectional", Handler: _CentrifugoProxy_SubscribeUnidirectional_Handler, ServerStreams: true, }, { StreamName: "SubscribeBidirectional", Handler: _CentrifugoProxy_SubscribeBidirectional_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "proxy.proto", }
CentrifugoProxy_ServiceDesc is the grpc.ServiceDesc for CentrifugoProxy service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_proxy_proto protoreflect.FileDescriptor
Functions ¶
func DisconnectFromProto ¶ added in v3.0.900
func DisconnectFromProto(s *Disconnect) *centrifuge.Disconnect
func ErrorFromProto ¶ added in v3.0.900
func ErrorFromProto(s *Error) *centrifuge.Error
func RegisterCentrifugoProxyServer ¶
func RegisterCentrifugoProxyServer(s grpc.ServiceRegistrar, srv CentrifugoProxyServer)
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) Descriptor
deprecated
func (*BoolValue) ProtoMessage ¶
func (*BoolValue) ProtoMessage()
func (*BoolValue) ProtoReflect ¶
func (x *BoolValue) ProtoReflect() protoreflect.Message
type CentrifugoProxyClient ¶
type CentrifugoProxyClient interface { // Connect to proxy connection authentication and communicate initial state. Connect(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (*ConnectResponse, error) // Refresh to proxy decision about connection expiration to the app backend. Refresh(ctx context.Context, in *RefreshRequest, opts ...grpc.CallOption) (*RefreshResponse, error) // Subscribe to proxy subscription attempts to channels. Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (*SubscribeResponse, error) // Publish to proxy publication attempts to channels. Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error) // RPC to execute custom logic on the backend over request through the real-time connection. RPC(ctx context.Context, in *RPCRequest, opts ...grpc.CallOption) (*RPCResponse, error) // SubRefresh to proxy decision about subscription expiration to the app backend. SubRefresh(ctx context.Context, in *SubRefreshRequest, opts ...grpc.CallOption) (*SubRefreshResponse, error) // SubscribeUnidirectional is an EXPERIMENTAL method which allows handling unidirectional // subscription streams. Stream starts with SubscribeRequest similar to Subscribe rpc, // then expects StreamSubscribeResponse with SubscribeResponse as first message, and // StreamSubscribeResponse with Publication afterwards. SubscribeUnidirectional(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (CentrifugoProxy_SubscribeUnidirectionalClient, error) // SubscribeBidirectional is an EXPERIMENTAL method which allows handling bidirectional // subscription streams. Stream receives StreamSubscribeRequest. First StreamSubscribeRequest // always contains SubscribeRequest, then StreamSubscribeRequest will contain data published // by client. Reverse direction works the same way as in SubscribeUnidirectional. SubscribeBidirectional(ctx context.Context, opts ...grpc.CallOption) (CentrifugoProxy_SubscribeBidirectionalClient, error) // NotifyCacheEmpty is an EXPERIMENTAL method which allows to load documents from the backend. NotifyCacheEmpty(ctx context.Context, in *NotifyCacheEmptyRequest, opts ...grpc.CallOption) (*NotifyCacheEmptyResponse, error) // NotifyChannelState can be used to receive channel events such as channel "occupied" and "vacated". // This is a feature in a preview state and is only available in Centrifugo PRO. NotifyChannelState(ctx context.Context, in *NotifyChannelStateRequest, opts ...grpc.CallOption) (*NotifyChannelStateResponse, error) }
CentrifugoProxyClient is the client API for CentrifugoProxy service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewCentrifugoProxyClient ¶
func NewCentrifugoProxyClient(cc grpc.ClientConnInterface) CentrifugoProxyClient
type CentrifugoProxyServer ¶
type CentrifugoProxyServer interface { // Connect to proxy connection authentication and communicate initial state. Connect(context.Context, *ConnectRequest) (*ConnectResponse, error) // Refresh to proxy decision about connection expiration to the app backend. Refresh(context.Context, *RefreshRequest) (*RefreshResponse, error) // Subscribe to proxy subscription attempts to channels. Subscribe(context.Context, *SubscribeRequest) (*SubscribeResponse, error) // Publish to proxy publication attempts to channels. Publish(context.Context, *PublishRequest) (*PublishResponse, error) // RPC to execute custom logic on the backend over request through the real-time connection. RPC(context.Context, *RPCRequest) (*RPCResponse, error) // SubRefresh to proxy decision about subscription expiration to the app backend. SubRefresh(context.Context, *SubRefreshRequest) (*SubRefreshResponse, error) // SubscribeUnidirectional is an EXPERIMENTAL method which allows handling unidirectional // subscription streams. Stream starts with SubscribeRequest similar to Subscribe rpc, // then expects StreamSubscribeResponse with SubscribeResponse as first message, and // StreamSubscribeResponse with Publication afterwards. SubscribeUnidirectional(*SubscribeRequest, CentrifugoProxy_SubscribeUnidirectionalServer) error // SubscribeBidirectional is an EXPERIMENTAL method which allows handling bidirectional // subscription streams. Stream receives StreamSubscribeRequest. First StreamSubscribeRequest // always contains SubscribeRequest, then StreamSubscribeRequest will contain data published // by client. Reverse direction works the same way as in SubscribeUnidirectional. SubscribeBidirectional(CentrifugoProxy_SubscribeBidirectionalServer) error // NotifyCacheEmpty is an EXPERIMENTAL method which allows to load documents from the backend. NotifyCacheEmpty(context.Context, *NotifyCacheEmptyRequest) (*NotifyCacheEmptyResponse, error) // NotifyChannelState can be used to receive channel events such as channel "occupied" and "vacated". // This is a feature in a preview state and is only available in Centrifugo PRO. NotifyChannelState(context.Context, *NotifyChannelStateRequest) (*NotifyChannelStateResponse, error) // contains filtered or unexported methods }
CentrifugoProxyServer is the server API for CentrifugoProxy service. All implementations must embed UnimplementedCentrifugoProxyServer for forward compatibility
type CentrifugoProxy_SubscribeBidirectionalClient ¶
type CentrifugoProxy_SubscribeBidirectionalClient interface { Send(*StreamSubscribeRequest) error Recv() (*StreamSubscribeResponse, error) grpc.ClientStream }
type CentrifugoProxy_SubscribeBidirectionalServer ¶
type CentrifugoProxy_SubscribeBidirectionalServer interface { Send(*StreamSubscribeResponse) error Recv() (*StreamSubscribeRequest, error) grpc.ServerStream }
type CentrifugoProxy_SubscribeUnidirectionalClient ¶
type CentrifugoProxy_SubscribeUnidirectionalClient interface { Recv() (*StreamSubscribeResponse, error) grpc.ClientStream }
type CentrifugoProxy_SubscribeUnidirectionalServer ¶
type CentrifugoProxy_SubscribeUnidirectionalServer interface { Send(*StreamSubscribeResponse) error grpc.ServerStream }
type ChannelEvent ¶
type ChannelEvent struct { TimeMs int64 `protobuf:"varint,1,opt,name=time_ms,json=timeMs,proto3" json:"time_ms,omitempty"` Channel string `protobuf:"bytes,2,opt,name=channel,proto3" json:"channel,omitempty"` Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"` // "occupied" | "vacated" | could be more in the future. Not using enums for better JSON interop. // contains filtered or unexported fields }
func (*ChannelEvent) Descriptor
deprecated
func (*ChannelEvent) Descriptor() ([]byte, []int)
Deprecated: Use ChannelEvent.ProtoReflect.Descriptor instead.
func (*ChannelEvent) GetChannel ¶
func (x *ChannelEvent) GetChannel() string
func (*ChannelEvent) GetTimeMs ¶
func (x *ChannelEvent) GetTimeMs() int64
func (*ChannelEvent) GetType ¶
func (x *ChannelEvent) GetType() string
func (*ChannelEvent) ProtoMessage ¶
func (*ChannelEvent) ProtoMessage()
func (*ChannelEvent) ProtoReflect ¶
func (x *ChannelEvent) ProtoReflect() protoreflect.Message
func (*ChannelEvent) Reset ¶
func (x *ChannelEvent) Reset()
func (*ChannelEvent) String ¶
func (x *ChannelEvent) String() string
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 Raw `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 Raw `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"` B64Info string `protobuf:"bytes,4,opt,name=b64info,proto3" json:"b64info,omitempty"` Data Raw `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 Raw `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"` // 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) 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) Descriptor
deprecated
func (*Error) GetMessage ¶
func (*Error) GetTemporary ¶
func (*Error) ProtoMessage ¶
func (*Error) ProtoMessage()
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 JSONDecoder ¶ added in v3.0.900
type JSONDecoder struct{}
func (*JSONDecoder) DecodeConnectResponse ¶ added in v3.0.900
func (e *JSONDecoder) DecodeConnectResponse(data []byte) (*ConnectResponse, error)
func (*JSONDecoder) DecodeNotifyCacheEmptyResponse ¶ added in v3.0.900
func (e *JSONDecoder) DecodeNotifyCacheEmptyResponse(data []byte) (*NotifyCacheEmptyResponse, error)
func (*JSONDecoder) DecodePublishResponse ¶ added in v3.0.900
func (e *JSONDecoder) DecodePublishResponse(data []byte) (*PublishResponse, error)
func (*JSONDecoder) DecodeRPCResponse ¶ added in v3.0.900
func (e *JSONDecoder) DecodeRPCResponse(data []byte) (*RPCResponse, error)
func (*JSONDecoder) DecodeRefreshResponse ¶ added in v3.0.900
func (e *JSONDecoder) DecodeRefreshResponse(data []byte) (*RefreshResponse, error)
func (*JSONDecoder) DecodeSubRefreshResponse ¶ added in v3.0.900
func (e *JSONDecoder) DecodeSubRefreshResponse(data []byte) (*SubRefreshResponse, error)
func (*JSONDecoder) DecodeSubscribeResponse ¶ added in v3.0.900
func (e *JSONDecoder) DecodeSubscribeResponse(data []byte) (*SubscribeResponse, error)
type JSONEncoder ¶ added in v3.0.900
type JSONEncoder struct{}
func (*JSONEncoder) EncodeConnectRequest ¶ added in v3.0.900
func (e *JSONEncoder) EncodeConnectRequest(req *ConnectRequest) ([]byte, error)
func (*JSONEncoder) EncodeNotifyCacheEmptyRequest ¶ added in v3.0.900
func (e *JSONEncoder) EncodeNotifyCacheEmptyRequest(req *NotifyCacheEmptyRequest) ([]byte, error)
func (*JSONEncoder) EncodePublishRequest ¶ added in v3.0.900
func (e *JSONEncoder) EncodePublishRequest(req *PublishRequest) ([]byte, error)
func (*JSONEncoder) EncodeRPCRequest ¶ added in v3.0.900
func (e *JSONEncoder) EncodeRPCRequest(req *RPCRequest) ([]byte, error)
func (*JSONEncoder) EncodeRefreshRequest ¶ added in v3.0.900
func (e *JSONEncoder) EncodeRefreshRequest(req *RefreshRequest) ([]byte, error)
func (*JSONEncoder) EncodeSubRefreshRequest ¶ added in v3.0.900
func (e *JSONEncoder) EncodeSubRefreshRequest(req *SubRefreshRequest) ([]byte, error)
func (*JSONEncoder) EncodeSubscribeRequest ¶ added in v3.0.900
func (e *JSONEncoder) EncodeSubscribeRequest(req *SubscribeRequest) ([]byte, error)
type NotifyCacheEmptyRequest ¶ added in v3.0.900
type NotifyCacheEmptyRequest struct { Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"` // contains filtered or unexported fields }
func (*NotifyCacheEmptyRequest) Descriptor
deprecated
added in
v3.0.900
func (*NotifyCacheEmptyRequest) Descriptor() ([]byte, []int)
Deprecated: Use NotifyCacheEmptyRequest.ProtoReflect.Descriptor instead.
func (*NotifyCacheEmptyRequest) GetChannel ¶ added in v3.0.900
func (x *NotifyCacheEmptyRequest) GetChannel() string
func (*NotifyCacheEmptyRequest) ProtoMessage ¶ added in v3.0.900
func (*NotifyCacheEmptyRequest) ProtoMessage()
func (*NotifyCacheEmptyRequest) ProtoReflect ¶ added in v3.0.900
func (x *NotifyCacheEmptyRequest) ProtoReflect() protoreflect.Message
func (*NotifyCacheEmptyRequest) Reset ¶ added in v3.0.900
func (x *NotifyCacheEmptyRequest) Reset()
func (*NotifyCacheEmptyRequest) String ¶ added in v3.0.900
func (x *NotifyCacheEmptyRequest) String() string
type NotifyCacheEmptyResponse ¶ added in v3.0.900
type NotifyCacheEmptyResponse struct { Result *NotifyCacheEmptyResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*NotifyCacheEmptyResponse) Descriptor
deprecated
added in
v3.0.900
func (*NotifyCacheEmptyResponse) Descriptor() ([]byte, []int)
Deprecated: Use NotifyCacheEmptyResponse.ProtoReflect.Descriptor instead.
func (*NotifyCacheEmptyResponse) GetResult ¶ added in v3.0.900
func (x *NotifyCacheEmptyResponse) GetResult() *NotifyCacheEmptyResult
func (*NotifyCacheEmptyResponse) ProtoMessage ¶ added in v3.0.900
func (*NotifyCacheEmptyResponse) ProtoMessage()
func (*NotifyCacheEmptyResponse) ProtoReflect ¶ added in v3.0.900
func (x *NotifyCacheEmptyResponse) ProtoReflect() protoreflect.Message
func (*NotifyCacheEmptyResponse) Reset ¶ added in v3.0.900
func (x *NotifyCacheEmptyResponse) Reset()
func (*NotifyCacheEmptyResponse) String ¶ added in v3.0.900
func (x *NotifyCacheEmptyResponse) String() string
type NotifyCacheEmptyResult ¶ added in v3.0.900
type NotifyCacheEmptyResult struct { Populated bool `protobuf:"varint,1,opt,name=populated,proto3" json:"populated,omitempty"` // contains filtered or unexported fields }
func (*NotifyCacheEmptyResult) Descriptor
deprecated
added in
v3.0.900
func (*NotifyCacheEmptyResult) Descriptor() ([]byte, []int)
Deprecated: Use NotifyCacheEmptyResult.ProtoReflect.Descriptor instead.
func (*NotifyCacheEmptyResult) GetPopulated ¶ added in v3.0.900
func (x *NotifyCacheEmptyResult) GetPopulated() bool
func (*NotifyCacheEmptyResult) ProtoMessage ¶ added in v3.0.900
func (*NotifyCacheEmptyResult) ProtoMessage()
func (*NotifyCacheEmptyResult) ProtoReflect ¶ added in v3.0.900
func (x *NotifyCacheEmptyResult) ProtoReflect() protoreflect.Message
func (*NotifyCacheEmptyResult) Reset ¶ added in v3.0.900
func (x *NotifyCacheEmptyResult) Reset()
func (*NotifyCacheEmptyResult) String ¶ added in v3.0.900
func (x *NotifyCacheEmptyResult) String() string
type NotifyChannelStateRequest ¶
type NotifyChannelStateRequest struct { Events []*ChannelEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"` // contains filtered or unexported fields }
func (*NotifyChannelStateRequest) Descriptor
deprecated
func (*NotifyChannelStateRequest) Descriptor() ([]byte, []int)
Deprecated: Use NotifyChannelStateRequest.ProtoReflect.Descriptor instead.
func (*NotifyChannelStateRequest) GetEvents ¶
func (x *NotifyChannelStateRequest) GetEvents() []*ChannelEvent
func (*NotifyChannelStateRequest) ProtoMessage ¶
func (*NotifyChannelStateRequest) ProtoMessage()
func (*NotifyChannelStateRequest) ProtoReflect ¶
func (x *NotifyChannelStateRequest) ProtoReflect() protoreflect.Message
func (*NotifyChannelStateRequest) Reset ¶
func (x *NotifyChannelStateRequest) Reset()
func (*NotifyChannelStateRequest) String ¶
func (x *NotifyChannelStateRequest) String() string
type NotifyChannelStateResponse ¶
type NotifyChannelStateResponse struct { Result *NotifyChannelStateResult `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"` Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*NotifyChannelStateResponse) Descriptor
deprecated
func (*NotifyChannelStateResponse) Descriptor() ([]byte, []int)
Deprecated: Use NotifyChannelStateResponse.ProtoReflect.Descriptor instead.
func (*NotifyChannelStateResponse) GetError ¶
func (x *NotifyChannelStateResponse) GetError() *Error
func (*NotifyChannelStateResponse) GetResult ¶
func (x *NotifyChannelStateResponse) GetResult() *NotifyChannelStateResult
func (*NotifyChannelStateResponse) ProtoMessage ¶
func (*NotifyChannelStateResponse) ProtoMessage()
func (*NotifyChannelStateResponse) ProtoReflect ¶
func (x *NotifyChannelStateResponse) ProtoReflect() protoreflect.Message
func (*NotifyChannelStateResponse) Reset ¶
func (x *NotifyChannelStateResponse) Reset()
func (*NotifyChannelStateResponse) String ¶
func (x *NotifyChannelStateResponse) String() string
type NotifyChannelStateResult ¶
type NotifyChannelStateResult struct {
// contains filtered or unexported fields
}
func (*NotifyChannelStateResult) Descriptor
deprecated
func (*NotifyChannelStateResult) Descriptor() ([]byte, []int)
Deprecated: Use NotifyChannelStateResult.ProtoReflect.Descriptor instead.
func (*NotifyChannelStateResult) ProtoMessage ¶
func (*NotifyChannelStateResult) ProtoMessage()
func (*NotifyChannelStateResult) ProtoReflect ¶
func (x *NotifyChannelStateResult) ProtoReflect() protoreflect.Message
func (*NotifyChannelStateResult) Reset ¶
func (x *NotifyChannelStateResult) Reset()
func (*NotifyChannelStateResult) String ¶
func (x *NotifyChannelStateResult) String() string
type Publication ¶
type Publication struct { Data Raw `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"` Tags map[string]string `` /* 149-byte string literal not displayed */ // contains filtered or unexported fields }
Publication is an event to be sent to a client. We intentionally make it use the same Protobuf numbers for fields as our client protocol Publication - for now only for consistency.
func (*Publication) Descriptor
deprecated
func (*Publication) Descriptor() ([]byte, []int)
Deprecated: Use Publication.ProtoReflect.Descriptor instead.
func (*Publication) GetData ¶
func (x *Publication) GetData() []byte
func (*Publication) GetTags ¶
func (x *Publication) GetTags() map[string]string
func (*Publication) ProtoMessage ¶
func (*Publication) ProtoMessage()
func (*Publication) ProtoReflect ¶
func (x *Publication) ProtoReflect() protoreflect.Message
func (*Publication) Reset ¶
func (x *Publication) Reset()
func (*Publication) String ¶
func (x *Publication) 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"` Channel string `protobuf:"bytes,11,opt,name=channel,proto3" json:"channel,omitempty"` Data Raw `protobuf:"bytes,12,opt,name=data,proto3" json:"data,omitempty"` B64Data string `protobuf:"bytes,13,opt,name=b64data,proto3" json:"b64data,omitempty"` Meta Raw `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 Raw `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"` Method string `protobuf:"bytes,11,opt,name=method,proto3" json:"method,omitempty"` Data Raw `protobuf:"bytes,12,opt,name=data,proto3" json:"data,omitempty"` B64Data string `protobuf:"bytes,13,opt,name=b64data,proto3" json:"b64data,omitempty"` Meta Raw `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 Raw `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) Descriptor
deprecated
func (*RPCResult) GetB64Data ¶
func (*RPCResult) ProtoMessage ¶
func (*RPCResult) ProtoMessage()
func (*RPCResult) ProtoReflect ¶
func (x *RPCResult) ProtoReflect() protoreflect.Message
type Raw ¶
type Raw []byte
Raw type used by Centrifugo as type for fields in structs which value we want to left untouched.
func (Raw) MarshalJSON ¶
MarshalJSON returns *r as the JSON encoding of r.
func (*Raw) UnmarshalJSON ¶
UnmarshalJSON sets *r to a copy of data.
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"` Meta Raw `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 Raw `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"` B64Info string `protobuf:"bytes,4,opt,name=b64info,proto3" json:"b64info,omitempty"` Meta Raw `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 RequestEncoder ¶ added in v3.0.900
type RequestEncoder interface { EncodeConnectRequest(req *ConnectRequest) ([]byte, error) EncodeRefreshRequest(req *RefreshRequest) ([]byte, error) EncodeRPCRequest(req *RPCRequest) ([]byte, error) EncodeSubscribeRequest(req *SubscribeRequest) ([]byte, error) EncodePublishRequest(req *PublishRequest) ([]byte, error) EncodeSubRefreshRequest(req *SubRefreshRequest) ([]byte, error) EncodeNotifyCacheEmptyRequest(req *NotifyCacheEmptyRequest) ([]byte, error) }
type ResponseDecoder ¶ added in v3.0.900
type ResponseDecoder interface { DecodeConnectResponse(data []byte) (*ConnectResponse, error) DecodeRefreshResponse(data []byte) (*RefreshResponse, error) DecodeRPCResponse(data []byte) (*RPCResponse, error) DecodeSubscribeResponse(data []byte) (*SubscribeResponse, error) DecodePublishResponse(data []byte) (*PublishResponse, error) DecodeSubRefreshResponse(data []byte) (*SubRefreshResponse, error) DecodeNotifyCacheEmptyResponse(data []byte) (*NotifyCacheEmptyResponse, error) }
type StreamSubscribeRequest ¶
type StreamSubscribeRequest struct { // Centrifugo always sends this within the first message upon user subscription request. // It's always not set in the following StreamRequest messages from Centrifugo. SubscribeRequest *SubscribeRequest `protobuf:"bytes,1,opt,name=subscribe_request,json=subscribeRequest,proto3" json:"subscribe_request,omitempty"` // Publication may be set when client publishes to the on-demand stream. If you are using // bidirectional stream then Centrifugo assumes publications from client-side are allowed. Publication *Publication `protobuf:"bytes,2,opt,name=publication,proto3" json:"publication,omitempty"` // contains filtered or unexported fields }
func (*StreamSubscribeRequest) Descriptor
deprecated
func (*StreamSubscribeRequest) Descriptor() ([]byte, []int)
Deprecated: Use StreamSubscribeRequest.ProtoReflect.Descriptor instead.
func (*StreamSubscribeRequest) GetPublication ¶
func (x *StreamSubscribeRequest) GetPublication() *Publication
func (*StreamSubscribeRequest) GetSubscribeRequest ¶
func (x *StreamSubscribeRequest) GetSubscribeRequest() *SubscribeRequest
func (*StreamSubscribeRequest) ProtoMessage ¶
func (*StreamSubscribeRequest) ProtoMessage()
func (*StreamSubscribeRequest) ProtoReflect ¶
func (x *StreamSubscribeRequest) ProtoReflect() protoreflect.Message
func (*StreamSubscribeRequest) Reset ¶
func (x *StreamSubscribeRequest) Reset()
func (*StreamSubscribeRequest) String ¶
func (x *StreamSubscribeRequest) String() string
type StreamSubscribeResponse ¶
type StreamSubscribeResponse struct { // SubscribeResponse may optionally be set in the first message from backend to Centrifugo. SubscribeResponse *SubscribeResponse `protobuf:"bytes,1,opt,name=subscribe_response,json=subscribeResponse,proto3" json:"subscribe_response,omitempty"` // Publication goes to client. Can't be set in the first message from backend to Centrifugo. Publication *Publication `protobuf:"bytes,2,opt,name=publication,proto3" json:"publication,omitempty"` // contains filtered or unexported fields }
func (*StreamSubscribeResponse) Descriptor
deprecated
func (*StreamSubscribeResponse) Descriptor() ([]byte, []int)
Deprecated: Use StreamSubscribeResponse.ProtoReflect.Descriptor instead.
func (*StreamSubscribeResponse) GetPublication ¶
func (x *StreamSubscribeResponse) GetPublication() *Publication
func (*StreamSubscribeResponse) GetSubscribeResponse ¶
func (x *StreamSubscribeResponse) GetSubscribeResponse() *SubscribeResponse
func (*StreamSubscribeResponse) ProtoMessage ¶
func (*StreamSubscribeResponse) ProtoMessage()
func (*StreamSubscribeResponse) ProtoReflect ¶
func (x *StreamSubscribeResponse) ProtoReflect() protoreflect.Message
func (*StreamSubscribeResponse) Reset ¶
func (x *StreamSubscribeResponse) Reset()
func (*StreamSubscribeResponse) String ¶
func (x *StreamSubscribeResponse) String() string
type SubRefreshRequest ¶
type SubRefreshRequest 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"` Channel string `protobuf:"bytes,11,opt,name=channel,proto3" json:"channel,omitempty"` Meta Raw `protobuf:"bytes,12,opt,name=meta,proto3" json:"meta,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) GetClient ¶
func (x *SubRefreshRequest) GetClient() string
func (*SubRefreshRequest) GetEncoding ¶
func (x *SubRefreshRequest) GetEncoding() string
func (*SubRefreshRequest) GetMeta ¶
func (x *SubRefreshRequest) GetMeta() []byte
func (*SubRefreshRequest) GetProtocol ¶
func (x *SubRefreshRequest) GetProtocol() string
func (*SubRefreshRequest) GetTransport ¶
func (x *SubRefreshRequest) GetTransport() string
func (*SubRefreshRequest) GetUser ¶
func (x *SubRefreshRequest) GetUser() string
func (*SubRefreshRequest) ProtoMessage ¶
func (*SubRefreshRequest) ProtoMessage()
func (*SubRefreshRequest) ProtoReflect ¶
func (x *SubRefreshRequest) ProtoReflect() protoreflect.Message
func (*SubRefreshRequest) Reset ¶
func (x *SubRefreshRequest) Reset()
func (*SubRefreshRequest) String ¶
func (x *SubRefreshRequest) String() string
type SubRefreshResponse ¶
type SubRefreshResponse struct { Result *SubRefreshResult `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 (*SubRefreshResponse) Descriptor
deprecated
func (*SubRefreshResponse) Descriptor() ([]byte, []int)
Deprecated: Use SubRefreshResponse.ProtoReflect.Descriptor instead.
func (*SubRefreshResponse) GetDisconnect ¶
func (x *SubRefreshResponse) GetDisconnect() *Disconnect
func (*SubRefreshResponse) GetError ¶
func (x *SubRefreshResponse) GetError() *Error
func (*SubRefreshResponse) GetResult ¶
func (x *SubRefreshResponse) GetResult() *SubRefreshResult
func (*SubRefreshResponse) ProtoMessage ¶
func (*SubRefreshResponse) ProtoMessage()
func (*SubRefreshResponse) ProtoReflect ¶
func (x *SubRefreshResponse) ProtoReflect() protoreflect.Message
func (*SubRefreshResponse) Reset ¶
func (x *SubRefreshResponse) Reset()
func (*SubRefreshResponse) String ¶
func (x *SubRefreshResponse) String() string
type SubRefreshResult ¶
type SubRefreshResult 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 Raw `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"` B64Info string `protobuf:"bytes,4,opt,name=b64info,proto3" json:"b64info,omitempty"` // contains filtered or unexported fields }
func (*SubRefreshResult) Descriptor
deprecated
func (*SubRefreshResult) Descriptor() ([]byte, []int)
Deprecated: Use SubRefreshResult.ProtoReflect.Descriptor instead.
func (*SubRefreshResult) GetB64Info ¶
func (x *SubRefreshResult) GetB64Info() string
func (*SubRefreshResult) GetExpireAt ¶
func (x *SubRefreshResult) GetExpireAt() int64
func (*SubRefreshResult) GetExpired ¶
func (x *SubRefreshResult) GetExpired() bool
func (*SubRefreshResult) GetInfo ¶
func (x *SubRefreshResult) GetInfo() []byte
func (*SubRefreshResult) ProtoMessage ¶
func (*SubRefreshResult) ProtoMessage()
func (*SubRefreshResult) ProtoReflect ¶
func (x *SubRefreshResult) ProtoReflect() protoreflect.Message
func (*SubRefreshResult) Reset ¶
func (x *SubRefreshResult) Reset()
func (*SubRefreshResult) String ¶
func (x *SubRefreshResult) 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 Raw `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"` B64Info string `protobuf:"bytes,3,opt,name=b64info,proto3" json:"b64info,omitempty"` Data Raw `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"` 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 Raw `protobuf:"bytes,13,opt,name=meta,proto3" json:"meta,omitempty"` Data Raw `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 Raw `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"` B64Info string `protobuf:"bytes,3,opt,name=b64info,proto3" json:"b64info,omitempty"` Data Raw `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
type UnimplementedCentrifugoProxyServer ¶
type UnimplementedCentrifugoProxyServer struct { }
UnimplementedCentrifugoProxyServer must be embedded to have forward compatible implementations.
func (UnimplementedCentrifugoProxyServer) Connect ¶
func (UnimplementedCentrifugoProxyServer) Connect(context.Context, *ConnectRequest) (*ConnectResponse, error)
func (UnimplementedCentrifugoProxyServer) NotifyCacheEmpty ¶ added in v3.0.900
func (UnimplementedCentrifugoProxyServer) NotifyCacheEmpty(context.Context, *NotifyCacheEmptyRequest) (*NotifyCacheEmptyResponse, error)
func (UnimplementedCentrifugoProxyServer) NotifyChannelState ¶
func (UnimplementedCentrifugoProxyServer) NotifyChannelState(context.Context, *NotifyChannelStateRequest) (*NotifyChannelStateResponse, error)
func (UnimplementedCentrifugoProxyServer) Publish ¶
func (UnimplementedCentrifugoProxyServer) Publish(context.Context, *PublishRequest) (*PublishResponse, error)
func (UnimplementedCentrifugoProxyServer) RPC ¶
func (UnimplementedCentrifugoProxyServer) RPC(context.Context, *RPCRequest) (*RPCResponse, error)
func (UnimplementedCentrifugoProxyServer) Refresh ¶
func (UnimplementedCentrifugoProxyServer) Refresh(context.Context, *RefreshRequest) (*RefreshResponse, error)
func (UnimplementedCentrifugoProxyServer) SubRefresh ¶
func (UnimplementedCentrifugoProxyServer) SubRefresh(context.Context, *SubRefreshRequest) (*SubRefreshResponse, error)
func (UnimplementedCentrifugoProxyServer) Subscribe ¶
func (UnimplementedCentrifugoProxyServer) Subscribe(context.Context, *SubscribeRequest) (*SubscribeResponse, error)
func (UnimplementedCentrifugoProxyServer) SubscribeBidirectional ¶
func (UnimplementedCentrifugoProxyServer) SubscribeBidirectional(CentrifugoProxy_SubscribeBidirectionalServer) error
func (UnimplementedCentrifugoProxyServer) SubscribeUnidirectional ¶
func (UnimplementedCentrifugoProxyServer) SubscribeUnidirectional(*SubscribeRequest, CentrifugoProxy_SubscribeUnidirectionalServer) error
type UnsafeCentrifugoProxyServer ¶
type UnsafeCentrifugoProxyServer interface {
// contains filtered or unexported methods
}
UnsafeCentrifugoProxyServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CentrifugoProxyServer will result in compilation errors.