apiproto

package

Go to main page

Versions in this module

v4

v4.1.5

Jun 24, 2023

v4.1.4

Jun 14, 2023

Changes in this version

type CentrifugoApiClient

+ UpdatePushStatus func(ctx context.Context, in *UpdatePushStatusRequest, opts ...grpc.CallOption) (*UpdatePushStatusResponse, error)

type CentrifugoApiServer

+ UpdatePushStatus func(context.Context, *UpdatePushStatusRequest) (*UpdatePushStatusResponse, error)

type UnimplementedCentrifugoApiServer

+ func (UnimplementedCentrifugoApiServer) UpdatePushStatus(context.Context, *UpdatePushStatusRequest) (*UpdatePushStatusResponse, error)

v4.1.3

Apr 19, 2023

Changes in this version

+ 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

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

+ func (*BatchRequest) ProtoMessage()

+ func (x *BatchRequest) GetCommands() []*Command

+ 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 CentrifugoApiClient

+ Batch func(ctx context.Context, in *BatchRequest, opts ...grpc.CallOption) (*BatchResponse, 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)

+ SendPushNotification func(ctx context.Context, in *SendPushNotificationRequest, opts ...grpc.CallOption) (*SendPushNotificationResponse, 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)

type CentrifugoApiServer

+ Batch func(context.Context, *BatchRequest) (*BatchResponse, 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)

+ SendPushNotification func(context.Context, *SendPushNotificationRequest) (*SendPushNotificationResponse, error)

+ UserTopicList func(context.Context, *UserTopicListRequest) (*UserTopicListResponse, error)

+ UserTopicUpdate func(context.Context, *UserTopicUpdateRequest) (*UserTopicUpdateResponse, error)

type Command

+ BlockUser *BlockUserRequest

+ Broadcast *BroadcastRequest

+ 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

+ Info *InfoRequest

+ InvalidateUserTokens *InvalidateUserTokensRequest

+ 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 (x *Command) GetBlockUser() *BlockUserRequest

+ func (x *Command) GetBroadcast() *BroadcastRequest

+ 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) GetInfo() *InfoRequest

+ func (x *Command) GetInvalidateUserTokens() *InvalidateUserTokensRequest

+ 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

type Command_MethodType

+ 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_SEND_PUSH_NOTIFICATION

+ const Command_UPDATE_PUSH_STATUS

+ const Command_USER_TOPIC_LIST

+ const Command_USER_TOPIC_UPDATE

+ type Device struct

+ Id string

+ Meta map[string]string

+ Platform string

+ Provider string

+ Tags map[string]string

+ Token string

+ Topics []string

+ User string

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

+ func (*Device) ProtoMessage()

+ func (x *Device) GetId() string

+ func (x *Device) GetMeta() map[string]string

+ func (x *Device) GetPlatform() string

+ func (x *Device) GetProvider() string

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

+ func (x *Device) GetToken() string

+ func (x *Device) GetTopics() []string

+ func (x *Device) GetUser() string

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

+ func (x *Device) Reset()

+ func (x *Device) String() string

+ type DeviceListRequest struct

+ Ids []string

+ IncludeMeta bool

+ IncludeTags bool

+ IncludeTopics bool

+ Limit int32

+ Platforms []string

+ ProviderTokens []*DeviceProviderTokens

+ Providers []string

+ Since string

+ Topics []string

+ Users []string

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

+ func (*DeviceListRequest) ProtoMessage()

+ func (x *DeviceListRequest) GetIds() []string

+ func (x *DeviceListRequest) GetIncludeMeta() bool

+ func (x *DeviceListRequest) GetIncludeTags() bool

+ func (x *DeviceListRequest) GetIncludeTopics() bool

+ func (x *DeviceListRequest) GetLimit() int32

+ func (x *DeviceListRequest) GetPlatforms() []string

+ func (x *DeviceListRequest) GetProviderTokens() []*DeviceProviderTokens

+ func (x *DeviceListRequest) GetProviders() []string

+ func (x *DeviceListRequest) GetSince() string

+ func (x *DeviceListRequest) GetTopics() []string

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

+ 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

+ HasMore bool

+ Items []*Device

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

+ func (*DeviceListResult) ProtoMessage()

+ func (x *DeviceListResult) GetHasMore() bool

+ func (x *DeviceListResult) GetItems() []*Device

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

+ func (x *DeviceListResult) Reset()

+ func (x *DeviceListResult) 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 DeviceProviderTokens struct

+ Provider string

+ Tokens []string

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

+ func (*DeviceProviderTokens) ProtoMessage()

+ func (x *DeviceProviderTokens) GetProvider() string

+ func (x *DeviceProviderTokens) GetTokens() []string

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

+ func (x *DeviceProviderTokens) Reset()

+ func (x *DeviceProviderTokens) String() string

+ type DeviceRegisterRequest struct

+ Id string

+ Meta map[string]string

+ Platform string

+ Provider string

+ Tags map[string]string

+ Token string

+ Topics []string

+ User string

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

+ func (*DeviceRegisterRequest) ProtoMessage()

+ func (x *DeviceRegisterRequest) GetId() string

+ func (x *DeviceRegisterRequest) GetMeta() map[string]string

+ func (x *DeviceRegisterRequest) GetPlatform() string

+ func (x *DeviceRegisterRequest) GetProvider() string

+ func (x *DeviceRegisterRequest) GetTags() map[string]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

+ ProviderTokens []*DeviceProviderTokens

+ Users []string

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

+ func (*DeviceRemoveRequest) ProtoMessage()

+ func (x *DeviceRemoveRequest) GetIds() []string

+ func (x *DeviceRemoveRequest) GetProviderTokens() []*DeviceProviderTokens

+ 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 DeviceTag struct

+ Device *Device

+ Id string

+ Key string

+ Value string

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

+ func (*DeviceTag) ProtoMessage()

+ func (x *DeviceTag) GetDevice() *Device

+ func (x *DeviceTag) GetId() string

+ func (x *DeviceTag) GetKey() string

+ func (x *DeviceTag) GetValue() string

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

+ func (x *DeviceTag) Reset()

+ func (x *DeviceTag) String() string

+ type DeviceTagListResult struct

+ HasMore bool

+ Items []*DeviceTag

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

+ func (*DeviceTagListResult) ProtoMessage()

+ func (x *DeviceTagListResult) GetHasMore() bool

+ func (x *DeviceTagListResult) GetItems() []*DeviceTag

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

+ func (x *DeviceTagListResult) Reset()

+ func (x *DeviceTagListResult) String() string

+ type DeviceTagsUpdate struct

+ Op string

+ Tags map[string]string

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

+ func (*DeviceTagsUpdate) ProtoMessage()

+ func (x *DeviceTagsUpdate) GetOp() string

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

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

+ func (x *DeviceTagsUpdate) Reset()

+ func (x *DeviceTagsUpdate) 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 DeviceTopicListRequest struct

+ DeviceIds []string

+ DevicePlatforms []string

+ DeviceProviderTokens []*DeviceProviderTokens

+ DeviceProviders []string

+ DeviceUsers []string

+ IncludeDevice bool

+ Limit int32

+ Since string

+ TopicPrefix string

+ Topics []string

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

+ func (*DeviceTopicListRequest) ProtoMessage()

+ func (x *DeviceTopicListRequest) GetDeviceIds() []string

+ func (x *DeviceTopicListRequest) GetDevicePlatforms() []string

+ func (x *DeviceTopicListRequest) GetDeviceProviderTokens() []*DeviceProviderTokens

+ func (x *DeviceTopicListRequest) GetDeviceProviders() []string

+ func (x *DeviceTopicListRequest) GetDeviceUsers() []string

+ func (x *DeviceTopicListRequest) GetIncludeDevice() bool

+ func (x *DeviceTopicListRequest) GetLimit() int32

+ func (x *DeviceTopicListRequest) GetSince() string

+ func (x *DeviceTopicListRequest) GetTopicPrefix() string

+ func (x *DeviceTopicListRequest) GetTopics() []string

+ 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

+ HasMore bool

+ Items []*DeviceTopic

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

+ func (*DeviceTopicListResult) ProtoMessage()

+ func (x *DeviceTopicListResult) GetHasMore() bool

+ func (x *DeviceTopicListResult) GetItems() []*DeviceTopic

+ 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

+ MetaUpdate *DeviceMetaUpdate

+ ProviderTokens []*DeviceProviderTokens

+ TagsUpdate *DeviceTagsUpdate

+ TopicsUpdate *DeviceTopicsUpdate

+ UserUpdate *DeviceUserUpdate

+ Users []string

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

+ func (*DeviceUpdateRequest) ProtoMessage()

+ func (x *DeviceUpdateRequest) GetIds() []string

+ func (x *DeviceUpdateRequest) GetMetaUpdate() *DeviceMetaUpdate

+ func (x *DeviceUpdateRequest) GetProviderTokens() []*DeviceProviderTokens

+ func (x *DeviceUpdateRequest) GetTagsUpdate() *DeviceTagsUpdate

+ 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 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 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 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

+ func NewJSONResultEncoder() *JSONResultEncoder

+ type PushNotification struct

+ Apns *ApnsPushNotification

+ ExpireAt int64

+ Fcm *FcmPushNotification

+ Hms *HmsPushNotification

+ Uid string

+ 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) GetUid() string

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

+ func (x *PushNotification) Reset()

+ func (x *PushNotification) String() string

+ type PushRecipient struct

+ ApnsTokens []string

+ DeviceIds []string

+ FcmCondition string

+ FcmTokens []string

+ FcmTopic string

+ HmsCondition string

+ HmsTokens []string

+ HmsTopic string

+ Topics []string

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

+ func (*PushRecipient) ProtoMessage()

+ func (x *PushRecipient) GetApnsTokens() []string

+ func (x *PushRecipient) GetDeviceIds() []string

+ func (x *PushRecipient) GetFcmCondition() string

+ func (x *PushRecipient) GetFcmTokens() []string

+ func (x *PushRecipient) GetFcmTopic() string

+ func (x *PushRecipient) GetHmsCondition() string

+ func (x *PushRecipient) GetHmsTokens() []string

+ func (x *PushRecipient) GetHmsTopic() string

+ func (x *PushRecipient) GetTopics() []string

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

+ func (x *PushRecipient) Reset()

+ func (x *PushRecipient) String() string

type Reply

+ BlockUser *BlockUserResult

+ Broadcast *BroadcastResult

+ Channels *ChannelsResult

+ Connections *ConnectionsResult

+ DeleteUserStatus *DeleteUserStatusResult

+ DeviceList *DeviceListResult

+ DeviceRegister *DeviceRegisterResult

+ DeviceRemove *DeviceRemoveResult

+ DeviceTopicList *DeviceTopicListResult

+ DeviceTopicUpdate *DeviceTopicUpdateResult

+ DeviceUpdate *DeviceUpdateResult

+ Disconnect *DisconnectResult

+ GetUserStatus *GetUserStatusResult

+ History *HistoryResult

+ HistoryRemove *HistoryRemoveResult

+ Info *InfoResult

+ InvalidateUserTokens *InvalidateUserTokensResult

+ Presence *PresenceResult

+ PresenceStats *PresenceStatsResult

+ Publish *PublishResult

+ Refresh *RefreshResult

+ RevokeToken *RevokeTokenResult

+ Rpc *RPCResult

+ SendPushNotification *SendPushNotificationResult

+ Subscribe *SubscribeResult

+ UnblockUser *UnblockUserResult

+ Unsubscribe *UnsubscribeResult

+ UpdatePushStatus *UpdatePushStatusResult

+ UpdateUserStatus *UpdateUserStatusResult

+ UserTopicList *UserTopicListResult

+ UserTopicUpdate *UserTopicUpdateResult

+ func (x *Reply) GetBlockUser() *BlockUserResult

+ func (x *Reply) GetBroadcast() *BroadcastResult

+ 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) GetGetUserStatus() *GetUserStatusResult

+ func (x *Reply) GetHistory() *HistoryResult

+ func (x *Reply) GetHistoryRemove() *HistoryRemoveResult

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

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

+ 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 SendPushNotificationRequest struct

+ Notification *PushNotification

+ Recipient *PushRecipient

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

+ func (*SendPushNotificationRequest) ProtoMessage()

+ func (x *SendPushNotificationRequest) GetNotification() *PushNotification

+ func (x *SendPushNotificationRequest) GetRecipient() *PushRecipient

+ 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 UnimplementedCentrifugoApiServer

+ func (UnimplementedCentrifugoApiServer) Batch(context.Context, *BatchRequest) (*BatchResponse, 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) SendPushNotification(context.Context, *SendPushNotificationRequest) (*SendPushNotificationResponse, error)

+ func (UnimplementedCentrifugoApiServer) UserTopicList(context.Context, *UserTopicListRequest) (*UserTopicListResponse, error)

+ func (UnimplementedCentrifugoApiServer) UserTopicUpdate(context.Context, *UserTopicUpdateRequest) (*UserTopicUpdateResponse, error)

+ type UpdatePushStatusRequest struct

+ DeviceId string

+ MsgId string

+ Status string

+ Uid string

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

+ func (*UpdatePushStatusRequest) ProtoMessage()

+ func (x *UpdatePushStatusRequest) GetDeviceId() string

+ func (x *UpdatePushStatusRequest) GetMsgId() string

+ func (x *UpdatePushStatusRequest) GetStatus() string

+ func (x *UpdatePushStatusRequest) GetUid() 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 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 UserTopicListRequest struct

+ Limit int32

+ Since string

+ TopicPrefix string

+ Topics []string

+ Users []string

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

+ func (*UserTopicListRequest) ProtoMessage()

+ func (x *UserTopicListRequest) GetLimit() int32

+ func (x *UserTopicListRequest) GetSince() string

+ func (x *UserTopicListRequest) GetTopicPrefix() string

+ func (x *UserTopicListRequest) GetTopics() []string

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

+ 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

+ HasMore bool

+ Items []*UserTopic

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

+ func (*UserTopicListResult) ProtoMessage()

+ func (x *UserTopicListResult) GetHasMore() bool

+ func (x *UserTopicListResult) GetItems() []*UserTopic

+ 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

v4.1.2

Jan 11, 2023

v4.1.1

Jan 10, 2023

v4.1.0

Dec 19, 2022

v4.0.5

Dec 14, 2022

v4.0.4

Nov 10, 2022

v4.0.3

Oct 24, 2022

v4.0.2

Oct 17, 2022

v4.0.1

Aug 25, 2022

Changes in this version

+ 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

v4.0.0

Jul 20, 2022

Changes in this version

+ var CentrifugoApi_ServiceDesc = grpc.ServiceDesc

+ var Command_MethodType_name = map[int32]string

+ var Command_MethodType_value = map[string]int32

+ var ErrorBadRequest = &Error

+ var ErrorInternal = &Error

+ var ErrorMethodNotFound = &Error

+ var ErrorNotAvailable = &Error

+ var ErrorUnknownChannel = &Error

+ var ErrorUnrecoverablePosition = &Error

+ var File_api_proto protoreflect.FileDescriptor

+ func PutCommandDecoder(d CommandDecoder)

+ func PutParamsDecoder(_ ParamsDecoder)

+ func PutReplyEncoder(e ReplyEncoder)

+ func PutResultEncoder(_ ResultEncoder)

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

+ type 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

+ 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) 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 CentrifugoApiClient interface

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

+ Broadcast func(ctx context.Context, in *BroadcastRequest, opts ...grpc.CallOption) (*BroadcastResponse, 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)

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

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

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

+ func NewCentrifugoApiClient(cc grpc.ClientConnInterface) CentrifugoApiClient

+ type CentrifugoApiServer interface

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type ChannelInfo struct

+ NumClients uint32

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

+ func (*ChannelInfo) ProtoMessage()

+ func (x *ChannelInfo) GetNumClients() uint32

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

+ func (x *ChannelInfo) Reset()

+ func (x *ChannelInfo) String() string

+ type ChannelsRequest struct

+ Pattern string

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

+ func (*ChannelsRequest) ProtoMessage()

+ func (x *ChannelsRequest) GetPattern() string

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

+ func (x *ChannelsRequest) Reset()

+ func (x *ChannelsRequest) String() string

+ type ChannelsResponse struct

+ Error *Error

+ Result *ChannelsResult

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

+ func (*ChannelsResponse) ProtoMessage()

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

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

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

+ func (x *ChannelsResponse) Reset()

+ func (x *ChannelsResponse) String() string

+ type ChannelsResult struct

+ Channels map[string]*ChannelInfo

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

+ func (*ChannelsResult) ProtoMessage()

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

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

+ func (x *ChannelsResult) Reset()

+ func (x *ChannelsResult) String() string

+ type ClientInfo struct

+ ChanInfo Raw

+ Client string

+ ConnInfo Raw

+ User string

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

+ func (*ClientInfo) ProtoMessage()

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

+ func (x *ClientInfo) GetClient() string

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

+ func (x *ClientInfo) GetUser() string

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

+ func (x *ClientInfo) Reset()

+ func (x *ClientInfo) String() string

+ type Command struct

+ Id uint32

+ Method Command_MethodType

+ Params Raw

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

+ func (*Command) ProtoMessage()

+ func (x *Command) GetId() uint32

+ func (x *Command) GetMethod() Command_MethodType

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

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

+ func (x *Command) Reset()

+ func (x *Command) String() string

+ type CommandDecoder interface

+ Decode func() (*Command, error)

+ Reset func([]byte)

+ func GetCommandDecoder(data []byte) CommandDecoder

+ type Command_MethodType int32

+ const Command_BLOCK_USER

+ const Command_BROADCAST

+ const Command_CHANNELS

+ const Command_CONNECTIONS

+ const Command_DELETE_USER_STATUS

+ const Command_DISCONNECT

+ const Command_GET_USER_STATUS

+ const Command_HISTORY

+ const Command_HISTORY_REMOVE

+ const Command_INFO

+ const Command_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_SUBSCRIBE

+ const Command_UNBLOCK_USER

+ const Command_UNSUBSCRIBE

+ const Command_UPDATE_USER_STATUS

+ 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 []string

+ ConnectionToken *ConnectionTokenInfo

+ Meta Raw

+ SubscriptionTokens map[string]*SubscriptionTokenInfo

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

+ func (*ConnectionState) ProtoMessage()

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

+ 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 Disconnect struct

+ Code uint32

+ Reason string

+ Reconnect bool

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

+ func (*Disconnect) ProtoMessage()

+ func (x *Disconnect) GetCode() uint32

+ func (x *Disconnect) GetReason() string

+ func (x *Disconnect) GetReconnect() bool

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

+ func (x *Disconnect) Reset()

+ func (x *Disconnect) String() string

+ type DisconnectRequest struct

+ Client string

+ Disconnect *Disconnect

+ 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 GetUserStatusRequest struct

+ Users []string

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

+ func (*GetUserStatusRequest) ProtoMessage()

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

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

+ func (x *GetUserStatusRequest) Reset()

+ func (x *GetUserStatusRequest) String() string

+ type GetUserStatusResponse struct

+ Error *Error

+ Result *GetUserStatusResult

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

+ func (*GetUserStatusResponse) ProtoMessage()

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

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

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

+ func (x *GetUserStatusResponse) Reset()

+ func (x *GetUserStatusResponse) String() string

+ type GetUserStatusResult struct

+ Statuses []*UserStatus

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

+ func (*GetUserStatusResult) ProtoMessage()

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

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

+ func (x *GetUserStatusResult) Reset()

+ func (x *GetUserStatusResult) String() string

+ type HistoryRemoveRequest struct

+ Channel string

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

+ func (*HistoryRemoveRequest) ProtoMessage()

+ func (x *HistoryRemoveRequest) GetChannel() string

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

+ func (x *HistoryRemoveRequest) Reset()

+ func (x *HistoryRemoveRequest) String() string

+ type HistoryRemoveResponse struct

+ Error *Error

+ Result *HistoryRemoveResult

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

+ func (*HistoryRemoveResponse) ProtoMessage()

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

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

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

+ func (x *HistoryRemoveResponse) Reset()

+ func (x *HistoryRemoveResponse) String() string

+ type HistoryRemoveResult struct

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

+ func (*HistoryRemoveResult) ProtoMessage()

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

+ func (x *HistoryRemoveResult) Reset()

+ func (x *HistoryRemoveResult) String() string

+ type HistoryRequest struct

+ Channel string

+ Limit int32

+ Reverse bool

+ Since *StreamPosition

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

+ func (*HistoryRequest) ProtoMessage()

+ func (x *HistoryRequest) GetChannel() string

+ func (x *HistoryRequest) GetLimit() int32

+ func (x *HistoryRequest) GetReverse() bool

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

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

+ func (x *HistoryRequest) Reset()

+ func (x *HistoryRequest) String() string

+ type HistoryResponse struct

+ Error *Error

+ Result *HistoryResult

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

+ func (*HistoryResponse) ProtoMessage()

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

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

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

+ func (x *HistoryResponse) Reset()

+ func (x *HistoryResponse) String() string

+ type HistoryResult struct

+ Epoch string

+ Offset uint64

+ Publications []*Publication

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

+ func (*HistoryResult) ProtoMessage()

+ func (x *HistoryResult) GetEpoch() string

+ func (x *HistoryResult) GetOffset() uint64

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

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

+ func (x *HistoryResult) Reset()

+ func (x *HistoryResult) String() string

+ type InfoRequest struct

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

+ func (*InfoRequest) ProtoMessage()

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

+ func (x *InfoRequest) Reset()

+ func (x *InfoRequest) String() string

+ type InfoResponse struct

+ Error *Error

+ Result *InfoResult

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

+ func (*InfoResponse) ProtoMessage()

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

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

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

+ func (x *InfoResponse) Reset()

+ func (x *InfoResponse) String() string

+ type InfoResult struct

+ Nodes []*NodeResult

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

+ func (*InfoResult) ProtoMessage()

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

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

+ func (x *InfoResult) Reset()

+ func (x *InfoResult) String() string

+ type Int32Value struct

+ Value int32

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

+ func (*Int32Value) ProtoMessage()

+ func (x *Int32Value) GetValue() int32

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

+ func (x *Int32Value) Reset()

+ func (x *Int32Value) String() string

+ type 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 JSONParamsDecoder struct

+ func NewJSONParamsDecoder() *JSONParamsDecoder

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type JSONReplyEncoder struct

+ func NewJSONReplyEncoder() *JSONReplyEncoder

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

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

+ func (e *JSONReplyEncoder) Reset()

+ type JSONResultEncoder struct

+ func NewJSONEncoder() *JSONResultEncoder

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

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

+ func (e *JSONResultEncoder) 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 ParamsDecoder interface

+ 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() ParamsDecoder

+ type PresenceRequest struct

+ Channel string

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

+ func (*PresenceRequest) ProtoMessage()

+ func (x *PresenceRequest) GetChannel() string

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

+ func (x *PresenceRequest) Reset()

+ func (x *PresenceRequest) String() string

+ type PresenceResponse struct

+ Error *Error

+ Result *PresenceResult

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

+ func (*PresenceResponse) ProtoMessage()

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

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

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

+ func (x *PresenceResponse) Reset()

+ func (x *PresenceResponse) String() string

+ type PresenceResult struct

+ Presence map[string]*ClientInfo

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

+ func (*PresenceResult) ProtoMessage()

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

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

+ func (x *PresenceResult) Reset()

+ func (x *PresenceResult) String() string

+ type PresenceStatsRequest struct

+ Channel string

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

+ func (*PresenceStatsRequest) ProtoMessage()

+ func (x *PresenceStatsRequest) GetChannel() string

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

+ func (x *PresenceStatsRequest) Reset()

+ func (x *PresenceStatsRequest) String() string

+ type PresenceStatsResponse struct

+ Error *Error

+ Result *PresenceStatsResult

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

+ func (*PresenceStatsResponse) ProtoMessage()

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

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

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

+ func (x *PresenceStatsResponse) Reset()

+ func (x *PresenceStatsResponse) String() string

+ type PresenceStatsResult struct

+ NumClients uint32

+ NumUsers uint32

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

+ func (*PresenceStatsResult) ProtoMessage()

+ func (x *PresenceStatsResult) GetNumClients() uint32

+ func (x *PresenceStatsResult) GetNumUsers() uint32

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

+ func (x *PresenceStatsResult) Reset()

+ func (x *PresenceStatsResult) String() string

+ type Process struct

+ Cpu float64

+ Rss int64

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

+ func (*Process) ProtoMessage()

+ func (x *Process) GetCpu() float64

+ func (x *Process) GetRss() int64

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

+ func (x *Process) Reset()

+ func (x *Process) String() string

+ type Publication struct

+ Data Raw

+ Info *ClientInfo

+ Offset uint64

+ 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

+ 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) 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 RPCRequest struct

+ Method string

+ Params Raw

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

+ func (*RPCRequest) ProtoMessage()

+ func (x *RPCRequest) GetMethod() string

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

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

+ func (x *RPCRequest) Reset()

+ func (x *RPCRequest) String() string

+ type RPCResponse struct

+ Error *Error

+ Result *RPCResult

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

+ func (*RPCResponse) ProtoMessage()

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

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

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

+ func (x *RPCResponse) Reset()

+ func (x *RPCResponse) String() string

+ type RPCResult struct

+ Data Raw

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

+ func (*RPCResult) ProtoMessage()

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

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

+ func (x *RPCResult) Reset()

+ func (x *RPCResult) String() string

+ type Raw []byte

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

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

+ type RefreshRequest struct

+ Client string

+ ExpireAt int64

+ Expired bool

+ Info Raw

+ 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

+ Error *Error

+ Id uint32

+ Result Raw

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

+ func (*Reply) ProtoMessage()

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

+ func (x *Reply) GetId() uint32

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

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

+ func (x *Reply) Reset()

+ func (x *Reply) String() string

+ type ReplyEncoder interface

+ Encode func(*Reply) error

+ Finish func() []byte

+ Reset func()

+ func GetReplyEncoder() ReplyEncoder

+ type ResultEncoder interface

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

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

+ 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 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) BlockUser(context.Context, *BlockUserRequest) (*BlockUserResponse, error)

+ func (UnimplementedCentrifugoApiServer) Broadcast(context.Context, *BroadcastRequest) (*BroadcastResponse, 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) 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) Subscribe(context.Context, *SubscribeRequest) (*SubscribeResponse, error)

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

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

+ func (UnimplementedCentrifugoApiServer) UpdateUserStatus(context.Context, *UpdateUserStatusRequest) (*UpdateUserStatusResponse, 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 UpdateUserStatusRequest struct

+ Users []string

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

+ func (*UpdateUserStatusRequest) ProtoMessage()

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

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

+ func (x *UpdateUserStatusRequest) Reset()

+ func (x *UpdateUserStatusRequest) String() string

+ type UpdateUserStatusResponse struct

+ Error *Error

+ Result *UpdateUserStatusResult

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

+ func (*UpdateUserStatusResponse) ProtoMessage()

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

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

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

+ func (x *UpdateUserStatusResponse) Reset()

+ func (x *UpdateUserStatusResponse) String() string

+ type UpdateUserStatusResult struct

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

+ func (*UpdateUserStatusResult) ProtoMessage()

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

+ func (x *UpdateUserStatusResult) Reset()

+ func (x *UpdateUserStatusResult) String() string

+ type UserStatus struct

+ Active int64

+ Online int64

+ User string

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

+ func (*UserStatus) ProtoMessage()

+ func (x *UserStatus) GetActive() int64

+ func (x *UserStatus) GetOnline() int64

+ func (x *UserStatus) GetUser() string

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

+ func (x *UserStatus) Reset()

+ func (x *UserStatus) String() string

v4.0.0-beta.1

Jul 9, 2022

Other modules containing this package

github.com/centrifugal/centrifugo/v3

github.com/centrifugal/centrifugo/v5

github.com/centrifugal/centrifugo/v6

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