Versions in this module Expand all Collapse all v6 v6.0.3 Feb 17, 2025 v6.0.2 Feb 2, 2025 v6.0.1 Jan 19, 2025 Changes in this version + const CentrifugoApi_Batch_FullMethodName + const CentrifugoApi_BlockUser_FullMethodName + const CentrifugoApi_Broadcast_FullMethodName + const CentrifugoApi_CancelPush_FullMethodName + const CentrifugoApi_Channels_FullMethodName + const CentrifugoApi_Connections_FullMethodName + const CentrifugoApi_DeleteUserStatus_FullMethodName + const CentrifugoApi_DeviceList_FullMethodName + const CentrifugoApi_DeviceRegister_FullMethodName + const CentrifugoApi_DeviceRemove_FullMethodName + const CentrifugoApi_DeviceTopicList_FullMethodName + const CentrifugoApi_DeviceTopicUpdate_FullMethodName + const CentrifugoApi_DeviceUpdate_FullMethodName + const CentrifugoApi_Disconnect_FullMethodName + const CentrifugoApi_GetUserStatus_FullMethodName + const CentrifugoApi_HistoryRemove_FullMethodName + const CentrifugoApi_History_FullMethodName + const CentrifugoApi_Info_FullMethodName + const CentrifugoApi_InvalidateUserTokens_FullMethodName + const CentrifugoApi_PresenceStats_FullMethodName + const CentrifugoApi_Presence_FullMethodName + const CentrifugoApi_Publish_FullMethodName + const CentrifugoApi_RPC_FullMethodName + const CentrifugoApi_Refresh_FullMethodName + const CentrifugoApi_RevokeToken_FullMethodName + const CentrifugoApi_SendPushNotification_FullMethodName + const CentrifugoApi_Subscribe_FullMethodName + const CentrifugoApi_UnblockUser_FullMethodName + const CentrifugoApi_Unsubscribe_FullMethodName + const CentrifugoApi_UpdatePushStatus_FullMethodName + const CentrifugoApi_UpdateUserStatus_FullMethodName + const CentrifugoApi_UserTopicList_FullMethodName + const CentrifugoApi_UserTopicUpdate_FullMethodName + var CentrifugoApi_ServiceDesc = grpc.ServiceDesc + var Command_MethodType_name = map[int32]string + var Command_MethodType_value = map[string]int32 + var ErrorBadRequest = &Error + var ErrorConflict = &Error + var ErrorInternal = &Error + var ErrorNotAvailable = &Error + var ErrorNotFound = &Error + var ErrorUnknownChannel = &Error + var ErrorUnrecoverablePosition = &Error + var File_api_proto protoreflect.FileDescriptor + func EncodeError(err *Error) ([]byte, error) + func MapErrorToGRPCCode(err *Error) codes.Code + func MapErrorToHTTPCode(err *Error) int + func PutCommandDecoder(d CommandDecoder) + func PutParamsDecoder(_ RequestDecoder) + func PutReplyEncoder(e ReplyEncoder) + func PutResultEncoder(_ ResultEncoder) + func RegisterCentrifugoApiServer(s grpc.ServiceRegistrar, srv CentrifugoApiServer) + type ApnsPushNotification struct + Headers map[string]string + Payload Raw + func (*ApnsPushNotification) Descriptor() ([]byte, []int) + func (*ApnsPushNotification) ProtoMessage() + func (x *ApnsPushNotification) GetHeaders() map[string]string + func (x *ApnsPushNotification) GetPayload() []byte + func (x *ApnsPushNotification) ProtoReflect() protoreflect.Message + func (x *ApnsPushNotification) Reset() + func (x *ApnsPushNotification) String() string + type BatchRequest struct + Commands []*Command + Parallel bool + func (*BatchRequest) Descriptor() ([]byte, []int) + func (*BatchRequest) ProtoMessage() + func (x *BatchRequest) GetCommands() []*Command + func (x *BatchRequest) GetParallel() bool + func (x *BatchRequest) ProtoReflect() protoreflect.Message + func (x *BatchRequest) Reset() + func (x *BatchRequest) String() string + type BatchResponse struct + Replies []*Reply + func (*BatchResponse) Descriptor() ([]byte, []int) + func (*BatchResponse) ProtoMessage() + func (x *BatchResponse) GetReplies() []*Reply + func (x *BatchResponse) ProtoReflect() protoreflect.Message + func (x *BatchResponse) Reset() + func (x *BatchResponse) String() string + 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 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 + Delta bool + IdempotencyKey string + SkipHistory bool + Tags map[string]string + 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) GetDelta() bool + func (x *BroadcastRequest) GetIdempotencyKey() string + func (x *BroadcastRequest) GetSkipHistory() bool + func (x *BroadcastRequest) GetTags() map[string]string + 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 CancelPushRequest struct + Uid string + func (*CancelPushRequest) Descriptor() ([]byte, []int) + func (*CancelPushRequest) ProtoMessage() + func (x *CancelPushRequest) GetUid() string + func (x *CancelPushRequest) ProtoReflect() protoreflect.Message + func (x *CancelPushRequest) Reset() + func (x *CancelPushRequest) String() string + type CancelPushResponse struct + Error *Error + Result *CancelPushResult + func (*CancelPushResponse) Descriptor() ([]byte, []int) + func (*CancelPushResponse) ProtoMessage() + func (x *CancelPushResponse) GetError() *Error + func (x *CancelPushResponse) GetResult() *CancelPushResult + func (x *CancelPushResponse) ProtoReflect() protoreflect.Message + func (x *CancelPushResponse) Reset() + func (x *CancelPushResponse) String() string + type CancelPushResult struct + func (*CancelPushResult) Descriptor() ([]byte, []int) + func (*CancelPushResult) ProtoMessage() + func (x *CancelPushResult) ProtoReflect() protoreflect.Message + func (x *CancelPushResult) Reset() + func (x *CancelPushResult) String() string + type CentrifugoApiClient interface + Batch func(ctx context.Context, in *BatchRequest, opts ...grpc.CallOption) (*BatchResponse, error) + BlockUser func(ctx context.Context, in *BlockUserRequest, opts ...grpc.CallOption) (*BlockUserResponse, error) + Broadcast func(ctx context.Context, in *BroadcastRequest, opts ...grpc.CallOption) (*BroadcastResponse, error) + CancelPush func(ctx context.Context, in *CancelPushRequest, opts ...grpc.CallOption) (*CancelPushResponse, error) + Channels func(ctx context.Context, in *ChannelsRequest, opts ...grpc.CallOption) (*ChannelsResponse, error) + Connections func(ctx context.Context, in *ConnectionsRequest, opts ...grpc.CallOption) (*ConnectionsResponse, error) + DeleteUserStatus func(ctx context.Context, in *DeleteUserStatusRequest, opts ...grpc.CallOption) (*DeleteUserStatusResponse, error) + DeviceList func(ctx context.Context, in *DeviceListRequest, opts ...grpc.CallOption) (*DeviceListResponse, error) + DeviceRegister func(ctx context.Context, in *DeviceRegisterRequest, opts ...grpc.CallOption) (*DeviceRegisterResponse, error) + DeviceRemove func(ctx context.Context, in *DeviceRemoveRequest, opts ...grpc.CallOption) (*DeviceRemoveResponse, error) + DeviceTopicList func(ctx context.Context, in *DeviceTopicListRequest, opts ...grpc.CallOption) (*DeviceTopicListResponse, error) + DeviceTopicUpdate func(ctx context.Context, in *DeviceTopicUpdateRequest, opts ...grpc.CallOption) (*DeviceTopicUpdateResponse, error) + DeviceUpdate func(ctx context.Context, in *DeviceUpdateRequest, opts ...grpc.CallOption) (*DeviceUpdateResponse, 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) + InvalidateUserTokens func(ctx context.Context, in *InvalidateUserTokensRequest, opts ...grpc.CallOption) (*InvalidateUserTokensResponse, 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) + RevokeToken func(ctx context.Context, in *RevokeTokenRequest, opts ...grpc.CallOption) (*RevokeTokenResponse, error) + SendPushNotification func(ctx context.Context, in *SendPushNotificationRequest, opts ...grpc.CallOption) (*SendPushNotificationResponse, error) + Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (*SubscribeResponse, error) + UnblockUser func(ctx context.Context, in *UnblockUserRequest, opts ...grpc.CallOption) (*UnblockUserResponse, error) + Unsubscribe func(ctx context.Context, in *UnsubscribeRequest, opts ...grpc.CallOption) (*UnsubscribeResponse, error) + UpdatePushStatus func(ctx context.Context, in *UpdatePushStatusRequest, opts ...grpc.CallOption) (*UpdatePushStatusResponse, error) + UpdateUserStatus func(ctx context.Context, in *UpdateUserStatusRequest, opts ...grpc.CallOption) (*UpdateUserStatusResponse, error) + UserTopicList func(ctx context.Context, in *UserTopicListRequest, opts ...grpc.CallOption) (*UserTopicListResponse, error) + UserTopicUpdate func(ctx context.Context, in *UserTopicUpdateRequest, opts ...grpc.CallOption) (*UserTopicUpdateResponse, error) + func NewCentrifugoApiClient(cc grpc.ClientConnInterface) CentrifugoApiClient + type CentrifugoApiServer interface + Batch func(context.Context, *BatchRequest) (*BatchResponse, error) + BlockUser func(context.Context, *BlockUserRequest) (*BlockUserResponse, error) + Broadcast func(context.Context, *BroadcastRequest) (*BroadcastResponse, error) + CancelPush func(context.Context, *CancelPushRequest) (*CancelPushResponse, error) + Channels func(context.Context, *ChannelsRequest) (*ChannelsResponse, error) + Connections func(context.Context, *ConnectionsRequest) (*ConnectionsResponse, error) + DeleteUserStatus func(context.Context, *DeleteUserStatusRequest) (*DeleteUserStatusResponse, error) + DeviceList func(context.Context, *DeviceListRequest) (*DeviceListResponse, error) + DeviceRegister func(context.Context, *DeviceRegisterRequest) (*DeviceRegisterResponse, error) + DeviceRemove func(context.Context, *DeviceRemoveRequest) (*DeviceRemoveResponse, error) + DeviceTopicList func(context.Context, *DeviceTopicListRequest) (*DeviceTopicListResponse, error) + DeviceTopicUpdate func(context.Context, *DeviceTopicUpdateRequest) (*DeviceTopicUpdateResponse, error) + DeviceUpdate func(context.Context, *DeviceUpdateRequest) (*DeviceUpdateResponse, 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) + InvalidateUserTokens func(context.Context, *InvalidateUserTokensRequest) (*InvalidateUserTokensResponse, 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) + RevokeToken func(context.Context, *RevokeTokenRequest) (*RevokeTokenResponse, error) + SendPushNotification func(context.Context, *SendPushNotificationRequest) (*SendPushNotificationResponse, error) + Subscribe func(context.Context, *SubscribeRequest) (*SubscribeResponse, error) + UnblockUser func(context.Context, *UnblockUserRequest) (*UnblockUserResponse, error) + Unsubscribe func(context.Context, *UnsubscribeRequest) (*UnsubscribeResponse, error) + UpdatePushStatus func(context.Context, *UpdatePushStatusRequest) (*UpdatePushStatusResponse, error) + UpdateUserStatus func(context.Context, *UpdateUserStatusRequest) (*UpdateUserStatusResponse, error) + UserTopicList func(context.Context, *UserTopicListRequest) (*UserTopicListResponse, error) + UserTopicUpdate func(context.Context, *UserTopicUpdateRequest) (*UserTopicUpdateResponse, error) + type ChannelContext struct + Source uint32 + func (*ChannelContext) Descriptor() ([]byte, []int) + func (*ChannelContext) ProtoMessage() + func (x *ChannelContext) GetSource() uint32 + func (x *ChannelContext) ProtoReflect() protoreflect.Message + func (x *ChannelContext) Reset() + func (x *ChannelContext) String() string + 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 + BlockUser *BlockUserRequest + Broadcast *BroadcastRequest + CancelPush *CancelPushRequest + Channels *ChannelsRequest + Connections *ConnectionsRequest + DeleteUserStatus *DeleteUserStatusRequest + DeviceList *DeviceListRequest + DeviceRegister *DeviceRegisterRequest + DeviceRemove *DeviceRemoveRequest + DeviceTopicList *DeviceTopicListRequest + DeviceTopicUpdate *DeviceTopicUpdateRequest + DeviceUpdate *DeviceUpdateRequest + Disconnect *DisconnectRequest + GetUserStatus *GetUserStatusRequest + History *HistoryRequest + HistoryRemove *HistoryRemoveRequest + Id uint32 + Info *InfoRequest + InvalidateUserTokens *InvalidateUserTokensRequest + Method Command_MethodType + Params Raw + Presence *PresenceRequest + PresenceStats *PresenceStatsRequest + Publish *PublishRequest + Refresh *RefreshRequest + RevokeToken *RevokeTokenRequest + Rpc *RPCRequest + SendPushNotification *SendPushNotificationRequest + Subscribe *SubscribeRequest + UnblockUser *UnblockUserRequest + Unsubscribe *UnsubscribeRequest + UpdatePushStatus *UpdatePushStatusRequest + UpdateUserStatus *UpdateUserStatusRequest + UserTopicList *UserTopicListRequest + UserTopicUpdate *UserTopicUpdateRequest + func (*Command) Descriptor() ([]byte, []int) + func (*Command) ProtoMessage() + func (x *Command) GetBlockUser() *BlockUserRequest + func (x *Command) GetBroadcast() *BroadcastRequest + func (x *Command) GetCancelPush() *CancelPushRequest + func (x *Command) GetChannels() *ChannelsRequest + func (x *Command) GetConnections() *ConnectionsRequest + func (x *Command) GetDeleteUserStatus() *DeleteUserStatusRequest + func (x *Command) GetDeviceList() *DeviceListRequest + func (x *Command) GetDeviceRegister() *DeviceRegisterRequest + func (x *Command) GetDeviceRemove() *DeviceRemoveRequest + func (x *Command) GetDeviceTopicList() *DeviceTopicListRequest + func (x *Command) GetDeviceTopicUpdate() *DeviceTopicUpdateRequest + func (x *Command) GetDeviceUpdate() *DeviceUpdateRequest + func (x *Command) GetDisconnect() *DisconnectRequest + func (x *Command) GetGetUserStatus() *GetUserStatusRequest + func (x *Command) GetHistory() *HistoryRequest + func (x *Command) GetHistoryRemove() *HistoryRemoveRequest + func (x *Command) GetId() uint32 + func (x *Command) GetInfo() *InfoRequest + func (x *Command) GetInvalidateUserTokens() *InvalidateUserTokensRequest + func (x *Command) GetMethod() Command_MethodType + func (x *Command) GetParams() []byte + func (x *Command) GetPresence() *PresenceRequest + func (x *Command) GetPresenceStats() *PresenceStatsRequest + func (x *Command) GetPublish() *PublishRequest + func (x *Command) GetRefresh() *RefreshRequest + func (x *Command) GetRevokeToken() *RevokeTokenRequest + func (x *Command) GetRpc() *RPCRequest + func (x *Command) GetSendPushNotification() *SendPushNotificationRequest + func (x *Command) GetSubscribe() *SubscribeRequest + func (x *Command) GetUnblockUser() *UnblockUserRequest + func (x *Command) GetUnsubscribe() *UnsubscribeRequest + func (x *Command) GetUpdatePushStatus() *UpdatePushStatusRequest + func (x *Command) GetUpdateUserStatus() *UpdateUserStatusRequest + func (x *Command) GetUserTopicList() *UserTopicListRequest + func (x *Command) GetUserTopicUpdate() *UserTopicUpdateRequest + 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_BLOCK_USER + const Command_BROADCAST + const Command_CANCEL_PUSH + const Command_CHANNELS + const Command_CONNECTIONS + const Command_DELETE_USER_STATUS + const Command_DEVICE_LIST + const Command_DEVICE_REGISTER + const Command_DEVICE_REMOVE + const Command_DEVICE_TOPIC_LIST + const Command_DEVICE_TOPIC_UPDATE + const Command_DEVICE_UPDATE + const Command_DISCONNECT + const Command_GET_USER_STATUS + const Command_HISTORY + const Command_HISTORY_REMOVE + const Command_INFO + const Command_INVALIDATE_USER_TOKENS + const Command_PRESENCE + const Command_PRESENCE_STATS + const Command_PUBLISH + const Command_REFRESH + const Command_REVOKE_TOKEN + const Command_RPC + const Command_SEND_PUSH_NOTIFICATION + const Command_SUBSCRIBE + const Command_UNBLOCK_USER + const Command_UNSUBSCRIBE + const Command_UPDATE_PUSH_STATUS + const Command_UPDATE_USER_STATUS + const Command_USER_TOPIC_LIST + const Command_USER_TOPIC_UPDATE + 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 ConnectionInfo struct + AppName string + AppVersion string + Protocol string + State *ConnectionState + Transport string + User string + func (*ConnectionInfo) Descriptor() ([]byte, []int) + func (*ConnectionInfo) ProtoMessage() + func (x *ConnectionInfo) GetAppName() string + func (x *ConnectionInfo) GetAppVersion() string + func (x *ConnectionInfo) GetProtocol() string + func (x *ConnectionInfo) GetState() *ConnectionState + func (x *ConnectionInfo) GetTransport() string + func (x *ConnectionInfo) GetUser() string + func (x *ConnectionInfo) ProtoReflect() protoreflect.Message + func (x *ConnectionInfo) Reset() + func (x *ConnectionInfo) String() string + type ConnectionState struct + Channels map[string]*ChannelContext + ConnectionToken *ConnectionTokenInfo + Meta Raw + SubscriptionTokens map[string]*SubscriptionTokenInfo + func (*ConnectionState) Descriptor() ([]byte, []int) + func (*ConnectionState) ProtoMessage() + func (x *ConnectionState) GetChannels() map[string]*ChannelContext + func (x *ConnectionState) GetConnectionToken() *ConnectionTokenInfo + func (x *ConnectionState) GetMeta() []byte + func (x *ConnectionState) GetSubscriptionTokens() map[string]*SubscriptionTokenInfo + func (x *ConnectionState) ProtoReflect() protoreflect.Message + func (x *ConnectionState) Reset() + func (x *ConnectionState) String() string + type ConnectionTokenInfo struct + IssuedAt int64 + Uid string + func (*ConnectionTokenInfo) Descriptor() ([]byte, []int) + func (*ConnectionTokenInfo) ProtoMessage() + func (x *ConnectionTokenInfo) GetIssuedAt() int64 + func (x *ConnectionTokenInfo) GetUid() string + func (x *ConnectionTokenInfo) ProtoReflect() protoreflect.Message + func (x *ConnectionTokenInfo) Reset() + func (x *ConnectionTokenInfo) String() string + type ConnectionsRequest struct + Expression string + User string + func (*ConnectionsRequest) Descriptor() ([]byte, []int) + func (*ConnectionsRequest) ProtoMessage() + func (x *ConnectionsRequest) GetExpression() string + func (x *ConnectionsRequest) GetUser() string + func (x *ConnectionsRequest) ProtoReflect() protoreflect.Message + func (x *ConnectionsRequest) Reset() + func (x *ConnectionsRequest) String() string + type ConnectionsResponse struct + Error *Error + Result *ConnectionsResult + func (*ConnectionsResponse) Descriptor() ([]byte, []int) + func (*ConnectionsResponse) ProtoMessage() + func (x *ConnectionsResponse) GetError() *Error + func (x *ConnectionsResponse) GetResult() *ConnectionsResult + func (x *ConnectionsResponse) ProtoReflect() protoreflect.Message + func (x *ConnectionsResponse) Reset() + func (x *ConnectionsResponse) String() string + type ConnectionsResult struct + Connections map[string]*ConnectionInfo + func (*ConnectionsResult) Descriptor() ([]byte, []int) + func (*ConnectionsResult) ProtoMessage() + func (x *ConnectionsResult) GetConnections() map[string]*ConnectionInfo + func (x *ConnectionsResult) ProtoReflect() protoreflect.Message + func (x *ConnectionsResult) Reset() + func (x *ConnectionsResult) 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 Device struct + CreatedAt int64 + Id string + Locale string + Meta map[string]string + Platform string + Provider string + Timezone string + Token string + Topics []string + UpdatedAt int64 + User string + func (*Device) Descriptor() ([]byte, []int) + func (*Device) ProtoMessage() + func (x *Device) GetCreatedAt() int64 + func (x *Device) GetId() string + func (x *Device) GetLocale() string + func (x *Device) GetMeta() map[string]string + func (x *Device) GetPlatform() string + func (x *Device) GetProvider() string + func (x *Device) GetTimezone() string + func (x *Device) GetToken() string + func (x *Device) GetTopics() []string + func (x *Device) GetUpdatedAt() int64 + func (x *Device) GetUser() string + func (x *Device) ProtoReflect() protoreflect.Message + func (x *Device) Reset() + func (x *Device) String() string + type DeviceFilter struct + Ids []string + Platforms []string + Providers []string + Topics []string + Users []string + func (*DeviceFilter) Descriptor() ([]byte, []int) + func (*DeviceFilter) ProtoMessage() + func (x *DeviceFilter) GetIds() []string + func (x *DeviceFilter) GetPlatforms() []string + func (x *DeviceFilter) GetProviders() []string + func (x *DeviceFilter) GetTopics() []string + func (x *DeviceFilter) GetUsers() []string + func (x *DeviceFilter) ProtoReflect() protoreflect.Message + func (x *DeviceFilter) Reset() + func (x *DeviceFilter) String() string + type DeviceListRequest struct + Cursor string + Filter *DeviceFilter + IncludeMeta bool + IncludeTopics bool + IncludeTotalCount bool + Limit int32 + func (*DeviceListRequest) Descriptor() ([]byte, []int) + func (*DeviceListRequest) ProtoMessage() + func (x *DeviceListRequest) GetCursor() string + func (x *DeviceListRequest) GetFilter() *DeviceFilter + func (x *DeviceListRequest) GetIncludeMeta() bool + func (x *DeviceListRequest) GetIncludeTopics() bool + func (x *DeviceListRequest) GetIncludeTotalCount() bool + func (x *DeviceListRequest) GetLimit() int32 + func (x *DeviceListRequest) ProtoReflect() protoreflect.Message + func (x *DeviceListRequest) Reset() + func (x *DeviceListRequest) String() string + type DeviceListResponse struct + Error *Error + Result *DeviceListResult + func (*DeviceListResponse) Descriptor() ([]byte, []int) + func (*DeviceListResponse) ProtoMessage() + func (x *DeviceListResponse) GetError() *Error + func (x *DeviceListResponse) GetResult() *DeviceListResult + func (x *DeviceListResponse) ProtoReflect() protoreflect.Message + func (x *DeviceListResponse) Reset() + func (x *DeviceListResponse) String() string + type DeviceListResult struct + Items []*Device + NextCursor string + TotalCount int64 + func (*DeviceListResult) Descriptor() ([]byte, []int) + func (*DeviceListResult) ProtoMessage() + func (x *DeviceListResult) GetItems() []*Device + func (x *DeviceListResult) GetNextCursor() string + func (x *DeviceListResult) GetTotalCount() int64 + func (x *DeviceListResult) ProtoReflect() protoreflect.Message + func (x *DeviceListResult) Reset() + func (x *DeviceListResult) String() string + type DeviceLocaleUpdate struct + Locale string + func (*DeviceLocaleUpdate) Descriptor() ([]byte, []int) + func (*DeviceLocaleUpdate) ProtoMessage() + func (x *DeviceLocaleUpdate) GetLocale() string + func (x *DeviceLocaleUpdate) ProtoReflect() protoreflect.Message + func (x *DeviceLocaleUpdate) Reset() + func (x *DeviceLocaleUpdate) String() string + type DeviceMetaUpdate struct + Meta map[string]string + func (*DeviceMetaUpdate) Descriptor() ([]byte, []int) + func (*DeviceMetaUpdate) ProtoMessage() + func (x *DeviceMetaUpdate) GetMeta() map[string]string + func (x *DeviceMetaUpdate) ProtoReflect() protoreflect.Message + func (x *DeviceMetaUpdate) Reset() + func (x *DeviceMetaUpdate) String() string + type DeviceRegisterRequest struct + Id string + Locale string + Meta map[string]string + Platform string + Provider string + Timezone string + Token string + Topics []string + User string + func (*DeviceRegisterRequest) Descriptor() ([]byte, []int) + func (*DeviceRegisterRequest) ProtoMessage() + func (x *DeviceRegisterRequest) GetId() string + func (x *DeviceRegisterRequest) GetLocale() string + func (x *DeviceRegisterRequest) GetMeta() map[string]string + func (x *DeviceRegisterRequest) GetPlatform() string + func (x *DeviceRegisterRequest) GetProvider() string + func (x *DeviceRegisterRequest) GetTimezone() string + func (x *DeviceRegisterRequest) GetToken() string + func (x *DeviceRegisterRequest) GetTopics() []string + func (x *DeviceRegisterRequest) GetUser() string + func (x *DeviceRegisterRequest) ProtoReflect() protoreflect.Message + func (x *DeviceRegisterRequest) Reset() + func (x *DeviceRegisterRequest) String() string + type DeviceRegisterResponse struct + Error *Error + Result *DeviceRegisterResult + func (*DeviceRegisterResponse) Descriptor() ([]byte, []int) + func (*DeviceRegisterResponse) ProtoMessage() + func (x *DeviceRegisterResponse) GetError() *Error + func (x *DeviceRegisterResponse) GetResult() *DeviceRegisterResult + func (x *DeviceRegisterResponse) ProtoReflect() protoreflect.Message + func (x *DeviceRegisterResponse) Reset() + func (x *DeviceRegisterResponse) String() string + type DeviceRegisterResult struct + Id string + func (*DeviceRegisterResult) Descriptor() ([]byte, []int) + func (*DeviceRegisterResult) ProtoMessage() + func (x *DeviceRegisterResult) GetId() string + func (x *DeviceRegisterResult) ProtoReflect() protoreflect.Message + func (x *DeviceRegisterResult) Reset() + func (x *DeviceRegisterResult) String() string + type DeviceRemoveRequest struct + Ids []string + Users []string + func (*DeviceRemoveRequest) Descriptor() ([]byte, []int) + func (*DeviceRemoveRequest) ProtoMessage() + func (x *DeviceRemoveRequest) GetIds() []string + func (x *DeviceRemoveRequest) GetUsers() []string + func (x *DeviceRemoveRequest) ProtoReflect() protoreflect.Message + func (x *DeviceRemoveRequest) Reset() + func (x *DeviceRemoveRequest) String() string + type DeviceRemoveResponse struct + Error *Error + Result *DeviceRemoveResult + func (*DeviceRemoveResponse) Descriptor() ([]byte, []int) + func (*DeviceRemoveResponse) ProtoMessage() + func (x *DeviceRemoveResponse) GetError() *Error + func (x *DeviceRemoveResponse) GetResult() *DeviceRemoveResult + func (x *DeviceRemoveResponse) ProtoReflect() protoreflect.Message + func (x *DeviceRemoveResponse) Reset() + func (x *DeviceRemoveResponse) String() string + type DeviceRemoveResult struct + func (*DeviceRemoveResult) Descriptor() ([]byte, []int) + func (*DeviceRemoveResult) ProtoMessage() + func (x *DeviceRemoveResult) ProtoReflect() protoreflect.Message + func (x *DeviceRemoveResult) Reset() + func (x *DeviceRemoveResult) String() string + type DeviceTimezoneUpdate struct + Timezone string + func (*DeviceTimezoneUpdate) Descriptor() ([]byte, []int) + func (*DeviceTimezoneUpdate) ProtoMessage() + func (x *DeviceTimezoneUpdate) GetTimezone() string + func (x *DeviceTimezoneUpdate) ProtoReflect() protoreflect.Message + func (x *DeviceTimezoneUpdate) Reset() + func (x *DeviceTimezoneUpdate) String() string + type DeviceTopic struct + Device *Device + Id string + Topic string + func (*DeviceTopic) Descriptor() ([]byte, []int) + func (*DeviceTopic) ProtoMessage() + func (x *DeviceTopic) GetDevice() *Device + func (x *DeviceTopic) GetId() string + func (x *DeviceTopic) GetTopic() string + func (x *DeviceTopic) ProtoReflect() protoreflect.Message + func (x *DeviceTopic) Reset() + func (x *DeviceTopic) String() string + type DeviceTopicFilter struct + DeviceIds []string + DevicePlatforms []string + DeviceProviders []string + DeviceUsers []string + TopicPrefix string + Topics []string + func (*DeviceTopicFilter) Descriptor() ([]byte, []int) + func (*DeviceTopicFilter) ProtoMessage() + func (x *DeviceTopicFilter) GetDeviceIds() []string + func (x *DeviceTopicFilter) GetDevicePlatforms() []string + func (x *DeviceTopicFilter) GetDeviceProviders() []string + func (x *DeviceTopicFilter) GetDeviceUsers() []string + func (x *DeviceTopicFilter) GetTopicPrefix() string + func (x *DeviceTopicFilter) GetTopics() []string + func (x *DeviceTopicFilter) ProtoReflect() protoreflect.Message + func (x *DeviceTopicFilter) Reset() + func (x *DeviceTopicFilter) String() string + type DeviceTopicListRequest struct + Cursor string + Filter *DeviceTopicFilter + IncludeDevice bool + IncludeTotalCount bool + Limit int32 + func (*DeviceTopicListRequest) Descriptor() ([]byte, []int) + func (*DeviceTopicListRequest) ProtoMessage() + func (x *DeviceTopicListRequest) GetCursor() string + func (x *DeviceTopicListRequest) GetFilter() *DeviceTopicFilter + func (x *DeviceTopicListRequest) GetIncludeDevice() bool + func (x *DeviceTopicListRequest) GetIncludeTotalCount() bool + func (x *DeviceTopicListRequest) GetLimit() int32 + func (x *DeviceTopicListRequest) ProtoReflect() protoreflect.Message + func (x *DeviceTopicListRequest) Reset() + func (x *DeviceTopicListRequest) String() string + type DeviceTopicListResponse struct + Error *Error + Result *DeviceTopicListResult + func (*DeviceTopicListResponse) Descriptor() ([]byte, []int) + func (*DeviceTopicListResponse) ProtoMessage() + func (x *DeviceTopicListResponse) GetError() *Error + func (x *DeviceTopicListResponse) GetResult() *DeviceTopicListResult + func (x *DeviceTopicListResponse) ProtoReflect() protoreflect.Message + func (x *DeviceTopicListResponse) Reset() + func (x *DeviceTopicListResponse) String() string + type DeviceTopicListResult struct + Items []*DeviceTopic + NextCursor string + TotalCount int64 + func (*DeviceTopicListResult) Descriptor() ([]byte, []int) + func (*DeviceTopicListResult) ProtoMessage() + func (x *DeviceTopicListResult) GetItems() []*DeviceTopic + func (x *DeviceTopicListResult) GetNextCursor() string + func (x *DeviceTopicListResult) GetTotalCount() int64 + func (x *DeviceTopicListResult) ProtoReflect() protoreflect.Message + func (x *DeviceTopicListResult) Reset() + func (x *DeviceTopicListResult) String() string + type DeviceTopicUpdateRequest struct + DeviceId string + Op string + Topics []string + func (*DeviceTopicUpdateRequest) Descriptor() ([]byte, []int) + func (*DeviceTopicUpdateRequest) ProtoMessage() + func (x *DeviceTopicUpdateRequest) GetDeviceId() string + func (x *DeviceTopicUpdateRequest) GetOp() string + func (x *DeviceTopicUpdateRequest) GetTopics() []string + func (x *DeviceTopicUpdateRequest) ProtoReflect() protoreflect.Message + func (x *DeviceTopicUpdateRequest) Reset() + func (x *DeviceTopicUpdateRequest) String() string + type DeviceTopicUpdateResponse struct + Error *Error + Result *DeviceTopicUpdateResult + func (*DeviceTopicUpdateResponse) Descriptor() ([]byte, []int) + func (*DeviceTopicUpdateResponse) ProtoMessage() + func (x *DeviceTopicUpdateResponse) GetError() *Error + func (x *DeviceTopicUpdateResponse) GetResult() *DeviceTopicUpdateResult + func (x *DeviceTopicUpdateResponse) ProtoReflect() protoreflect.Message + func (x *DeviceTopicUpdateResponse) Reset() + func (x *DeviceTopicUpdateResponse) String() string + type DeviceTopicUpdateResult struct + func (*DeviceTopicUpdateResult) Descriptor() ([]byte, []int) + func (*DeviceTopicUpdateResult) ProtoMessage() + func (x *DeviceTopicUpdateResult) ProtoReflect() protoreflect.Message + func (x *DeviceTopicUpdateResult) Reset() + func (x *DeviceTopicUpdateResult) String() string + type DeviceTopicsUpdate struct + Op string + Topics []string + func (*DeviceTopicsUpdate) Descriptor() ([]byte, []int) + func (*DeviceTopicsUpdate) ProtoMessage() + func (x *DeviceTopicsUpdate) GetOp() string + func (x *DeviceTopicsUpdate) GetTopics() []string + func (x *DeviceTopicsUpdate) ProtoReflect() protoreflect.Message + func (x *DeviceTopicsUpdate) Reset() + func (x *DeviceTopicsUpdate) String() string + type DeviceUpdateRequest struct + Ids []string + LocaleUpdate *DeviceLocaleUpdate + MetaUpdate *DeviceMetaUpdate + TimezoneUpdate *DeviceTimezoneUpdate + TopicsUpdate *DeviceTopicsUpdate + UserUpdate *DeviceUserUpdate + Users []string + func (*DeviceUpdateRequest) Descriptor() ([]byte, []int) + func (*DeviceUpdateRequest) ProtoMessage() + func (x *DeviceUpdateRequest) GetIds() []string + func (x *DeviceUpdateRequest) GetLocaleUpdate() *DeviceLocaleUpdate + func (x *DeviceUpdateRequest) GetMetaUpdate() *DeviceMetaUpdate + func (x *DeviceUpdateRequest) GetTimezoneUpdate() *DeviceTimezoneUpdate + func (x *DeviceUpdateRequest) GetTopicsUpdate() *DeviceTopicsUpdate + func (x *DeviceUpdateRequest) GetUserUpdate() *DeviceUserUpdate + func (x *DeviceUpdateRequest) GetUsers() []string + func (x *DeviceUpdateRequest) ProtoReflect() protoreflect.Message + func (x *DeviceUpdateRequest) Reset() + func (x *DeviceUpdateRequest) String() string + type DeviceUpdateResponse struct + Error *Error + Result *DeviceUpdateResult + func (*DeviceUpdateResponse) Descriptor() ([]byte, []int) + func (*DeviceUpdateResponse) ProtoMessage() + func (x *DeviceUpdateResponse) GetError() *Error + func (x *DeviceUpdateResponse) GetResult() *DeviceUpdateResult + func (x *DeviceUpdateResponse) ProtoReflect() protoreflect.Message + func (x *DeviceUpdateResponse) Reset() + func (x *DeviceUpdateResponse) String() string + type DeviceUpdateResult struct + func (*DeviceUpdateResult) Descriptor() ([]byte, []int) + func (*DeviceUpdateResult) ProtoMessage() + func (x *DeviceUpdateResult) ProtoReflect() protoreflect.Message + func (x *DeviceUpdateResult) Reset() + func (x *DeviceUpdateResult) String() string + type DeviceUserUpdate struct + User string + func (*DeviceUserUpdate) Descriptor() ([]byte, []int) + func (*DeviceUserUpdate) ProtoMessage() + func (x *DeviceUserUpdate) GetUser() string + func (x *DeviceUserUpdate) ProtoReflect() protoreflect.Message + func (x *DeviceUserUpdate) Reset() + func (x *DeviceUserUpdate) String() string + type Disconnect struct + Code uint32 + Reason string + func (*Disconnect) Descriptor() ([]byte, []int) + func (*Disconnect) ProtoMessage() + func (x *Disconnect) GetCode() uint32 + func (x *Disconnect) GetReason() string + func (x *Disconnect) ProtoReflect() protoreflect.Message + func (x *Disconnect) Reset() + func (x *Disconnect) String() string + type DisconnectRequest struct + Client string + Disconnect *Disconnect + Session string + 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) GetSession() string + 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 FcmPushNotification struct + Message Raw + func (*FcmPushNotification) Descriptor() ([]byte, []int) + func (*FcmPushNotification) ProtoMessage() + func (x *FcmPushNotification) GetMessage() []byte + func (x *FcmPushNotification) ProtoReflect() protoreflect.Message + func (x *FcmPushNotification) Reset() + func (x *FcmPushNotification) 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 HmsPushNotification struct + Message Raw + func (*HmsPushNotification) Descriptor() ([]byte, []int) + func (*HmsPushNotification) ProtoMessage() + func (x *HmsPushNotification) GetMessage() []byte + func (x *HmsPushNotification) ProtoReflect() protoreflect.Message + func (x *HmsPushNotification) Reset() + func (x *HmsPushNotification) 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 InvalidateUserTokensRequest struct + Channel string + ExpireAt int64 + IssuedBefore int64 + User string + func (*InvalidateUserTokensRequest) Descriptor() ([]byte, []int) + func (*InvalidateUserTokensRequest) ProtoMessage() + func (x *InvalidateUserTokensRequest) GetChannel() string + 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 JSONCommandDecoder struct + func NewJSONCommandDecoder(data []byte) *JSONCommandDecoder + func (d *JSONCommandDecoder) Decode() (*Command, error) + func (d *JSONCommandDecoder) Reset(data []byte) + type JSONReplyEncoder struct + func NewJSONReplyEncoder() *JSONReplyEncoder + func (e *JSONReplyEncoder) Encode(r *Reply) error + func (e *JSONReplyEncoder) Finish() []byte + func (e *JSONReplyEncoder) Reset() + type JSONRequestDecoder struct + func NewJSONRequestDecoder() *JSONRequestDecoder + func (d *JSONRequestDecoder) DecodeBatch(data []byte) (*BatchRequest, error) + func (d *JSONRequestDecoder) DecodeBroadcast(data []byte) (*BroadcastRequest, error) + func (d *JSONRequestDecoder) DecodeChannels(data []byte) (*ChannelsRequest, error) + func (d *JSONRequestDecoder) DecodeDisconnect(data []byte) (*DisconnectRequest, error) + func (d *JSONRequestDecoder) DecodeHistory(data []byte) (*HistoryRequest, error) + func (d *JSONRequestDecoder) DecodeHistoryRemove(data []byte) (*HistoryRemoveRequest, error) + func (d *JSONRequestDecoder) DecodeInfo(data []byte) (*InfoRequest, error) + func (d *JSONRequestDecoder) DecodePresence(data []byte) (*PresenceRequest, error) + func (d *JSONRequestDecoder) DecodePresenceStats(data []byte) (*PresenceStatsRequest, error) + func (d *JSONRequestDecoder) DecodePublish(data []byte) (*PublishRequest, error) + func (d *JSONRequestDecoder) DecodeRPC(data []byte) (*RPCRequest, error) + func (d *JSONRequestDecoder) DecodeRefresh(data []byte) (*RefreshRequest, error) + func (d *JSONRequestDecoder) DecodeSubscribe(data []byte) (*SubscribeRequest, error) + func (d *JSONRequestDecoder) DecodeUnsubscribe(data []byte) (*UnsubscribeRequest, error) + type JSONResponseEncoder struct + func NewJSONResponseEncoder() *JSONResponseEncoder + func (e *JSONResponseEncoder) EncodeBatch(response *BatchResponse) ([]byte, error) + func (e *JSONResponseEncoder) EncodeBroadcast(response *BroadcastResponse) ([]byte, error) + func (e *JSONResponseEncoder) EncodeChannels(response *ChannelsResponse) ([]byte, error) + func (e *JSONResponseEncoder) EncodeDisconnect(response *DisconnectResponse) ([]byte, error) + func (e *JSONResponseEncoder) EncodeHistory(response *HistoryResponse) ([]byte, error) + func (e *JSONResponseEncoder) EncodeHistoryRemove(response *HistoryRemoveResponse) ([]byte, error) + func (e *JSONResponseEncoder) EncodeInfo(response *InfoResponse) ([]byte, error) + func (e *JSONResponseEncoder) EncodePresence(response *PresenceResponse) ([]byte, error) + func (e *JSONResponseEncoder) EncodePresenceStats(response *PresenceStatsResponse) ([]byte, error) + func (e *JSONResponseEncoder) EncodePublish(response *PublishResponse) ([]byte, error) + func (e *JSONResponseEncoder) EncodeRPC(response *RPCResponse) ([]byte, error) + func (e *JSONResponseEncoder) EncodeRefresh(response *RefreshResponse) ([]byte, error) + func (e *JSONResponseEncoder) EncodeSubscribe(response *SubscribeResponse) ([]byte, error) + func (e *JSONResponseEncoder) EncodeUnsubscribe(response *UnsubscribeResponse) ([]byte, error) + type JSONResultEncoder struct + func NewJSONResultEncoder() *JSONResultEncoder + func (e *JSONResultEncoder) EncodeBroadcast(res *BroadcastResult) ([]byte, error) + func (e *JSONResultEncoder) EncodeChannels(res *ChannelsResult) ([]byte, error) + func (e *JSONResultEncoder) EncodeDisconnect(res *DisconnectResult) ([]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) + 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 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 + Tags map[string]string + 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) GetTags() map[string]string + func (x *Publication) ProtoReflect() protoreflect.Message + func (x *Publication) Reset() + func (x *Publication) String() string + type PublishRequest struct + B64Data string + Channel string + Data Raw + Delta bool + IdempotencyKey string + SkipHistory bool + Tags map[string]string + 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) GetDelta() bool + func (x *PublishRequest) GetIdempotencyKey() string + func (x *PublishRequest) GetSkipHistory() bool + func (x *PublishRequest) GetTags() map[string]string + 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 PushLimitStrategy struct + RateLimit *PushRateLimitStrategy + TimeLimit *PushTimeLimitStrategy + func (*PushLimitStrategy) Descriptor() ([]byte, []int) + func (*PushLimitStrategy) ProtoMessage() + func (x *PushLimitStrategy) GetRateLimit() *PushRateLimitStrategy + func (x *PushLimitStrategy) GetTimeLimit() *PushTimeLimitStrategy + func (x *PushLimitStrategy) ProtoReflect() protoreflect.Message + func (x *PushLimitStrategy) Reset() + func (x *PushLimitStrategy) String() string + type PushLocalization struct + Translations map[string]string + func (*PushLocalization) Descriptor() ([]byte, []int) + func (*PushLocalization) ProtoMessage() + func (x *PushLocalization) GetTranslations() map[string]string + func (x *PushLocalization) ProtoReflect() protoreflect.Message + func (x *PushLocalization) Reset() + func (x *PushLocalization) String() string + type PushNotification struct + Apns *ApnsPushNotification + ExpireAt int64 + Fcm *FcmPushNotification + Hms *HmsPushNotification + func (*PushNotification) Descriptor() ([]byte, []int) + func (*PushNotification) ProtoMessage() + func (x *PushNotification) GetApns() *ApnsPushNotification + func (x *PushNotification) GetExpireAt() int64 + func (x *PushNotification) GetFcm() *FcmPushNotification + func (x *PushNotification) GetHms() *HmsPushNotification + func (x *PushNotification) ProtoReflect() protoreflect.Message + func (x *PushNotification) Reset() + func (x *PushNotification) String() string + type PushRateLimitStrategy struct + DropIfRateLimited bool + Key string + Policies []*RateLimitPolicy + func (*PushRateLimitStrategy) Descriptor() ([]byte, []int) + func (*PushRateLimitStrategy) ProtoMessage() + func (x *PushRateLimitStrategy) GetDropIfRateLimited() bool + func (x *PushRateLimitStrategy) GetKey() string + func (x *PushRateLimitStrategy) GetPolicies() []*RateLimitPolicy + func (x *PushRateLimitStrategy) ProtoReflect() protoreflect.Message + func (x *PushRateLimitStrategy) Reset() + func (x *PushRateLimitStrategy) String() string + type PushRecipient struct + ApnsTokens []string + FcmCondition string + FcmTokens []string + FcmTopic string + Filter *DeviceFilter + HmsCondition string + HmsTokens []string + HmsTopic string + func (*PushRecipient) Descriptor() ([]byte, []int) + func (*PushRecipient) ProtoMessage() + func (x *PushRecipient) GetApnsTokens() []string + func (x *PushRecipient) GetFcmCondition() string + func (x *PushRecipient) GetFcmTokens() []string + func (x *PushRecipient) GetFcmTopic() string + func (x *PushRecipient) GetFilter() *DeviceFilter + func (x *PushRecipient) GetHmsCondition() string + func (x *PushRecipient) GetHmsTokens() []string + func (x *PushRecipient) GetHmsTopic() string + func (x *PushRecipient) ProtoReflect() protoreflect.Message + func (x *PushRecipient) Reset() + func (x *PushRecipient) String() string + type PushTimeLimitStrategy struct + NoTzSendNow bool + SendAfterTime string + SendBeforeTime string + func (*PushTimeLimitStrategy) Descriptor() ([]byte, []int) + func (*PushTimeLimitStrategy) ProtoMessage() + func (x *PushTimeLimitStrategy) GetNoTzSendNow() bool + func (x *PushTimeLimitStrategy) GetSendAfterTime() string + func (x *PushTimeLimitStrategy) GetSendBeforeTime() string + func (x *PushTimeLimitStrategy) ProtoReflect() protoreflect.Message + func (x *PushTimeLimitStrategy) Reset() + func (x *PushTimeLimitStrategy) 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 RateLimitPolicy struct + IntervalMs int32 + Rate int64 + func (*RateLimitPolicy) Descriptor() ([]byte, []int) + func (*RateLimitPolicy) ProtoMessage() + func (x *RateLimitPolicy) GetIntervalMs() int32 + func (x *RateLimitPolicy) GetRate() int64 + func (x *RateLimitPolicy) ProtoReflect() protoreflect.Message + func (x *RateLimitPolicy) Reset() + func (x *RateLimitPolicy) String() string + type RateLimitPolicyEvaluation struct + Allowed bool + AllowedInMs int32 + TokensLeft int64 + func (*RateLimitPolicyEvaluation) Descriptor() ([]byte, []int) + func (*RateLimitPolicyEvaluation) ProtoMessage() + func (x *RateLimitPolicyEvaluation) GetAllowed() bool + func (x *RateLimitPolicyEvaluation) GetAllowedInMs() int32 + func (x *RateLimitPolicyEvaluation) GetTokensLeft() int64 + func (x *RateLimitPolicyEvaluation) ProtoReflect() protoreflect.Message + func (x *RateLimitPolicyEvaluation) Reset() + func (x *RateLimitPolicyEvaluation) String() string + type RateLimitRequest struct + DryRun bool + IncludePolicyEvaluations bool + Key string + Policies []*RateLimitPolicy + Score int64 + func (*RateLimitRequest) Descriptor() ([]byte, []int) + func (*RateLimitRequest) ProtoMessage() + func (x *RateLimitRequest) GetDryRun() bool + func (x *RateLimitRequest) GetIncludePolicyEvaluations() bool + func (x *RateLimitRequest) GetKey() string + func (x *RateLimitRequest) GetPolicies() []*RateLimitPolicy + func (x *RateLimitRequest) GetScore() int64 + func (x *RateLimitRequest) ProtoReflect() protoreflect.Message + func (x *RateLimitRequest) Reset() + func (x *RateLimitRequest) String() string + type RateLimitResponse struct + Error *Error + Result *RateLimitResult + func (*RateLimitResponse) Descriptor() ([]byte, []int) + func (*RateLimitResponse) ProtoMessage() + func (x *RateLimitResponse) GetError() *Error + func (x *RateLimitResponse) GetResult() *RateLimitResult + func (x *RateLimitResponse) ProtoReflect() protoreflect.Message + func (x *RateLimitResponse) Reset() + func (x *RateLimitResponse) String() string + type RateLimitResult struct + Allowed bool + AllowedInMs int32 + Policies []*RateLimitPolicyEvaluation + ServerTimeMs int64 + func (*RateLimitResult) Descriptor() ([]byte, []int) + func (*RateLimitResult) ProtoMessage() + func (x *RateLimitResult) GetAllowed() bool + func (x *RateLimitResult) GetAllowedInMs() int32 + func (x *RateLimitResult) GetPolicies() []*RateLimitPolicyEvaluation + func (x *RateLimitResult) GetServerTimeMs() int64 + func (x *RateLimitResult) ProtoReflect() protoreflect.Message + func (x *RateLimitResult) Reset() + func (x *RateLimitResult) 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 + Session string + 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) GetSession() string + 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 + BlockUser *BlockUserResult + Broadcast *BroadcastResult + CancelPush *CancelPushResult + Channels *ChannelsResult + Connections *ConnectionsResult + DeleteUserStatus *DeleteUserStatusResult + DeviceList *DeviceListResult + DeviceRegister *DeviceRegisterResult + DeviceRemove *DeviceRemoveResult + DeviceTopicList *DeviceTopicListResult + DeviceTopicUpdate *DeviceTopicUpdateResult + DeviceUpdate *DeviceUpdateResult + Disconnect *DisconnectResult + Error *Error + GetUserStatus *GetUserStatusResult + History *HistoryResult + HistoryRemove *HistoryRemoveResult + Id uint32 + Info *InfoResult + InvalidateUserTokens *InvalidateUserTokensResult + Presence *PresenceResult + PresenceStats *PresenceStatsResult + Publish *PublishResult + Refresh *RefreshResult + Result Raw + RevokeToken *RevokeTokenResult + Rpc *RPCResult + SendPushNotification *SendPushNotificationResult + Subscribe *SubscribeResult + UnblockUser *UnblockUserResult + Unsubscribe *UnsubscribeResult + UpdatePushStatus *UpdatePushStatusResult + UpdateUserStatus *UpdateUserStatusResult + UserTopicList *UserTopicListResult + UserTopicUpdate *UserTopicUpdateResult + func (*Reply) Descriptor() ([]byte, []int) + func (*Reply) ProtoMessage() + func (x *Reply) GetBlockUser() *BlockUserResult + func (x *Reply) GetBroadcast() *BroadcastResult + func (x *Reply) GetCancelPush() *CancelPushResult + func (x *Reply) GetChannels() *ChannelsResult + func (x *Reply) GetConnections() *ConnectionsResult + func (x *Reply) GetDeleteUserStatus() *DeleteUserStatusResult + func (x *Reply) GetDeviceList() *DeviceListResult + func (x *Reply) GetDeviceRegister() *DeviceRegisterResult + func (x *Reply) GetDeviceRemove() *DeviceRemoveResult + func (x *Reply) GetDeviceTopicList() *DeviceTopicListResult + func (x *Reply) GetDeviceTopicUpdate() *DeviceTopicUpdateResult + func (x *Reply) GetDeviceUpdate() *DeviceUpdateResult + func (x *Reply) GetDisconnect() *DisconnectResult + func (x *Reply) GetError() *Error + func (x *Reply) GetGetUserStatus() *GetUserStatusResult + func (x *Reply) GetHistory() *HistoryResult + func (x *Reply) GetHistoryRemove() *HistoryRemoveResult + func (x *Reply) GetId() uint32 + func (x *Reply) GetInfo() *InfoResult + func (x *Reply) GetInvalidateUserTokens() *InvalidateUserTokensResult + func (x *Reply) GetPresence() *PresenceResult + func (x *Reply) GetPresenceStats() *PresenceStatsResult + func (x *Reply) GetPublish() *PublishResult + func (x *Reply) GetRefresh() *RefreshResult + func (x *Reply) GetResult() []byte + func (x *Reply) GetRevokeToken() *RevokeTokenResult + func (x *Reply) GetRpc() *RPCResult + func (x *Reply) GetSendPushNotification() *SendPushNotificationResult + func (x *Reply) GetSubscribe() *SubscribeResult + func (x *Reply) GetUnblockUser() *UnblockUserResult + func (x *Reply) GetUnsubscribe() *UnsubscribeResult + func (x *Reply) GetUpdatePushStatus() *UpdatePushStatusResult + func (x *Reply) GetUpdateUserStatus() *UpdateUserStatusResult + func (x *Reply) GetUserTopicList() *UserTopicListResult + func (x *Reply) GetUserTopicUpdate() *UserTopicUpdateResult + 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 RequestDecoder interface + DecodeBatch func([]byte) (*BatchRequest, error) + DecodeBroadcast func([]byte) (*BroadcastRequest, error) + DecodeChannels func([]byte) (*ChannelsRequest, error) + DecodeDisconnect func([]byte) (*DisconnectRequest, 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) + func GetParamsDecoder() RequestDecoder + type ResetRateLimitRequest struct + Key string + func (*ResetRateLimitRequest) Descriptor() ([]byte, []int) + func (*ResetRateLimitRequest) ProtoMessage() + func (x *ResetRateLimitRequest) GetKey() string + func (x *ResetRateLimitRequest) ProtoReflect() protoreflect.Message + func (x *ResetRateLimitRequest) Reset() + func (x *ResetRateLimitRequest) String() string + type ResetRateLimitResponse struct + Error *Error + Result *ResetRateLimitResult + func (*ResetRateLimitResponse) Descriptor() ([]byte, []int) + func (*ResetRateLimitResponse) ProtoMessage() + func (x *ResetRateLimitResponse) GetError() *Error + func (x *ResetRateLimitResponse) GetResult() *ResetRateLimitResult + func (x *ResetRateLimitResponse) ProtoReflect() protoreflect.Message + func (x *ResetRateLimitResponse) Reset() + func (x *ResetRateLimitResponse) String() string + type ResetRateLimitResult struct + func (*ResetRateLimitResult) Descriptor() ([]byte, []int) + func (*ResetRateLimitResult) ProtoMessage() + func (x *ResetRateLimitResult) ProtoReflect() protoreflect.Message + func (x *ResetRateLimitResult) Reset() + func (x *ResetRateLimitResult) String() string + type ResponseEncoder interface + EncodeBatch func(response *BatchResponse) ([]byte, error) + EncodeBroadcast func(*BroadcastResponse) ([]byte, error) + EncodeChannels func(*ChannelsResponse) ([]byte, error) + EncodeDisconnect func(*DisconnectResponse) ([]byte, error) + EncodeHistory func(*HistoryResponse) ([]byte, error) + EncodeHistoryRemove func(*HistoryRemoveResponse) ([]byte, error) + EncodeInfo func(*InfoResponse) ([]byte, error) + EncodePresence func(*PresenceResponse) ([]byte, error) + EncodePresenceStats func(*PresenceStatsResponse) ([]byte, error) + EncodePublish func(*PublishResponse) ([]byte, error) + EncodeRPC func(*RPCResponse) ([]byte, error) + EncodeRefresh func(*RefreshResponse) ([]byte, error) + EncodeSubscribe func(*SubscribeResponse) ([]byte, error) + EncodeUnsubscribe func(*UnsubscribeResponse) ([]byte, error) + type ResultEncoder interface + EncodeBroadcast func(*BroadcastResult) ([]byte, error) + EncodeChannels func(*ChannelsResult) ([]byte, error) + EncodeDisconnect func(*DisconnectResult) ([]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) + func GetResultEncoder() ResultEncoder + 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 SendPushNotificationRequest struct + AnalyticsUid string + LimitStrategy *PushLimitStrategy + Localizations map[string]*PushLocalization + Notification *PushNotification + OptimizeForReliability bool + Recipient *PushRecipient + SendAt int64 + Uid string + UseMeta bool + UseTemplating bool + func (*SendPushNotificationRequest) Descriptor() ([]byte, []int) + func (*SendPushNotificationRequest) ProtoMessage() + func (x *SendPushNotificationRequest) GetAnalyticsUid() string + func (x *SendPushNotificationRequest) GetLimitStrategy() *PushLimitStrategy + func (x *SendPushNotificationRequest) GetLocalizations() map[string]*PushLocalization + func (x *SendPushNotificationRequest) GetNotification() *PushNotification + func (x *SendPushNotificationRequest) GetOptimizeForReliability() bool + func (x *SendPushNotificationRequest) GetRecipient() *PushRecipient + func (x *SendPushNotificationRequest) GetSendAt() int64 + func (x *SendPushNotificationRequest) GetUid() string + func (x *SendPushNotificationRequest) GetUseMeta() bool + func (x *SendPushNotificationRequest) GetUseTemplating() bool + func (x *SendPushNotificationRequest) ProtoReflect() protoreflect.Message + func (x *SendPushNotificationRequest) Reset() + func (x *SendPushNotificationRequest) String() string + type SendPushNotificationResponse struct + Error *Error + Result *SendPushNotificationResult + func (*SendPushNotificationResponse) Descriptor() ([]byte, []int) + func (*SendPushNotificationResponse) ProtoMessage() + func (x *SendPushNotificationResponse) GetError() *Error + func (x *SendPushNotificationResponse) GetResult() *SendPushNotificationResult + func (x *SendPushNotificationResponse) ProtoReflect() protoreflect.Message + func (x *SendPushNotificationResponse) Reset() + func (x *SendPushNotificationResponse) String() string + type SendPushNotificationResult struct + Uid string + func (*SendPushNotificationResult) Descriptor() ([]byte, []int) + func (*SendPushNotificationResult) ProtoMessage() + func (x *SendPushNotificationResult) GetUid() string + func (x *SendPushNotificationResult) ProtoReflect() protoreflect.Message + func (x *SendPushNotificationResult) Reset() + func (x *SendPushNotificationResult) String() string + 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 + ForcePositioning *BoolValue + ForcePushJoinLeave *BoolValue + ForceRecovery *BoolValue + JoinLeave *BoolValue + Presence *BoolValue + func (*SubscribeOptionOverride) Descriptor() ([]byte, []int) + func (*SubscribeOptionOverride) ProtoMessage() + func (x *SubscribeOptionOverride) GetForcePositioning() *BoolValue + func (x *SubscribeOptionOverride) GetForcePushJoinLeave() *BoolValue + func (x *SubscribeOptionOverride) GetForceRecovery() *BoolValue + func (x *SubscribeOptionOverride) GetJoinLeave() *BoolValue + func (x *SubscribeOptionOverride) GetPresence() *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 + Session string + 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) GetSession() string + 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 SubscriptionTokenInfo struct + IssuedAt int64 + Uid string + func (*SubscriptionTokenInfo) Descriptor() ([]byte, []int) + func (*SubscriptionTokenInfo) ProtoMessage() + func (x *SubscriptionTokenInfo) GetIssuedAt() int64 + func (x *SubscriptionTokenInfo) GetUid() string + func (x *SubscriptionTokenInfo) ProtoReflect() protoreflect.Message + func (x *SubscriptionTokenInfo) Reset() + func (x *SubscriptionTokenInfo) 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 struct + func (UnimplementedCentrifugoApiServer) Batch(context.Context, *BatchRequest) (*BatchResponse, error) + func (UnimplementedCentrifugoApiServer) BlockUser(context.Context, *BlockUserRequest) (*BlockUserResponse, error) + func (UnimplementedCentrifugoApiServer) Broadcast(context.Context, *BroadcastRequest) (*BroadcastResponse, error) + func (UnimplementedCentrifugoApiServer) CancelPush(context.Context, *CancelPushRequest) (*CancelPushResponse, error) + func (UnimplementedCentrifugoApiServer) Channels(context.Context, *ChannelsRequest) (*ChannelsResponse, error) + func (UnimplementedCentrifugoApiServer) Connections(context.Context, *ConnectionsRequest) (*ConnectionsResponse, error) + func (UnimplementedCentrifugoApiServer) DeleteUserStatus(context.Context, *DeleteUserStatusRequest) (*DeleteUserStatusResponse, error) + func (UnimplementedCentrifugoApiServer) DeviceList(context.Context, *DeviceListRequest) (*DeviceListResponse, error) + func (UnimplementedCentrifugoApiServer) DeviceRegister(context.Context, *DeviceRegisterRequest) (*DeviceRegisterResponse, error) + func (UnimplementedCentrifugoApiServer) DeviceRemove(context.Context, *DeviceRemoveRequest) (*DeviceRemoveResponse, error) + func (UnimplementedCentrifugoApiServer) DeviceTopicList(context.Context, *DeviceTopicListRequest) (*DeviceTopicListResponse, error) + func (UnimplementedCentrifugoApiServer) DeviceTopicUpdate(context.Context, *DeviceTopicUpdateRequest) (*DeviceTopicUpdateResponse, error) + func (UnimplementedCentrifugoApiServer) DeviceUpdate(context.Context, *DeviceUpdateRequest) (*DeviceUpdateResponse, 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) InvalidateUserTokens(context.Context, *InvalidateUserTokensRequest) (*InvalidateUserTokensResponse, 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) RevokeToken(context.Context, *RevokeTokenRequest) (*RevokeTokenResponse, error) + func (UnimplementedCentrifugoApiServer) SendPushNotification(context.Context, *SendPushNotificationRequest) (*SendPushNotificationResponse, error) + func (UnimplementedCentrifugoApiServer) Subscribe(context.Context, *SubscribeRequest) (*SubscribeResponse, error) + func (UnimplementedCentrifugoApiServer) UnblockUser(context.Context, *UnblockUserRequest) (*UnblockUserResponse, error) + func (UnimplementedCentrifugoApiServer) Unsubscribe(context.Context, *UnsubscribeRequest) (*UnsubscribeResponse, error) + func (UnimplementedCentrifugoApiServer) UpdatePushStatus(context.Context, *UpdatePushStatusRequest) (*UpdatePushStatusResponse, error) + func (UnimplementedCentrifugoApiServer) UpdateUserStatus(context.Context, *UpdateUserStatusRequest) (*UpdateUserStatusResponse, error) + func (UnimplementedCentrifugoApiServer) UserTopicList(context.Context, *UserTopicListRequest) (*UserTopicListResponse, error) + func (UnimplementedCentrifugoApiServer) UserTopicUpdate(context.Context, *UserTopicUpdateRequest) (*UserTopicUpdateResponse, error) + type UnsafeCentrifugoApiServer interface + type UnsubscribeRequest struct + Channel string + Client string + Session string + User string + func (*UnsubscribeRequest) Descriptor() ([]byte, []int) + func (*UnsubscribeRequest) ProtoMessage() + func (x *UnsubscribeRequest) GetChannel() string + func (x *UnsubscribeRequest) GetClient() string + func (x *UnsubscribeRequest) GetSession() 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 UpdatePushStatusRequest struct + AnalyticsUid string + DeviceId string + MsgId string + Status string + func (*UpdatePushStatusRequest) Descriptor() ([]byte, []int) + func (*UpdatePushStatusRequest) ProtoMessage() + func (x *UpdatePushStatusRequest) GetAnalyticsUid() string + func (x *UpdatePushStatusRequest) GetDeviceId() string + func (x *UpdatePushStatusRequest) GetMsgId() string + func (x *UpdatePushStatusRequest) GetStatus() string + func (x *UpdatePushStatusRequest) ProtoReflect() protoreflect.Message + func (x *UpdatePushStatusRequest) Reset() + func (x *UpdatePushStatusRequest) String() string + type UpdatePushStatusResponse struct + Error *Error + Result *UpdatePushStatusResult + func (*UpdatePushStatusResponse) Descriptor() ([]byte, []int) + func (*UpdatePushStatusResponse) ProtoMessage() + func (x *UpdatePushStatusResponse) GetError() *Error + func (x *UpdatePushStatusResponse) GetResult() *UpdatePushStatusResult + func (x *UpdatePushStatusResponse) ProtoReflect() protoreflect.Message + func (x *UpdatePushStatusResponse) Reset() + func (x *UpdatePushStatusResponse) String() string + type UpdatePushStatusResult struct + func (*UpdatePushStatusResult) Descriptor() ([]byte, []int) + func (*UpdatePushStatusResult) ProtoMessage() + func (x *UpdatePushStatusResult) ProtoReflect() protoreflect.Message + func (x *UpdatePushStatusResult) Reset() + func (x *UpdatePushStatusResult) String() string + type UpdateUserStatusRequest struct + State string + Users []string + func (*UpdateUserStatusRequest) Descriptor() ([]byte, []int) + func (*UpdateUserStatusRequest) ProtoMessage() + func (x *UpdateUserStatusRequest) GetState() string + 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 UserStatus struct + Active int64 + Online int64 + State string + User string + func (*UserStatus) Descriptor() ([]byte, []int) + func (*UserStatus) ProtoMessage() + func (x *UserStatus) GetActive() int64 + func (x *UserStatus) GetOnline() int64 + func (x *UserStatus) GetState() string + func (x *UserStatus) GetUser() string + func (x *UserStatus) ProtoReflect() protoreflect.Message + func (x *UserStatus) Reset() + func (x *UserStatus) String() string + type UserTopic struct + Id string + Topic string + User string + func (*UserTopic) Descriptor() ([]byte, []int) + func (*UserTopic) ProtoMessage() + func (x *UserTopic) GetId() string + func (x *UserTopic) GetTopic() string + func (x *UserTopic) GetUser() string + func (x *UserTopic) ProtoReflect() protoreflect.Message + func (x *UserTopic) Reset() + func (x *UserTopic) String() string + type UserTopicFilter struct + TopicPrefix string + Topics []string + Users []string + func (*UserTopicFilter) Descriptor() ([]byte, []int) + func (*UserTopicFilter) ProtoMessage() + func (x *UserTopicFilter) GetTopicPrefix() string + func (x *UserTopicFilter) GetTopics() []string + func (x *UserTopicFilter) GetUsers() []string + func (x *UserTopicFilter) ProtoReflect() protoreflect.Message + func (x *UserTopicFilter) Reset() + func (x *UserTopicFilter) String() string + type UserTopicListRequest struct + Cursor string + Filter *UserTopicFilter + IncludeTotalCount bool + Limit int32 + func (*UserTopicListRequest) Descriptor() ([]byte, []int) + func (*UserTopicListRequest) ProtoMessage() + func (x *UserTopicListRequest) GetCursor() string + func (x *UserTopicListRequest) GetFilter() *UserTopicFilter + func (x *UserTopicListRequest) GetIncludeTotalCount() bool + func (x *UserTopicListRequest) GetLimit() int32 + func (x *UserTopicListRequest) ProtoReflect() protoreflect.Message + func (x *UserTopicListRequest) Reset() + func (x *UserTopicListRequest) String() string + type UserTopicListResponse struct + Error *Error + Result *UserTopicListResult + func (*UserTopicListResponse) Descriptor() ([]byte, []int) + func (*UserTopicListResponse) ProtoMessage() + func (x *UserTopicListResponse) GetError() *Error + func (x *UserTopicListResponse) GetResult() *UserTopicListResult + func (x *UserTopicListResponse) ProtoReflect() protoreflect.Message + func (x *UserTopicListResponse) Reset() + func (x *UserTopicListResponse) String() string + type UserTopicListResult struct + Items []*UserTopic + NextCursor string + TotalCount int64 + func (*UserTopicListResult) Descriptor() ([]byte, []int) + func (*UserTopicListResult) ProtoMessage() + func (x *UserTopicListResult) GetItems() []*UserTopic + func (x *UserTopicListResult) GetNextCursor() string + func (x *UserTopicListResult) GetTotalCount() int64 + func (x *UserTopicListResult) ProtoReflect() protoreflect.Message + func (x *UserTopicListResult) Reset() + func (x *UserTopicListResult) String() string + type UserTopicUpdateRequest struct + Op string + Topics []string + User string + func (*UserTopicUpdateRequest) Descriptor() ([]byte, []int) + func (*UserTopicUpdateRequest) ProtoMessage() + func (x *UserTopicUpdateRequest) GetOp() string + func (x *UserTopicUpdateRequest) GetTopics() []string + func (x *UserTopicUpdateRequest) GetUser() string + func (x *UserTopicUpdateRequest) ProtoReflect() protoreflect.Message + func (x *UserTopicUpdateRequest) Reset() + func (x *UserTopicUpdateRequest) String() string + type UserTopicUpdateResponse struct + Error *Error + Result *UserTopicUpdateResult + func (*UserTopicUpdateResponse) Descriptor() ([]byte, []int) + func (*UserTopicUpdateResponse) ProtoMessage() + func (x *UserTopicUpdateResponse) GetError() *Error + func (x *UserTopicUpdateResponse) GetResult() *UserTopicUpdateResult + func (x *UserTopicUpdateResponse) ProtoReflect() protoreflect.Message + func (x *UserTopicUpdateResponse) Reset() + func (x *UserTopicUpdateResponse) String() string + type UserTopicUpdateResult struct + func (*UserTopicUpdateResult) Descriptor() ([]byte, []int) + func (*UserTopicUpdateResult) ProtoMessage() + func (x *UserTopicUpdateResult) ProtoReflect() protoreflect.Message + func (x *UserTopicUpdateResult) Reset() + func (x *UserTopicUpdateResult) String() string Other modules containing this package github.com/centrifugal/centrifugo/v3 github.com/centrifugal/centrifugo/v4 github.com/centrifugal/centrifugo/v5
Go to main page