v1

package
v4.16.0 Latest Latest
Warning

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

 Go to latest Published: Jul 22, 2024 License: MIT Imports: 8 Imported by: 2

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_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: "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: "centrifugo/proxy/v1/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_centrifugo_proxy_v1_proxy_proto protoreflect.FileDescriptor

Functions

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

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

type CentrifugoProxy_SubscribeBidirectionalClient added in v4.11.0 

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

type CentrifugoProxy_SubscribeBidirectionalServer added in v4.11.0 

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

type CentrifugoProxy_SubscribeUnidirectionalClient added in v4.11.0 

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

type CentrifugoProxy_SubscribeUnidirectionalServer added in v4.11.0 

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

type ChannelEvent added in v4.11.0 

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 v4.11.0 

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

Deprecated: Use ChannelEvent.ProtoReflect.Descriptor instead.

func (*ChannelEvent) GetChannel added in v4.11.0 

func (x *ChannelEvent) GetChannel() string

func (*ChannelEvent) GetTimeMs added in v4.11.0 

func (x *ChannelEvent) GetTimeMs() int64

func (*ChannelEvent) GetType added in v4.11.0 

func (x *ChannelEvent) GetType() string

func (*ChannelEvent) ProtoMessage added in v4.11.0 

func (*ChannelEvent) ProtoMessage()

func (*ChannelEvent) ProtoReflect added in v4.11.0 

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

func (*ChannelEvent) Reset added in v4.11.0 

func (x *ChannelEvent) Reset()

func (*ChannelEvent) String added in v4.11.0 

func (x *ChannelEvent) String() string

type ChannelsCapability 

type ChannelsCapability struct {
	Channels []string `protobuf:"bytes,1,rep,name=channels,proto3" json:"channels,omitempty"`
	Allow    []string `protobuf:"bytes,2,rep,name=allow,proto3" json:"allow,omitempty"`
	Match    string   `protobuf:"bytes,3,opt,name=match,proto3" json:"match,omitempty"`
	// contains filtered or unexported fields
}

func (*ChannelsCapability) Descriptor deprecated 

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

Deprecated: Use ChannelsCapability.ProtoReflect.Descriptor instead.

func (*ChannelsCapability) GetAllow 

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

func (*ChannelsCapability) GetChannels 

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

func (*ChannelsCapability) GetMatch 

func (x *ChannelsCapability) GetMatch() string

func (*ChannelsCapability) ProtoMessage 

func (*ChannelsCapability) ProtoMessage()

func (*ChannelsCapability) ProtoReflect 

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

func (*ChannelsCapability) Reset 

func (x *ChannelsCapability) Reset()

func (*ChannelsCapability) String 

func (x *ChannelsCapability) String() string

type ConnectRequest 

type ConnectRequest struct {
	Client    string   `protobuf:"bytes,1,opt,name=client,proto3" json:"client,omitempty"`
	Transport string   `protobuf:"bytes,2,opt,name=transport,proto3" json:"transport,omitempty"`
	Protocol  string   `protobuf:"bytes,3,opt,name=protocol,proto3" json:"protocol,omitempty"`
	Encoding  string   `protobuf:"bytes,4,opt,name=encoding,proto3" json:"encoding,omitempty"`
	Data      []byte   `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     []byte                       `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
	B64Info  string                       `protobuf:"bytes,4,opt,name=b64info,proto3" json:"b64info,omitempty"`
	Data     []byte                       `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     []byte                       `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 NotifyChannelStateRequest added in v4.11.0 

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 v4.11.0 

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

Deprecated: Use NotifyChannelStateRequest.ProtoReflect.Descriptor instead.

func (*NotifyChannelStateRequest) GetEvents added in v4.11.0 

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

func (*NotifyChannelStateRequest) ProtoMessage added in v4.11.0 

func (*NotifyChannelStateRequest) ProtoMessage()

func (*NotifyChannelStateRequest) ProtoReflect added in v4.11.0 

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

func (*NotifyChannelStateRequest) Reset added in v4.11.0 

func (x *NotifyChannelStateRequest) Reset()

func (*NotifyChannelStateRequest) String added in v4.11.0 

func (x *NotifyChannelStateRequest) String() string

type NotifyChannelStateResponse added in v4.11.0 

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 v4.11.0 

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

Deprecated: Use NotifyChannelStateResponse.ProtoReflect.Descriptor instead.

func (*NotifyChannelStateResponse) GetError added in v4.11.0 

func (x *NotifyChannelStateResponse) GetError() *Error

func (*NotifyChannelStateResponse) GetResult added in v4.11.0 

func (x *NotifyChannelStateResponse) GetResult() *NotifyChannelStateResult

func (*NotifyChannelStateResponse) ProtoMessage added in v4.11.0 

func (*NotifyChannelStateResponse) ProtoMessage()

func (*NotifyChannelStateResponse) ProtoReflect added in v4.11.0 

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

func (*NotifyChannelStateResponse) Reset added in v4.11.0 

func (x *NotifyChannelStateResponse) Reset()

func (*NotifyChannelStateResponse) String added in v4.11.0 

func (x *NotifyChannelStateResponse) String() string

type NotifyChannelStateResult added in v4.11.0 

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

func (*NotifyChannelStateResult) Descriptor deprecated added in v4.11.0 

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

Deprecated: Use NotifyChannelStateResult.ProtoReflect.Descriptor instead.

func (*NotifyChannelStateResult) ProtoMessage added in v4.11.0 

func (*NotifyChannelStateResult) ProtoMessage()

func (*NotifyChannelStateResult) ProtoReflect added in v4.11.0 

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

func (*NotifyChannelStateResult) Reset added in v4.11.0 

func (x *NotifyChannelStateResult) Reset()

func (*NotifyChannelStateResult) String added in v4.11.0 

func (x *NotifyChannelStateResult) String() string

type Publication added in v4.11.0 

type Publication struct {
	Data []byte            `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 v4.11.0 

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

Deprecated: Use Publication.ProtoReflect.Descriptor instead.

func (*Publication) GetData added in v4.11.0 

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

func (*Publication) GetTags added in v4.11.0 

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

func (*Publication) ProtoMessage added in v4.11.0 

func (*Publication) ProtoMessage()

func (*Publication) ProtoReflect added in v4.11.0 

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

func (*Publication) Reset added in v4.11.0 

func (x *Publication) Reset()

func (*Publication) String added in v4.11.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,omitempty"`
	Channel   string `protobuf:"bytes,11,opt,name=channel,proto3" json:"channel,omitempty"`
	Data      []byte `protobuf:"bytes,12,opt,name=data,proto3" json:"data,omitempty"`
	B64Data   string `protobuf:"bytes,13,opt,name=b64data,proto3" json:"b64data,omitempty"`
	Meta      []byte `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        []byte `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,omitempty"`
	Method    string `protobuf:"bytes,11,opt,name=method,proto3" json:"method,omitempty"`
	Data      []byte `protobuf:"bytes,12,opt,name=data,proto3" json:"data,omitempty"`
	B64Data   string `protobuf:"bytes,13,opt,name=b64data,proto3" json:"b64data,omitempty"`
	Meta      []byte `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    []byte `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 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,omitempty"`
	Meta      []byte `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     []byte                `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
	B64Info  string                `protobuf:"bytes,4,opt,name=b64info,proto3" json:"b64info,omitempty"`
	Meta     []byte                `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 StreamSubscribeRequest added in v4.11.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 v4.11.0 

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

Deprecated: Use StreamSubscribeRequest.ProtoReflect.Descriptor instead.

func (*StreamSubscribeRequest) GetPublication added in v4.11.0 

func (x *StreamSubscribeRequest) GetPublication() *Publication

func (*StreamSubscribeRequest) GetSubscribeRequest added in v4.11.0 

func (x *StreamSubscribeRequest) GetSubscribeRequest() *SubscribeRequest

func (*StreamSubscribeRequest) ProtoMessage added in v4.11.0 

func (*StreamSubscribeRequest) ProtoMessage()

func (*StreamSubscribeRequest) ProtoReflect added in v4.11.0 

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

func (*StreamSubscribeRequest) Reset added in v4.11.0 

func (x *StreamSubscribeRequest) Reset()

func (*StreamSubscribeRequest) String added in v4.11.0 

func (x *StreamSubscribeRequest) String() string

type StreamSubscribeResponse added in v4.11.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 v4.11.0 

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

Deprecated: Use StreamSubscribeResponse.ProtoReflect.Descriptor instead.

func (*StreamSubscribeResponse) GetPublication added in v4.11.0 

func (x *StreamSubscribeResponse) GetPublication() *Publication

func (*StreamSubscribeResponse) GetSubscribeResponse added in v4.11.0 

func (x *StreamSubscribeResponse) GetSubscribeResponse() *SubscribeResponse

func (*StreamSubscribeResponse) ProtoMessage added in v4.11.0 

func (*StreamSubscribeResponse) ProtoMessage()

func (*StreamSubscribeResponse) ProtoReflect added in v4.11.0 

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

func (*StreamSubscribeResponse) Reset added in v4.11.0 

func (x *StreamSubscribeResponse) Reset()

func (*StreamSubscribeResponse) String added in v4.11.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,omitempty"`
	Channel   string `protobuf:"bytes,11,opt,name=channel,proto3" json:"channel,omitempty"`
	Meta      []byte `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     []byte `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     []byte                   `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	B64Info  string                   `protobuf:"bytes,3,opt,name=b64info,proto3" json:"b64info,omitempty"`
	Data     []byte                   `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,omitempty"`
	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      []byte `protobuf:"bytes,13,opt,name=meta,proto3" json:"meta,omitempty"`
	Data      []byte `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     []byte                   `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	B64Info  string                   `protobuf:"bytes,3,opt,name=b64info,proto3" json:"b64info,omitempty"`
	Data     []byte                   `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 should be embedded to have forward compatible implementations.

func (UnimplementedCentrifugoProxyServer) Connect 

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

func (UnimplementedCentrifugoProxyServer) NotifyChannelState added in v4.11.0 

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 v4.11.0 

func (UnimplementedCentrifugoProxyServer) SubscribeBidirectional(CentrifugoProxy_SubscribeBidirectionalServer) error

func (UnimplementedCentrifugoProxyServer) SubscribeUnidirectional added in v4.11.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.