apiproto

package

Go to main page

Versions in this module

v3

v3.2.3

Jun 30, 2022

v3.2.2

Jun 8, 2022

v3.2.1

May 30, 2022

Changes in this version

type InvalidateUserTokensRequest

+ Channel string

+ func (x *InvalidateUserTokensRequest) GetChannel() string

v3.2.0

Apr 29, 2022

Changes in this version

type BroadcastRequest

+ Tags map[string]string

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

type DisconnectRequest

+ Session string

+ func (x *DisconnectRequest) GetSession() string

type Publication

+ Tags map[string]string

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

type PublishRequest

+ Tags map[string]string

+ func (x *PublishRequest) GetTags() map[string]string

type RefreshRequest

+ Session string

+ func (x *RefreshRequest) GetSession() string

type SubscribeRequest

+ Session string

+ func (x *SubscribeRequest) GetSession() string

type UnsubscribeRequest

+ Session string

+ func (x *UnsubscribeRequest) GetSession() string

v3.1.1

Dec 5, 2021

v3.1.0

Nov 6, 2021

Changes in this version

+ type BlockUserRequest struct

+ ExpireAt int64

+ User string

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

+ func (*BlockUserRequest) ProtoMessage()

+ func (x *BlockUserRequest) GetExpireAt() int64

+ func (x *BlockUserRequest) GetUser() string

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

+ func (x *BlockUserRequest) Reset()

+ func (x *BlockUserRequest) String() string

+ type BlockUserResponse struct

+ Error *Error

+ Result *BlockUserResult

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

+ func (*BlockUserResponse) ProtoMessage()

+ func (x *BlockUserResponse) GetError() *Error

+ func (x *BlockUserResponse) GetResult() *BlockUserResult

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

+ func (x *BlockUserResponse) Reset()

+ func (x *BlockUserResponse) String() string

+ type BlockUserResult struct

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

+ func (*BlockUserResult) ProtoMessage()

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

+ func (x *BlockUserResult) Reset()

+ func (x *BlockUserResult) String() string

type CentrifugoApiClient

+ BlockUser func(ctx context.Context, in *BlockUserRequest, opts ...grpc.CallOption) (*BlockUserResponse, error)

+ InvalidateUserTokens func(ctx context.Context, in *InvalidateUserTokensRequest, opts ...grpc.CallOption) (*InvalidateUserTokensResponse, error)

+ RevokeToken func(ctx context.Context, in *RevokeTokenRequest, opts ...grpc.CallOption) (*RevokeTokenResponse, error)

+ UnblockUser func(ctx context.Context, in *UnblockUserRequest, opts ...grpc.CallOption) (*UnblockUserResponse, error)

type CentrifugoApiServer

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

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

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

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

type Command_MethodType

+ const Command_BLOCK_USER

+ const Command_INVALIDATE_USER_TOKENS

+ const Command_REVOKE_TOKEN

+ const Command_UNBLOCK_USER

+ type InvalidateUserTokensRequest struct

+ ExpireAt int64

+ IssuedBefore int64

+ User string

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

+ func (*InvalidateUserTokensRequest) ProtoMessage()

+ func (x *InvalidateUserTokensRequest) GetExpireAt() int64

+ func (x *InvalidateUserTokensRequest) GetIssuedBefore() int64

+ func (x *InvalidateUserTokensRequest) GetUser() string

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

+ func (x *InvalidateUserTokensRequest) Reset()

+ func (x *InvalidateUserTokensRequest) String() string

+ type InvalidateUserTokensResponse struct

+ Error *Error

+ Result *InvalidateUserTokensResult

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

+ func (*InvalidateUserTokensResponse) ProtoMessage()

+ func (x *InvalidateUserTokensResponse) GetError() *Error

+ func (x *InvalidateUserTokensResponse) GetResult() *InvalidateUserTokensResult

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

+ func (x *InvalidateUserTokensResponse) Reset()

+ func (x *InvalidateUserTokensResponse) String() string

+ type InvalidateUserTokensResult struct

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

+ func (*InvalidateUserTokensResult) ProtoMessage()

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

+ func (x *InvalidateUserTokensResult) Reset()

+ func (x *InvalidateUserTokensResult) String() string

+ type RevokeTokenRequest struct

+ ExpireAt int64

+ Uid string

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

+ func (*RevokeTokenRequest) ProtoMessage()

+ func (x *RevokeTokenRequest) GetExpireAt() int64

+ func (x *RevokeTokenRequest) GetUid() string

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

+ func (x *RevokeTokenRequest) Reset()

+ func (x *RevokeTokenRequest) String() string

+ type RevokeTokenResponse struct

+ Error *Error

+ Result *RevokeTokenResult

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

+ func (*RevokeTokenResponse) ProtoMessage()

+ func (x *RevokeTokenResponse) GetError() *Error

+ func (x *RevokeTokenResponse) GetResult() *RevokeTokenResult

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

+ func (x *RevokeTokenResponse) Reset()

+ func (x *RevokeTokenResponse) String() string

+ type RevokeTokenResult struct

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

+ func (*RevokeTokenResult) ProtoMessage()

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

+ func (x *RevokeTokenResult) Reset()

+ func (x *RevokeTokenResult) String() string

+ type UnblockUserRequest struct

+ User string

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

+ func (*UnblockUserRequest) ProtoMessage()

+ func (x *UnblockUserRequest) GetUser() string

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

+ func (x *UnblockUserRequest) Reset()

+ func (x *UnblockUserRequest) String() string

+ type UnblockUserResponse struct

+ Error *Error

+ Result *UnblockUserResult

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

+ func (*UnblockUserResponse) ProtoMessage()

+ func (x *UnblockUserResponse) GetError() *Error

+ func (x *UnblockUserResponse) GetResult() *UnblockUserResult

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

+ func (x *UnblockUserResponse) Reset()

+ func (x *UnblockUserResponse) String() string

+ type UnblockUserResult struct

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

+ func (*UnblockUserResult) ProtoMessage()

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

+ func (x *UnblockUserResult) Reset()

+ func (x *UnblockUserResult) String() string

type UnimplementedCentrifugoApiServer

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

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

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

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

type UserConnectionInfo

+ TokenIssuedAt int64

+ TokenUid string

+ func (x *UserConnectionInfo) GetTokenIssuedAt() int64

+ func (x *UserConnectionInfo) GetTokenUid() string

v3.0.5

Oct 18, 2021

v3.0.4

Oct 16, 2021

v3.0.3

Oct 10, 2021

v3.0.2

Oct 6, 2021

v3.0.1

Sep 12, 2021

v3.0.0

Sep 1, 2021

Changes in this version

+ var CentrifugoApi_ServiceDesc = grpc.ServiceDesc

+ var Command_MethodType_name = map[int32]string

+ var Command_MethodType_value = map[string]int32

+ var ErrorBadRequest = &Error

+ var ErrorInternal = &Error

+ var ErrorMethodNotFound = &Error

+ var ErrorNotAvailable = &Error

+ var ErrorUnknownChannel = &Error

+ var ErrorUnrecoverablePosition = &Error

+ var File_api_proto protoreflect.FileDescriptor

+ func PutCommandDecoder(d CommandDecoder)

+ func PutParamsDecoder(_ ParamsDecoder)

+ func PutReplyEncoder(e ReplyEncoder)

+ func PutResultEncoder(_ ResultEncoder)

+ func RegisterCentrifugoApiServer(s grpc.ServiceRegistrar, srv CentrifugoApiServer)

+ type BoolValue struct

+ Value bool

+ func (*BoolValue) Descriptor() ([]byte, []int)

+ func (*BoolValue) ProtoMessage()

+ func (x *BoolValue) GetValue() bool

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

+ func (x *BoolValue) Reset()

+ func (x *BoolValue) String() string

+ type BroadcastRequest struct

+ B64Data string

+ Channels []string

+ Data Raw

+ SkipHistory bool

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

+ func (*BroadcastRequest) ProtoMessage()

+ func (x *BroadcastRequest) GetB64Data() string

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

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

+ func (x *BroadcastRequest) GetSkipHistory() bool

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

+ func (x *BroadcastRequest) Reset()

+ func (x *BroadcastRequest) String() string

+ type BroadcastResponse struct

+ Error *Error

+ Result *BroadcastResult

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

+ func (*BroadcastResponse) ProtoMessage()

+ func (x *BroadcastResponse) GetError() *Error

+ func (x *BroadcastResponse) GetResult() *BroadcastResult

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

+ func (x *BroadcastResponse) Reset()

+ func (x *BroadcastResponse) String() string

+ type BroadcastResult struct

+ Responses []*PublishResponse

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

+ func (*BroadcastResult) ProtoMessage()

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

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

+ func (x *BroadcastResult) Reset()

+ func (x *BroadcastResult) String() string

+ type CentrifugoApiClient interface

+ Broadcast func(ctx context.Context, in *BroadcastRequest, opts ...grpc.CallOption) (*BroadcastResponse, error)

+ Channels func(ctx context.Context, in *ChannelsRequest, opts ...grpc.CallOption) (*ChannelsResponse, error)

+ DeleteUserStatus func(ctx context.Context, in *DeleteUserStatusRequest, opts ...grpc.CallOption) (*DeleteUserStatusResponse, error)

+ Disconnect func(ctx context.Context, in *DisconnectRequest, opts ...grpc.CallOption) (*DisconnectResponse, error)

+ GetUserStatus func(ctx context.Context, in *GetUserStatusRequest, opts ...grpc.CallOption) (*GetUserStatusResponse, error)

+ History func(ctx context.Context, in *HistoryRequest, opts ...grpc.CallOption) (*HistoryResponse, error)

+ HistoryRemove func(ctx context.Context, in *HistoryRemoveRequest, opts ...grpc.CallOption) (*HistoryRemoveResponse, error)

+ Info func(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error)

+ Presence func(ctx context.Context, in *PresenceRequest, opts ...grpc.CallOption) (*PresenceResponse, error)

+ PresenceStats func(ctx context.Context, in *PresenceStatsRequest, opts ...grpc.CallOption) (*PresenceStatsResponse, error)

+ Publish func(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error)

+ RPC func(ctx context.Context, in *RPCRequest, opts ...grpc.CallOption) (*RPCResponse, error)

+ Refresh func(ctx context.Context, in *RefreshRequest, opts ...grpc.CallOption) (*RefreshResponse, error)

+ Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (*SubscribeResponse, error)

+ Unsubscribe func(ctx context.Context, in *UnsubscribeRequest, opts ...grpc.CallOption) (*UnsubscribeResponse, error)

+ UpdateUserStatus func(ctx context.Context, in *UpdateUserStatusRequest, opts ...grpc.CallOption) (*UpdateUserStatusResponse, error)

+ UserConnections func(ctx context.Context, in *UserConnectionsRequest, opts ...grpc.CallOption) (*UserConnectionsResponse, error)

+ func NewCentrifugoApiClient(cc grpc.ClientConnInterface) CentrifugoApiClient

+ type CentrifugoApiServer interface

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ UserConnections func(context.Context, *UserConnectionsRequest) (*UserConnectionsResponse, error)

+ type ChannelInfo struct

+ NumClients uint32

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

+ func (*ChannelInfo) ProtoMessage()

+ func (x *ChannelInfo) GetNumClients() uint32

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

+ func (x *ChannelInfo) Reset()

+ func (x *ChannelInfo) String() string

+ type ChannelsRequest struct

+ Pattern string

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

+ func (*ChannelsRequest) ProtoMessage()

+ func (x *ChannelsRequest) GetPattern() string

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

+ func (x *ChannelsRequest) Reset()

+ func (x *ChannelsRequest) String() string

+ type ChannelsResponse struct

+ Error *Error

+ Result *ChannelsResult

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

+ func (*ChannelsResponse) ProtoMessage()

+ func (x *ChannelsResponse) GetError() *Error

+ func (x *ChannelsResponse) GetResult() *ChannelsResult

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

+ func (x *ChannelsResponse) Reset()

+ func (x *ChannelsResponse) String() string

+ type ChannelsResult struct

+ Channels map[string]*ChannelInfo

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

+ func (*ChannelsResult) ProtoMessage()

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

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

+ func (x *ChannelsResult) Reset()

+ func (x *ChannelsResult) String() string

+ type ClientInfo struct

+ ChanInfo Raw

+ Client string

+ ConnInfo Raw

+ User string

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

+ func (*ClientInfo) ProtoMessage()

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

+ func (x *ClientInfo) GetClient() string

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

+ func (x *ClientInfo) GetUser() string

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

+ func (x *ClientInfo) Reset()

+ func (x *ClientInfo) String() string

+ type Command struct

+ Id uint32

+ Method Command_MethodType

+ Params Raw

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

+ func (*Command) ProtoMessage()

+ func (x *Command) GetId() uint32

+ func (x *Command) GetMethod() Command_MethodType

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

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

+ func (x *Command) Reset()

+ func (x *Command) String() string

+ type CommandDecoder interface

+ Decode func() (*Command, error)

+ Reset func([]byte)

+ func GetCommandDecoder(data []byte) CommandDecoder

+ type Command_MethodType int32

+ const Command_BROADCAST

+ const Command_CHANNELS

+ const Command_DELETE_USER_STATUS

+ const Command_DISCONNECT

+ const Command_GET_USER_STATUS

+ const Command_HISTORY

+ const Command_HISTORY_REMOVE

+ const Command_INFO

+ const Command_PRESENCE

+ const Command_PRESENCE_STATS

+ const Command_PUBLISH

+ const Command_REFRESH

+ const Command_RPC

+ const Command_SUBSCRIBE

+ const Command_UNSUBSCRIBE

+ const Command_UPDATE_USER_STATUS

+ const Command_USER_CONNECTIONS

+ func (Command_MethodType) Descriptor() protoreflect.EnumDescriptor

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

+ func (Command_MethodType) Type() protoreflect.EnumType

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

+ func (x Command_MethodType) Enum() *Command_MethodType

+ func (x Command_MethodType) Number() protoreflect.EnumNumber

+ func (x Command_MethodType) String() string

+ type DeleteUserStatusRequest struct

+ Users []string

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

+ func (*DeleteUserStatusRequest) ProtoMessage()

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

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

+ func (x *DeleteUserStatusRequest) Reset()

+ func (x *DeleteUserStatusRequest) String() string

+ type DeleteUserStatusResponse struct

+ Error *Error

+ Result *DeleteUserStatusResult

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

+ func (*DeleteUserStatusResponse) ProtoMessage()

+ func (x *DeleteUserStatusResponse) GetError() *Error

+ func (x *DeleteUserStatusResponse) GetResult() *DeleteUserStatusResult

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

+ func (x *DeleteUserStatusResponse) Reset()

+ func (x *DeleteUserStatusResponse) String() string

+ type DeleteUserStatusResult struct

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

+ func (*DeleteUserStatusResult) ProtoMessage()

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

+ func (x *DeleteUserStatusResult) Reset()

+ func (x *DeleteUserStatusResult) String() string

+ type Disconnect struct

+ Code uint32

+ Reason string

+ Reconnect bool

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

+ func (*Disconnect) ProtoMessage()

+ func (x *Disconnect) GetCode() uint32

+ func (x *Disconnect) GetReason() string

+ func (x *Disconnect) GetReconnect() bool

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

+ func (x *Disconnect) Reset()

+ func (x *Disconnect) String() string

+ type DisconnectRequest struct

+ Client string

+ Disconnect *Disconnect

+ User string

+ Whitelist []string

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

+ func (*DisconnectRequest) ProtoMessage()

+ func (x *DisconnectRequest) GetClient() string

+ func (x *DisconnectRequest) GetDisconnect() *Disconnect

+ func (x *DisconnectRequest) GetUser() string

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

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

+ func (x *DisconnectRequest) Reset()

+ func (x *DisconnectRequest) String() string

+ type DisconnectResponse struct

+ Error *Error

+ Result *DisconnectResult

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

+ func (*DisconnectResponse) ProtoMessage()

+ func (x *DisconnectResponse) GetError() *Error

+ func (x *DisconnectResponse) GetResult() *DisconnectResult

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

+ func (x *DisconnectResponse) Reset()

+ func (x *DisconnectResponse) String() string

+ type DisconnectResult struct

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

+ func (*DisconnectResult) ProtoMessage()

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

+ func (x *DisconnectResult) Reset()

+ func (x *DisconnectResult) String() string

+ type Error struct

+ Code uint32

+ Message string

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

+ func (*Error) ProtoMessage()

+ func (x *Error) Error() string

+ func (x *Error) GetCode() uint32

+ func (x *Error) GetMessage() string

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

+ func (x *Error) Reset()

+ func (x *Error) String() string

+ type GetUserStatusRequest struct

+ Users []string

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

+ func (*GetUserStatusRequest) ProtoMessage()

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

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

+ func (x *GetUserStatusRequest) Reset()

+ func (x *GetUserStatusRequest) String() string

+ type GetUserStatusResponse struct

+ Error *Error

+ Result *GetUserStatusResult

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

+ func (*GetUserStatusResponse) ProtoMessage()

+ func (x *GetUserStatusResponse) GetError() *Error

+ func (x *GetUserStatusResponse) GetResult() *GetUserStatusResult

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

+ func (x *GetUserStatusResponse) Reset()

+ func (x *GetUserStatusResponse) String() string

+ type GetUserStatusResult struct

+ Statuses []*UserStatus

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

+ func (*GetUserStatusResult) ProtoMessage()

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

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

+ func (x *GetUserStatusResult) Reset()

+ func (x *GetUserStatusResult) String() string

+ type HistoryRemoveRequest struct

+ Channel string

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

+ func (*HistoryRemoveRequest) ProtoMessage()

+ func (x *HistoryRemoveRequest) GetChannel() string

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

+ func (x *HistoryRemoveRequest) Reset()

+ func (x *HistoryRemoveRequest) String() string

+ type HistoryRemoveResponse struct

+ Error *Error

+ Result *HistoryRemoveResult

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

+ func (*HistoryRemoveResponse) ProtoMessage()

+ func (x *HistoryRemoveResponse) GetError() *Error

+ func (x *HistoryRemoveResponse) GetResult() *HistoryRemoveResult

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

+ func (x *HistoryRemoveResponse) Reset()

+ func (x *HistoryRemoveResponse) String() string

+ type HistoryRemoveResult struct

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

+ func (*HistoryRemoveResult) ProtoMessage()

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

+ func (x *HistoryRemoveResult) Reset()

+ func (x *HistoryRemoveResult) String() string

+ type HistoryRequest struct

+ Channel string

+ Limit int32

+ Reverse bool

+ Since *StreamPosition

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

+ func (*HistoryRequest) ProtoMessage()

+ func (x *HistoryRequest) GetChannel() string

+ func (x *HistoryRequest) GetLimit() int32

+ func (x *HistoryRequest) GetReverse() bool

+ func (x *HistoryRequest) GetSince() *StreamPosition

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

+ func (x *HistoryRequest) Reset()

+ func (x *HistoryRequest) String() string

+ type HistoryResponse struct

+ Error *Error

+ Result *HistoryResult

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

+ func (*HistoryResponse) ProtoMessage()

+ func (x *HistoryResponse) GetError() *Error

+ func (x *HistoryResponse) GetResult() *HistoryResult

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

+ func (x *HistoryResponse) Reset()

+ func (x *HistoryResponse) String() string

+ type HistoryResult struct

+ Epoch string

+ Offset uint64

+ Publications []*Publication

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

+ func (*HistoryResult) ProtoMessage()

+ func (x *HistoryResult) GetEpoch() string

+ func (x *HistoryResult) GetOffset() uint64

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

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

+ func (x *HistoryResult) Reset()

+ func (x *HistoryResult) String() string

+ type InfoRequest struct

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

+ func (*InfoRequest) ProtoMessage()

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

+ func (x *InfoRequest) Reset()

+ func (x *InfoRequest) String() string

+ type InfoResponse struct

+ Error *Error

+ Result *InfoResult

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

+ func (*InfoResponse) ProtoMessage()

+ func (x *InfoResponse) GetError() *Error

+ func (x *InfoResponse) GetResult() *InfoResult

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

+ func (x *InfoResponse) Reset()

+ func (x *InfoResponse) String() string

+ type InfoResult struct

+ Nodes []*NodeResult

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

+ func (*InfoResult) ProtoMessage()

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

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

+ func (x *InfoResult) Reset()

+ func (x *InfoResult) String() string

+ type Int32Value struct

+ Value int32

+ func (*Int32Value) Descriptor() ([]byte, []int)

+ func (*Int32Value) ProtoMessage()

+ func (x *Int32Value) GetValue() int32

+ func (x *Int32Value) ProtoReflect() protoreflect.Message

+ func (x *Int32Value) Reset()

+ func (x *Int32Value) String() string

+ type JSONCommandDecoder struct

+ func NewJSONCommandDecoder(data []byte) *JSONCommandDecoder

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

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

+ type JSONParamsDecoder struct

+ func NewJSONParamsDecoder() *JSONParamsDecoder

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

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

+ func (d *JSONParamsDecoder) DecodeDeleteUserStatus(data []byte) (*DeleteUserStatusRequest, error)

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

+ func (d *JSONParamsDecoder) DecodeGetUserStatus(data []byte) (*GetUserStatusRequest, error)

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

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

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

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

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

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

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

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

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

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

+ func (d *JSONParamsDecoder) DecodeUpdateUserStatus(data []byte) (*UpdateUserStatusRequest, error)

+ func (d *JSONParamsDecoder) DecodeUserConnections(data []byte) (*UserConnectionsRequest, error)

+ type JSONReplyEncoder struct

+ func NewJSONReplyEncoder() *JSONReplyEncoder

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

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

+ func (e *JSONReplyEncoder) Reset()

+ type JSONResultEncoder struct

+ func NewJSONEncoder() *JSONResultEncoder

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

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

+ func (e *JSONResultEncoder) EncodeDeleteUserStatus(res *DeleteUserStatusResult) ([]byte, error)

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

+ func (e *JSONResultEncoder) EncodeGetUserStatus(res *GetUserStatusResult) ([]byte, error)

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

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

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

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

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

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

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

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

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

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

+ func (e *JSONResultEncoder) EncodeUpdateUserStatus(res *UpdateUserStatusResult) ([]byte, error)

+ func (e *JSONResultEncoder) EncodeUserConnections(res *UserConnectionsResult) ([]byte, error)

+ type Metrics struct

+ Interval float64

+ Items map[string]float64

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

+ func (*Metrics) ProtoMessage()

+ func (x *Metrics) GetInterval() float64

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

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

+ func (x *Metrics) Reset()

+ func (x *Metrics) String() string

+ type NodeResult struct

+ Metrics *Metrics

+ Name string

+ NumChannels uint32

+ NumClients uint32

+ NumSubs uint32

+ NumUsers uint32

+ Process *Process

+ Uid string

+ Uptime uint32

+ Version string

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

+ func (*NodeResult) ProtoMessage()

+ func (x *NodeResult) GetMetrics() *Metrics

+ func (x *NodeResult) GetName() string

+ func (x *NodeResult) GetNumChannels() uint32

+ func (x *NodeResult) GetNumClients() uint32

+ func (x *NodeResult) GetNumSubs() uint32

+ func (x *NodeResult) GetNumUsers() uint32

+ func (x *NodeResult) GetProcess() *Process

+ func (x *NodeResult) GetUid() string

+ func (x *NodeResult) GetUptime() uint32

+ func (x *NodeResult) GetVersion() string

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

+ func (x *NodeResult) Reset()

+ func (x *NodeResult) String() string

+ type ParamsDecoder interface

+ DecodeBroadcast func([]byte) (*BroadcastRequest, error)

+ DecodeChannels func([]byte) (*ChannelsRequest, error)

+ DecodeDeleteUserStatus func([]byte) (*DeleteUserStatusRequest, error)

+ DecodeDisconnect func([]byte) (*DisconnectRequest, error)

+ DecodeGetUserStatus func([]byte) (*GetUserStatusRequest, error)

+ DecodeHistory func([]byte) (*HistoryRequest, error)

+ DecodeHistoryRemove func([]byte) (*HistoryRemoveRequest, error)

+ DecodeInfo func([]byte) (*InfoRequest, error)

+ DecodePresence func([]byte) (*PresenceRequest, error)

+ DecodePresenceStats func([]byte) (*PresenceStatsRequest, error)

+ DecodePublish func([]byte) (*PublishRequest, error)

+ DecodeRPC func([]byte) (*RPCRequest, error)

+ DecodeRefresh func([]byte) (*RefreshRequest, error)

+ DecodeSubscribe func([]byte) (*SubscribeRequest, error)

+ DecodeUnsubscribe func([]byte) (*UnsubscribeRequest, error)

+ DecodeUpdateUserStatus func([]byte) (*UpdateUserStatusRequest, error)

+ DecodeUserConnections func([]byte) (*UserConnectionsRequest, error)

+ func GetParamsDecoder() ParamsDecoder

+ type PresenceRequest struct

+ Channel string

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

+ func (*PresenceRequest) ProtoMessage()

+ func (x *PresenceRequest) GetChannel() string

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

+ func (x *PresenceRequest) Reset()

+ func (x *PresenceRequest) String() string

+ type PresenceResponse struct

+ Error *Error

+ Result *PresenceResult

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

+ func (*PresenceResponse) ProtoMessage()

+ func (x *PresenceResponse) GetError() *Error

+ func (x *PresenceResponse) GetResult() *PresenceResult

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

+ func (x *PresenceResponse) Reset()

+ func (x *PresenceResponse) String() string

+ type PresenceResult struct

+ Presence map[string]*ClientInfo

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

+ func (*PresenceResult) ProtoMessage()

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

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

+ func (x *PresenceResult) Reset()

+ func (x *PresenceResult) String() string

+ type PresenceStatsRequest struct

+ Channel string

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

+ func (*PresenceStatsRequest) ProtoMessage()

+ func (x *PresenceStatsRequest) GetChannel() string

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

+ func (x *PresenceStatsRequest) Reset()

+ func (x *PresenceStatsRequest) String() string

+ type PresenceStatsResponse struct

+ Error *Error

+ Result *PresenceStatsResult

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

+ func (*PresenceStatsResponse) ProtoMessage()

+ func (x *PresenceStatsResponse) GetError() *Error

+ func (x *PresenceStatsResponse) GetResult() *PresenceStatsResult

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

+ func (x *PresenceStatsResponse) Reset()

+ func (x *PresenceStatsResponse) String() string

+ type PresenceStatsResult struct

+ NumClients uint32

+ NumUsers uint32

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

+ func (*PresenceStatsResult) ProtoMessage()

+ func (x *PresenceStatsResult) GetNumClients() uint32

+ func (x *PresenceStatsResult) GetNumUsers() uint32

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

+ func (x *PresenceStatsResult) Reset()

+ func (x *PresenceStatsResult) String() string

+ type Process struct

+ Cpu float64

+ Rss int64

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

+ func (*Process) ProtoMessage()

+ func (x *Process) GetCpu() float64

+ func (x *Process) GetRss() int64

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

+ func (x *Process) Reset()

+ func (x *Process) String() string

+ type Publication struct

+ Data Raw

+ Info *ClientInfo

+ Offset uint64

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

+ func (*Publication) ProtoMessage()

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

+ func (x *Publication) GetInfo() *ClientInfo

+ func (x *Publication) GetOffset() uint64

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

+ func (x *Publication) Reset()

+ func (x *Publication) String() string

+ type PublishRequest struct

+ B64Data string

+ Channel string

+ Data Raw

+ SkipHistory bool

+ func (*PublishRequest) Descriptor() ([]byte, []int)

+ func (*PublishRequest) ProtoMessage()

+ func (x *PublishRequest) GetB64Data() string

+ func (x *PublishRequest) GetChannel() string

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

+ func (x *PublishRequest) GetSkipHistory() bool

+ func (x *PublishRequest) ProtoReflect() protoreflect.Message

+ func (x *PublishRequest) Reset()

+ func (x *PublishRequest) String() string

+ type PublishResponse struct

+ Error *Error

+ Result *PublishResult

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

+ func (*PublishResponse) ProtoMessage()

+ func (x *PublishResponse) GetError() *Error

+ func (x *PublishResponse) GetResult() *PublishResult

+ func (x *PublishResponse) ProtoReflect() protoreflect.Message

+ func (x *PublishResponse) Reset()

+ func (x *PublishResponse) String() string

+ type PublishResult struct

+ Epoch string

+ Offset uint64

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

+ func (*PublishResult) ProtoMessage()

+ func (x *PublishResult) GetEpoch() string

+ func (x *PublishResult) GetOffset() uint64

+ func (x *PublishResult) ProtoReflect() protoreflect.Message

+ func (x *PublishResult) Reset()

+ func (x *PublishResult) String() string

+ type RPCRequest struct

+ Method string

+ Params Raw

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

+ func (*RPCRequest) ProtoMessage()

+ func (x *RPCRequest) GetMethod() string

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

+ func (x *RPCRequest) ProtoReflect() protoreflect.Message

+ func (x *RPCRequest) Reset()

+ func (x *RPCRequest) String() string

+ type RPCResponse struct

+ Error *Error

+ Result *RPCResult

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

+ func (*RPCResponse) ProtoMessage()

+ func (x *RPCResponse) GetError() *Error

+ func (x *RPCResponse) GetResult() *RPCResult

+ func (x *RPCResponse) ProtoReflect() protoreflect.Message

+ func (x *RPCResponse) Reset()

+ func (x *RPCResponse) String() string

+ type RPCResult struct

+ Data Raw

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

+ func (*RPCResult) ProtoMessage()

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

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

+ func (x *RPCResult) Reset()

+ func (x *RPCResult) String() string

+ type Raw []byte

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

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

+ type RefreshRequest struct

+ Client string

+ ExpireAt int64

+ Expired bool

+ Info Raw

+ User string

+ func (*RefreshRequest) Descriptor() ([]byte, []int)

+ func (*RefreshRequest) ProtoMessage()

+ func (x *RefreshRequest) GetClient() string

+ func (x *RefreshRequest) GetExpireAt() int64

+ func (x *RefreshRequest) GetExpired() bool

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

+ func (x *RefreshRequest) GetUser() string

+ func (x *RefreshRequest) ProtoReflect() protoreflect.Message

+ func (x *RefreshRequest) Reset()

+ func (x *RefreshRequest) String() string

+ type RefreshResponse struct

+ Error *Error

+ Result *RefreshResult

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

+ func (*RefreshResponse) ProtoMessage()

+ func (x *RefreshResponse) GetError() *Error

+ func (x *RefreshResponse) GetResult() *RefreshResult

+ func (x *RefreshResponse) ProtoReflect() protoreflect.Message

+ func (x *RefreshResponse) Reset()

+ func (x *RefreshResponse) String() string

+ type RefreshResult struct

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

+ func (*RefreshResult) ProtoMessage()

+ func (x *RefreshResult) ProtoReflect() protoreflect.Message

+ func (x *RefreshResult) Reset()

+ func (x *RefreshResult) String() string

+ type Reply struct

+ Error *Error

+ Id uint32

+ Result Raw

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

+ func (*Reply) ProtoMessage()

+ func (x *Reply) GetError() *Error

+ func (x *Reply) GetId() uint32

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

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

+ func (x *Reply) Reset()

+ func (x *Reply) String() string

+ type ReplyEncoder interface

+ Encode func(*Reply) error

+ Finish func() []byte

+ Reset func()

+ func GetReplyEncoder() ReplyEncoder

+ type ResultEncoder interface

+ EncodeBroadcast func(*BroadcastResult) ([]byte, error)

+ EncodeChannels func(*ChannelsResult) ([]byte, error)

+ EncodeDeleteUserStatus func(*DeleteUserStatusResult) ([]byte, error)

+ EncodeDisconnect func(*DisconnectResult) ([]byte, error)

+ EncodeGetUserStatus func(*GetUserStatusResult) ([]byte, error)

+ EncodeHistory func(*HistoryResult) ([]byte, error)

+ EncodeHistoryRemove func(*HistoryRemoveResult) ([]byte, error)

+ EncodeInfo func(*InfoResult) ([]byte, error)

+ EncodePresence func(*PresenceResult) ([]byte, error)

+ EncodePresenceStats func(*PresenceStatsResult) ([]byte, error)

+ EncodePublish func(*PublishResult) ([]byte, error)

+ EncodeRPC func(*RPCResult) ([]byte, error)

+ EncodeRefresh func(*RefreshResult) ([]byte, error)

+ EncodeSubscribe func(*SubscribeResult) ([]byte, error)

+ EncodeUnsubscribe func(*UnsubscribeResult) ([]byte, error)

+ EncodeUpdateUserStatus func(*UpdateUserStatusResult) ([]byte, error)

+ EncodeUserConnections func(*UserConnectionsResult) ([]byte, error)

+ func GetResultEncoder() ResultEncoder

+ type StreamPosition struct

+ Epoch string

+ Offset uint64

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

+ func (*StreamPosition) ProtoMessage()

+ func (x *StreamPosition) GetEpoch() string

+ func (x *StreamPosition) GetOffset() uint64

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

+ func (x *StreamPosition) Reset()

+ func (x *StreamPosition) String() string

+ type SubscribeOptionOverride struct

+ JoinLeave *BoolValue

+ Position *BoolValue

+ Presence *BoolValue

+ Recover *BoolValue

+ func (*SubscribeOptionOverride) Descriptor() ([]byte, []int)

+ func (*SubscribeOptionOverride) ProtoMessage()

+ func (x *SubscribeOptionOverride) GetJoinLeave() *BoolValue

+ func (x *SubscribeOptionOverride) GetPosition() *BoolValue

+ func (x *SubscribeOptionOverride) GetPresence() *BoolValue

+ func (x *SubscribeOptionOverride) GetRecover() *BoolValue

+ func (x *SubscribeOptionOverride) ProtoReflect() protoreflect.Message

+ func (x *SubscribeOptionOverride) Reset()

+ func (x *SubscribeOptionOverride) String() string

+ type SubscribeRequest struct

+ B64Data string

+ B64Info string

+ Channel string

+ Client string

+ Data Raw

+ ExpireAt int64

+ Info Raw

+ Override *SubscribeOptionOverride

+ RecoverSince *StreamPosition

+ User string

+ func (*SubscribeRequest) Descriptor() ([]byte, []int)

+ func (*SubscribeRequest) ProtoMessage()

+ func (x *SubscribeRequest) GetB64Data() string

+ func (x *SubscribeRequest) GetB64Info() string

+ func (x *SubscribeRequest) GetChannel() string

+ func (x *SubscribeRequest) GetClient() string

+ func (x *SubscribeRequest) GetData() []byte

+ func (x *SubscribeRequest) GetExpireAt() int64

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

+ func (x *SubscribeRequest) GetOverride() *SubscribeOptionOverride

+ func (x *SubscribeRequest) GetRecoverSince() *StreamPosition

+ func (x *SubscribeRequest) GetUser() string

+ func (x *SubscribeRequest) ProtoReflect() protoreflect.Message

+ func (x *SubscribeRequest) Reset()

+ func (x *SubscribeRequest) String() string

+ type SubscribeResponse struct

+ Error *Error

+ Result *SubscribeResult

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

+ func (*SubscribeResponse) ProtoMessage()

+ func (x *SubscribeResponse) GetError() *Error

+ func (x *SubscribeResponse) GetResult() *SubscribeResult

+ func (x *SubscribeResponse) ProtoReflect() protoreflect.Message

+ func (x *SubscribeResponse) Reset()

+ func (x *SubscribeResponse) String() string

+ type SubscribeResult struct

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

+ func (*SubscribeResult) ProtoMessage()

+ func (x *SubscribeResult) ProtoReflect() protoreflect.Message

+ func (x *SubscribeResult) Reset()

+ func (x *SubscribeResult) String() string

+ type UnimplementedCentrifugoApiServer struct

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ func (UnimplementedCentrifugoApiServer) UserConnections(context.Context, *UserConnectionsRequest) (*UserConnectionsResponse, error)

+ type UnsafeCentrifugoApiServer interface

+ type UnsubscribeRequest struct

+ Channel string

+ Client string

+ User string

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

+ func (*UnsubscribeRequest) ProtoMessage()

+ func (x *UnsubscribeRequest) GetChannel() string

+ func (x *UnsubscribeRequest) GetClient() string

+ func (x *UnsubscribeRequest) GetUser() string

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

+ func (x *UnsubscribeRequest) Reset()

+ func (x *UnsubscribeRequest) String() string

+ type UnsubscribeResponse struct

+ Error *Error

+ Result *UnsubscribeResult

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

+ func (*UnsubscribeResponse) ProtoMessage()

+ func (x *UnsubscribeResponse) GetError() *Error

+ func (x *UnsubscribeResponse) GetResult() *UnsubscribeResult

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

+ func (x *UnsubscribeResponse) Reset()

+ func (x *UnsubscribeResponse) String() string

+ type UnsubscribeResult struct

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

+ func (*UnsubscribeResult) ProtoMessage()

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

+ func (x *UnsubscribeResult) Reset()

+ func (x *UnsubscribeResult) String() string

+ type UpdateUserStatusRequest struct

+ Users []string

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

+ func (*UpdateUserStatusRequest) ProtoMessage()

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

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

+ func (x *UpdateUserStatusRequest) Reset()

+ func (x *UpdateUserStatusRequest) String() string

+ type UpdateUserStatusResponse struct

+ Error *Error

+ Result *UpdateUserStatusResult

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

+ func (*UpdateUserStatusResponse) ProtoMessage()

+ func (x *UpdateUserStatusResponse) GetError() *Error

+ func (x *UpdateUserStatusResponse) GetResult() *UpdateUserStatusResult

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

+ func (x *UpdateUserStatusResponse) Reset()

+ func (x *UpdateUserStatusResponse) String() string

+ type UpdateUserStatusResult struct

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

+ func (*UpdateUserStatusResult) ProtoMessage()

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

+ func (x *UpdateUserStatusResult) Reset()

+ func (x *UpdateUserStatusResult) String() string

+ type UserConnectionInfo struct

+ AppName string

+ AppVersion string

+ Meta Raw

+ Protocol string

+ Transport string

+ func (*UserConnectionInfo) Descriptor() ([]byte, []int)

+ func (*UserConnectionInfo) ProtoMessage()

+ func (x *UserConnectionInfo) GetAppName() string

+ func (x *UserConnectionInfo) GetAppVersion() string

+ func (x *UserConnectionInfo) GetMeta() []byte

+ func (x *UserConnectionInfo) GetProtocol() string

+ func (x *UserConnectionInfo) GetTransport() string

+ func (x *UserConnectionInfo) ProtoReflect() protoreflect.Message

+ func (x *UserConnectionInfo) Reset()

+ func (x *UserConnectionInfo) String() string

+ type UserConnectionsRequest struct

+ User string

+ func (*UserConnectionsRequest) Descriptor() ([]byte, []int)

+ func (*UserConnectionsRequest) ProtoMessage()

+ func (x *UserConnectionsRequest) GetUser() string

+ func (x *UserConnectionsRequest) ProtoReflect() protoreflect.Message

+ func (x *UserConnectionsRequest) Reset()

+ func (x *UserConnectionsRequest) String() string

+ type UserConnectionsResponse struct

+ Error *Error

+ Result *UserConnectionsResult

+ func (*UserConnectionsResponse) Descriptor() ([]byte, []int)

+ func (*UserConnectionsResponse) ProtoMessage()

+ func (x *UserConnectionsResponse) GetError() *Error

+ func (x *UserConnectionsResponse) GetResult() *UserConnectionsResult

+ func (x *UserConnectionsResponse) ProtoReflect() protoreflect.Message

+ func (x *UserConnectionsResponse) Reset()

+ func (x *UserConnectionsResponse) String() string

+ type UserConnectionsResult struct

+ Connections map[string]*UserConnectionInfo

+ func (*UserConnectionsResult) Descriptor() ([]byte, []int)

+ func (*UserConnectionsResult) ProtoMessage()

+ func (x *UserConnectionsResult) GetConnections() map[string]*UserConnectionInfo

+ func (x *UserConnectionsResult) ProtoReflect() protoreflect.Message

+ func (x *UserConnectionsResult) Reset()

+ func (x *UserConnectionsResult) String() string

+ type UserStatus struct

+ Active int64

+ Online int64

+ User string

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

+ func (*UserStatus) ProtoMessage()

+ func (x *UserStatus) GetActive() int64

+ func (x *UserStatus) GetOnline() int64

+ func (x *UserStatus) GetUser() string

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

+ func (x *UserStatus) Reset()

+ func (x *UserStatus) String() string

v3.0.0-beta.2

Aug 15, 2021

v3.0.0-beta.1

Jul 12, 2021

Other modules containing this package

github.com/centrifugal/centrifugo/v4

github.com/centrifugal/centrifugo/v5

github.com/centrifugal/centrifugo/v6

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL