proxyproto

package
v4.0.3 Latest Latest
Warning

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

 Go to latest Published: Oct 24, 2022 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

This section is empty.

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,
		},
	},
	Streams:  []grpc.StreamDesc{},
	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(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (*ConnectResponse, error)
	Refresh(ctx context.Context, in *RefreshRequest, opts ...grpc.CallOption) (*RefreshResponse, error)
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (*SubscribeResponse, error)
	Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error)
	RPC(ctx context.Context, in *RPCRequest, opts ...grpc.CallOption) (*RPCResponse, 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(context.Context, *ConnectRequest) (*ConnectResponse, error)
	Refresh(context.Context, *RefreshRequest) (*RefreshResponse, error)
	Subscribe(context.Context, *SubscribeRequest) (*SubscribeResponse, error)
	Publish(context.Context, *PublishRequest) (*PublishResponse, error)
	RPC(context.Context, *RPCRequest) (*RPCResponse, error)
	// contains filtered or unexported methods
}

CentrifugoProxyServer is the server API for CentrifugoProxy service. All implementations must embed UnimplementedCentrifugoProxyServer for forward compatibility

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 interface{}) ([]byte, error)

func (Codec) Name 

func (Codec) Name() string

func (Codec) Unmarshal 

func (Codec) Unmarshal(data []byte, v interface{}) 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"`
	Reconnect bool   `protobuf:"varint,3,opt,name=reconnect,proto3" json:"reconnect,omitempty"`
	// contains filtered or unexported fields
}

func (*Disconnect) Descriptor deprecated 

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

Deprecated: Use Disconnect.ProtoReflect.Descriptor instead.

func (*Disconnect) GetCode 

func (x *Disconnect) GetCode() uint32

func (*Disconnect) GetReason 

func (x *Disconnect) GetReason() string

func (*Disconnect) GetReconnect 

func (x *Disconnect) GetReconnect() bool

func (*Disconnect) ProtoMessage 

func (*Disconnect) ProtoMessage()

func (*Disconnect) ProtoReflect 

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

func (*Disconnect) Reset 

func (x *Disconnect) Reset()

func (*Disconnect) String 

func (x *Disconnect) String() string

type Error 

type Error struct {
	Code      uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Message   string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Temporary bool   `protobuf:"varint,3,opt,name=temporary,proto3" json:"temporary,omitempty"`
	// contains filtered or unexported fields
}

func (*Error) 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) 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) 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) 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) EncodeSubscribeRequest 

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

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)
}

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)
}

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) 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) Subscribe 

func (UnimplementedCentrifugoProxyServer) Subscribe(context.Context, *SubscribeRequest) (*SubscribeResponse, 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.