proxyproto

package
v5.4.8 Latest Latest
Warning

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

 Go to latest Published: Dec 8, 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 

func DisconnectFromProto(s *Disconnect) *centrifuge.Disconnect

func ErrorFromProto 

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 added in v5.1.0 

type CentrifugoProxy_SubscribeBidirectionalClient interface {
	Send(*StreamSubscribeRequest) error
	Recv() (*StreamSubscribeResponse, error)
	grpc.ClientStream
}

type CentrifugoProxy_SubscribeBidirectionalServer added in v5.1.0 

type CentrifugoProxy_SubscribeBidirectionalServer interface {
	Send(*StreamSubscribeResponse) error
	Recv() (*StreamSubscribeRequest, error)
	grpc.ServerStream
}

type CentrifugoProxy_SubscribeUnidirectionalClient added in v5.1.0 

type CentrifugoProxy_SubscribeUnidirectionalClient interface {
	Recv() (*StreamSubscribeResponse, error)
	grpc.ClientStream
}

type CentrifugoProxy_SubscribeUnidirectionalServer added in v5.1.0 

type CentrifugoProxy_SubscribeUnidirectionalServer interface {
	Send(*StreamSubscribeResponse) error
	grpc.ServerStream
}

type ChannelEvent added in v5.1.1 

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 added in v5.1.1 

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

Deprecated: Use ChannelEvent.ProtoReflect.Descriptor instead.

func (*ChannelEvent) GetChannel added in v5.1.1 

func (x *ChannelEvent) GetChannel() string

func (*ChannelEvent) GetTimeMs added in v5.1.1 

func (x *ChannelEvent) GetTimeMs() int64

func (*ChannelEvent) GetType added in v5.1.1 

func (x *ChannelEvent) GetType() string

func (*ChannelEvent) ProtoMessage added in v5.1.1 

func (*ChannelEvent) ProtoMessage()

func (*ChannelEvent) ProtoReflect added in v5.1.1 

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

func (*ChannelEvent) Reset added in v5.1.1 

func (x *ChannelEvent) Reset()

func (*ChannelEvent) String added in v5.1.1 

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 

type Codec struct{}

Codec is std GRPC codec.

func (Codec) Marshal 

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

func (Codec) Name 

func (Codec) Name() string

func (Codec) Unmarshal 

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 

type JSONDecoder struct{}

func (*JSONDecoder) DecodeConnectResponse 

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

func (*JSONDecoder) DecodeNotifyCacheEmptyResponse added in v5.4.0 

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

func (*JSONDecoder) DecodePublishResponse 

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

func (*JSONDecoder) DecodeRPCResponse 

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

func (*JSONDecoder) DecodeRefreshResponse 

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

func (*JSONDecoder) DecodeSubRefreshResponse 

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

func (*JSONDecoder) DecodeSubscribeResponse 

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

type JSONEncoder 

type JSONEncoder struct{}

func (*JSONEncoder) EncodeConnectRequest 

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

func (*JSONEncoder) EncodeNotifyCacheEmptyRequest added in v5.4.0 

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

func (*JSONEncoder) EncodePublishRequest 

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

func (*JSONEncoder) EncodeRPCRequest 

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

func (*JSONEncoder) EncodeRefreshRequest 

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

func (*JSONEncoder) EncodeSubRefreshRequest 

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

func (*JSONEncoder) EncodeSubscribeRequest 

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

type NotifyCacheEmptyRequest added in v5.4.0 

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 v5.4.0 

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

Deprecated: Use NotifyCacheEmptyRequest.ProtoReflect.Descriptor instead.

func (*NotifyCacheEmptyRequest) GetChannel added in v5.4.0 

func (x *NotifyCacheEmptyRequest) GetChannel() string

func (*NotifyCacheEmptyRequest) ProtoMessage added in v5.4.0 

func (*NotifyCacheEmptyRequest) ProtoMessage()

func (*NotifyCacheEmptyRequest) ProtoReflect added in v5.4.0 

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

func (*NotifyCacheEmptyRequest) Reset added in v5.4.0 

func (x *NotifyCacheEmptyRequest) Reset()

func (*NotifyCacheEmptyRequest) String added in v5.4.0 

func (x *NotifyCacheEmptyRequest) String() string

type NotifyCacheEmptyResponse added in v5.4.0 

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 v5.4.0 

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

Deprecated: Use NotifyCacheEmptyResponse.ProtoReflect.Descriptor instead.

func (*NotifyCacheEmptyResponse) GetResult added in v5.4.0 

func (x *NotifyCacheEmptyResponse) GetResult() *NotifyCacheEmptyResult

func (*NotifyCacheEmptyResponse) ProtoMessage added in v5.4.0 

func (*NotifyCacheEmptyResponse) ProtoMessage()

func (*NotifyCacheEmptyResponse) ProtoReflect added in v5.4.0 

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

func (*NotifyCacheEmptyResponse) Reset added in v5.4.0 

func (x *NotifyCacheEmptyResponse) Reset()

func (*NotifyCacheEmptyResponse) String added in v5.4.0 

func (x *NotifyCacheEmptyResponse) String() string

type NotifyCacheEmptyResult added in v5.4.0 

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 v5.4.0 

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

Deprecated: Use NotifyCacheEmptyResult.ProtoReflect.Descriptor instead.

func (*NotifyCacheEmptyResult) GetPopulated added in v5.4.0 

func (x *NotifyCacheEmptyResult) GetPopulated() bool

func (*NotifyCacheEmptyResult) ProtoMessage added in v5.4.0 

func (*NotifyCacheEmptyResult) ProtoMessage()

func (*NotifyCacheEmptyResult) ProtoReflect added in v5.4.0 

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

func (*NotifyCacheEmptyResult) Reset added in v5.4.0 

func (x *NotifyCacheEmptyResult) Reset()

func (*NotifyCacheEmptyResult) String added in v5.4.0 

func (x *NotifyCacheEmptyResult) String() string

type NotifyChannelStateRequest added in v5.1.1 

type NotifyChannelStateRequest struct {
	Events []*ChannelEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*NotifyChannelStateRequest) Descriptor deprecated added in v5.1.1 

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

Deprecated: Use NotifyChannelStateRequest.ProtoReflect.Descriptor instead.

func (*NotifyChannelStateRequest) GetEvents added in v5.1.1 

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

func (*NotifyChannelStateRequest) ProtoMessage added in v5.1.1 

func (*NotifyChannelStateRequest) ProtoMessage()

func (*NotifyChannelStateRequest) ProtoReflect added in v5.1.1 

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

func (*NotifyChannelStateRequest) Reset added in v5.1.1 

func (x *NotifyChannelStateRequest) Reset()

func (*NotifyChannelStateRequest) String added in v5.1.1 

func (x *NotifyChannelStateRequest) String() string

type NotifyChannelStateResponse added in v5.1.1 

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 added in v5.1.1 

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

Deprecated: Use NotifyChannelStateResponse.ProtoReflect.Descriptor instead.

func (*NotifyChannelStateResponse) GetError added in v5.1.1 

func (x *NotifyChannelStateResponse) GetError() *Error

func (*NotifyChannelStateResponse) GetResult added in v5.1.1 

func (x *NotifyChannelStateResponse) GetResult() *NotifyChannelStateResult

func (*NotifyChannelStateResponse) ProtoMessage added in v5.1.1 

func (*NotifyChannelStateResponse) ProtoMessage()

func (*NotifyChannelStateResponse) ProtoReflect added in v5.1.1 

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

func (*NotifyChannelStateResponse) Reset added in v5.1.1 

func (x *NotifyChannelStateResponse) Reset()

func (*NotifyChannelStateResponse) String added in v5.1.1 

func (x *NotifyChannelStateResponse) String() string

type NotifyChannelStateResult added in v5.1.1 

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

func (*NotifyChannelStateResult) Descriptor deprecated added in v5.1.1 

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

Deprecated: Use NotifyChannelStateResult.ProtoReflect.Descriptor instead.

func (*NotifyChannelStateResult) ProtoMessage added in v5.1.1 

func (*NotifyChannelStateResult) ProtoMessage()

func (*NotifyChannelStateResult) ProtoReflect added in v5.1.1 

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

func (*NotifyChannelStateResult) Reset added in v5.1.1 

func (x *NotifyChannelStateResult) Reset()

func (*NotifyChannelStateResult) String added in v5.1.1 

func (x *NotifyChannelStateResult) String() string

type Publication added in v5.1.0 

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 added in v5.1.0 

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

Deprecated: Use Publication.ProtoReflect.Descriptor instead.

func (*Publication) GetData added in v5.1.0 

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

func (*Publication) GetTags added in v5.1.0 

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

func (*Publication) ProtoMessage added in v5.1.0 

func (*Publication) ProtoMessage()

func (*Publication) ProtoReflect added in v5.1.0 

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

func (*Publication) Reset added in v5.1.0 

func (x *Publication) Reset()

func (*Publication) String added in v5.1.0 

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 

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 

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 added in v5.1.0 

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 added in v5.1.0 

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

Deprecated: Use StreamSubscribeRequest.ProtoReflect.Descriptor instead.

func (*StreamSubscribeRequest) GetPublication added in v5.1.0 

func (x *StreamSubscribeRequest) GetPublication() *Publication

func (*StreamSubscribeRequest) GetSubscribeRequest added in v5.1.0 

func (x *StreamSubscribeRequest) GetSubscribeRequest() *SubscribeRequest

func (*StreamSubscribeRequest) ProtoMessage added in v5.1.0 

func (*StreamSubscribeRequest) ProtoMessage()

func (*StreamSubscribeRequest) ProtoReflect added in v5.1.0 

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

func (*StreamSubscribeRequest) Reset added in v5.1.0 

func (x *StreamSubscribeRequest) Reset()

func (*StreamSubscribeRequest) String added in v5.1.0 

func (x *StreamSubscribeRequest) String() string

type StreamSubscribeResponse added in v5.1.0 

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 added in v5.1.0 

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

Deprecated: Use StreamSubscribeResponse.ProtoReflect.Descriptor instead.

func (*StreamSubscribeResponse) GetPublication added in v5.1.0 

func (x *StreamSubscribeResponse) GetPublication() *Publication

func (*StreamSubscribeResponse) GetSubscribeResponse added in v5.1.0 

func (x *StreamSubscribeResponse) GetSubscribeResponse() *SubscribeResponse

func (*StreamSubscribeResponse) ProtoMessage added in v5.1.0 

func (*StreamSubscribeResponse) ProtoMessage()

func (*StreamSubscribeResponse) ProtoReflect added in v5.1.0 

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

func (*StreamSubscribeResponse) Reset added in v5.1.0 

func (x *StreamSubscribeResponse) Reset()

func (*StreamSubscribeResponse) String added in v5.1.0 

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 v5.4.0 

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

func (UnimplementedCentrifugoProxyServer) NotifyChannelState added in v5.1.1 

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 added in v5.1.0 

func (UnimplementedCentrifugoProxyServer) SubscribeBidirectional(CentrifugoProxy_SubscribeBidirectionalServer) error

func (UnimplementedCentrifugoProxyServer) SubscribeUnidirectional added in v5.1.0 

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.