apiproto

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: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Command_MethodType_name = map[int32]string{
		0:  "PUBLISH",
		1:  "BROADCAST",
		2:  "UNSUBSCRIBE",
		3:  "DISCONNECT",
		4:  "PRESENCE",
		5:  "PRESENCE_STATS",
		6:  "HISTORY",
		7:  "HISTORY_REMOVE",
		8:  "CHANNELS",
		9:  "INFO",
		10: "RPC",
		11: "SUBSCRIBE",
		12: "REFRESH",
		14: "CONNECTIONS",
		15: "UPDATE_USER_STATUS",
		16: "GET_USER_STATUS",
		17: "DELETE_USER_STATUS",
		18: "BLOCK_USER",
		19: "UNBLOCK_USER",
		20: "REVOKE_TOKEN",
		21: "INVALIDATE_USER_TOKENS",
	}
	Command_MethodType_value = map[string]int32{
		"PUBLISH":                0,
		"BROADCAST":              1,
		"UNSUBSCRIBE":            2,
		"DISCONNECT":             3,
		"PRESENCE":               4,
		"PRESENCE_STATS":         5,
		"HISTORY":                6,
		"HISTORY_REMOVE":         7,
		"CHANNELS":               8,
		"INFO":                   9,
		"RPC":                    10,
		"SUBSCRIBE":              11,
		"REFRESH":                12,
		"CONNECTIONS":            14,
		"UPDATE_USER_STATUS":     15,
		"GET_USER_STATUS":        16,
		"DELETE_USER_STATUS":     17,
		"BLOCK_USER":             18,
		"UNBLOCK_USER":           19,
		"REVOKE_TOKEN":           20,
		"INVALIDATE_USER_TOKENS": 21,
	}
)

Enum value maps for Command_MethodType.

View Source 
var (
	// ErrorInternal means server error, if returned this is a signal
	// that something went wrong with Centrifugo itself.
	ErrorInternal = &Error{
		Code:    100,
		Message: "internal server error",
	}
	// ErrorUnknownChannel means that namespace in channel name does not exist.
	ErrorUnknownChannel = &Error{
		Code:    102,
		Message: "unknown channel",
	}
	// ErrorMethodNotFound means that method sent in command does not exist.
	ErrorMethodNotFound = &Error{
		Code:    104,
		Message: "method not found",
	}
	// ErrorBadRequest says that Centrifugo can not parse received data
	// because it is malformed.
	ErrorBadRequest = &Error{
		Code:    107,
		Message: "bad request",
	}
	// ErrorNotAvailable means that resource is not enabled.
	ErrorNotAvailable = &Error{
		Code:    108,
		Message: "not available",
	}
	// ErrorUnrecoverablePosition means that stream does not contain required
	// range of publications to fulfill a history query. This can be happen to
	// expiration, size limitation or due to wrong epoch.
	ErrorUnrecoverablePosition = &Error{
		Code:    112,
		Message: "unrecoverable position",
	}
)

Here we define errors that can be exposed in server API replies.

View Source 
var CentrifugoApi_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "centrifugal.centrifugo.api.CentrifugoApi",
	HandlerType: (*CentrifugoApiServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Publish",
			Handler:    _CentrifugoApi_Publish_Handler,
		},
		{
			MethodName: "Broadcast",
			Handler:    _CentrifugoApi_Broadcast_Handler,
		},
		{
			MethodName: "Subscribe",
			Handler:    _CentrifugoApi_Subscribe_Handler,
		},
		{
			MethodName: "Unsubscribe",
			Handler:    _CentrifugoApi_Unsubscribe_Handler,
		},
		{
			MethodName: "Disconnect",
			Handler:    _CentrifugoApi_Disconnect_Handler,
		},
		{
			MethodName: "Presence",
			Handler:    _CentrifugoApi_Presence_Handler,
		},
		{
			MethodName: "PresenceStats",
			Handler:    _CentrifugoApi_PresenceStats_Handler,
		},
		{
			MethodName: "History",
			Handler:    _CentrifugoApi_History_Handler,
		},
		{
			MethodName: "HistoryRemove",
			Handler:    _CentrifugoApi_HistoryRemove_Handler,
		},
		{
			MethodName: "Info",
			Handler:    _CentrifugoApi_Info_Handler,
		},
		{
			MethodName: "RPC",
			Handler:    _CentrifugoApi_RPC_Handler,
		},
		{
			MethodName: "Refresh",
			Handler:    _CentrifugoApi_Refresh_Handler,
		},
		{
			MethodName: "Channels",
			Handler:    _CentrifugoApi_Channels_Handler,
		},
		{
			MethodName: "Connections",
			Handler:    _CentrifugoApi_Connections_Handler,
		},
		{
			MethodName: "UpdateUserStatus",
			Handler:    _CentrifugoApi_UpdateUserStatus_Handler,
		},
		{
			MethodName: "GetUserStatus",
			Handler:    _CentrifugoApi_GetUserStatus_Handler,
		},
		{
			MethodName: "DeleteUserStatus",
			Handler:    _CentrifugoApi_DeleteUserStatus_Handler,
		},
		{
			MethodName: "BlockUser",
			Handler:    _CentrifugoApi_BlockUser_Handler,
		},
		{
			MethodName: "UnblockUser",
			Handler:    _CentrifugoApi_UnblockUser_Handler,
		},
		{
			MethodName: "RevokeToken",
			Handler:    _CentrifugoApi_RevokeToken_Handler,
		},
		{
			MethodName: "InvalidateUserTokens",
			Handler:    _CentrifugoApi_InvalidateUserTokens_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api.proto",
}

CentrifugoApi_ServiceDesc is the grpc.ServiceDesc for CentrifugoApi 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_api_proto protoreflect.FileDescriptor

Functions

func PutCommandDecoder 

func PutCommandDecoder(d CommandDecoder)

PutCommandDecoder ...

func PutParamsDecoder 

func PutParamsDecoder(_ ParamsDecoder)

PutParamsDecoder ...

func PutReplyEncoder 

func PutReplyEncoder(e ReplyEncoder)

PutReplyEncoder ...

func PutResultEncoder 

func PutResultEncoder(_ ResultEncoder)

PutResultEncoder ...

func RegisterCentrifugoApiServer 

func RegisterCentrifugoApiServer(s grpc.ServiceRegistrar, srv CentrifugoApiServer)

Types

type BlockUserRequest 

type BlockUserRequest struct {
	ExpireAt int64  `protobuf:"varint,1,opt,name=expire_at,json=expireAt,proto3" json:"expire_at,omitempty"`
	User     string `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockUserRequest) Descriptor deprecated 

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

Deprecated: Use BlockUserRequest.ProtoReflect.Descriptor instead.

func (*BlockUserRequest) GetExpireAt 

func (x *BlockUserRequest) GetExpireAt() int64

func (*BlockUserRequest) GetUser 

func (x *BlockUserRequest) GetUser() string

func (*BlockUserRequest) ProtoMessage 

func (*BlockUserRequest) ProtoMessage()

func (*BlockUserRequest) ProtoReflect 

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

func (*BlockUserRequest) Reset 

func (x *BlockUserRequest) Reset()

func (*BlockUserRequest) String 

func (x *BlockUserRequest) String() string

type BlockUserResponse 

type BlockUserResponse struct {
	Error  *Error           `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Result *BlockUserResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockUserResponse) Descriptor deprecated 

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

Deprecated: Use BlockUserResponse.ProtoReflect.Descriptor instead.

func (*BlockUserResponse) GetError 

func (x *BlockUserResponse) GetError() *Error

func (*BlockUserResponse) GetResult 

func (x *BlockUserResponse) GetResult() *BlockUserResult

func (*BlockUserResponse) ProtoMessage 

func (*BlockUserResponse) ProtoMessage()

func (*BlockUserResponse) ProtoReflect 

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

func (*BlockUserResponse) Reset 

func (x *BlockUserResponse) Reset()

func (*BlockUserResponse) String 

func (x *BlockUserResponse) String() string

type BlockUserResult 

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

func (*BlockUserResult) Descriptor deprecated 

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

Deprecated: Use BlockUserResult.ProtoReflect.Descriptor instead.

func (*BlockUserResult) ProtoMessage 

func (*BlockUserResult) ProtoMessage()

func (*BlockUserResult) ProtoReflect 

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

func (*BlockUserResult) Reset 

func (x *BlockUserResult) Reset()

func (*BlockUserResult) String 

func (x *BlockUserResult) String() string

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 BroadcastRequest 

type BroadcastRequest struct {
	Channels    []string          `protobuf:"bytes,1,rep,name=channels,proto3" json:"channels,omitempty"`
	Data        Raw               `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	B64Data     string            `protobuf:"bytes,3,opt,name=b64data,proto3" json:"b64data,omitempty"`
	SkipHistory bool              `protobuf:"varint,4,opt,name=skip_history,json=skipHistory,proto3" json:"skip_history,omitempty"`
	Tags        map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*BroadcastRequest) Descriptor deprecated 

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

Deprecated: Use BroadcastRequest.ProtoReflect.Descriptor instead.

func (*BroadcastRequest) GetB64Data 

func (x *BroadcastRequest) GetB64Data() string

func (*BroadcastRequest) GetChannels 

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

func (*BroadcastRequest) GetData 

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

func (*BroadcastRequest) GetSkipHistory 

func (x *BroadcastRequest) GetSkipHistory() bool

func (*BroadcastRequest) GetTags 

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

func (*BroadcastRequest) ProtoMessage 

func (*BroadcastRequest) ProtoMessage()

func (*BroadcastRequest) ProtoReflect 

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

func (*BroadcastRequest) Reset 

func (x *BroadcastRequest) Reset()

func (*BroadcastRequest) String 

func (x *BroadcastRequest) String() string

type BroadcastResponse 

type BroadcastResponse struct {
	Error  *Error           `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Result *BroadcastResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*BroadcastResponse) Descriptor deprecated 

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

Deprecated: Use BroadcastResponse.ProtoReflect.Descriptor instead.

func (*BroadcastResponse) GetError 

func (x *BroadcastResponse) GetError() *Error

func (*BroadcastResponse) GetResult 

func (x *BroadcastResponse) GetResult() *BroadcastResult

func (*BroadcastResponse) ProtoMessage 

func (*BroadcastResponse) ProtoMessage()

func (*BroadcastResponse) ProtoReflect 

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

func (*BroadcastResponse) Reset 

func (x *BroadcastResponse) Reset()

func (*BroadcastResponse) String 

func (x *BroadcastResponse) String() string

type BroadcastResult 

type BroadcastResult struct {
	Responses []*PublishResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

func (*BroadcastResult) Descriptor deprecated 

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

Deprecated: Use BroadcastResult.ProtoReflect.Descriptor instead.

func (*BroadcastResult) GetResponses 

func (x *BroadcastResult) GetResponses() []*PublishResponse

func (*BroadcastResult) ProtoMessage 

func (*BroadcastResult) ProtoMessage()

func (*BroadcastResult) ProtoReflect 

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

func (*BroadcastResult) Reset 

func (x *BroadcastResult) Reset()

func (*BroadcastResult) String 

func (x *BroadcastResult) String() string

type CentrifugoApiClient 

type CentrifugoApiClient interface {
	Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error)
	Broadcast(ctx context.Context, in *BroadcastRequest, opts ...grpc.CallOption) (*BroadcastResponse, error)
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (*SubscribeResponse, error)
	Unsubscribe(ctx context.Context, in *UnsubscribeRequest, opts ...grpc.CallOption) (*UnsubscribeResponse, error)
	Disconnect(ctx context.Context, in *DisconnectRequest, opts ...grpc.CallOption) (*DisconnectResponse, error)
	Presence(ctx context.Context, in *PresenceRequest, opts ...grpc.CallOption) (*PresenceResponse, error)
	PresenceStats(ctx context.Context, in *PresenceStatsRequest, opts ...grpc.CallOption) (*PresenceStatsResponse, error)
	History(ctx context.Context, in *HistoryRequest, opts ...grpc.CallOption) (*HistoryResponse, error)
	HistoryRemove(ctx context.Context, in *HistoryRemoveRequest, opts ...grpc.CallOption) (*HistoryRemoveResponse, error)
	Info(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error)
	RPC(ctx context.Context, in *RPCRequest, opts ...grpc.CallOption) (*RPCResponse, error)
	Refresh(ctx context.Context, in *RefreshRequest, opts ...grpc.CallOption) (*RefreshResponse, error)
	Channels(ctx context.Context, in *ChannelsRequest, opts ...grpc.CallOption) (*ChannelsResponse, error)
	Connections(ctx context.Context, in *ConnectionsRequest, opts ...grpc.CallOption) (*ConnectionsResponse, error)
	UpdateUserStatus(ctx context.Context, in *UpdateUserStatusRequest, opts ...grpc.CallOption) (*UpdateUserStatusResponse, error)
	GetUserStatus(ctx context.Context, in *GetUserStatusRequest, opts ...grpc.CallOption) (*GetUserStatusResponse, error)
	DeleteUserStatus(ctx context.Context, in *DeleteUserStatusRequest, opts ...grpc.CallOption) (*DeleteUserStatusResponse, error)
	BlockUser(ctx context.Context, in *BlockUserRequest, opts ...grpc.CallOption) (*BlockUserResponse, error)
	UnblockUser(ctx context.Context, in *UnblockUserRequest, opts ...grpc.CallOption) (*UnblockUserResponse, error)
	RevokeToken(ctx context.Context, in *RevokeTokenRequest, opts ...grpc.CallOption) (*RevokeTokenResponse, error)
	InvalidateUserTokens(ctx context.Context, in *InvalidateUserTokensRequest, opts ...grpc.CallOption) (*InvalidateUserTokensResponse, error)
}

CentrifugoApiClient is the client API for CentrifugoApi 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 NewCentrifugoApiClient 

func NewCentrifugoApiClient(cc grpc.ClientConnInterface) CentrifugoApiClient

type CentrifugoApiServer 

type CentrifugoApiServer interface {
	Publish(context.Context, *PublishRequest) (*PublishResponse, error)
	Broadcast(context.Context, *BroadcastRequest) (*BroadcastResponse, error)
	Subscribe(context.Context, *SubscribeRequest) (*SubscribeResponse, error)
	Unsubscribe(context.Context, *UnsubscribeRequest) (*UnsubscribeResponse, error)
	Disconnect(context.Context, *DisconnectRequest) (*DisconnectResponse, error)
	Presence(context.Context, *PresenceRequest) (*PresenceResponse, error)
	PresenceStats(context.Context, *PresenceStatsRequest) (*PresenceStatsResponse, error)
	History(context.Context, *HistoryRequest) (*HistoryResponse, error)
	HistoryRemove(context.Context, *HistoryRemoveRequest) (*HistoryRemoveResponse, error)
	Info(context.Context, *InfoRequest) (*InfoResponse, error)
	RPC(context.Context, *RPCRequest) (*RPCResponse, error)
	Refresh(context.Context, *RefreshRequest) (*RefreshResponse, error)
	Channels(context.Context, *ChannelsRequest) (*ChannelsResponse, error)
	Connections(context.Context, *ConnectionsRequest) (*ConnectionsResponse, error)
	UpdateUserStatus(context.Context, *UpdateUserStatusRequest) (*UpdateUserStatusResponse, error)
	GetUserStatus(context.Context, *GetUserStatusRequest) (*GetUserStatusResponse, error)
	DeleteUserStatus(context.Context, *DeleteUserStatusRequest) (*DeleteUserStatusResponse, error)
	BlockUser(context.Context, *BlockUserRequest) (*BlockUserResponse, error)
	UnblockUser(context.Context, *UnblockUserRequest) (*UnblockUserResponse, error)
	RevokeToken(context.Context, *RevokeTokenRequest) (*RevokeTokenResponse, error)
	InvalidateUserTokens(context.Context, *InvalidateUserTokensRequest) (*InvalidateUserTokensResponse, error)
	// contains filtered or unexported methods
}

CentrifugoApiServer is the server API for CentrifugoApi service. All implementations must embed UnimplementedCentrifugoApiServer for forward compatibility

type ChannelContext added in v4.0.1 

type ChannelContext struct {
	Source uint32 `protobuf:"varint,1,opt,name=source,proto3" json:"source,omitempty"`
	// contains filtered or unexported fields
}

func (*ChannelContext) Descriptor deprecated added in v4.0.1 

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

Deprecated: Use ChannelContext.ProtoReflect.Descriptor instead.

func (*ChannelContext) GetSource added in v4.0.1 

func (x *ChannelContext) GetSource() uint32

func (*ChannelContext) ProtoMessage added in v4.0.1 

func (*ChannelContext) ProtoMessage()

func (*ChannelContext) ProtoReflect added in v4.0.1 

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

func (*ChannelContext) Reset added in v4.0.1 

func (x *ChannelContext) Reset()

func (*ChannelContext) String added in v4.0.1 

func (x *ChannelContext) String() string

type ChannelInfo 

type ChannelInfo struct {
	NumClients uint32 `protobuf:"varint,1,opt,name=num_clients,json=numClients,proto3" json:"num_clients,omitempty"`
	// contains filtered or unexported fields
}

func (*ChannelInfo) Descriptor deprecated 

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

Deprecated: Use ChannelInfo.ProtoReflect.Descriptor instead.

func (*ChannelInfo) GetNumClients 

func (x *ChannelInfo) GetNumClients() uint32

func (*ChannelInfo) ProtoMessage 

func (*ChannelInfo) ProtoMessage()

func (*ChannelInfo) ProtoReflect 

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

func (*ChannelInfo) Reset 

func (x *ChannelInfo) Reset()

func (*ChannelInfo) String 

func (x *ChannelInfo) String() string

type ChannelsRequest 

type ChannelsRequest struct {
	Pattern string `protobuf:"bytes,1,opt,name=pattern,proto3" json:"pattern,omitempty"`
	// contains filtered or unexported fields
}

func (*ChannelsRequest) Descriptor deprecated 

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

Deprecated: Use ChannelsRequest.ProtoReflect.Descriptor instead.

func (*ChannelsRequest) GetPattern 

func (x *ChannelsRequest) GetPattern() string

func (*ChannelsRequest) ProtoMessage 

func (*ChannelsRequest) ProtoMessage()

func (*ChannelsRequest) ProtoReflect 

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

func (*ChannelsRequest) Reset 

func (x *ChannelsRequest) Reset()

func (*ChannelsRequest) String 

func (x *ChannelsRequest) String() string

type ChannelsResponse 

type ChannelsResponse struct {
	Error  *Error          `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Result *ChannelsResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*ChannelsResponse) Descriptor deprecated 

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

Deprecated: Use ChannelsResponse.ProtoReflect.Descriptor instead.

func (*ChannelsResponse) GetError 

func (x *ChannelsResponse) GetError() *Error

func (*ChannelsResponse) GetResult 

func (x *ChannelsResponse) GetResult() *ChannelsResult

func (*ChannelsResponse) ProtoMessage 

func (*ChannelsResponse) ProtoMessage()

func (*ChannelsResponse) ProtoReflect 

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

func (*ChannelsResponse) Reset 

func (x *ChannelsResponse) Reset()

func (*ChannelsResponse) String 

func (x *ChannelsResponse) String() string

type ChannelsResult 

type ChannelsResult struct {
	Channels map[string]*ChannelInfo `` /* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ChannelsResult) Descriptor deprecated 

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

Deprecated: Use ChannelsResult.ProtoReflect.Descriptor instead.

func (*ChannelsResult) GetChannels 

func (x *ChannelsResult) GetChannels() map[string]*ChannelInfo

func (*ChannelsResult) ProtoMessage 

func (*ChannelsResult) ProtoMessage()

func (*ChannelsResult) ProtoReflect 

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

func (*ChannelsResult) Reset 

func (x *ChannelsResult) Reset()

func (*ChannelsResult) String 

func (x *ChannelsResult) String() string

type ClientInfo 

type ClientInfo struct {
	User     string `protobuf:"bytes,1,opt,name=user,proto3" json:"user"`
	Client   string `protobuf:"bytes,2,opt,name=client,proto3" json:"client"`
	ConnInfo Raw    `protobuf:"bytes,3,opt,name=conn_info,json=connInfo,proto3" json:"conn_info,omitempty"`
	ChanInfo Raw    `protobuf:"bytes,4,opt,name=chan_info,json=chanInfo,proto3" json:"chan_info,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientInfo) Descriptor deprecated 

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

Deprecated: Use ClientInfo.ProtoReflect.Descriptor instead.

func (*ClientInfo) GetChanInfo 

func (x *ClientInfo) GetChanInfo() []byte

func (*ClientInfo) GetClient 

func (x *ClientInfo) GetClient() string

func (*ClientInfo) GetConnInfo 

func (x *ClientInfo) GetConnInfo() []byte

func (*ClientInfo) GetUser 

func (x *ClientInfo) GetUser() string

func (*ClientInfo) ProtoMessage 

func (*ClientInfo) ProtoMessage()

func (*ClientInfo) ProtoReflect 

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

func (*ClientInfo) Reset 

func (x *ClientInfo) Reset()

func (*ClientInfo) String 

func (x *ClientInfo) String() string

type Command 

type Command struct {
	Id     uint32             `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Method Command_MethodType `protobuf:"varint,2,opt,name=method,proto3,enum=centrifugal.centrifugo.api.Command_MethodType" json:"method,omitempty"`
	Params Raw                `protobuf:"bytes,3,opt,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

func (*Command) Descriptor deprecated 

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

Deprecated: Use Command.ProtoReflect.Descriptor instead.

func (*Command) GetId 

func (x *Command) GetId() uint32

func (*Command) GetMethod 

func (x *Command) GetMethod() Command_MethodType

func (*Command) GetParams 

func (x *Command) GetParams() []byte

func (*Command) ProtoMessage 

func (*Command) ProtoMessage()

func (*Command) ProtoReflect 

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

func (*Command) Reset 

func (x *Command) Reset()

func (*Command) String 

func (x *Command) String() string

type CommandDecoder 

type CommandDecoder interface {
	Reset([]byte)
	Decode() (*Command, error)
}

CommandDecoder ...

func GetCommandDecoder 

func GetCommandDecoder(data []byte) CommandDecoder

GetCommandDecoder ...

type Command_MethodType 

type Command_MethodType int32
const (
	Command_PUBLISH                Command_MethodType = 0
	Command_BROADCAST              Command_MethodType = 1
	Command_UNSUBSCRIBE            Command_MethodType = 2
	Command_DISCONNECT             Command_MethodType = 3
	Command_PRESENCE               Command_MethodType = 4
	Command_PRESENCE_STATS         Command_MethodType = 5
	Command_HISTORY                Command_MethodType = 6
	Command_HISTORY_REMOVE         Command_MethodType = 7
	Command_CHANNELS               Command_MethodType = 8
	Command_INFO                   Command_MethodType = 9
	Command_RPC                    Command_MethodType = 10
	Command_SUBSCRIBE              Command_MethodType = 11
	Command_REFRESH                Command_MethodType = 12
	Command_CONNECTIONS            Command_MethodType = 14
	Command_UPDATE_USER_STATUS     Command_MethodType = 15
	Command_GET_USER_STATUS        Command_MethodType = 16
	Command_DELETE_USER_STATUS     Command_MethodType = 17
	Command_BLOCK_USER             Command_MethodType = 18
	Command_UNBLOCK_USER           Command_MethodType = 19
	Command_REVOKE_TOKEN           Command_MethodType = 20
	Command_INVALIDATE_USER_TOKENS Command_MethodType = 21
)

func (Command_MethodType) Descriptor 

func (Command_MethodType) Descriptor() protoreflect.EnumDescriptor

func (Command_MethodType) Enum 

func (x Command_MethodType) Enum() *Command_MethodType

func (Command_MethodType) EnumDescriptor deprecated 

func (Command_MethodType) EnumDescriptor() ([]byte, []int)

Deprecated: Use Command_MethodType.Descriptor instead.

func (Command_MethodType) Number 

func (x Command_MethodType) Number() protoreflect.EnumNumber

func (Command_MethodType) String 

func (x Command_MethodType) String() string

func (Command_MethodType) Type 

func (Command_MethodType) Type() protoreflect.EnumType

func (*Command_MethodType) UnmarshalJSON 

func (m *Command_MethodType) UnmarshalJSON(data []byte) error

UnmarshalJSON helps to unmarshal command method when set as string.

type ConnectionInfo 

type ConnectionInfo struct {
	AppName    string `protobuf:"bytes,1,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"`
	AppVersion string `protobuf:"bytes,2,opt,name=app_version,json=appVersion,proto3" json:"app_version,omitempty"`
	Transport  string `protobuf:"bytes,3,opt,name=transport,proto3" json:"transport,omitempty"`
	Protocol   string `protobuf:"bytes,4,opt,name=protocol,proto3" json:"protocol,omitempty"`
	// 5-7 dropped for backwards compatibility.
	User  string           `protobuf:"bytes,8,opt,name=user,proto3" json:"user,omitempty"`
	State *ConnectionState `protobuf:"bytes,9,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectionInfo) Descriptor deprecated 

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

Deprecated: Use ConnectionInfo.ProtoReflect.Descriptor instead.

func (*ConnectionInfo) GetAppName 

func (x *ConnectionInfo) GetAppName() string

func (*ConnectionInfo) GetAppVersion 

func (x *ConnectionInfo) GetAppVersion() string

func (*ConnectionInfo) GetProtocol 

func (x *ConnectionInfo) GetProtocol() string

func (*ConnectionInfo) GetState 

func (x *ConnectionInfo) GetState() *ConnectionState

func (*ConnectionInfo) GetTransport 

func (x *ConnectionInfo) GetTransport() string

func (*ConnectionInfo) GetUser 

func (x *ConnectionInfo) GetUser() string

func (*ConnectionInfo) ProtoMessage 

func (*ConnectionInfo) ProtoMessage()

func (*ConnectionInfo) ProtoReflect 

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

func (*ConnectionInfo) Reset 

func (x *ConnectionInfo) Reset()

func (*ConnectionInfo) String 

func (x *ConnectionInfo) String() string

type ConnectionState 

type ConnectionState struct {
	Channels           map[string]*ChannelContext        `` /* 157-byte string literal not displayed */
	ConnectionToken    *ConnectionTokenInfo              `protobuf:"bytes,2,opt,name=connection_token,json=connectionToken,proto3" json:"connection_token,omitempty"`
	SubscriptionTokens map[string]*SubscriptionTokenInfo `` /* 203-byte string literal not displayed */
	Meta               Raw                               `protobuf:"bytes,4,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectionState) Descriptor deprecated 

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

Deprecated: Use ConnectionState.ProtoReflect.Descriptor instead.

func (*ConnectionState) GetChannels 

func (x *ConnectionState) GetChannels() map[string]*ChannelContext

func (*ConnectionState) GetConnectionToken 

func (x *ConnectionState) GetConnectionToken() *ConnectionTokenInfo

func (*ConnectionState) GetMeta 

func (x *ConnectionState) GetMeta() []byte

func (*ConnectionState) GetSubscriptionTokens 

func (x *ConnectionState) GetSubscriptionTokens() map[string]*SubscriptionTokenInfo

func (*ConnectionState) ProtoMessage 

func (*ConnectionState) ProtoMessage()

func (*ConnectionState) ProtoReflect 

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

func (*ConnectionState) Reset 

func (x *ConnectionState) Reset()

func (*ConnectionState) String 

func (x *ConnectionState) String() string

type ConnectionTokenInfo 

type ConnectionTokenInfo struct {
	Uid      string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
	IssuedAt int64  `protobuf:"varint,2,opt,name=issued_at,json=issuedAt,proto3" json:"issued_at,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectionTokenInfo) Descriptor deprecated 

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

Deprecated: Use ConnectionTokenInfo.ProtoReflect.Descriptor instead.

func (*ConnectionTokenInfo) GetIssuedAt 

func (x *ConnectionTokenInfo) GetIssuedAt() int64

func (*ConnectionTokenInfo) GetUid 

func (x *ConnectionTokenInfo) GetUid() string

func (*ConnectionTokenInfo) ProtoMessage 

func (*ConnectionTokenInfo) ProtoMessage()

func (*ConnectionTokenInfo) ProtoReflect 

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

func (*ConnectionTokenInfo) Reset 

func (x *ConnectionTokenInfo) Reset()

func (*ConnectionTokenInfo) String 

func (x *ConnectionTokenInfo) String() string

type ConnectionsRequest 

type ConnectionsRequest struct {
	User       string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Expression string `protobuf:"bytes,2,opt,name=expression,proto3" json:"expression,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectionsRequest) Descriptor deprecated 

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

Deprecated: Use ConnectionsRequest.ProtoReflect.Descriptor instead.

func (*ConnectionsRequest) GetExpression 

func (x *ConnectionsRequest) GetExpression() string

func (*ConnectionsRequest) GetUser 

func (x *ConnectionsRequest) GetUser() string

func (*ConnectionsRequest) ProtoMessage 

func (*ConnectionsRequest) ProtoMessage()

func (*ConnectionsRequest) ProtoReflect 

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

func (*ConnectionsRequest) Reset 

func (x *ConnectionsRequest) Reset()

func (*ConnectionsRequest) String 

func (x *ConnectionsRequest) String() string

type ConnectionsResponse 

type ConnectionsResponse struct {
	Error  *Error             `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Result *ConnectionsResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectionsResponse) Descriptor deprecated 

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

Deprecated: Use ConnectionsResponse.ProtoReflect.Descriptor instead.

func (*ConnectionsResponse) GetError 

func (x *ConnectionsResponse) GetError() *Error

func (*ConnectionsResponse) GetResult 

func (x *ConnectionsResponse) GetResult() *ConnectionsResult

func (*ConnectionsResponse) ProtoMessage 

func (*ConnectionsResponse) ProtoMessage()

func (*ConnectionsResponse) ProtoReflect 

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

func (*ConnectionsResponse) Reset 

func (x *ConnectionsResponse) Reset()

func (*ConnectionsResponse) String 

func (x *ConnectionsResponse) String() string

type ConnectionsResult 

type ConnectionsResult struct {
	Connections map[string]*ConnectionInfo `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ConnectionsResult) Descriptor deprecated 

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

Deprecated: Use ConnectionsResult.ProtoReflect.Descriptor instead.

func (*ConnectionsResult) GetConnections 

func (x *ConnectionsResult) GetConnections() map[string]*ConnectionInfo

func (*ConnectionsResult) ProtoMessage 

func (*ConnectionsResult) ProtoMessage()

func (*ConnectionsResult) ProtoReflect 

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

func (*ConnectionsResult) Reset 

func (x *ConnectionsResult) Reset()

func (*ConnectionsResult) String 

func (x *ConnectionsResult) String() string

type DeleteUserStatusRequest 

type DeleteUserStatusRequest struct {
	Users []string `protobuf:"bytes,1,rep,name=users,proto3" json:"users,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteUserStatusRequest) Descriptor deprecated 

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

Deprecated: Use DeleteUserStatusRequest.ProtoReflect.Descriptor instead.

func (*DeleteUserStatusRequest) GetUsers 

func (x *DeleteUserStatusRequest) GetUsers() []string

func (*DeleteUserStatusRequest) ProtoMessage 

func (*DeleteUserStatusRequest) ProtoMessage()

func (*DeleteUserStatusRequest) ProtoReflect 

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

func (*DeleteUserStatusRequest) Reset 

func (x *DeleteUserStatusRequest) Reset()

func (*DeleteUserStatusRequest) String 

func (x *DeleteUserStatusRequest) String() string

type DeleteUserStatusResponse 

type DeleteUserStatusResponse struct {
	Error  *Error                  `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Result *DeleteUserStatusResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteUserStatusResponse) Descriptor deprecated 

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

Deprecated: Use DeleteUserStatusResponse.ProtoReflect.Descriptor instead.

func (*DeleteUserStatusResponse) GetError 

func (x *DeleteUserStatusResponse) GetError() *Error

func (*DeleteUserStatusResponse) GetResult 

func (x *DeleteUserStatusResponse) GetResult() *DeleteUserStatusResult

func (*DeleteUserStatusResponse) ProtoMessage 

func (*DeleteUserStatusResponse) ProtoMessage()

func (*DeleteUserStatusResponse) ProtoReflect 

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

func (*DeleteUserStatusResponse) Reset 

func (x *DeleteUserStatusResponse) Reset()

func (*DeleteUserStatusResponse) String 

func (x *DeleteUserStatusResponse) String() string

type DeleteUserStatusResult 

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

func (*DeleteUserStatusResult) Descriptor deprecated 

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

Deprecated: Use DeleteUserStatusResult.ProtoReflect.Descriptor instead.

func (*DeleteUserStatusResult) ProtoMessage 

func (*DeleteUserStatusResult) ProtoMessage()

func (*DeleteUserStatusResult) ProtoReflect 

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

func (*DeleteUserStatusResult) Reset 

func (x *DeleteUserStatusResult) Reset()

func (*DeleteUserStatusResult) String 

func (x *DeleteUserStatusResult) 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 DisconnectRequest 

type DisconnectRequest struct {
	User       string      `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Disconnect *Disconnect `protobuf:"bytes,2,opt,name=disconnect,proto3" json:"disconnect,omitempty"`
	Client     string      `protobuf:"bytes,3,opt,name=client,proto3" json:"client,omitempty"`
	Whitelist  []string    `protobuf:"bytes,4,rep,name=whitelist,proto3" json:"whitelist,omitempty"`
	Session    string      `protobuf:"bytes,5,opt,name=session,proto3" json:"session,omitempty"`
	// contains filtered or unexported fields
}

func (*DisconnectRequest) Descriptor deprecated 

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

Deprecated: Use DisconnectRequest.ProtoReflect.Descriptor instead.

func (*DisconnectRequest) GetClient 

func (x *DisconnectRequest) GetClient() string

func (*DisconnectRequest) GetDisconnect 

func (x *DisconnectRequest) GetDisconnect() *Disconnect

func (*DisconnectRequest) GetSession 

func (x *DisconnectRequest) GetSession() string

func (*DisconnectRequest) GetUser 

func (x *DisconnectRequest) GetUser() string

func (*DisconnectRequest) GetWhitelist 

func (x *DisconnectRequest) GetWhitelist() []string

func (*DisconnectRequest) ProtoMessage 

func (*DisconnectRequest) ProtoMessage()

func (*DisconnectRequest) ProtoReflect 

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

func (*DisconnectRequest) Reset 

func (x *DisconnectRequest) Reset()

func (*DisconnectRequest) String 

func (x *DisconnectRequest) String() string

type DisconnectResponse 

type DisconnectResponse struct {
	Error  *Error            `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Result *DisconnectResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*DisconnectResponse) Descriptor deprecated 

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

Deprecated: Use DisconnectResponse.ProtoReflect.Descriptor instead.

func (*DisconnectResponse) GetError 

func (x *DisconnectResponse) GetError() *Error

func (*DisconnectResponse) GetResult 

func (x *DisconnectResponse) GetResult() *DisconnectResult

func (*DisconnectResponse) ProtoMessage 

func (*DisconnectResponse) ProtoMessage()

func (*DisconnectResponse) ProtoReflect 

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

func (*DisconnectResponse) Reset 

func (x *DisconnectResponse) Reset()

func (*DisconnectResponse) String 

func (x *DisconnectResponse) String() string

type DisconnectResult 

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

func (*DisconnectResult) Descriptor deprecated 

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

Deprecated: Use DisconnectResult.ProtoReflect.Descriptor instead.

func (*DisconnectResult) ProtoMessage 

func (*DisconnectResult) ProtoMessage()

func (*DisconnectResult) ProtoReflect 

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

func (*DisconnectResult) Reset 

func (x *DisconnectResult) Reset()

func (*DisconnectResult) String 

func (x *DisconnectResult) 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"`
	// contains filtered or unexported fields
}

func (*Error) Descriptor deprecated 

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

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) Error 

func (x *Error) Error() string

func (*Error) GetCode 

func (x *Error) GetCode() uint32

func (*Error) GetMessage 

func (x *Error) GetMessage() string

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 GetUserStatusRequest 

type GetUserStatusRequest struct {
	Users []string `protobuf:"bytes,1,rep,name=users,proto3" json:"users,omitempty"`
	// contains filtered or unexported fields
}

func (*GetUserStatusRequest) Descriptor deprecated 

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

Deprecated: Use GetUserStatusRequest.ProtoReflect.Descriptor instead.

func (*GetUserStatusRequest) GetUsers 

func (x *GetUserStatusRequest) GetUsers() []string

func (*GetUserStatusRequest) ProtoMessage 

func (*GetUserStatusRequest) ProtoMessage()

func (*GetUserStatusRequest) ProtoReflect 

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

func (*GetUserStatusRequest) Reset 

func (x *GetUserStatusRequest) Reset()

func (*GetUserStatusRequest) String 

func (x *GetUserStatusRequest) String() string

type GetUserStatusResponse 

type GetUserStatusResponse struct {
	Error  *Error               `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Result *GetUserStatusResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*GetUserStatusResponse) Descriptor deprecated 

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

Deprecated: Use GetUserStatusResponse.ProtoReflect.Descriptor instead.

func (*GetUserStatusResponse) GetError 

func (x *GetUserStatusResponse) GetError() *Error

func (*GetUserStatusResponse) GetResult 

func (x *GetUserStatusResponse) GetResult() *GetUserStatusResult

func (*GetUserStatusResponse) ProtoMessage 

func (*GetUserStatusResponse) ProtoMessage()

func (*GetUserStatusResponse) ProtoReflect 

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

func (*GetUserStatusResponse) Reset 

func (x *GetUserStatusResponse) Reset()

func (*GetUserStatusResponse) String 

func (x *GetUserStatusResponse) String() string

type GetUserStatusResult 

type GetUserStatusResult struct {
	Statuses []*UserStatus `protobuf:"bytes,1,rep,name=statuses,proto3" json:"statuses"`
	// contains filtered or unexported fields
}

func (*GetUserStatusResult) Descriptor deprecated 

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

Deprecated: Use GetUserStatusResult.ProtoReflect.Descriptor instead.

func (*GetUserStatusResult) GetStatuses 

func (x *GetUserStatusResult) GetStatuses() []*UserStatus

func (*GetUserStatusResult) ProtoMessage 

func (*GetUserStatusResult) ProtoMessage()

func (*GetUserStatusResult) ProtoReflect 

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

func (*GetUserStatusResult) Reset 

func (x *GetUserStatusResult) Reset()

func (*GetUserStatusResult) String 

func (x *GetUserStatusResult) String() string

type HistoryRemoveRequest 

type HistoryRemoveRequest struct {
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	// contains filtered or unexported fields
}

func (*HistoryRemoveRequest) Descriptor deprecated 

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

Deprecated: Use HistoryRemoveRequest.ProtoReflect.Descriptor instead.

func (*HistoryRemoveRequest) GetChannel 

func (x *HistoryRemoveRequest) GetChannel() string

func (*HistoryRemoveRequest) ProtoMessage 

func (*HistoryRemoveRequest) ProtoMessage()

func (*HistoryRemoveRequest) ProtoReflect 

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

func (*HistoryRemoveRequest) Reset 

func (x *HistoryRemoveRequest) Reset()

func (*HistoryRemoveRequest) String 

func (x *HistoryRemoveRequest) String() string

type HistoryRemoveResponse 

type HistoryRemoveResponse struct {
	Error  *Error               `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Result *HistoryRemoveResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*HistoryRemoveResponse) Descriptor deprecated 

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

Deprecated: Use HistoryRemoveResponse.ProtoReflect.Descriptor instead.

func (*HistoryRemoveResponse) GetError 

func (x *HistoryRemoveResponse) GetError() *Error

func (*HistoryRemoveResponse) GetResult 

func (x *HistoryRemoveResponse) GetResult() *HistoryRemoveResult

func (*HistoryRemoveResponse) ProtoMessage 

func (*HistoryRemoveResponse) ProtoMessage()

func (*HistoryRemoveResponse) ProtoReflect 

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

func (*HistoryRemoveResponse) Reset 

func (x *HistoryRemoveResponse) Reset()

func (*HistoryRemoveResponse) String 

func (x *HistoryRemoveResponse) String() string

type HistoryRemoveResult 

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

func (*HistoryRemoveResult) Descriptor deprecated 

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

Deprecated: Use HistoryRemoveResult.ProtoReflect.Descriptor instead.

func (*HistoryRemoveResult) ProtoMessage 

func (*HistoryRemoveResult) ProtoMessage()

func (*HistoryRemoveResult) ProtoReflect 

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

func (*HistoryRemoveResult) Reset 

func (x *HistoryRemoveResult) Reset()

func (*HistoryRemoveResult) String 

func (x *HistoryRemoveResult) String() string

type HistoryRequest 

type HistoryRequest struct {
	Channel string          `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	Limit   int32           `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	Since   *StreamPosition `protobuf:"bytes,3,opt,name=since,proto3" json:"since,omitempty"`
	Reverse bool            `protobuf:"varint,4,opt,name=reverse,proto3" json:"reverse,omitempty"`
	// contains filtered or unexported fields
}

func (*HistoryRequest) Descriptor deprecated 

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

Deprecated: Use HistoryRequest.ProtoReflect.Descriptor instead.

func (*HistoryRequest) GetChannel 

func (x *HistoryRequest) GetChannel() string

func (*HistoryRequest) GetLimit 

func (x *HistoryRequest) GetLimit() int32

func (*HistoryRequest) GetReverse 

func (x *HistoryRequest) GetReverse() bool

func (*HistoryRequest) GetSince 

func (x *HistoryRequest) GetSince() *StreamPosition

func (*HistoryRequest) ProtoMessage 

func (*HistoryRequest) ProtoMessage()

func (*HistoryRequest) ProtoReflect 

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

func (*HistoryRequest) Reset 

func (x *HistoryRequest) Reset()

func (*HistoryRequest) String 

func (x *HistoryRequest) String() string

type HistoryResponse 

type HistoryResponse struct {
	Error  *Error         `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Result *HistoryResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*HistoryResponse) Descriptor deprecated 

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

Deprecated: Use HistoryResponse.ProtoReflect.Descriptor instead.

func (*HistoryResponse) GetError 

func (x *HistoryResponse) GetError() *Error

func (*HistoryResponse) GetResult 

func (x *HistoryResponse) GetResult() *HistoryResult

func (*HistoryResponse) ProtoMessage 

func (*HistoryResponse) ProtoMessage()

func (*HistoryResponse) ProtoReflect 

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

func (*HistoryResponse) Reset 

func (x *HistoryResponse) Reset()

func (*HistoryResponse) String 

func (x *HistoryResponse) String() string

type HistoryResult 

type HistoryResult struct {
	Publications []*Publication `protobuf:"bytes,1,rep,name=publications,proto3" json:"publications"`
	Epoch        string         `protobuf:"bytes,2,opt,name=epoch,proto3" json:"epoch"`
	Offset       uint64         `protobuf:"varint,3,opt,name=offset,proto3" json:"offset"`
	// contains filtered or unexported fields
}

func (*HistoryResult) Descriptor deprecated 

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

Deprecated: Use HistoryResult.ProtoReflect.Descriptor instead.

func (*HistoryResult) GetEpoch 

func (x *HistoryResult) GetEpoch() string

func (*HistoryResult) GetOffset 

func (x *HistoryResult) GetOffset() uint64

func (*HistoryResult) GetPublications 

func (x *HistoryResult) GetPublications() []*Publication

func (*HistoryResult) ProtoMessage 

func (*HistoryResult) ProtoMessage()

func (*HistoryResult) ProtoReflect 

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

func (*HistoryResult) Reset 

func (x *HistoryResult) Reset()

func (*HistoryResult) String 

func (x *HistoryResult) String() string

type InfoRequest 

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

func (*InfoRequest) Descriptor deprecated 

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

Deprecated: Use InfoRequest.ProtoReflect.Descriptor instead.

func (*InfoRequest) ProtoMessage 

func (*InfoRequest) ProtoMessage()

func (*InfoRequest) ProtoReflect 

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

func (*InfoRequest) Reset 

func (x *InfoRequest) Reset()

func (*InfoRequest) String 

func (x *InfoRequest) String() string

type InfoResponse 

type InfoResponse struct {
	Error  *Error      `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Result *InfoResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*InfoResponse) Descriptor deprecated 

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

Deprecated: Use InfoResponse.ProtoReflect.Descriptor instead.

func (*InfoResponse) GetError 

func (x *InfoResponse) GetError() *Error

func (*InfoResponse) GetResult 

func (x *InfoResponse) GetResult() *InfoResult

func (*InfoResponse) ProtoMessage 

func (*InfoResponse) ProtoMessage()

func (*InfoResponse) ProtoReflect 

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

func (*InfoResponse) Reset 

func (x *InfoResponse) Reset()

func (*InfoResponse) String 

func (x *InfoResponse) String() string

type InfoResult 

type InfoResult struct {
	Nodes []*NodeResult `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

func (*InfoResult) Descriptor deprecated 

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

Deprecated: Use InfoResult.ProtoReflect.Descriptor instead.

func (*InfoResult) GetNodes 

func (x *InfoResult) GetNodes() []*NodeResult

func (*InfoResult) ProtoMessage 

func (*InfoResult) ProtoMessage()

func (*InfoResult) ProtoReflect 

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

func (*InfoResult) Reset 

func (x *InfoResult) Reset()

func (*InfoResult) String 

func (x *InfoResult) 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 InvalidateUserTokensRequest 

type InvalidateUserTokensRequest struct {
	ExpireAt     int64  `protobuf:"varint,1,opt,name=expire_at,json=expireAt,proto3" json:"expire_at,omitempty"`
	User         string `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	IssuedBefore int64  `protobuf:"varint,3,opt,name=issued_before,json=issuedBefore,proto3" json:"issued_before,omitempty"`
	Channel      string `protobuf:"bytes,4,opt,name=channel,proto3" json:"channel,omitempty"`
	// contains filtered or unexported fields
}

func (*InvalidateUserTokensRequest) Descriptor deprecated 

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

Deprecated: Use InvalidateUserTokensRequest.ProtoReflect.Descriptor instead.

func (*InvalidateUserTokensRequest) GetChannel 

func (x *InvalidateUserTokensRequest) GetChannel() string

func (*InvalidateUserTokensRequest) GetExpireAt 

func (x *InvalidateUserTokensRequest) GetExpireAt() int64

func (*InvalidateUserTokensRequest) GetIssuedBefore 

func (x *InvalidateUserTokensRequest) GetIssuedBefore() int64

func (*InvalidateUserTokensRequest) GetUser 

func (x *InvalidateUserTokensRequest) GetUser() string

func (*InvalidateUserTokensRequest) ProtoMessage 

func (*InvalidateUserTokensRequest) ProtoMessage()

func (*InvalidateUserTokensRequest) ProtoReflect 

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

func (*InvalidateUserTokensRequest) Reset 

func (x *InvalidateUserTokensRequest) Reset()

func (*InvalidateUserTokensRequest) String 

func (x *InvalidateUserTokensRequest) String() string

type InvalidateUserTokensResponse 

type InvalidateUserTokensResponse struct {
	Error  *Error                      `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Result *InvalidateUserTokensResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*InvalidateUserTokensResponse) Descriptor deprecated 

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

Deprecated: Use InvalidateUserTokensResponse.ProtoReflect.Descriptor instead.

func (*InvalidateUserTokensResponse) GetError 

func (x *InvalidateUserTokensResponse) GetError() *Error

func (*InvalidateUserTokensResponse) GetResult 

func (x *InvalidateUserTokensResponse) GetResult() *InvalidateUserTokensResult

func (*InvalidateUserTokensResponse) ProtoMessage 

func (*InvalidateUserTokensResponse) ProtoMessage()

func (*InvalidateUserTokensResponse) ProtoReflect 

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

func (*InvalidateUserTokensResponse) Reset 

func (x *InvalidateUserTokensResponse) Reset()

func (*InvalidateUserTokensResponse) String 

func (x *InvalidateUserTokensResponse) String() string

type InvalidateUserTokensResult 

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

func (*InvalidateUserTokensResult) Descriptor deprecated 

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

Deprecated: Use InvalidateUserTokensResult.ProtoReflect.Descriptor instead.

func (*InvalidateUserTokensResult) ProtoMessage 

func (*InvalidateUserTokensResult) ProtoMessage()

func (*InvalidateUserTokensResult) ProtoReflect 

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

func (*InvalidateUserTokensResult) Reset 

func (x *InvalidateUserTokensResult) Reset()

func (*InvalidateUserTokensResult) String 

func (x *InvalidateUserTokensResult) String() string

type JSONCommandDecoder 

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

JSONCommandDecoder ...

func NewJSONCommandDecoder 

func NewJSONCommandDecoder(data []byte) *JSONCommandDecoder

NewJSONCommandDecoder ...

func (*JSONCommandDecoder) Decode 

func (d *JSONCommandDecoder) Decode() (*Command, error)

Decode ...

func (*JSONCommandDecoder) Reset 

func (d *JSONCommandDecoder) Reset(data []byte)

Reset ...

type JSONParamsDecoder 

type JSONParamsDecoder struct{}

JSONParamsDecoder ...

func NewJSONParamsDecoder 

func NewJSONParamsDecoder() *JSONParamsDecoder

NewJSONParamsDecoder ...

func (*JSONParamsDecoder) DecodeBroadcast 

func (d *JSONParamsDecoder) DecodeBroadcast(data []byte) (*BroadcastRequest, error)

DecodeBroadcast ...

func (*JSONParamsDecoder) DecodeChannels 

func (d *JSONParamsDecoder) DecodeChannels(data []byte) (*ChannelsRequest, error)

DecodeChannels ...

func (*JSONParamsDecoder) DecodeDisconnect 

func (d *JSONParamsDecoder) DecodeDisconnect(data []byte) (*DisconnectRequest, error)

DecodeDisconnect ...

func (*JSONParamsDecoder) DecodeHistory 

func (d *JSONParamsDecoder) DecodeHistory(data []byte) (*HistoryRequest, error)

DecodeHistory ...

func (*JSONParamsDecoder) DecodeHistoryRemove 

func (d *JSONParamsDecoder) DecodeHistoryRemove(data []byte) (*HistoryRemoveRequest, error)

DecodeHistoryRemove ...

func (*JSONParamsDecoder) DecodeInfo 

func (d *JSONParamsDecoder) DecodeInfo(data []byte) (*InfoRequest, error)

DecodeInfo ...

func (*JSONParamsDecoder) DecodePresence 

func (d *JSONParamsDecoder) DecodePresence(data []byte) (*PresenceRequest, error)

DecodePresence ...

func (*JSONParamsDecoder) DecodePresenceStats 

func (d *JSONParamsDecoder) DecodePresenceStats(data []byte) (*PresenceStatsRequest, error)

DecodePresenceStats ...

func (*JSONParamsDecoder) DecodePublish 

func (d *JSONParamsDecoder) DecodePublish(data []byte) (*PublishRequest, error)

DecodePublish ...

func (*JSONParamsDecoder) DecodeRPC 

func (d *JSONParamsDecoder) DecodeRPC(data []byte) (*RPCRequest, error)

DecodeRPC ...

func (*JSONParamsDecoder) DecodeRefresh 

func (d *JSONParamsDecoder) DecodeRefresh(data []byte) (*RefreshRequest, error)

DecodeRefresh ...

func (*JSONParamsDecoder) DecodeSubscribe 

func (d *JSONParamsDecoder) DecodeSubscribe(data []byte) (*SubscribeRequest, error)

DecodeSubscribe ...

func (*JSONParamsDecoder) DecodeUnsubscribe 

func (d *JSONParamsDecoder) DecodeUnsubscribe(data []byte) (*UnsubscribeRequest, error)

DecodeUnsubscribe ...

type JSONReplyEncoder 

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

JSONReplyEncoder ...

func NewJSONReplyEncoder 

func NewJSONReplyEncoder() *JSONReplyEncoder

NewJSONReplyEncoder ...

func (*JSONReplyEncoder) Encode 

func (e *JSONReplyEncoder) Encode(r *Reply) error

Encode ...

func (*JSONReplyEncoder) Finish 

func (e *JSONReplyEncoder) Finish() []byte

Finish ...

func (*JSONReplyEncoder) Reset 

func (e *JSONReplyEncoder) Reset()

Reset ...

type JSONResultEncoder 

type JSONResultEncoder struct{}

JSONResultEncoder ...

func NewJSONEncoder 

func NewJSONEncoder() *JSONResultEncoder

NewJSONEncoder ...

func (*JSONResultEncoder) EncodeBroadcast 

func (e *JSONResultEncoder) EncodeBroadcast(res *BroadcastResult) ([]byte, error)

EncodeBroadcast ...

func (*JSONResultEncoder) EncodeChannels 

func (e *JSONResultEncoder) EncodeChannels(res *ChannelsResult) ([]byte, error)

EncodeChannels ...

func (*JSONResultEncoder) EncodeDisconnect 

func (e *JSONResultEncoder) EncodeDisconnect(res *DisconnectResult) ([]byte, error)

EncodeDisconnect ...

func (*JSONResultEncoder) EncodeHistory 

func (e *JSONResultEncoder) EncodeHistory(res *HistoryResult) ([]byte, error)

EncodeHistory ...

func (*JSONResultEncoder) EncodeHistoryRemove 

func (e *JSONResultEncoder) EncodeHistoryRemove(res *HistoryRemoveResult) ([]byte, error)

EncodeHistoryRemove ...

func (*JSONResultEncoder) EncodeInfo 

func (e *JSONResultEncoder) EncodeInfo(res *InfoResult) ([]byte, error)

EncodeInfo ...

func (*JSONResultEncoder) EncodePresence 

func (e *JSONResultEncoder) EncodePresence(res *PresenceResult) ([]byte, error)

EncodePresence ...

func (*JSONResultEncoder) EncodePresenceStats 

func (e *JSONResultEncoder) EncodePresenceStats(res *PresenceStatsResult) ([]byte, error)

EncodePresenceStats ...

func (*JSONResultEncoder) EncodePublish 

func (e *JSONResultEncoder) EncodePublish(res *PublishResult) ([]byte, error)

EncodePublish ...

func (*JSONResultEncoder) EncodeRPC 

func (e *JSONResultEncoder) EncodeRPC(res *RPCResult) ([]byte, error)

EncodeRPC ...

func (*JSONResultEncoder) EncodeRefresh 

func (e *JSONResultEncoder) EncodeRefresh(res *RefreshResult) ([]byte, error)

EncodeRefresh ...

func (*JSONResultEncoder) EncodeSubscribe 

func (e *JSONResultEncoder) EncodeSubscribe(res *SubscribeResult) ([]byte, error)

EncodeSubscribe ...

func (*JSONResultEncoder) EncodeUnsubscribe 

func (e *JSONResultEncoder) EncodeUnsubscribe(res *UnsubscribeResult) ([]byte, error)

EncodeUnsubscribe ...

type Metrics 

type Metrics struct {
	Interval float64            `protobuf:"fixed64,1,opt,name=interval,proto3" json:"interval,omitempty"`
	Items    map[string]float64 `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Metrics) Descriptor deprecated 

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

Deprecated: Use Metrics.ProtoReflect.Descriptor instead.

func (*Metrics) GetInterval 

func (x *Metrics) GetInterval() float64

func (*Metrics) GetItems 

func (x *Metrics) GetItems() map[string]float64

func (*Metrics) ProtoMessage 

func (*Metrics) ProtoMessage()

func (*Metrics) ProtoReflect 

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

func (*Metrics) Reset 

func (x *Metrics) Reset()

func (*Metrics) String 

func (x *Metrics) String() string

type NodeResult 

type NodeResult struct {
	Uid         string   `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid"`
	Name        string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name"`
	Version     string   `protobuf:"bytes,3,opt,name=version,proto3" json:"version"`
	NumClients  uint32   `protobuf:"varint,4,opt,name=num_clients,json=numClients,proto3" json:"num_clients"`
	NumUsers    uint32   `protobuf:"varint,5,opt,name=num_users,json=numUsers,proto3" json:"num_users"`
	NumChannels uint32   `protobuf:"varint,6,opt,name=num_channels,json=numChannels,proto3" json:"num_channels"`
	Uptime      uint32   `protobuf:"varint,7,opt,name=uptime,proto3" json:"uptime,omitempty"`
	Metrics     *Metrics `protobuf:"bytes,8,opt,name=metrics,proto3" json:"metrics,omitempty"`
	Process     *Process `protobuf:"bytes,9,opt,name=process,proto3" json:"process,omitempty"`
	NumSubs     uint32   `protobuf:"varint,10,opt,name=num_subs,json=numSubs,proto3" json:"num_subs"`
	// contains filtered or unexported fields
}

func (*NodeResult) Descriptor deprecated 

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

Deprecated: Use NodeResult.ProtoReflect.Descriptor instead.

func (*NodeResult) GetMetrics 

func (x *NodeResult) GetMetrics() *Metrics

func (*NodeResult) GetName 

func (x *NodeResult) GetName() string

func (*NodeResult) GetNumChannels 

func (x *NodeResult) GetNumChannels() uint32

func (*NodeResult) GetNumClients 

func (x *NodeResult) GetNumClients() uint32

func (*NodeResult) GetNumSubs 

func (x *NodeResult) GetNumSubs() uint32

func (*NodeResult) GetNumUsers 

func (x *NodeResult) GetNumUsers() uint32

func (*NodeResult) GetProcess 

func (x *NodeResult) GetProcess() *Process

func (*NodeResult) GetUid 

func (x *NodeResult) GetUid() string

func (*NodeResult) GetUptime 

func (x *NodeResult) GetUptime() uint32

func (*NodeResult) GetVersion 

func (x *NodeResult) GetVersion() string

func (*NodeResult) ProtoMessage 

func (*NodeResult) ProtoMessage()

func (*NodeResult) ProtoReflect 

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

func (*NodeResult) Reset 

func (x *NodeResult) Reset()

func (*NodeResult) String 

func (x *NodeResult) String() string

type ParamsDecoder 

type ParamsDecoder interface {
	DecodePublish([]byte) (*PublishRequest, error)
	DecodeBroadcast([]byte) (*BroadcastRequest, error)
	DecodeSubscribe([]byte) (*SubscribeRequest, error)
	DecodeUnsubscribe([]byte) (*UnsubscribeRequest, error)
	DecodeDisconnect([]byte) (*DisconnectRequest, error)
	DecodePresence([]byte) (*PresenceRequest, error)
	DecodePresenceStats([]byte) (*PresenceStatsRequest, error)
	DecodeHistory([]byte) (*HistoryRequest, error)
	DecodeHistoryRemove([]byte) (*HistoryRemoveRequest, error)
	DecodeInfo([]byte) (*InfoRequest, error)
	DecodeRPC([]byte) (*RPCRequest, error)
	DecodeRefresh([]byte) (*RefreshRequest, error)
	DecodeChannels([]byte) (*ChannelsRequest, error)
}

ParamsDecoder ...

func GetParamsDecoder 

func GetParamsDecoder() ParamsDecoder

GetParamsDecoder ...

type PresenceRequest 

type PresenceRequest struct {
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	// contains filtered or unexported fields
}

func (*PresenceRequest) Descriptor deprecated 

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

Deprecated: Use PresenceRequest.ProtoReflect.Descriptor instead.

func (*PresenceRequest) GetChannel 

func (x *PresenceRequest) GetChannel() string

func (*PresenceRequest) ProtoMessage 

func (*PresenceRequest) ProtoMessage()

func (*PresenceRequest) ProtoReflect 

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

func (*PresenceRequest) Reset 

func (x *PresenceRequest) Reset()

func (*PresenceRequest) String 

func (x *PresenceRequest) String() string

type PresenceResponse 

type PresenceResponse struct {
	Error  *Error          `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Result *PresenceResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*PresenceResponse) Descriptor deprecated 

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

Deprecated: Use PresenceResponse.ProtoReflect.Descriptor instead.

func (*PresenceResponse) GetError 

func (x *PresenceResponse) GetError() *Error

func (*PresenceResponse) GetResult 

func (x *PresenceResponse) GetResult() *PresenceResult

func (*PresenceResponse) ProtoMessage 

func (*PresenceResponse) ProtoMessage()

func (*PresenceResponse) ProtoReflect 

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

func (*PresenceResponse) Reset 

func (x *PresenceResponse) Reset()

func (*PresenceResponse) String 

func (x *PresenceResponse) String() string

type PresenceResult 

type PresenceResult struct {
	Presence map[string]*ClientInfo `` /* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PresenceResult) Descriptor deprecated 

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

Deprecated: Use PresenceResult.ProtoReflect.Descriptor instead.

func (*PresenceResult) GetPresence 

func (x *PresenceResult) GetPresence() map[string]*ClientInfo

func (*PresenceResult) ProtoMessage 

func (*PresenceResult) ProtoMessage()

func (*PresenceResult) ProtoReflect 

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

func (*PresenceResult) Reset 

func (x *PresenceResult) Reset()

func (*PresenceResult) String 

func (x *PresenceResult) String() string

type PresenceStatsRequest 

type PresenceStatsRequest struct {
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	// contains filtered or unexported fields
}

func (*PresenceStatsRequest) Descriptor deprecated 

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

Deprecated: Use PresenceStatsRequest.ProtoReflect.Descriptor instead.

func (*PresenceStatsRequest) GetChannel 

func (x *PresenceStatsRequest) GetChannel() string

func (*PresenceStatsRequest) ProtoMessage 

func (*PresenceStatsRequest) ProtoMessage()

func (*PresenceStatsRequest) ProtoReflect 

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

func (*PresenceStatsRequest) Reset 

func (x *PresenceStatsRequest) Reset()

func (*PresenceStatsRequest) String 

func (x *PresenceStatsRequest) String() string

type PresenceStatsResponse 

type PresenceStatsResponse struct {
	Error  *Error               `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Result *PresenceStatsResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*PresenceStatsResponse) Descriptor deprecated 

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

Deprecated: Use PresenceStatsResponse.ProtoReflect.Descriptor instead.

func (*PresenceStatsResponse) GetError 

func (x *PresenceStatsResponse) GetError() *Error

func (*PresenceStatsResponse) GetResult 

func (x *PresenceStatsResponse) GetResult() *PresenceStatsResult

func (*PresenceStatsResponse) ProtoMessage 

func (*PresenceStatsResponse) ProtoMessage()

func (*PresenceStatsResponse) ProtoReflect 

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

func (*PresenceStatsResponse) Reset 

func (x *PresenceStatsResponse) Reset()

func (*PresenceStatsResponse) String 

func (x *PresenceStatsResponse) String() string

type PresenceStatsResult 

type PresenceStatsResult struct {
	NumClients uint32 `protobuf:"varint,1,opt,name=num_clients,json=numClients,proto3" json:"num_clients"`
	NumUsers   uint32 `protobuf:"varint,2,opt,name=num_users,json=numUsers,proto3" json:"num_users"`
	// contains filtered or unexported fields
}

func (*PresenceStatsResult) Descriptor deprecated 

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

Deprecated: Use PresenceStatsResult.ProtoReflect.Descriptor instead.

func (*PresenceStatsResult) GetNumClients 

func (x *PresenceStatsResult) GetNumClients() uint32

func (*PresenceStatsResult) GetNumUsers 

func (x *PresenceStatsResult) GetNumUsers() uint32

func (*PresenceStatsResult) ProtoMessage 

func (*PresenceStatsResult) ProtoMessage()

func (*PresenceStatsResult) ProtoReflect 

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

func (*PresenceStatsResult) Reset 

func (x *PresenceStatsResult) Reset()

func (*PresenceStatsResult) String 

func (x *PresenceStatsResult) String() string

type Process 

type Process struct {
	Cpu float64 `protobuf:"fixed64,1,opt,name=cpu,proto3" json:"cpu,omitempty"`
	Rss int64   `protobuf:"varint,2,opt,name=rss,proto3" json:"rss,omitempty"`
	// contains filtered or unexported fields
}

func (*Process) Descriptor deprecated 

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

Deprecated: Use Process.ProtoReflect.Descriptor instead.

func (*Process) GetCpu 

func (x *Process) GetCpu() float64

func (*Process) GetRss 

func (x *Process) GetRss() int64

func (*Process) ProtoMessage 

func (*Process) ProtoMessage()

func (*Process) ProtoReflect 

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

func (*Process) Reset 

func (x *Process) Reset()

func (*Process) String 

func (x *Process) String() string

type Publication 

type Publication struct {

	// Removed: string uid = 1;
	Data   Raw               `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Info   *ClientInfo       `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
	Offset uint64            `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"`
	Tags   map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Publication) Descriptor deprecated 

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

Deprecated: Use Publication.ProtoReflect.Descriptor instead.

func (*Publication) GetData 

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

func (*Publication) GetInfo 

func (x *Publication) GetInfo() *ClientInfo

func (*Publication) GetOffset 

func (x *Publication) GetOffset() uint64

func (*Publication) GetTags 

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

func (*Publication) ProtoMessage 

func (*Publication) ProtoMessage()

func (*Publication) ProtoReflect 

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

func (*Publication) Reset 

func (x *Publication) Reset()

func (*Publication) String 

func (x *Publication) String() string

type PublishRequest 

type PublishRequest struct {
	Channel     string            `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	Data        Raw               `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	B64Data     string            `protobuf:"bytes,3,opt,name=b64data,proto3" json:"b64data,omitempty"`
	SkipHistory bool              `protobuf:"varint,4,opt,name=skip_history,json=skipHistory,proto3" json:"skip_history,omitempty"`
	Tags        map[string]string `` /* 149-byte string literal not displayed */
	// 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) GetData 

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

func (*PublishRequest) GetSkipHistory 

func (x *PublishRequest) GetSkipHistory() bool

func (*PublishRequest) GetTags 

func (x *PublishRequest) GetTags() map[string]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 {
	Error  *Error         `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Result *PublishResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishResponse) Descriptor deprecated 

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

Deprecated: Use PublishResponse.ProtoReflect.Descriptor instead.

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 {
	Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	Epoch  string `protobuf:"bytes,2,opt,name=epoch,proto3" json:"epoch,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishResult) Descriptor deprecated 

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

Deprecated: Use PublishResult.ProtoReflect.Descriptor instead.

func (*PublishResult) GetEpoch 

func (x *PublishResult) GetEpoch() string

func (*PublishResult) GetOffset 

func (x *PublishResult) GetOffset() uint64

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 {
	Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	Params Raw    `protobuf:"bytes,2,opt,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

func (*RPCRequest) Descriptor deprecated 

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

Deprecated: Use RPCRequest.ProtoReflect.Descriptor instead.

func (*RPCRequest) GetMethod 

func (x *RPCRequest) GetMethod() string

func (*RPCRequest) GetParams 

func (x *RPCRequest) GetParams() []byte

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 {
	Error  *Error     `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Result *RPCResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*RPCResponse) Descriptor deprecated 

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

Deprecated: Use RPCResponse.ProtoReflect.Descriptor instead.

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"`
	// contains filtered or unexported fields
}

func (*RPCResult) Descriptor deprecated 

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

Deprecated: Use RPCResult.ProtoReflect.Descriptor instead.

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. For example custom application specific JSON payload data in published message. This is very similar to json.RawMessage type.

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 {
	User     string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Client   string `protobuf:"bytes,2,opt,name=client,proto3" json:"client,omitempty"`
	Expired  bool   `protobuf:"varint,3,opt,name=expired,proto3" json:"expired,omitempty"`
	ExpireAt int64  `protobuf:"varint,4,opt,name=expire_at,json=expireAt,proto3" json:"expire_at,omitempty"`
	Info     Raw    `protobuf:"bytes,5,opt,name=info,proto3" json:"info,omitempty"`
	Session  string `protobuf:"bytes,6,opt,name=session,proto3" json:"session,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) GetExpireAt 

func (x *RefreshRequest) GetExpireAt() int64

func (*RefreshRequest) GetExpired 

func (x *RefreshRequest) GetExpired() bool

func (*RefreshRequest) GetInfo 

func (x *RefreshRequest) GetInfo() []byte

func (*RefreshRequest) GetSession 

func (x *RefreshRequest) GetSession() 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 {
	Error  *Error         `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Result *RefreshResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*RefreshResponse) Descriptor deprecated 

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

Deprecated: Use RefreshResponse.ProtoReflect.Descriptor instead.

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 {
	// contains filtered or unexported fields
}

func (*RefreshResult) Descriptor deprecated 

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

Deprecated: Use RefreshResult.ProtoReflect.Descriptor instead.

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 Reply 

type Reply struct {
	Id     uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Error  *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Result Raw    `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*Reply) Descriptor deprecated 

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

Deprecated: Use Reply.ProtoReflect.Descriptor instead.

func (*Reply) GetError 

func (x *Reply) GetError() *Error

func (*Reply) GetId 

func (x *Reply) GetId() uint32

func (*Reply) GetResult 

func (x *Reply) GetResult() []byte

func (*Reply) ProtoMessage 

func (*Reply) ProtoMessage()

func (*Reply) ProtoReflect 

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

func (*Reply) Reset 

func (x *Reply) Reset()

func (*Reply) String 

func (x *Reply) String() string

type ReplyEncoder 

type ReplyEncoder interface {
	Reset()
	Encode(*Reply) error
	Finish() []byte
}

ReplyEncoder ...

func GetReplyEncoder 

func GetReplyEncoder() ReplyEncoder

GetReplyEncoder ...

type ResultEncoder 

type ResultEncoder interface {
	EncodePublish(*PublishResult) ([]byte, error)
	EncodeBroadcast(*BroadcastResult) ([]byte, error)
	EncodeSubscribe(*SubscribeResult) ([]byte, error)
	EncodeUnsubscribe(*UnsubscribeResult) ([]byte, error)
	EncodeDisconnect(*DisconnectResult) ([]byte, error)
	EncodePresence(*PresenceResult) ([]byte, error)
	EncodePresenceStats(*PresenceStatsResult) ([]byte, error)
	EncodeHistory(*HistoryResult) ([]byte, error)
	EncodeHistoryRemove(*HistoryRemoveResult) ([]byte, error)
	EncodeInfo(*InfoResult) ([]byte, error)
	EncodeRPC(*RPCResult) ([]byte, error)
	EncodeRefresh(*RefreshResult) ([]byte, error)
	EncodeChannels(*ChannelsResult) ([]byte, error)
}

ResultEncoder ...

func GetResultEncoder 

func GetResultEncoder() ResultEncoder

GetResultEncoder ...

type RevokeTokenRequest 

type RevokeTokenRequest struct {
	ExpireAt int64  `protobuf:"varint,1,opt,name=expire_at,json=expireAt,proto3" json:"expire_at,omitempty"`
	Uid      string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	// contains filtered or unexported fields
}

func (*RevokeTokenRequest) Descriptor deprecated 

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

Deprecated: Use RevokeTokenRequest.ProtoReflect.Descriptor instead.

func (*RevokeTokenRequest) GetExpireAt 

func (x *RevokeTokenRequest) GetExpireAt() int64

func (*RevokeTokenRequest) GetUid 

func (x *RevokeTokenRequest) GetUid() string

func (*RevokeTokenRequest) ProtoMessage 

func (*RevokeTokenRequest) ProtoMessage()

func (*RevokeTokenRequest) ProtoReflect 

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

func (*RevokeTokenRequest) Reset 

func (x *RevokeTokenRequest) Reset()

func (*RevokeTokenRequest) String 

func (x *RevokeTokenRequest) String() string

type RevokeTokenResponse 

type RevokeTokenResponse struct {
	Error  *Error             `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Result *RevokeTokenResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*RevokeTokenResponse) Descriptor deprecated 

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

Deprecated: Use RevokeTokenResponse.ProtoReflect.Descriptor instead.

func (*RevokeTokenResponse) GetError 

func (x *RevokeTokenResponse) GetError() *Error

func (*RevokeTokenResponse) GetResult 

func (x *RevokeTokenResponse) GetResult() *RevokeTokenResult

func (*RevokeTokenResponse) ProtoMessage 

func (*RevokeTokenResponse) ProtoMessage()

func (*RevokeTokenResponse) ProtoReflect 

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

func (*RevokeTokenResponse) Reset 

func (x *RevokeTokenResponse) Reset()

func (*RevokeTokenResponse) String 

func (x *RevokeTokenResponse) String() string

type RevokeTokenResult 

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

func (*RevokeTokenResult) Descriptor deprecated 

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

Deprecated: Use RevokeTokenResult.ProtoReflect.Descriptor instead.

func (*RevokeTokenResult) ProtoMessage 

func (*RevokeTokenResult) ProtoMessage()

func (*RevokeTokenResult) ProtoReflect 

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

func (*RevokeTokenResult) Reset 

func (x *RevokeTokenResult) Reset()

func (*RevokeTokenResult) String 

func (x *RevokeTokenResult) String() string

type StreamPosition 

type StreamPosition struct {
	Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	Epoch  string `protobuf:"bytes,2,opt,name=epoch,proto3" json:"epoch,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamPosition) Descriptor deprecated 

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

Deprecated: Use StreamPosition.ProtoReflect.Descriptor instead.

func (*StreamPosition) GetEpoch 

func (x *StreamPosition) GetEpoch() string

func (*StreamPosition) GetOffset 

func (x *StreamPosition) GetOffset() uint64

func (*StreamPosition) ProtoMessage 

func (*StreamPosition) ProtoMessage()

func (*StreamPosition) ProtoReflect 

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

func (*StreamPosition) Reset 

func (x *StreamPosition) Reset()

func (*StreamPosition) String 

func (x *StreamPosition) 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 SubscribeRequest 

type SubscribeRequest struct {
	Channel      string                   `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	User         string                   `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	ExpireAt     int64                    `protobuf:"varint,3,opt,name=expire_at,json=expireAt,proto3" json:"expire_at,omitempty"`
	Info         Raw                      `protobuf:"bytes,4,opt,name=info,proto3" json:"info,omitempty"`
	B64Info      string                   `protobuf:"bytes,5,opt,name=b64info,proto3" json:"b64info,omitempty"`
	Client       string                   `protobuf:"bytes,6,opt,name=client,proto3" json:"client,omitempty"`
	Data         Raw                      `protobuf:"bytes,7,opt,name=data,proto3" json:"data,omitempty"`
	B64Data      string                   `protobuf:"bytes,8,opt,name=b64data,proto3" json:"b64data,omitempty"`
	RecoverSince *StreamPosition          `protobuf:"bytes,9,opt,name=recover_since,json=recoverSince,proto3" json:"recover_since,omitempty"`
	Override     *SubscribeOptionOverride `protobuf:"bytes,10,opt,name=override,proto3" json:"override,omitempty"`
	Session      string                   `protobuf:"bytes,11,opt,name=session,proto3" json:"session,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) GetB64Info 

func (x *SubscribeRequest) GetB64Info() 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) GetExpireAt 

func (x *SubscribeRequest) GetExpireAt() int64

func (*SubscribeRequest) GetInfo 

func (x *SubscribeRequest) GetInfo() []byte

func (*SubscribeRequest) GetOverride 

func (x *SubscribeRequest) GetOverride() *SubscribeOptionOverride

func (*SubscribeRequest) GetRecoverSince 

func (x *SubscribeRequest) GetRecoverSince() *StreamPosition

func (*SubscribeRequest) GetSession 

func (x *SubscribeRequest) GetSession() 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 {
	Error  *Error           `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Result *SubscribeResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeResponse) Descriptor deprecated 

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

Deprecated: Use SubscribeResponse.ProtoReflect.Descriptor instead.

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 {
	// contains filtered or unexported fields
}

func (*SubscribeResult) Descriptor deprecated 

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

Deprecated: Use SubscribeResult.ProtoReflect.Descriptor instead.

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 SubscriptionTokenInfo 

type SubscriptionTokenInfo struct {
	Uid      string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
	IssuedAt int64  `protobuf:"varint,2,opt,name=issued_at,json=issuedAt,proto3" json:"issued_at,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscriptionTokenInfo) Descriptor deprecated 

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

Deprecated: Use SubscriptionTokenInfo.ProtoReflect.Descriptor instead.

func (*SubscriptionTokenInfo) GetIssuedAt 

func (x *SubscriptionTokenInfo) GetIssuedAt() int64

func (*SubscriptionTokenInfo) GetUid 

func (x *SubscriptionTokenInfo) GetUid() string

func (*SubscriptionTokenInfo) ProtoMessage 

func (*SubscriptionTokenInfo) ProtoMessage()

func (*SubscriptionTokenInfo) ProtoReflect 

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

func (*SubscriptionTokenInfo) Reset 

func (x *SubscriptionTokenInfo) Reset()

func (*SubscriptionTokenInfo) String 

func (x *SubscriptionTokenInfo) String() string

type UnblockUserRequest 

type UnblockUserRequest struct {
	User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	// contains filtered or unexported fields
}

func (*UnblockUserRequest) Descriptor deprecated 

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

Deprecated: Use UnblockUserRequest.ProtoReflect.Descriptor instead.

func (*UnblockUserRequest) GetUser 

func (x *UnblockUserRequest) GetUser() string

func (*UnblockUserRequest) ProtoMessage 

func (*UnblockUserRequest) ProtoMessage()

func (*UnblockUserRequest) ProtoReflect 

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

func (*UnblockUserRequest) Reset 

func (x *UnblockUserRequest) Reset()

func (*UnblockUserRequest) String 

func (x *UnblockUserRequest) String() string

type UnblockUserResponse 

type UnblockUserResponse struct {
	Error  *Error             `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Result *UnblockUserResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*UnblockUserResponse) Descriptor deprecated 

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

Deprecated: Use UnblockUserResponse.ProtoReflect.Descriptor instead.

func (*UnblockUserResponse) GetError 

func (x *UnblockUserResponse) GetError() *Error

func (*UnblockUserResponse) GetResult 

func (x *UnblockUserResponse) GetResult() *UnblockUserResult

func (*UnblockUserResponse) ProtoMessage 

func (*UnblockUserResponse) ProtoMessage()

func (*UnblockUserResponse) ProtoReflect 

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

func (*UnblockUserResponse) Reset 

func (x *UnblockUserResponse) Reset()

func (*UnblockUserResponse) String 

func (x *UnblockUserResponse) String() string

type UnblockUserResult 

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

func (*UnblockUserResult) Descriptor deprecated 

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

Deprecated: Use UnblockUserResult.ProtoReflect.Descriptor instead.

func (*UnblockUserResult) ProtoMessage 

func (*UnblockUserResult) ProtoMessage()

func (*UnblockUserResult) ProtoReflect 

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

func (*UnblockUserResult) Reset 

func (x *UnblockUserResult) Reset()

func (*UnblockUserResult) String 

func (x *UnblockUserResult) String() string

type UnimplementedCentrifugoApiServer 

type UnimplementedCentrifugoApiServer struct {
}

UnimplementedCentrifugoApiServer must be embedded to have forward compatible implementations.

func (UnimplementedCentrifugoApiServer) BlockUser 

func (UnimplementedCentrifugoApiServer) BlockUser(context.Context, *BlockUserRequest) (*BlockUserResponse, error)

func (UnimplementedCentrifugoApiServer) Broadcast 

func (UnimplementedCentrifugoApiServer) Broadcast(context.Context, *BroadcastRequest) (*BroadcastResponse, error)

func (UnimplementedCentrifugoApiServer) Channels 

func (UnimplementedCentrifugoApiServer) Channels(context.Context, *ChannelsRequest) (*ChannelsResponse, error)

func (UnimplementedCentrifugoApiServer) Connections 

func (UnimplementedCentrifugoApiServer) Connections(context.Context, *ConnectionsRequest) (*ConnectionsResponse, error)

func (UnimplementedCentrifugoApiServer) DeleteUserStatus 

func (UnimplementedCentrifugoApiServer) DeleteUserStatus(context.Context, *DeleteUserStatusRequest) (*DeleteUserStatusResponse, error)

func (UnimplementedCentrifugoApiServer) Disconnect 

func (UnimplementedCentrifugoApiServer) Disconnect(context.Context, *DisconnectRequest) (*DisconnectResponse, error)

func (UnimplementedCentrifugoApiServer) GetUserStatus 

func (UnimplementedCentrifugoApiServer) GetUserStatus(context.Context, *GetUserStatusRequest) (*GetUserStatusResponse, error)

func (UnimplementedCentrifugoApiServer) History 

func (UnimplementedCentrifugoApiServer) History(context.Context, *HistoryRequest) (*HistoryResponse, error)

func (UnimplementedCentrifugoApiServer) HistoryRemove 

func (UnimplementedCentrifugoApiServer) HistoryRemove(context.Context, *HistoryRemoveRequest) (*HistoryRemoveResponse, error)

func (UnimplementedCentrifugoApiServer) Info 

func (UnimplementedCentrifugoApiServer) Info(context.Context, *InfoRequest) (*InfoResponse, error)

func (UnimplementedCentrifugoApiServer) InvalidateUserTokens 

func (UnimplementedCentrifugoApiServer) InvalidateUserTokens(context.Context, *InvalidateUserTokensRequest) (*InvalidateUserTokensResponse, error)

func (UnimplementedCentrifugoApiServer) Presence 

func (UnimplementedCentrifugoApiServer) Presence(context.Context, *PresenceRequest) (*PresenceResponse, error)

func (UnimplementedCentrifugoApiServer) PresenceStats 

func (UnimplementedCentrifugoApiServer) PresenceStats(context.Context, *PresenceStatsRequest) (*PresenceStatsResponse, error)

func (UnimplementedCentrifugoApiServer) Publish 

func (UnimplementedCentrifugoApiServer) Publish(context.Context, *PublishRequest) (*PublishResponse, error)

func (UnimplementedCentrifugoApiServer) RPC 

func (UnimplementedCentrifugoApiServer) RPC(context.Context, *RPCRequest) (*RPCResponse, error)

func (UnimplementedCentrifugoApiServer) Refresh 

func (UnimplementedCentrifugoApiServer) Refresh(context.Context, *RefreshRequest) (*RefreshResponse, error)

func (UnimplementedCentrifugoApiServer) RevokeToken 

func (UnimplementedCentrifugoApiServer) RevokeToken(context.Context, *RevokeTokenRequest) (*RevokeTokenResponse, error)

func (UnimplementedCentrifugoApiServer) Subscribe 

func (UnimplementedCentrifugoApiServer) Subscribe(context.Context, *SubscribeRequest) (*SubscribeResponse, error)

func (UnimplementedCentrifugoApiServer) UnblockUser 

func (UnimplementedCentrifugoApiServer) UnblockUser(context.Context, *UnblockUserRequest) (*UnblockUserResponse, error)

func (UnimplementedCentrifugoApiServer) Unsubscribe 

func (UnimplementedCentrifugoApiServer) Unsubscribe(context.Context, *UnsubscribeRequest) (*UnsubscribeResponse, error)

func (UnimplementedCentrifugoApiServer) UpdateUserStatus 

func (UnimplementedCentrifugoApiServer) UpdateUserStatus(context.Context, *UpdateUserStatusRequest) (*UpdateUserStatusResponse, error)

type UnsafeCentrifugoApiServer 

type UnsafeCentrifugoApiServer interface {
	// contains filtered or unexported methods
}

UnsafeCentrifugoApiServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CentrifugoApiServer will result in compilation errors.

type UnsubscribeRequest 

type UnsubscribeRequest struct {
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	User    string `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	Client  string `protobuf:"bytes,3,opt,name=client,proto3" json:"client,omitempty"`
	Session string `protobuf:"bytes,4,opt,name=session,proto3" json:"session,omitempty"`
	// contains filtered or unexported fields
}

func (*UnsubscribeRequest) Descriptor deprecated 

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

Deprecated: Use UnsubscribeRequest.ProtoReflect.Descriptor instead.

func (*UnsubscribeRequest) GetChannel 

func (x *UnsubscribeRequest) GetChannel() string

func (*UnsubscribeRequest) GetClient 

func (x *UnsubscribeRequest) GetClient() string

func (*UnsubscribeRequest) GetSession 

func (x *UnsubscribeRequest) GetSession() string

func (*UnsubscribeRequest) GetUser 

func (x *UnsubscribeRequest) GetUser() string

func (*UnsubscribeRequest) ProtoMessage 

func (*UnsubscribeRequest) ProtoMessage()

func (*UnsubscribeRequest) ProtoReflect 

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

func (*UnsubscribeRequest) Reset 

func (x *UnsubscribeRequest) Reset()

func (*UnsubscribeRequest) String 

func (x *UnsubscribeRequest) String() string

type UnsubscribeResponse 

type UnsubscribeResponse struct {
	Error  *Error             `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Result *UnsubscribeResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*UnsubscribeResponse) Descriptor deprecated 

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

Deprecated: Use UnsubscribeResponse.ProtoReflect.Descriptor instead.

func (*UnsubscribeResponse) GetError 

func (x *UnsubscribeResponse) GetError() *Error

func (*UnsubscribeResponse) GetResult 

func (x *UnsubscribeResponse) GetResult() *UnsubscribeResult

func (*UnsubscribeResponse) ProtoMessage 

func (*UnsubscribeResponse) ProtoMessage()

func (*UnsubscribeResponse) ProtoReflect 

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

func (*UnsubscribeResponse) Reset 

func (x *UnsubscribeResponse) Reset()

func (*UnsubscribeResponse) String 

func (x *UnsubscribeResponse) String() string

type UnsubscribeResult 

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

func (*UnsubscribeResult) Descriptor deprecated 

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

Deprecated: Use UnsubscribeResult.ProtoReflect.Descriptor instead.

func (*UnsubscribeResult) ProtoMessage 

func (*UnsubscribeResult) ProtoMessage()

func (*UnsubscribeResult) ProtoReflect 

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

func (*UnsubscribeResult) Reset 

func (x *UnsubscribeResult) Reset()

func (*UnsubscribeResult) String 

func (x *UnsubscribeResult) String() string

type UpdateUserStatusRequest 

type UpdateUserStatusRequest struct {
	Users []string `protobuf:"bytes,1,rep,name=users,proto3" json:"users,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateUserStatusRequest) Descriptor deprecated 

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

Deprecated: Use UpdateUserStatusRequest.ProtoReflect.Descriptor instead.

func (*UpdateUserStatusRequest) GetUsers 

func (x *UpdateUserStatusRequest) GetUsers() []string

func (*UpdateUserStatusRequest) ProtoMessage 

func (*UpdateUserStatusRequest) ProtoMessage()

func (*UpdateUserStatusRequest) ProtoReflect 

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

func (*UpdateUserStatusRequest) Reset 

func (x *UpdateUserStatusRequest) Reset()

func (*UpdateUserStatusRequest) String 

func (x *UpdateUserStatusRequest) String() string

type UpdateUserStatusResponse 

type UpdateUserStatusResponse struct {
	Error  *Error                  `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Result *UpdateUserStatusResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateUserStatusResponse) Descriptor deprecated 

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

Deprecated: Use UpdateUserStatusResponse.ProtoReflect.Descriptor instead.

func (*UpdateUserStatusResponse) GetError 

func (x *UpdateUserStatusResponse) GetError() *Error

func (*UpdateUserStatusResponse) GetResult 

func (x *UpdateUserStatusResponse) GetResult() *UpdateUserStatusResult

func (*UpdateUserStatusResponse) ProtoMessage 

func (*UpdateUserStatusResponse) ProtoMessage()

func (*UpdateUserStatusResponse) ProtoReflect 

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

func (*UpdateUserStatusResponse) Reset 

func (x *UpdateUserStatusResponse) Reset()

func (*UpdateUserStatusResponse) String 

func (x *UpdateUserStatusResponse) String() string

type UpdateUserStatusResult 

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

func (*UpdateUserStatusResult) Descriptor deprecated 

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

Deprecated: Use UpdateUserStatusResult.ProtoReflect.Descriptor instead.

func (*UpdateUserStatusResult) ProtoMessage 

func (*UpdateUserStatusResult) ProtoMessage()

func (*UpdateUserStatusResult) ProtoReflect 

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

func (*UpdateUserStatusResult) Reset 

func (x *UpdateUserStatusResult) Reset()

func (*UpdateUserStatusResult) String 

func (x *UpdateUserStatusResult) String() string

type UserStatus 

type UserStatus struct {
	User   string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Active int64  `protobuf:"varint,2,opt,name=active,proto3" json:"active,omitempty"`
	Online int64  `protobuf:"varint,3,opt,name=online,proto3" json:"online,omitempty"`
	// contains filtered or unexported fields
}

func (*UserStatus) Descriptor deprecated 

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

Deprecated: Use UserStatus.ProtoReflect.Descriptor instead.

func (*UserStatus) GetActive 

func (x *UserStatus) GetActive() int64

func (*UserStatus) GetOnline 

func (x *UserStatus) GetOnline() int64

func (*UserStatus) GetUser 

func (x *UserStatus) GetUser() string

func (*UserStatus) ProtoMessage 

func (*UserStatus) ProtoMessage()

func (*UserStatus) ProtoReflect 

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

func (*UserStatus) Reset 

func (x *UserStatus) Reset()

func (*UserStatus) String 

func (x *UserStatus) String() string

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.