proxyproto

package
v3.0.917 Latest Latest
Warning

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

 Go to latest Published: Jul 23, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

README

Proxy transform rules:

Client protocol type Proxy type Headers Meta
HTTP HTTP In request headers No meta
GRPC GRPC No headers In request meta
HTTP GRPC In request meta No meta
GRPC HTTP No headers In request headers

Documentation

Index

Constants

View Source 
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

View Source 
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)

View Source 
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) Descriptor() ([]byte, []int)

Deprecated: Use BoolValue.ProtoReflect.Descriptor instead.

func (*BoolValue) GetValue 

func (x *BoolValue) GetValue() bool

func (*BoolValue) ProtoMessage 

func (*BoolValue) ProtoMessage()

func (*BoolValue) ProtoReflect 

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

func (*BoolValue) Reset 

func (x *BoolValue) Reset()

func (*BoolValue) String 

func (x *BoolValue) String() string

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 Codec added in v3.0.900 

type Codec struct{}

Codec is std GRPC codec.

func (Codec) Marshal added in v3.0.900 

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

func (Codec) Name added in v3.0.900 

func (Codec) Name() string

func (Codec) Unmarshal added in v3.0.900 

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

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) Descriptor() ([]byte, []int)

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetCode 

func (x *Error) GetCode() uint32

func (*Error) GetMessage 

func (x *Error) GetMessage() string

func (*Error) GetTemporary 

func (x *Error) GetTemporary() bool

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect 

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

func (*Error) Reset 

func (x *Error) Reset()

func (*Error) String 

func (x *Error) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use RPCResult.ProtoReflect.Descriptor instead.

func (*RPCResult) GetB64Data 

func (x *RPCResult) GetB64Data() string

func (*RPCResult) GetData 

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

func (*RPCResult) ProtoMessage 

func (*RPCResult) ProtoMessage()

func (*RPCResult) ProtoReflect 

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

func (*RPCResult) Reset 

func (x *RPCResult) Reset()

func (*RPCResult) String 

func (x *RPCResult) String() string

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 

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

MarshalJSON returns *r as the JSON encoding of r.

func (*Raw) UnmarshalJSON 

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

UnmarshalJSON sets *r to a copy of data.

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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