Documentation ¶
Index ¶
- Variables
- type BlockUserRequest
- func (*BlockUserRequest) Descriptor() ([]byte, []int)deprecated
- func (x *BlockUserRequest) GetExpireAt() int64
- func (x *BlockUserRequest) GetUser() string
- func (*BlockUserRequest) ProtoMessage()
- func (x *BlockUserRequest) ProtoReflect() protoreflect.Message
- func (x *BlockUserRequest) Reset()
- func (x *BlockUserRequest) String() string
- type BlockUserResponse
- func (*BlockUserResponse) Descriptor() ([]byte, []int)deprecated
- func (x *BlockUserResponse) GetError() *Error
- func (x *BlockUserResponse) GetResult() *BlockUserResult
- func (*BlockUserResponse) ProtoMessage()
- func (x *BlockUserResponse) ProtoReflect() protoreflect.Message
- func (x *BlockUserResponse) Reset()
- func (x *BlockUserResponse) String() string
- type BlockUserResult
- type BoolValue
- type BroadcastRequest
- func (*BroadcastRequest) Descriptor() ([]byte, []int)deprecated
- 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 (*BroadcastRequest) ProtoMessage()
- func (x *BroadcastRequest) ProtoReflect() protoreflect.Message
- func (x *BroadcastRequest) Reset()
- func (x *BroadcastRequest) String() string
- type BroadcastResponse
- func (*BroadcastResponse) Descriptor() ([]byte, []int)deprecated
- func (x *BroadcastResponse) GetError() *Error
- func (x *BroadcastResponse) GetResult() *BroadcastResult
- func (*BroadcastResponse) ProtoMessage()
- func (x *BroadcastResponse) ProtoReflect() protoreflect.Message
- func (x *BroadcastResponse) Reset()
- func (x *BroadcastResponse) String() string
- type BroadcastResult
- type ChannelContext
- type ChannelInfo
- type ChannelsRequest
- type ChannelsResponse
- func (*ChannelsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ChannelsResponse) GetError() *Error
- func (x *ChannelsResponse) GetResult() *ChannelsResult
- func (*ChannelsResponse) ProtoMessage()
- func (x *ChannelsResponse) ProtoReflect() protoreflect.Message
- func (x *ChannelsResponse) Reset()
- func (x *ChannelsResponse) String() string
- type ChannelsResult
- type ClientInfo
- func (*ClientInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ClientInfo) GetChanInfo() []byte
- func (x *ClientInfo) GetClient() string
- func (x *ClientInfo) GetConnInfo() []byte
- func (x *ClientInfo) GetUser() string
- func (*ClientInfo) ProtoMessage()
- func (x *ClientInfo) ProtoReflect() protoreflect.Message
- func (x *ClientInfo) Reset()
- func (x *ClientInfo) String() string
- type Command
- func (*Command) Descriptor() ([]byte, []int)deprecated
- func (x *Command) GetId() uint32
- func (x *Command) GetMethod() Command_MethodType
- func (x *Command) GetParams() []byte
- func (*Command) ProtoMessage()
- func (x *Command) ProtoReflect() protoreflect.Message
- func (x *Command) Reset()
- func (x *Command) String() string
- type Command_MethodType
- func (Command_MethodType) Descriptor() protoreflect.EnumDescriptor
- func (x Command_MethodType) Enum() *Command_MethodType
- func (Command_MethodType) EnumDescriptor() ([]byte, []int)deprecated
- func (x Command_MethodType) Number() protoreflect.EnumNumber
- func (x Command_MethodType) String() string
- func (Command_MethodType) Type() protoreflect.EnumType
- type ConnectionInfo
- func (*ConnectionInfo) Descriptor() ([]byte, []int)deprecated
- 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 (*ConnectionInfo) ProtoMessage()
- func (x *ConnectionInfo) ProtoReflect() protoreflect.Message
- func (x *ConnectionInfo) Reset()
- func (x *ConnectionInfo) String() string
- type ConnectionState
- func (*ConnectionState) Descriptor() ([]byte, []int)deprecated
- 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 (*ConnectionState) ProtoMessage()
- func (x *ConnectionState) ProtoReflect() protoreflect.Message
- func (x *ConnectionState) Reset()
- func (x *ConnectionState) String() string
- type ConnectionTokenInfo
- func (*ConnectionTokenInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectionTokenInfo) GetIssuedAt() int64
- func (x *ConnectionTokenInfo) GetUid() string
- func (*ConnectionTokenInfo) ProtoMessage()
- func (x *ConnectionTokenInfo) ProtoReflect() protoreflect.Message
- func (x *ConnectionTokenInfo) Reset()
- func (x *ConnectionTokenInfo) String() string
- type ConnectionsRequest
- func (*ConnectionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectionsRequest) GetExpression() string
- func (x *ConnectionsRequest) GetUser() string
- func (*ConnectionsRequest) ProtoMessage()
- func (x *ConnectionsRequest) ProtoReflect() protoreflect.Message
- func (x *ConnectionsRequest) Reset()
- func (x *ConnectionsRequest) String() string
- type ConnectionsResponse
- func (*ConnectionsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectionsResponse) GetError() *Error
- func (x *ConnectionsResponse) GetResult() *ConnectionsResult
- func (*ConnectionsResponse) ProtoMessage()
- func (x *ConnectionsResponse) ProtoReflect() protoreflect.Message
- func (x *ConnectionsResponse) Reset()
- func (x *ConnectionsResponse) String() string
- type ConnectionsResult
- func (*ConnectionsResult) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectionsResult) GetConnections() map[string]*ConnectionInfo
- func (*ConnectionsResult) ProtoMessage()
- func (x *ConnectionsResult) ProtoReflect() protoreflect.Message
- func (x *ConnectionsResult) Reset()
- func (x *ConnectionsResult) String() string
- type DeleteUserStatusRequest
- func (*DeleteUserStatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteUserStatusRequest) GetUsers() []string
- func (*DeleteUserStatusRequest) ProtoMessage()
- func (x *DeleteUserStatusRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteUserStatusRequest) Reset()
- func (x *DeleteUserStatusRequest) String() string
- type DeleteUserStatusResponse
- func (*DeleteUserStatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteUserStatusResponse) GetError() *Error
- func (x *DeleteUserStatusResponse) GetResult() *DeleteUserStatusResult
- func (*DeleteUserStatusResponse) ProtoMessage()
- func (x *DeleteUserStatusResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteUserStatusResponse) Reset()
- func (x *DeleteUserStatusResponse) String() string
- type DeleteUserStatusResult
- type Disconnect
- func (*Disconnect) Descriptor() ([]byte, []int)deprecated
- func (x *Disconnect) GetCode() uint32
- func (x *Disconnect) GetReason() string
- func (x *Disconnect) GetReconnect() bool
- func (*Disconnect) ProtoMessage()
- func (x *Disconnect) ProtoReflect() protoreflect.Message
- func (x *Disconnect) Reset()
- func (x *Disconnect) String() string
- type DisconnectRequest
- func (*DisconnectRequest) Descriptor() ([]byte, []int)deprecated
- 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 (*DisconnectRequest) ProtoMessage()
- func (x *DisconnectRequest) ProtoReflect() protoreflect.Message
- func (x *DisconnectRequest) Reset()
- func (x *DisconnectRequest) String() string
- type DisconnectResponse
- func (*DisconnectResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DisconnectResponse) GetError() *Error
- func (x *DisconnectResponse) GetResult() *DisconnectResult
- func (*DisconnectResponse) ProtoMessage()
- func (x *DisconnectResponse) ProtoReflect() protoreflect.Message
- func (x *DisconnectResponse) Reset()
- func (x *DisconnectResponse) String() string
- type DisconnectResult
- type Error
- type GetUserStatusRequest
- func (*GetUserStatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetUserStatusRequest) GetUsers() []string
- func (*GetUserStatusRequest) ProtoMessage()
- func (x *GetUserStatusRequest) ProtoReflect() protoreflect.Message
- func (x *GetUserStatusRequest) Reset()
- func (x *GetUserStatusRequest) String() string
- type GetUserStatusResponse
- func (*GetUserStatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetUserStatusResponse) GetError() *Error
- func (x *GetUserStatusResponse) GetResult() *GetUserStatusResult
- func (*GetUserStatusResponse) ProtoMessage()
- func (x *GetUserStatusResponse) ProtoReflect() protoreflect.Message
- func (x *GetUserStatusResponse) Reset()
- func (x *GetUserStatusResponse) String() string
- type GetUserStatusResult
- func (*GetUserStatusResult) Descriptor() ([]byte, []int)deprecated
- func (x *GetUserStatusResult) GetStatuses() []*UserStatus
- func (*GetUserStatusResult) ProtoMessage()
- func (x *GetUserStatusResult) ProtoReflect() protoreflect.Message
- func (x *GetUserStatusResult) Reset()
- func (x *GetUserStatusResult) String() string
- type HistoryRemoveRequest
- func (*HistoryRemoveRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HistoryRemoveRequest) GetChannel() string
- func (*HistoryRemoveRequest) ProtoMessage()
- func (x *HistoryRemoveRequest) ProtoReflect() protoreflect.Message
- func (x *HistoryRemoveRequest) Reset()
- func (x *HistoryRemoveRequest) String() string
- type HistoryRemoveResponse
- func (*HistoryRemoveResponse) Descriptor() ([]byte, []int)deprecated
- func (x *HistoryRemoveResponse) GetError() *Error
- func (x *HistoryRemoveResponse) GetResult() *HistoryRemoveResult
- func (*HistoryRemoveResponse) ProtoMessage()
- func (x *HistoryRemoveResponse) ProtoReflect() protoreflect.Message
- func (x *HistoryRemoveResponse) Reset()
- func (x *HistoryRemoveResponse) String() string
- type HistoryRemoveResult
- type HistoryRequest
- func (*HistoryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HistoryRequest) GetChannel() string
- func (x *HistoryRequest) GetLimit() int32
- func (x *HistoryRequest) GetReverse() bool
- func (x *HistoryRequest) GetSince() *StreamPosition
- func (*HistoryRequest) ProtoMessage()
- func (x *HistoryRequest) ProtoReflect() protoreflect.Message
- func (x *HistoryRequest) Reset()
- func (x *HistoryRequest) String() string
- type HistoryResponse
- func (*HistoryResponse) Descriptor() ([]byte, []int)deprecated
- func (x *HistoryResponse) GetError() *Error
- func (x *HistoryResponse) GetResult() *HistoryResult
- func (*HistoryResponse) ProtoMessage()
- func (x *HistoryResponse) ProtoReflect() protoreflect.Message
- func (x *HistoryResponse) Reset()
- func (x *HistoryResponse) String() string
- type HistoryResult
- func (*HistoryResult) Descriptor() ([]byte, []int)deprecated
- func (x *HistoryResult) GetEpoch() string
- func (x *HistoryResult) GetOffset() uint64
- func (x *HistoryResult) GetPublications() []*Publication
- func (*HistoryResult) ProtoMessage()
- func (x *HistoryResult) ProtoReflect() protoreflect.Message
- func (x *HistoryResult) Reset()
- func (x *HistoryResult) String() string
- type InfoRequest
- type InfoResponse
- func (*InfoResponse) Descriptor() ([]byte, []int)deprecated
- func (x *InfoResponse) GetError() *Error
- func (x *InfoResponse) GetResult() *InfoResult
- func (*InfoResponse) ProtoMessage()
- func (x *InfoResponse) ProtoReflect() protoreflect.Message
- func (x *InfoResponse) Reset()
- func (x *InfoResponse) String() string
- type InfoResult
- type Int32Value
- type InvalidateUserTokensRequest
- func (*InvalidateUserTokensRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InvalidateUserTokensRequest) GetChannel() string
- func (x *InvalidateUserTokensRequest) GetExpireAt() int64
- func (x *InvalidateUserTokensRequest) GetIssuedBefore() int64
- func (x *InvalidateUserTokensRequest) GetUser() string
- func (*InvalidateUserTokensRequest) ProtoMessage()
- func (x *InvalidateUserTokensRequest) ProtoReflect() protoreflect.Message
- func (x *InvalidateUserTokensRequest) Reset()
- func (x *InvalidateUserTokensRequest) String() string
- type InvalidateUserTokensResponse
- func (*InvalidateUserTokensResponse) Descriptor() ([]byte, []int)deprecated
- func (x *InvalidateUserTokensResponse) GetError() *Error
- func (x *InvalidateUserTokensResponse) GetResult() *InvalidateUserTokensResult
- func (*InvalidateUserTokensResponse) ProtoMessage()
- func (x *InvalidateUserTokensResponse) ProtoReflect() protoreflect.Message
- func (x *InvalidateUserTokensResponse) Reset()
- func (x *InvalidateUserTokensResponse) String() string
- type InvalidateUserTokensResult
- type Metrics
- type NodeResult
- func (*NodeResult) Descriptor() ([]byte, []int)deprecated
- 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 (*NodeResult) ProtoMessage()
- func (x *NodeResult) ProtoReflect() protoreflect.Message
- func (x *NodeResult) Reset()
- func (x *NodeResult) String() string
- type PresenceRequest
- type PresenceResponse
- func (*PresenceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PresenceResponse) GetError() *Error
- func (x *PresenceResponse) GetResult() *PresenceResult
- func (*PresenceResponse) ProtoMessage()
- func (x *PresenceResponse) ProtoReflect() protoreflect.Message
- func (x *PresenceResponse) Reset()
- func (x *PresenceResponse) String() string
- type PresenceResult
- type PresenceStatsRequest
- func (*PresenceStatsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PresenceStatsRequest) GetChannel() string
- func (*PresenceStatsRequest) ProtoMessage()
- func (x *PresenceStatsRequest) ProtoReflect() protoreflect.Message
- func (x *PresenceStatsRequest) Reset()
- func (x *PresenceStatsRequest) String() string
- type PresenceStatsResponse
- func (*PresenceStatsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PresenceStatsResponse) GetError() *Error
- func (x *PresenceStatsResponse) GetResult() *PresenceStatsResult
- func (*PresenceStatsResponse) ProtoMessage()
- func (x *PresenceStatsResponse) ProtoReflect() protoreflect.Message
- func (x *PresenceStatsResponse) Reset()
- func (x *PresenceStatsResponse) String() string
- type PresenceStatsResult
- func (*PresenceStatsResult) Descriptor() ([]byte, []int)deprecated
- func (x *PresenceStatsResult) GetNumClients() uint32
- func (x *PresenceStatsResult) GetNumUsers() uint32
- func (*PresenceStatsResult) ProtoMessage()
- func (x *PresenceStatsResult) ProtoReflect() protoreflect.Message
- func (x *PresenceStatsResult) Reset()
- func (x *PresenceStatsResult) String() string
- type Process
- type Publication
- func (*Publication) Descriptor() ([]byte, []int)deprecated
- func (x *Publication) GetData() []byte
- func (x *Publication) GetInfo() *ClientInfo
- func (x *Publication) GetOffset() uint64
- func (x *Publication) GetTags() map[string]string
- func (*Publication) ProtoMessage()
- func (x *Publication) ProtoReflect() protoreflect.Message
- func (x *Publication) Reset()
- func (x *Publication) String() string
- type PublishRequest
- func (*PublishRequest) Descriptor() ([]byte, []int)deprecated
- 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 (*PublishRequest) ProtoMessage()
- func (x *PublishRequest) ProtoReflect() protoreflect.Message
- func (x *PublishRequest) Reset()
- func (x *PublishRequest) String() string
- type PublishResponse
- func (*PublishResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PublishResponse) GetError() *Error
- func (x *PublishResponse) GetResult() *PublishResult
- func (*PublishResponse) ProtoMessage()
- func (x *PublishResponse) ProtoReflect() protoreflect.Message
- func (x *PublishResponse) Reset()
- func (x *PublishResponse) String() string
- type PublishResult
- func (*PublishResult) Descriptor() ([]byte, []int)deprecated
- func (x *PublishResult) GetEpoch() string
- func (x *PublishResult) GetOffset() uint64
- func (*PublishResult) ProtoMessage()
- func (x *PublishResult) ProtoReflect() protoreflect.Message
- func (x *PublishResult) Reset()
- func (x *PublishResult) String() string
- type RPCRequest
- type RPCResponse
- func (*RPCResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RPCResponse) GetError() *Error
- func (x *RPCResponse) GetResult() *RPCResult
- func (*RPCResponse) ProtoMessage()
- func (x *RPCResponse) ProtoReflect() protoreflect.Message
- func (x *RPCResponse) Reset()
- func (x *RPCResponse) String() string
- type RPCResult
- type RefreshRequest
- func (*RefreshRequest) Descriptor() ([]byte, []int)deprecated
- 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 (*RefreshRequest) ProtoMessage()
- func (x *RefreshRequest) ProtoReflect() protoreflect.Message
- func (x *RefreshRequest) Reset()
- func (x *RefreshRequest) String() string
- type RefreshResponse
- func (*RefreshResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RefreshResponse) GetError() *Error
- func (x *RefreshResponse) GetResult() *RefreshResult
- func (*RefreshResponse) ProtoMessage()
- func (x *RefreshResponse) ProtoReflect() protoreflect.Message
- func (x *RefreshResponse) Reset()
- func (x *RefreshResponse) String() string
- type RefreshResult
- type Reply
- type RevokeTokenRequest
- func (*RevokeTokenRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RevokeTokenRequest) GetExpireAt() int64
- func (x *RevokeTokenRequest) GetUid() string
- func (*RevokeTokenRequest) ProtoMessage()
- func (x *RevokeTokenRequest) ProtoReflect() protoreflect.Message
- func (x *RevokeTokenRequest) Reset()
- func (x *RevokeTokenRequest) String() string
- type RevokeTokenResponse
- func (*RevokeTokenResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RevokeTokenResponse) GetError() *Error
- func (x *RevokeTokenResponse) GetResult() *RevokeTokenResult
- func (*RevokeTokenResponse) ProtoMessage()
- func (x *RevokeTokenResponse) ProtoReflect() protoreflect.Message
- func (x *RevokeTokenResponse) Reset()
- func (x *RevokeTokenResponse) String() string
- type RevokeTokenResult
- type StreamPosition
- func (*StreamPosition) Descriptor() ([]byte, []int)deprecated
- func (x *StreamPosition) GetEpoch() string
- func (x *StreamPosition) GetOffset() uint64
- func (*StreamPosition) ProtoMessage()
- func (x *StreamPosition) ProtoReflect() protoreflect.Message
- func (x *StreamPosition) Reset()
- func (x *StreamPosition) String() string
- type SubscribeOptionOverride
- func (*SubscribeOptionOverride) Descriptor() ([]byte, []int)deprecated
- 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 (*SubscribeOptionOverride) ProtoMessage()
- func (x *SubscribeOptionOverride) ProtoReflect() protoreflect.Message
- func (x *SubscribeOptionOverride) Reset()
- func (x *SubscribeOptionOverride) String() string
- type SubscribeRequest
- func (*SubscribeRequest) Descriptor() ([]byte, []int)deprecated
- 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 (*SubscribeRequest) ProtoMessage()
- func (x *SubscribeRequest) ProtoReflect() protoreflect.Message
- func (x *SubscribeRequest) Reset()
- func (x *SubscribeRequest) String() string
- type SubscribeResponse
- func (*SubscribeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SubscribeResponse) GetError() *Error
- func (x *SubscribeResponse) GetResult() *SubscribeResult
- func (*SubscribeResponse) ProtoMessage()
- func (x *SubscribeResponse) ProtoReflect() protoreflect.Message
- func (x *SubscribeResponse) Reset()
- func (x *SubscribeResponse) String() string
- type SubscribeResult
- type SubscriptionTokenInfo
- func (*SubscriptionTokenInfo) Descriptor() ([]byte, []int)deprecated
- func (x *SubscriptionTokenInfo) GetIssuedAt() int64
- func (x *SubscriptionTokenInfo) GetUid() string
- func (*SubscriptionTokenInfo) ProtoMessage()
- func (x *SubscriptionTokenInfo) ProtoReflect() protoreflect.Message
- func (x *SubscriptionTokenInfo) Reset()
- func (x *SubscriptionTokenInfo) String() string
- type UnblockUserRequest
- func (*UnblockUserRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UnblockUserRequest) GetUser() string
- func (*UnblockUserRequest) ProtoMessage()
- func (x *UnblockUserRequest) ProtoReflect() protoreflect.Message
- func (x *UnblockUserRequest) Reset()
- func (x *UnblockUserRequest) String() string
- type UnblockUserResponse
- func (*UnblockUserResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UnblockUserResponse) GetError() *Error
- func (x *UnblockUserResponse) GetResult() *UnblockUserResult
- func (*UnblockUserResponse) ProtoMessage()
- func (x *UnblockUserResponse) ProtoReflect() protoreflect.Message
- func (x *UnblockUserResponse) Reset()
- func (x *UnblockUserResponse) String() string
- type UnblockUserResult
- type UnsubscribeRequest
- func (*UnsubscribeRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UnsubscribeRequest) GetChannel() string
- func (x *UnsubscribeRequest) GetClient() string
- func (x *UnsubscribeRequest) GetSession() string
- func (x *UnsubscribeRequest) GetUser() string
- func (*UnsubscribeRequest) ProtoMessage()
- func (x *UnsubscribeRequest) ProtoReflect() protoreflect.Message
- func (x *UnsubscribeRequest) Reset()
- func (x *UnsubscribeRequest) String() string
- type UnsubscribeResponse
- func (*UnsubscribeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UnsubscribeResponse) GetError() *Error
- func (x *UnsubscribeResponse) GetResult() *UnsubscribeResult
- func (*UnsubscribeResponse) ProtoMessage()
- func (x *UnsubscribeResponse) ProtoReflect() protoreflect.Message
- func (x *UnsubscribeResponse) Reset()
- func (x *UnsubscribeResponse) String() string
- type UnsubscribeResult
- type UpdateUserStatusRequest
- func (*UpdateUserStatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateUserStatusRequest) GetUsers() []string
- func (*UpdateUserStatusRequest) ProtoMessage()
- func (x *UpdateUserStatusRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateUserStatusRequest) Reset()
- func (x *UpdateUserStatusRequest) String() string
- type UpdateUserStatusResponse
- func (*UpdateUserStatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateUserStatusResponse) GetError() *Error
- func (x *UpdateUserStatusResponse) GetResult() *UpdateUserStatusResult
- func (*UpdateUserStatusResponse) ProtoMessage()
- func (x *UpdateUserStatusResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateUserStatusResponse) Reset()
- func (x *UpdateUserStatusResponse) String() string
- type UpdateUserStatusResult
- type UserStatus
- func (*UserStatus) Descriptor() ([]byte, []int)deprecated
- func (x *UserStatus) GetActive() int64
- func (x *UserStatus) GetOnline() int64
- func (x *UserStatus) GetUser() string
- func (*UserStatus) ProtoMessage()
- func (x *UserStatus) ProtoReflect() protoreflect.Message
- func (x *UserStatus) Reset()
- func (x *UserStatus) String() string
Constants ¶
This section is empty.
Variables ¶
var ( Command_MethodType_name = map[int32]string{ 0: "PUBLISH", 1: "BROADCAST", 2: "UNSUBSCRIBE", 3: "DISCONNECT", 4: "PRESENCE", 5: "PRESENCE_STATS", 6: "HISTORY", 7: "HISTORY_REMOVE", 8: "CHANNELS", 9: "INFO", 10: "RPC", 11: "SUBSCRIBE", 12: "REFRESH", 14: "CONNECTIONS", 15: "UPDATE_USER_STATUS", 16: "GET_USER_STATUS", 17: "DELETE_USER_STATUS", 18: "BLOCK_USER", 19: "UNBLOCK_USER", 20: "REVOKE_TOKEN", 21: "INVALIDATE_USER_TOKENS", } Command_MethodType_value = map[string]int32{ "PUBLISH": 0, "BROADCAST": 1, "UNSUBSCRIBE": 2, "DISCONNECT": 3, "PRESENCE": 4, "PRESENCE_STATS": 5, "HISTORY": 6, "HISTORY_REMOVE": 7, "CHANNELS": 8, "INFO": 9, "RPC": 10, "SUBSCRIBE": 11, "REFRESH": 12, "CONNECTIONS": 14, "UPDATE_USER_STATUS": 15, "GET_USER_STATUS": 16, "DELETE_USER_STATUS": 17, "BLOCK_USER": 18, "UNBLOCK_USER": 19, "REVOKE_TOKEN": 20, "INVALIDATE_USER_TOKENS": 21, } )
Enum value maps for Command_MethodType.
var File_centrifugo_api_v1_api_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type BlockUserRequest ¶
type BlockUserRequest struct { ExpireAt int64 `protobuf:"varint,1,opt,name=expire_at,json=expireAt,proto3" json:"expire_at,omitempty"` User string `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"` // contains filtered or unexported fields }
func (*BlockUserRequest) Descriptor
deprecated
func (*BlockUserRequest) Descriptor() ([]byte, []int)
Deprecated: Use BlockUserRequest.ProtoReflect.Descriptor instead.
func (*BlockUserRequest) GetExpireAt ¶
func (x *BlockUserRequest) GetExpireAt() int64
func (*BlockUserRequest) GetUser ¶
func (x *BlockUserRequest) GetUser() string
func (*BlockUserRequest) ProtoMessage ¶
func (*BlockUserRequest) ProtoMessage()
func (*BlockUserRequest) ProtoReflect ¶
func (x *BlockUserRequest) ProtoReflect() protoreflect.Message
func (*BlockUserRequest) Reset ¶
func (x *BlockUserRequest) Reset()
func (*BlockUserRequest) String ¶
func (x *BlockUserRequest) String() string
type BlockUserResponse ¶
type BlockUserResponse struct { Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Result *BlockUserResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*BlockUserResponse) Descriptor
deprecated
func (*BlockUserResponse) Descriptor() ([]byte, []int)
Deprecated: Use BlockUserResponse.ProtoReflect.Descriptor instead.
func (*BlockUserResponse) GetError ¶
func (x *BlockUserResponse) GetError() *Error
func (*BlockUserResponse) GetResult ¶
func (x *BlockUserResponse) GetResult() *BlockUserResult
func (*BlockUserResponse) ProtoMessage ¶
func (*BlockUserResponse) ProtoMessage()
func (*BlockUserResponse) ProtoReflect ¶
func (x *BlockUserResponse) ProtoReflect() protoreflect.Message
func (*BlockUserResponse) Reset ¶
func (x *BlockUserResponse) Reset()
func (*BlockUserResponse) String ¶
func (x *BlockUserResponse) String() string
type BlockUserResult ¶
type BlockUserResult struct {
// contains filtered or unexported fields
}
func (*BlockUserResult) Descriptor
deprecated
func (*BlockUserResult) Descriptor() ([]byte, []int)
Deprecated: Use BlockUserResult.ProtoReflect.Descriptor instead.
func (*BlockUserResult) ProtoMessage ¶
func (*BlockUserResult) ProtoMessage()
func (*BlockUserResult) ProtoReflect ¶
func (x *BlockUserResult) ProtoReflect() protoreflect.Message
func (*BlockUserResult) Reset ¶
func (x *BlockUserResult) Reset()
func (*BlockUserResult) String ¶
func (x *BlockUserResult) String() string
type BoolValue ¶
type BoolValue struct { Value bool `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*BoolValue) ProtoReflect ¶
func (x *BoolValue) ProtoReflect() protoreflect.Message
type BroadcastRequest ¶
type BroadcastRequest struct { Channels []string `protobuf:"bytes,1,rep,name=channels,proto3" json:"channels,omitempty"` Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` B64Data string `protobuf:"bytes,3,opt,name=b64data,proto3" json:"b64data,omitempty"` SkipHistory bool `protobuf:"varint,4,opt,name=skip_history,json=skipHistory,proto3" json:"skip_history,omitempty"` Tags map[string]string `` /* 149-byte string literal not displayed */ // contains filtered or unexported fields }
func (*BroadcastRequest) Descriptor
deprecated
func (*BroadcastRequest) Descriptor() ([]byte, []int)
Deprecated: Use BroadcastRequest.ProtoReflect.Descriptor instead.
func (*BroadcastRequest) GetB64Data ¶
func (x *BroadcastRequest) GetB64Data() string
func (*BroadcastRequest) GetChannels ¶
func (x *BroadcastRequest) GetChannels() []string
func (*BroadcastRequest) GetData ¶
func (x *BroadcastRequest) GetData() []byte
func (*BroadcastRequest) GetSkipHistory ¶
func (x *BroadcastRequest) GetSkipHistory() bool
func (*BroadcastRequest) GetTags ¶
func (x *BroadcastRequest) GetTags() map[string]string
func (*BroadcastRequest) ProtoMessage ¶
func (*BroadcastRequest) ProtoMessage()
func (*BroadcastRequest) ProtoReflect ¶
func (x *BroadcastRequest) ProtoReflect() protoreflect.Message
func (*BroadcastRequest) Reset ¶
func (x *BroadcastRequest) Reset()
func (*BroadcastRequest) String ¶
func (x *BroadcastRequest) String() string
type BroadcastResponse ¶
type BroadcastResponse struct { Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Result *BroadcastResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*BroadcastResponse) Descriptor
deprecated
func (*BroadcastResponse) Descriptor() ([]byte, []int)
Deprecated: Use BroadcastResponse.ProtoReflect.Descriptor instead.
func (*BroadcastResponse) GetError ¶
func (x *BroadcastResponse) GetError() *Error
func (*BroadcastResponse) GetResult ¶
func (x *BroadcastResponse) GetResult() *BroadcastResult
func (*BroadcastResponse) ProtoMessage ¶
func (*BroadcastResponse) ProtoMessage()
func (*BroadcastResponse) ProtoReflect ¶
func (x *BroadcastResponse) ProtoReflect() protoreflect.Message
func (*BroadcastResponse) Reset ¶
func (x *BroadcastResponse) Reset()
func (*BroadcastResponse) String ¶
func (x *BroadcastResponse) String() string
type BroadcastResult ¶
type BroadcastResult struct { Responses []*PublishResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"` // contains filtered or unexported fields }
func (*BroadcastResult) Descriptor
deprecated
func (*BroadcastResult) Descriptor() ([]byte, []int)
Deprecated: Use BroadcastResult.ProtoReflect.Descriptor instead.
func (*BroadcastResult) GetResponses ¶
func (x *BroadcastResult) GetResponses() []*PublishResponse
func (*BroadcastResult) ProtoMessage ¶
func (*BroadcastResult) ProtoMessage()
func (*BroadcastResult) ProtoReflect ¶
func (x *BroadcastResult) ProtoReflect() protoreflect.Message
func (*BroadcastResult) Reset ¶
func (x *BroadcastResult) Reset()
func (*BroadcastResult) String ¶
func (x *BroadcastResult) String() string
type ChannelContext ¶
type ChannelContext struct { Source uint32 `protobuf:"varint,1,opt,name=source,proto3" json:"source,omitempty"` // contains filtered or unexported fields }
func (*ChannelContext) Descriptor
deprecated
func (*ChannelContext) Descriptor() ([]byte, []int)
Deprecated: Use ChannelContext.ProtoReflect.Descriptor instead.
func (*ChannelContext) GetSource ¶
func (x *ChannelContext) GetSource() uint32
func (*ChannelContext) ProtoMessage ¶
func (*ChannelContext) ProtoMessage()
func (*ChannelContext) ProtoReflect ¶
func (x *ChannelContext) ProtoReflect() protoreflect.Message
func (*ChannelContext) Reset ¶
func (x *ChannelContext) Reset()
func (*ChannelContext) String ¶
func (x *ChannelContext) String() string
type ChannelInfo ¶
type ChannelInfo struct { NumClients uint32 `protobuf:"varint,1,opt,name=num_clients,json=numClients,proto3" json:"num_clients,omitempty"` // contains filtered or unexported fields }
func (*ChannelInfo) Descriptor
deprecated
func (*ChannelInfo) Descriptor() ([]byte, []int)
Deprecated: Use ChannelInfo.ProtoReflect.Descriptor instead.
func (*ChannelInfo) GetNumClients ¶
func (x *ChannelInfo) GetNumClients() uint32
func (*ChannelInfo) ProtoMessage ¶
func (*ChannelInfo) ProtoMessage()
func (*ChannelInfo) ProtoReflect ¶
func (x *ChannelInfo) ProtoReflect() protoreflect.Message
func (*ChannelInfo) Reset ¶
func (x *ChannelInfo) Reset()
func (*ChannelInfo) String ¶
func (x *ChannelInfo) String() string
type ChannelsRequest ¶
type ChannelsRequest struct { Pattern string `protobuf:"bytes,1,opt,name=pattern,proto3" json:"pattern,omitempty"` // contains filtered or unexported fields }
func (*ChannelsRequest) Descriptor
deprecated
func (*ChannelsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ChannelsRequest.ProtoReflect.Descriptor instead.
func (*ChannelsRequest) GetPattern ¶
func (x *ChannelsRequest) GetPattern() string
func (*ChannelsRequest) ProtoMessage ¶
func (*ChannelsRequest) ProtoMessage()
func (*ChannelsRequest) ProtoReflect ¶
func (x *ChannelsRequest) ProtoReflect() protoreflect.Message
func (*ChannelsRequest) Reset ¶
func (x *ChannelsRequest) Reset()
func (*ChannelsRequest) String ¶
func (x *ChannelsRequest) String() string
type ChannelsResponse ¶
type ChannelsResponse struct { Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Result *ChannelsResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*ChannelsResponse) Descriptor
deprecated
func (*ChannelsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ChannelsResponse.ProtoReflect.Descriptor instead.
func (*ChannelsResponse) GetError ¶
func (x *ChannelsResponse) GetError() *Error
func (*ChannelsResponse) GetResult ¶
func (x *ChannelsResponse) GetResult() *ChannelsResult
func (*ChannelsResponse) ProtoMessage ¶
func (*ChannelsResponse) ProtoMessage()
func (*ChannelsResponse) ProtoReflect ¶
func (x *ChannelsResponse) ProtoReflect() protoreflect.Message
func (*ChannelsResponse) Reset ¶
func (x *ChannelsResponse) Reset()
func (*ChannelsResponse) String ¶
func (x *ChannelsResponse) String() string
type ChannelsResult ¶
type ChannelsResult struct { Channels map[string]*ChannelInfo `` /* 157-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ChannelsResult) Descriptor
deprecated
func (*ChannelsResult) Descriptor() ([]byte, []int)
Deprecated: Use ChannelsResult.ProtoReflect.Descriptor instead.
func (*ChannelsResult) GetChannels ¶
func (x *ChannelsResult) GetChannels() map[string]*ChannelInfo
func (*ChannelsResult) ProtoMessage ¶
func (*ChannelsResult) ProtoMessage()
func (*ChannelsResult) ProtoReflect ¶
func (x *ChannelsResult) ProtoReflect() protoreflect.Message
func (*ChannelsResult) Reset ¶
func (x *ChannelsResult) Reset()
func (*ChannelsResult) String ¶
func (x *ChannelsResult) String() string
type ClientInfo ¶
type ClientInfo struct { User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` Client string `protobuf:"bytes,2,opt,name=client,proto3" json:"client,omitempty"` ConnInfo []byte `protobuf:"bytes,3,opt,name=conn_info,json=connInfo,proto3" json:"conn_info,omitempty"` ChanInfo []byte `protobuf:"bytes,4,opt,name=chan_info,json=chanInfo,proto3" json:"chan_info,omitempty"` // contains filtered or unexported fields }
func (*ClientInfo) Descriptor
deprecated
func (*ClientInfo) Descriptor() ([]byte, []int)
Deprecated: Use ClientInfo.ProtoReflect.Descriptor instead.
func (*ClientInfo) GetChanInfo ¶
func (x *ClientInfo) GetChanInfo() []byte
func (*ClientInfo) GetClient ¶
func (x *ClientInfo) GetClient() string
func (*ClientInfo) GetConnInfo ¶
func (x *ClientInfo) GetConnInfo() []byte
func (*ClientInfo) GetUser ¶
func (x *ClientInfo) GetUser() string
func (*ClientInfo) ProtoMessage ¶
func (*ClientInfo) ProtoMessage()
func (*ClientInfo) ProtoReflect ¶
func (x *ClientInfo) ProtoReflect() protoreflect.Message
func (*ClientInfo) Reset ¶
func (x *ClientInfo) Reset()
func (*ClientInfo) String ¶
func (x *ClientInfo) String() string
type Command ¶
type Command struct { Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Method Command_MethodType `protobuf:"varint,2,opt,name=method,proto3,enum=centrifugal.centrifugo.api.Command_MethodType" json:"method,omitempty"` Params []byte `protobuf:"bytes,3,opt,name=params,proto3" json:"params,omitempty"` // contains filtered or unexported fields }
func (*Command) GetMethod ¶
func (x *Command) GetMethod() Command_MethodType
func (*Command) ProtoReflect ¶
func (x *Command) ProtoReflect() protoreflect.Message
type Command_MethodType ¶
type Command_MethodType int32
const ( Command_PUBLISH Command_MethodType = 0 Command_BROADCAST Command_MethodType = 1 Command_UNSUBSCRIBE Command_MethodType = 2 Command_DISCONNECT Command_MethodType = 3 Command_PRESENCE Command_MethodType = 4 Command_PRESENCE_STATS Command_MethodType = 5 Command_HISTORY Command_MethodType = 6 Command_HISTORY_REMOVE Command_MethodType = 7 Command_CHANNELS Command_MethodType = 8 Command_INFO Command_MethodType = 9 Command_RPC Command_MethodType = 10 Command_SUBSCRIBE Command_MethodType = 11 Command_REFRESH Command_MethodType = 12 Command_CONNECTIONS Command_MethodType = 14 Command_UPDATE_USER_STATUS Command_MethodType = 15 Command_GET_USER_STATUS Command_MethodType = 16 Command_DELETE_USER_STATUS Command_MethodType = 17 Command_BLOCK_USER Command_MethodType = 18 Command_UNBLOCK_USER Command_MethodType = 19 Command_REVOKE_TOKEN Command_MethodType = 20 Command_INVALIDATE_USER_TOKENS Command_MethodType = 21 )
func (Command_MethodType) Descriptor ¶
func (Command_MethodType) Descriptor() protoreflect.EnumDescriptor
func (Command_MethodType) Enum ¶
func (x Command_MethodType) Enum() *Command_MethodType
func (Command_MethodType) EnumDescriptor
deprecated
func (Command_MethodType) EnumDescriptor() ([]byte, []int)
Deprecated: Use Command_MethodType.Descriptor instead.
func (Command_MethodType) Number ¶
func (x Command_MethodType) Number() protoreflect.EnumNumber
func (Command_MethodType) String ¶
func (x Command_MethodType) String() string
func (Command_MethodType) Type ¶
func (Command_MethodType) Type() protoreflect.EnumType
type ConnectionInfo ¶
type ConnectionInfo struct { AppName string `protobuf:"bytes,1,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"` AppVersion string `protobuf:"bytes,2,opt,name=app_version,json=appVersion,proto3" json:"app_version,omitempty"` Transport string `protobuf:"bytes,3,opt,name=transport,proto3" json:"transport,omitempty"` Protocol string `protobuf:"bytes,4,opt,name=protocol,proto3" json:"protocol,omitempty"` User string `protobuf:"bytes,8,opt,name=user,proto3" json:"user,omitempty"` State *ConnectionState `protobuf:"bytes,9,opt,name=state,proto3" json:"state,omitempty"` // contains filtered or unexported fields }
func (*ConnectionInfo) Descriptor
deprecated
func (*ConnectionInfo) Descriptor() ([]byte, []int)
Deprecated: Use ConnectionInfo.ProtoReflect.Descriptor instead.
func (*ConnectionInfo) GetAppName ¶
func (x *ConnectionInfo) GetAppName() string
func (*ConnectionInfo) GetAppVersion ¶
func (x *ConnectionInfo) GetAppVersion() string
func (*ConnectionInfo) GetProtocol ¶
func (x *ConnectionInfo) GetProtocol() string
func (*ConnectionInfo) GetState ¶
func (x *ConnectionInfo) GetState() *ConnectionState
func (*ConnectionInfo) GetTransport ¶
func (x *ConnectionInfo) GetTransport() string
func (*ConnectionInfo) GetUser ¶
func (x *ConnectionInfo) GetUser() string
func (*ConnectionInfo) ProtoMessage ¶
func (*ConnectionInfo) ProtoMessage()
func (*ConnectionInfo) ProtoReflect ¶
func (x *ConnectionInfo) ProtoReflect() protoreflect.Message
func (*ConnectionInfo) Reset ¶
func (x *ConnectionInfo) Reset()
func (*ConnectionInfo) String ¶
func (x *ConnectionInfo) String() string
type ConnectionState ¶
type ConnectionState struct { Channels map[string]*ChannelContext `` /* 157-byte string literal not displayed */ ConnectionToken *ConnectionTokenInfo `protobuf:"bytes,2,opt,name=connection_token,json=connectionToken,proto3" json:"connection_token,omitempty"` SubscriptionTokens map[string]*SubscriptionTokenInfo `` /* 203-byte string literal not displayed */ Meta []byte `protobuf:"bytes,4,opt,name=meta,proto3" json:"meta,omitempty"` // contains filtered or unexported fields }
func (*ConnectionState) Descriptor
deprecated
func (*ConnectionState) Descriptor() ([]byte, []int)
Deprecated: Use ConnectionState.ProtoReflect.Descriptor instead.
func (*ConnectionState) GetChannels ¶
func (x *ConnectionState) GetChannels() map[string]*ChannelContext
func (*ConnectionState) GetConnectionToken ¶
func (x *ConnectionState) GetConnectionToken() *ConnectionTokenInfo
func (*ConnectionState) GetMeta ¶
func (x *ConnectionState) GetMeta() []byte
func (*ConnectionState) GetSubscriptionTokens ¶
func (x *ConnectionState) GetSubscriptionTokens() map[string]*SubscriptionTokenInfo
func (*ConnectionState) ProtoMessage ¶
func (*ConnectionState) ProtoMessage()
func (*ConnectionState) ProtoReflect ¶
func (x *ConnectionState) ProtoReflect() protoreflect.Message
func (*ConnectionState) Reset ¶
func (x *ConnectionState) Reset()
func (*ConnectionState) String ¶
func (x *ConnectionState) String() string
type ConnectionTokenInfo ¶
type ConnectionTokenInfo struct { Uid string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"` IssuedAt int64 `protobuf:"varint,2,opt,name=issued_at,json=issuedAt,proto3" json:"issued_at,omitempty"` // contains filtered or unexported fields }
func (*ConnectionTokenInfo) Descriptor
deprecated
func (*ConnectionTokenInfo) Descriptor() ([]byte, []int)
Deprecated: Use ConnectionTokenInfo.ProtoReflect.Descriptor instead.
func (*ConnectionTokenInfo) GetIssuedAt ¶
func (x *ConnectionTokenInfo) GetIssuedAt() int64
func (*ConnectionTokenInfo) GetUid ¶
func (x *ConnectionTokenInfo) GetUid() string
func (*ConnectionTokenInfo) ProtoMessage ¶
func (*ConnectionTokenInfo) ProtoMessage()
func (*ConnectionTokenInfo) ProtoReflect ¶
func (x *ConnectionTokenInfo) ProtoReflect() protoreflect.Message
func (*ConnectionTokenInfo) Reset ¶
func (x *ConnectionTokenInfo) Reset()
func (*ConnectionTokenInfo) String ¶
func (x *ConnectionTokenInfo) String() string
type ConnectionsRequest ¶
type ConnectionsRequest struct { User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` Expression string `protobuf:"bytes,2,opt,name=expression,proto3" json:"expression,omitempty"` // contains filtered or unexported fields }
func (*ConnectionsRequest) Descriptor
deprecated
func (*ConnectionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConnectionsRequest.ProtoReflect.Descriptor instead.
func (*ConnectionsRequest) GetExpression ¶
func (x *ConnectionsRequest) GetExpression() string
func (*ConnectionsRequest) GetUser ¶
func (x *ConnectionsRequest) GetUser() string
func (*ConnectionsRequest) ProtoMessage ¶
func (*ConnectionsRequest) ProtoMessage()
func (*ConnectionsRequest) ProtoReflect ¶
func (x *ConnectionsRequest) ProtoReflect() protoreflect.Message
func (*ConnectionsRequest) Reset ¶
func (x *ConnectionsRequest) Reset()
func (*ConnectionsRequest) String ¶
func (x *ConnectionsRequest) String() string
type ConnectionsResponse ¶
type ConnectionsResponse struct { Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Result *ConnectionsResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*ConnectionsResponse) Descriptor
deprecated
func (*ConnectionsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ConnectionsResponse.ProtoReflect.Descriptor instead.
func (*ConnectionsResponse) GetError ¶
func (x *ConnectionsResponse) GetError() *Error
func (*ConnectionsResponse) GetResult ¶
func (x *ConnectionsResponse) GetResult() *ConnectionsResult
func (*ConnectionsResponse) ProtoMessage ¶
func (*ConnectionsResponse) ProtoMessage()
func (*ConnectionsResponse) ProtoReflect ¶
func (x *ConnectionsResponse) ProtoReflect() protoreflect.Message
func (*ConnectionsResponse) Reset ¶
func (x *ConnectionsResponse) Reset()
func (*ConnectionsResponse) String ¶
func (x *ConnectionsResponse) String() string
type ConnectionsResult ¶
type ConnectionsResult struct { Connections map[string]*ConnectionInfo `` /* 163-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ConnectionsResult) Descriptor
deprecated
func (*ConnectionsResult) Descriptor() ([]byte, []int)
Deprecated: Use ConnectionsResult.ProtoReflect.Descriptor instead.
func (*ConnectionsResult) GetConnections ¶
func (x *ConnectionsResult) GetConnections() map[string]*ConnectionInfo
func (*ConnectionsResult) ProtoMessage ¶
func (*ConnectionsResult) ProtoMessage()
func (*ConnectionsResult) ProtoReflect ¶
func (x *ConnectionsResult) ProtoReflect() protoreflect.Message
func (*ConnectionsResult) Reset ¶
func (x *ConnectionsResult) Reset()
func (*ConnectionsResult) String ¶
func (x *ConnectionsResult) String() string
type DeleteUserStatusRequest ¶
type DeleteUserStatusRequest struct { Users []string `protobuf:"bytes,1,rep,name=users,proto3" json:"users,omitempty"` // contains filtered or unexported fields }
func (*DeleteUserStatusRequest) Descriptor
deprecated
func (*DeleteUserStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteUserStatusRequest.ProtoReflect.Descriptor instead.
func (*DeleteUserStatusRequest) GetUsers ¶
func (x *DeleteUserStatusRequest) GetUsers() []string
func (*DeleteUserStatusRequest) ProtoMessage ¶
func (*DeleteUserStatusRequest) ProtoMessage()
func (*DeleteUserStatusRequest) ProtoReflect ¶
func (x *DeleteUserStatusRequest) ProtoReflect() protoreflect.Message
func (*DeleteUserStatusRequest) Reset ¶
func (x *DeleteUserStatusRequest) Reset()
func (*DeleteUserStatusRequest) String ¶
func (x *DeleteUserStatusRequest) String() string
type DeleteUserStatusResponse ¶
type DeleteUserStatusResponse struct { Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Result *DeleteUserStatusResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*DeleteUserStatusResponse) Descriptor
deprecated
func (*DeleteUserStatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteUserStatusResponse.ProtoReflect.Descriptor instead.
func (*DeleteUserStatusResponse) GetError ¶
func (x *DeleteUserStatusResponse) GetError() *Error
func (*DeleteUserStatusResponse) GetResult ¶
func (x *DeleteUserStatusResponse) GetResult() *DeleteUserStatusResult
func (*DeleteUserStatusResponse) ProtoMessage ¶
func (*DeleteUserStatusResponse) ProtoMessage()
func (*DeleteUserStatusResponse) ProtoReflect ¶
func (x *DeleteUserStatusResponse) ProtoReflect() protoreflect.Message
func (*DeleteUserStatusResponse) Reset ¶
func (x *DeleteUserStatusResponse) Reset()
func (*DeleteUserStatusResponse) String ¶
func (x *DeleteUserStatusResponse) String() string
type DeleteUserStatusResult ¶
type DeleteUserStatusResult struct {
// contains filtered or unexported fields
}
func (*DeleteUserStatusResult) Descriptor
deprecated
func (*DeleteUserStatusResult) Descriptor() ([]byte, []int)
Deprecated: Use DeleteUserStatusResult.ProtoReflect.Descriptor instead.
func (*DeleteUserStatusResult) ProtoMessage ¶
func (*DeleteUserStatusResult) ProtoMessage()
func (*DeleteUserStatusResult) ProtoReflect ¶
func (x *DeleteUserStatusResult) ProtoReflect() protoreflect.Message
func (*DeleteUserStatusResult) Reset ¶
func (x *DeleteUserStatusResult) Reset()
func (*DeleteUserStatusResult) String ¶
func (x *DeleteUserStatusResult) String() string
type Disconnect ¶
type Disconnect struct { Code uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"` Reconnect bool `protobuf:"varint,3,opt,name=reconnect,proto3" json:"reconnect,omitempty"` // contains filtered or unexported fields }
func (*Disconnect) Descriptor
deprecated
func (*Disconnect) Descriptor() ([]byte, []int)
Deprecated: Use Disconnect.ProtoReflect.Descriptor instead.
func (*Disconnect) GetCode ¶
func (x *Disconnect) GetCode() uint32
func (*Disconnect) GetReason ¶
func (x *Disconnect) GetReason() string
func (*Disconnect) GetReconnect ¶
func (x *Disconnect) GetReconnect() bool
func (*Disconnect) ProtoMessage ¶
func (*Disconnect) ProtoMessage()
func (*Disconnect) ProtoReflect ¶
func (x *Disconnect) ProtoReflect() protoreflect.Message
func (*Disconnect) Reset ¶
func (x *Disconnect) Reset()
func (*Disconnect) String ¶
func (x *Disconnect) String() string
type DisconnectRequest ¶
type DisconnectRequest struct { User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` Disconnect *Disconnect `protobuf:"bytes,2,opt,name=disconnect,proto3" json:"disconnect,omitempty"` Client string `protobuf:"bytes,3,opt,name=client,proto3" json:"client,omitempty"` Whitelist []string `protobuf:"bytes,4,rep,name=whitelist,proto3" json:"whitelist,omitempty"` Session string `protobuf:"bytes,5,opt,name=session,proto3" json:"session,omitempty"` // contains filtered or unexported fields }
func (*DisconnectRequest) Descriptor
deprecated
func (*DisconnectRequest) Descriptor() ([]byte, []int)
Deprecated: Use DisconnectRequest.ProtoReflect.Descriptor instead.
func (*DisconnectRequest) GetClient ¶
func (x *DisconnectRequest) GetClient() string
func (*DisconnectRequest) GetDisconnect ¶
func (x *DisconnectRequest) GetDisconnect() *Disconnect
func (*DisconnectRequest) GetSession ¶
func (x *DisconnectRequest) GetSession() string
func (*DisconnectRequest) GetUser ¶
func (x *DisconnectRequest) GetUser() string
func (*DisconnectRequest) GetWhitelist ¶
func (x *DisconnectRequest) GetWhitelist() []string
func (*DisconnectRequest) ProtoMessage ¶
func (*DisconnectRequest) ProtoMessage()
func (*DisconnectRequest) ProtoReflect ¶
func (x *DisconnectRequest) ProtoReflect() protoreflect.Message
func (*DisconnectRequest) Reset ¶
func (x *DisconnectRequest) Reset()
func (*DisconnectRequest) String ¶
func (x *DisconnectRequest) String() string
type DisconnectResponse ¶
type DisconnectResponse struct { Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Result *DisconnectResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*DisconnectResponse) Descriptor
deprecated
func (*DisconnectResponse) Descriptor() ([]byte, []int)
Deprecated: Use DisconnectResponse.ProtoReflect.Descriptor instead.
func (*DisconnectResponse) GetError ¶
func (x *DisconnectResponse) GetError() *Error
func (*DisconnectResponse) GetResult ¶
func (x *DisconnectResponse) GetResult() *DisconnectResult
func (*DisconnectResponse) ProtoMessage ¶
func (*DisconnectResponse) ProtoMessage()
func (*DisconnectResponse) ProtoReflect ¶
func (x *DisconnectResponse) ProtoReflect() protoreflect.Message
func (*DisconnectResponse) Reset ¶
func (x *DisconnectResponse) Reset()
func (*DisconnectResponse) String ¶
func (x *DisconnectResponse) String() string
type DisconnectResult ¶
type DisconnectResult struct {
// contains filtered or unexported fields
}
func (*DisconnectResult) Descriptor
deprecated
func (*DisconnectResult) Descriptor() ([]byte, []int)
Deprecated: Use DisconnectResult.ProtoReflect.Descriptor instead.
func (*DisconnectResult) ProtoMessage ¶
func (*DisconnectResult) ProtoMessage()
func (*DisconnectResult) ProtoReflect ¶
func (x *DisconnectResult) ProtoReflect() protoreflect.Message
func (*DisconnectResult) Reset ¶
func (x *DisconnectResult) Reset()
func (*DisconnectResult) String ¶
func (x *DisconnectResult) String() string
type Error ¶
type Error struct { Code uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*Error) ProtoReflect ¶
func (x *Error) ProtoReflect() protoreflect.Message
type GetUserStatusRequest ¶
type GetUserStatusRequest struct { Users []string `protobuf:"bytes,1,rep,name=users,proto3" json:"users,omitempty"` // contains filtered or unexported fields }
func (*GetUserStatusRequest) Descriptor
deprecated
func (*GetUserStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetUserStatusRequest.ProtoReflect.Descriptor instead.
func (*GetUserStatusRequest) GetUsers ¶
func (x *GetUserStatusRequest) GetUsers() []string
func (*GetUserStatusRequest) ProtoMessage ¶
func (*GetUserStatusRequest) ProtoMessage()
func (*GetUserStatusRequest) ProtoReflect ¶
func (x *GetUserStatusRequest) ProtoReflect() protoreflect.Message
func (*GetUserStatusRequest) Reset ¶
func (x *GetUserStatusRequest) Reset()
func (*GetUserStatusRequest) String ¶
func (x *GetUserStatusRequest) String() string
type GetUserStatusResponse ¶
type GetUserStatusResponse struct { Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Result *GetUserStatusResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*GetUserStatusResponse) Descriptor
deprecated
func (*GetUserStatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetUserStatusResponse.ProtoReflect.Descriptor instead.
func (*GetUserStatusResponse) GetError ¶
func (x *GetUserStatusResponse) GetError() *Error
func (*GetUserStatusResponse) GetResult ¶
func (x *GetUserStatusResponse) GetResult() *GetUserStatusResult
func (*GetUserStatusResponse) ProtoMessage ¶
func (*GetUserStatusResponse) ProtoMessage()
func (*GetUserStatusResponse) ProtoReflect ¶
func (x *GetUserStatusResponse) ProtoReflect() protoreflect.Message
func (*GetUserStatusResponse) Reset ¶
func (x *GetUserStatusResponse) Reset()
func (*GetUserStatusResponse) String ¶
func (x *GetUserStatusResponse) String() string
type GetUserStatusResult ¶
type GetUserStatusResult struct { Statuses []*UserStatus `protobuf:"bytes,1,rep,name=statuses,proto3" json:"statuses,omitempty"` // contains filtered or unexported fields }
func (*GetUserStatusResult) Descriptor
deprecated
func (*GetUserStatusResult) Descriptor() ([]byte, []int)
Deprecated: Use GetUserStatusResult.ProtoReflect.Descriptor instead.
func (*GetUserStatusResult) GetStatuses ¶
func (x *GetUserStatusResult) GetStatuses() []*UserStatus
func (*GetUserStatusResult) ProtoMessage ¶
func (*GetUserStatusResult) ProtoMessage()
func (*GetUserStatusResult) ProtoReflect ¶
func (x *GetUserStatusResult) ProtoReflect() protoreflect.Message
func (*GetUserStatusResult) Reset ¶
func (x *GetUserStatusResult) Reset()
func (*GetUserStatusResult) String ¶
func (x *GetUserStatusResult) String() string
type HistoryRemoveRequest ¶
type HistoryRemoveRequest struct { Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"` // contains filtered or unexported fields }
func (*HistoryRemoveRequest) Descriptor
deprecated
func (*HistoryRemoveRequest) Descriptor() ([]byte, []int)
Deprecated: Use HistoryRemoveRequest.ProtoReflect.Descriptor instead.
func (*HistoryRemoveRequest) GetChannel ¶
func (x *HistoryRemoveRequest) GetChannel() string
func (*HistoryRemoveRequest) ProtoMessage ¶
func (*HistoryRemoveRequest) ProtoMessage()
func (*HistoryRemoveRequest) ProtoReflect ¶
func (x *HistoryRemoveRequest) ProtoReflect() protoreflect.Message
func (*HistoryRemoveRequest) Reset ¶
func (x *HistoryRemoveRequest) Reset()
func (*HistoryRemoveRequest) String ¶
func (x *HistoryRemoveRequest) String() string
type HistoryRemoveResponse ¶
type HistoryRemoveResponse struct { Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Result *HistoryRemoveResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*HistoryRemoveResponse) Descriptor
deprecated
func (*HistoryRemoveResponse) Descriptor() ([]byte, []int)
Deprecated: Use HistoryRemoveResponse.ProtoReflect.Descriptor instead.
func (*HistoryRemoveResponse) GetError ¶
func (x *HistoryRemoveResponse) GetError() *Error
func (*HistoryRemoveResponse) GetResult ¶
func (x *HistoryRemoveResponse) GetResult() *HistoryRemoveResult
func (*HistoryRemoveResponse) ProtoMessage ¶
func (*HistoryRemoveResponse) ProtoMessage()
func (*HistoryRemoveResponse) ProtoReflect ¶
func (x *HistoryRemoveResponse) ProtoReflect() protoreflect.Message
func (*HistoryRemoveResponse) Reset ¶
func (x *HistoryRemoveResponse) Reset()
func (*HistoryRemoveResponse) String ¶
func (x *HistoryRemoveResponse) String() string
type HistoryRemoveResult ¶
type HistoryRemoveResult struct {
// contains filtered or unexported fields
}
func (*HistoryRemoveResult) Descriptor
deprecated
func (*HistoryRemoveResult) Descriptor() ([]byte, []int)
Deprecated: Use HistoryRemoveResult.ProtoReflect.Descriptor instead.
func (*HistoryRemoveResult) ProtoMessage ¶
func (*HistoryRemoveResult) ProtoMessage()
func (*HistoryRemoveResult) ProtoReflect ¶
func (x *HistoryRemoveResult) ProtoReflect() protoreflect.Message
func (*HistoryRemoveResult) Reset ¶
func (x *HistoryRemoveResult) Reset()
func (*HistoryRemoveResult) String ¶
func (x *HistoryRemoveResult) String() string
type HistoryRequest ¶
type HistoryRequest struct { Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"` Limit int32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` Since *StreamPosition `protobuf:"bytes,3,opt,name=since,proto3" json:"since,omitempty"` Reverse bool `protobuf:"varint,4,opt,name=reverse,proto3" json:"reverse,omitempty"` // contains filtered or unexported fields }
func (*HistoryRequest) Descriptor
deprecated
func (*HistoryRequest) Descriptor() ([]byte, []int)
Deprecated: Use HistoryRequest.ProtoReflect.Descriptor instead.
func (*HistoryRequest) GetChannel ¶
func (x *HistoryRequest) GetChannel() string
func (*HistoryRequest) GetLimit ¶
func (x *HistoryRequest) GetLimit() int32
func (*HistoryRequest) GetReverse ¶
func (x *HistoryRequest) GetReverse() bool
func (*HistoryRequest) GetSince ¶
func (x *HistoryRequest) GetSince() *StreamPosition
func (*HistoryRequest) ProtoMessage ¶
func (*HistoryRequest) ProtoMessage()
func (*HistoryRequest) ProtoReflect ¶
func (x *HistoryRequest) ProtoReflect() protoreflect.Message
func (*HistoryRequest) Reset ¶
func (x *HistoryRequest) Reset()
func (*HistoryRequest) String ¶
func (x *HistoryRequest) String() string
type HistoryResponse ¶
type HistoryResponse struct { Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Result *HistoryResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*HistoryResponse) Descriptor
deprecated
func (*HistoryResponse) Descriptor() ([]byte, []int)
Deprecated: Use HistoryResponse.ProtoReflect.Descriptor instead.
func (*HistoryResponse) GetError ¶
func (x *HistoryResponse) GetError() *Error
func (*HistoryResponse) GetResult ¶
func (x *HistoryResponse) GetResult() *HistoryResult
func (*HistoryResponse) ProtoMessage ¶
func (*HistoryResponse) ProtoMessage()
func (*HistoryResponse) ProtoReflect ¶
func (x *HistoryResponse) ProtoReflect() protoreflect.Message
func (*HistoryResponse) Reset ¶
func (x *HistoryResponse) Reset()
func (*HistoryResponse) String ¶
func (x *HistoryResponse) String() string
type HistoryResult ¶
type HistoryResult struct { Publications []*Publication `protobuf:"bytes,1,rep,name=publications,proto3" json:"publications,omitempty"` Epoch string `protobuf:"bytes,2,opt,name=epoch,proto3" json:"epoch,omitempty"` Offset uint64 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"` // contains filtered or unexported fields }
func (*HistoryResult) Descriptor
deprecated
func (*HistoryResult) Descriptor() ([]byte, []int)
Deprecated: Use HistoryResult.ProtoReflect.Descriptor instead.
func (*HistoryResult) GetEpoch ¶
func (x *HistoryResult) GetEpoch() string
func (*HistoryResult) GetOffset ¶
func (x *HistoryResult) GetOffset() uint64
func (*HistoryResult) GetPublications ¶
func (x *HistoryResult) GetPublications() []*Publication
func (*HistoryResult) ProtoMessage ¶
func (*HistoryResult) ProtoMessage()
func (*HistoryResult) ProtoReflect ¶
func (x *HistoryResult) ProtoReflect() protoreflect.Message
func (*HistoryResult) Reset ¶
func (x *HistoryResult) Reset()
func (*HistoryResult) String ¶
func (x *HistoryResult) String() string
type InfoRequest ¶
type InfoRequest struct {
// contains filtered or unexported fields
}
func (*InfoRequest) Descriptor
deprecated
func (*InfoRequest) Descriptor() ([]byte, []int)
Deprecated: Use InfoRequest.ProtoReflect.Descriptor instead.
func (*InfoRequest) ProtoMessage ¶
func (*InfoRequest) ProtoMessage()
func (*InfoRequest) ProtoReflect ¶
func (x *InfoRequest) ProtoReflect() protoreflect.Message
func (*InfoRequest) Reset ¶
func (x *InfoRequest) Reset()
func (*InfoRequest) String ¶
func (x *InfoRequest) String() string
type InfoResponse ¶
type InfoResponse struct { Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Result *InfoResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*InfoResponse) Descriptor
deprecated
func (*InfoResponse) Descriptor() ([]byte, []int)
Deprecated: Use InfoResponse.ProtoReflect.Descriptor instead.
func (*InfoResponse) GetError ¶
func (x *InfoResponse) GetError() *Error
func (*InfoResponse) GetResult ¶
func (x *InfoResponse) GetResult() *InfoResult
func (*InfoResponse) ProtoMessage ¶
func (*InfoResponse) ProtoMessage()
func (*InfoResponse) ProtoReflect ¶
func (x *InfoResponse) ProtoReflect() protoreflect.Message
func (*InfoResponse) Reset ¶
func (x *InfoResponse) Reset()
func (*InfoResponse) String ¶
func (x *InfoResponse) String() string
type InfoResult ¶
type InfoResult struct { Nodes []*NodeResult `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"` // contains filtered or unexported fields }
func (*InfoResult) Descriptor
deprecated
func (*InfoResult) Descriptor() ([]byte, []int)
Deprecated: Use InfoResult.ProtoReflect.Descriptor instead.
func (*InfoResult) GetNodes ¶
func (x *InfoResult) GetNodes() []*NodeResult
func (*InfoResult) ProtoMessage ¶
func (*InfoResult) ProtoMessage()
func (*InfoResult) ProtoReflect ¶
func (x *InfoResult) ProtoReflect() protoreflect.Message
func (*InfoResult) Reset ¶
func (x *InfoResult) Reset()
func (*InfoResult) String ¶
func (x *InfoResult) String() string
type Int32Value ¶
type Int32Value struct { Value int32 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*Int32Value) Descriptor
deprecated
func (*Int32Value) Descriptor() ([]byte, []int)
Deprecated: Use Int32Value.ProtoReflect.Descriptor instead.
func (*Int32Value) GetValue ¶
func (x *Int32Value) GetValue() int32
func (*Int32Value) ProtoMessage ¶
func (*Int32Value) ProtoMessage()
func (*Int32Value) ProtoReflect ¶
func (x *Int32Value) ProtoReflect() protoreflect.Message
func (*Int32Value) Reset ¶
func (x *Int32Value) Reset()
func (*Int32Value) String ¶
func (x *Int32Value) String() string
type InvalidateUserTokensRequest ¶
type InvalidateUserTokensRequest struct { ExpireAt int64 `protobuf:"varint,1,opt,name=expire_at,json=expireAt,proto3" json:"expire_at,omitempty"` User string `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"` IssuedBefore int64 `protobuf:"varint,3,opt,name=issued_before,json=issuedBefore,proto3" json:"issued_before,omitempty"` Channel string `protobuf:"bytes,4,opt,name=channel,proto3" json:"channel,omitempty"` // contains filtered or unexported fields }
func (*InvalidateUserTokensRequest) Descriptor
deprecated
func (*InvalidateUserTokensRequest) Descriptor() ([]byte, []int)
Deprecated: Use InvalidateUserTokensRequest.ProtoReflect.Descriptor instead.
func (*InvalidateUserTokensRequest) GetChannel ¶
func (x *InvalidateUserTokensRequest) GetChannel() string
func (*InvalidateUserTokensRequest) GetExpireAt ¶
func (x *InvalidateUserTokensRequest) GetExpireAt() int64
func (*InvalidateUserTokensRequest) GetIssuedBefore ¶
func (x *InvalidateUserTokensRequest) GetIssuedBefore() int64
func (*InvalidateUserTokensRequest) GetUser ¶
func (x *InvalidateUserTokensRequest) GetUser() string
func (*InvalidateUserTokensRequest) ProtoMessage ¶
func (*InvalidateUserTokensRequest) ProtoMessage()
func (*InvalidateUserTokensRequest) ProtoReflect ¶
func (x *InvalidateUserTokensRequest) ProtoReflect() protoreflect.Message
func (*InvalidateUserTokensRequest) Reset ¶
func (x *InvalidateUserTokensRequest) Reset()
func (*InvalidateUserTokensRequest) String ¶
func (x *InvalidateUserTokensRequest) String() string
type InvalidateUserTokensResponse ¶
type InvalidateUserTokensResponse struct { Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Result *InvalidateUserTokensResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*InvalidateUserTokensResponse) Descriptor
deprecated
func (*InvalidateUserTokensResponse) Descriptor() ([]byte, []int)
Deprecated: Use InvalidateUserTokensResponse.ProtoReflect.Descriptor instead.
func (*InvalidateUserTokensResponse) GetError ¶
func (x *InvalidateUserTokensResponse) GetError() *Error
func (*InvalidateUserTokensResponse) GetResult ¶
func (x *InvalidateUserTokensResponse) GetResult() *InvalidateUserTokensResult
func (*InvalidateUserTokensResponse) ProtoMessage ¶
func (*InvalidateUserTokensResponse) ProtoMessage()
func (*InvalidateUserTokensResponse) ProtoReflect ¶
func (x *InvalidateUserTokensResponse) ProtoReflect() protoreflect.Message
func (*InvalidateUserTokensResponse) Reset ¶
func (x *InvalidateUserTokensResponse) Reset()
func (*InvalidateUserTokensResponse) String ¶
func (x *InvalidateUserTokensResponse) String() string
type InvalidateUserTokensResult ¶
type InvalidateUserTokensResult struct {
// contains filtered or unexported fields
}
func (*InvalidateUserTokensResult) Descriptor
deprecated
func (*InvalidateUserTokensResult) Descriptor() ([]byte, []int)
Deprecated: Use InvalidateUserTokensResult.ProtoReflect.Descriptor instead.
func (*InvalidateUserTokensResult) ProtoMessage ¶
func (*InvalidateUserTokensResult) ProtoMessage()
func (*InvalidateUserTokensResult) ProtoReflect ¶
func (x *InvalidateUserTokensResult) ProtoReflect() protoreflect.Message
func (*InvalidateUserTokensResult) Reset ¶
func (x *InvalidateUserTokensResult) Reset()
func (*InvalidateUserTokensResult) String ¶
func (x *InvalidateUserTokensResult) String() string
type Metrics ¶
type Metrics struct { Interval float64 `protobuf:"fixed64,1,opt,name=interval,proto3" json:"interval,omitempty"` Items map[string]float64 `` /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Metrics) ProtoReflect ¶
func (x *Metrics) ProtoReflect() protoreflect.Message
type NodeResult ¶
type NodeResult struct { Uid string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"` NumClients uint32 `protobuf:"varint,4,opt,name=num_clients,json=numClients,proto3" json:"num_clients,omitempty"` NumUsers uint32 `protobuf:"varint,5,opt,name=num_users,json=numUsers,proto3" json:"num_users,omitempty"` NumChannels uint32 `protobuf:"varint,6,opt,name=num_channels,json=numChannels,proto3" json:"num_channels,omitempty"` Uptime uint32 `protobuf:"varint,7,opt,name=uptime,proto3" json:"uptime,omitempty"` Metrics *Metrics `protobuf:"bytes,8,opt,name=metrics,proto3" json:"metrics,omitempty"` Process *Process `protobuf:"bytes,9,opt,name=process,proto3" json:"process,omitempty"` NumSubs uint32 `protobuf:"varint,10,opt,name=num_subs,json=numSubs,proto3" json:"num_subs,omitempty"` // contains filtered or unexported fields }
func (*NodeResult) Descriptor
deprecated
func (*NodeResult) Descriptor() ([]byte, []int)
Deprecated: Use NodeResult.ProtoReflect.Descriptor instead.
func (*NodeResult) GetMetrics ¶
func (x *NodeResult) GetMetrics() *Metrics
func (*NodeResult) GetName ¶
func (x *NodeResult) GetName() string
func (*NodeResult) GetNumChannels ¶
func (x *NodeResult) GetNumChannels() uint32
func (*NodeResult) GetNumClients ¶
func (x *NodeResult) GetNumClients() uint32
func (*NodeResult) GetNumSubs ¶
func (x *NodeResult) GetNumSubs() uint32
func (*NodeResult) GetNumUsers ¶
func (x *NodeResult) GetNumUsers() uint32
func (*NodeResult) GetProcess ¶
func (x *NodeResult) GetProcess() *Process
func (*NodeResult) GetUid ¶
func (x *NodeResult) GetUid() string
func (*NodeResult) GetUptime ¶
func (x *NodeResult) GetUptime() uint32
func (*NodeResult) GetVersion ¶
func (x *NodeResult) GetVersion() string
func (*NodeResult) ProtoMessage ¶
func (*NodeResult) ProtoMessage()
func (*NodeResult) ProtoReflect ¶
func (x *NodeResult) ProtoReflect() protoreflect.Message
func (*NodeResult) Reset ¶
func (x *NodeResult) Reset()
func (*NodeResult) String ¶
func (x *NodeResult) String() string
type PresenceRequest ¶
type PresenceRequest struct { Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"` // contains filtered or unexported fields }
func (*PresenceRequest) Descriptor
deprecated
func (*PresenceRequest) Descriptor() ([]byte, []int)
Deprecated: Use PresenceRequest.ProtoReflect.Descriptor instead.
func (*PresenceRequest) GetChannel ¶
func (x *PresenceRequest) GetChannel() string
func (*PresenceRequest) ProtoMessage ¶
func (*PresenceRequest) ProtoMessage()
func (*PresenceRequest) ProtoReflect ¶
func (x *PresenceRequest) ProtoReflect() protoreflect.Message
func (*PresenceRequest) Reset ¶
func (x *PresenceRequest) Reset()
func (*PresenceRequest) String ¶
func (x *PresenceRequest) String() string
type PresenceResponse ¶
type PresenceResponse struct { Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Result *PresenceResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*PresenceResponse) Descriptor
deprecated
func (*PresenceResponse) Descriptor() ([]byte, []int)
Deprecated: Use PresenceResponse.ProtoReflect.Descriptor instead.
func (*PresenceResponse) GetError ¶
func (x *PresenceResponse) GetError() *Error
func (*PresenceResponse) GetResult ¶
func (x *PresenceResponse) GetResult() *PresenceResult
func (*PresenceResponse) ProtoMessage ¶
func (*PresenceResponse) ProtoMessage()
func (*PresenceResponse) ProtoReflect ¶
func (x *PresenceResponse) ProtoReflect() protoreflect.Message
func (*PresenceResponse) Reset ¶
func (x *PresenceResponse) Reset()
func (*PresenceResponse) String ¶
func (x *PresenceResponse) String() string
type PresenceResult ¶
type PresenceResult struct { Presence map[string]*ClientInfo `` /* 157-byte string literal not displayed */ // contains filtered or unexported fields }
func (*PresenceResult) Descriptor
deprecated
func (*PresenceResult) Descriptor() ([]byte, []int)
Deprecated: Use PresenceResult.ProtoReflect.Descriptor instead.
func (*PresenceResult) GetPresence ¶
func (x *PresenceResult) GetPresence() map[string]*ClientInfo
func (*PresenceResult) ProtoMessage ¶
func (*PresenceResult) ProtoMessage()
func (*PresenceResult) ProtoReflect ¶
func (x *PresenceResult) ProtoReflect() protoreflect.Message
func (*PresenceResult) Reset ¶
func (x *PresenceResult) Reset()
func (*PresenceResult) String ¶
func (x *PresenceResult) String() string
type PresenceStatsRequest ¶
type PresenceStatsRequest struct { Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"` // contains filtered or unexported fields }
func (*PresenceStatsRequest) Descriptor
deprecated
func (*PresenceStatsRequest) Descriptor() ([]byte, []int)
Deprecated: Use PresenceStatsRequest.ProtoReflect.Descriptor instead.
func (*PresenceStatsRequest) GetChannel ¶
func (x *PresenceStatsRequest) GetChannel() string
func (*PresenceStatsRequest) ProtoMessage ¶
func (*PresenceStatsRequest) ProtoMessage()
func (*PresenceStatsRequest) ProtoReflect ¶
func (x *PresenceStatsRequest) ProtoReflect() protoreflect.Message
func (*PresenceStatsRequest) Reset ¶
func (x *PresenceStatsRequest) Reset()
func (*PresenceStatsRequest) String ¶
func (x *PresenceStatsRequest) String() string
type PresenceStatsResponse ¶
type PresenceStatsResponse struct { Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Result *PresenceStatsResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*PresenceStatsResponse) Descriptor
deprecated
func (*PresenceStatsResponse) Descriptor() ([]byte, []int)
Deprecated: Use PresenceStatsResponse.ProtoReflect.Descriptor instead.
func (*PresenceStatsResponse) GetError ¶
func (x *PresenceStatsResponse) GetError() *Error
func (*PresenceStatsResponse) GetResult ¶
func (x *PresenceStatsResponse) GetResult() *PresenceStatsResult
func (*PresenceStatsResponse) ProtoMessage ¶
func (*PresenceStatsResponse) ProtoMessage()
func (*PresenceStatsResponse) ProtoReflect ¶
func (x *PresenceStatsResponse) ProtoReflect() protoreflect.Message
func (*PresenceStatsResponse) Reset ¶
func (x *PresenceStatsResponse) Reset()
func (*PresenceStatsResponse) String ¶
func (x *PresenceStatsResponse) String() string
type PresenceStatsResult ¶
type PresenceStatsResult struct { NumClients uint32 `protobuf:"varint,1,opt,name=num_clients,json=numClients,proto3" json:"num_clients,omitempty"` NumUsers uint32 `protobuf:"varint,2,opt,name=num_users,json=numUsers,proto3" json:"num_users,omitempty"` // contains filtered or unexported fields }
func (*PresenceStatsResult) Descriptor
deprecated
func (*PresenceStatsResult) Descriptor() ([]byte, []int)
Deprecated: Use PresenceStatsResult.ProtoReflect.Descriptor instead.
func (*PresenceStatsResult) GetNumClients ¶
func (x *PresenceStatsResult) GetNumClients() uint32
func (*PresenceStatsResult) GetNumUsers ¶
func (x *PresenceStatsResult) GetNumUsers() uint32
func (*PresenceStatsResult) ProtoMessage ¶
func (*PresenceStatsResult) ProtoMessage()
func (*PresenceStatsResult) ProtoReflect ¶
func (x *PresenceStatsResult) ProtoReflect() protoreflect.Message
func (*PresenceStatsResult) Reset ¶
func (x *PresenceStatsResult) Reset()
func (*PresenceStatsResult) String ¶
func (x *PresenceStatsResult) String() string
type Process ¶
type Process struct { Cpu float64 `protobuf:"fixed64,1,opt,name=cpu,proto3" json:"cpu,omitempty"` Rss int64 `protobuf:"varint,2,opt,name=rss,proto3" json:"rss,omitempty"` // contains filtered or unexported fields }
func (*Process) ProtoReflect ¶
func (x *Process) ProtoReflect() protoreflect.Message
type Publication ¶
type Publication struct { Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` Info *ClientInfo `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"` Offset uint64 `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"` Tags map[string]string `` /* 149-byte string literal not displayed */ // contains filtered or unexported fields }
func (*Publication) Descriptor
deprecated
func (*Publication) Descriptor() ([]byte, []int)
Deprecated: Use Publication.ProtoReflect.Descriptor instead.
func (*Publication) GetData ¶
func (x *Publication) GetData() []byte
func (*Publication) GetInfo ¶
func (x *Publication) GetInfo() *ClientInfo
func (*Publication) GetOffset ¶
func (x *Publication) GetOffset() uint64
func (*Publication) GetTags ¶
func (x *Publication) GetTags() map[string]string
func (*Publication) ProtoMessage ¶
func (*Publication) ProtoMessage()
func (*Publication) ProtoReflect ¶
func (x *Publication) ProtoReflect() protoreflect.Message
func (*Publication) Reset ¶
func (x *Publication) Reset()
func (*Publication) String ¶
func (x *Publication) String() string
type PublishRequest ¶
type PublishRequest struct { Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"` Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` B64Data string `protobuf:"bytes,3,opt,name=b64data,proto3" json:"b64data,omitempty"` SkipHistory bool `protobuf:"varint,4,opt,name=skip_history,json=skipHistory,proto3" json:"skip_history,omitempty"` Tags map[string]string `` /* 149-byte string literal not displayed */ // contains filtered or unexported fields }
func (*PublishRequest) Descriptor
deprecated
func (*PublishRequest) Descriptor() ([]byte, []int)
Deprecated: Use PublishRequest.ProtoReflect.Descriptor instead.
func (*PublishRequest) GetB64Data ¶
func (x *PublishRequest) GetB64Data() string
func (*PublishRequest) GetChannel ¶
func (x *PublishRequest) GetChannel() string
func (*PublishRequest) GetData ¶
func (x *PublishRequest) GetData() []byte
func (*PublishRequest) GetSkipHistory ¶
func (x *PublishRequest) GetSkipHistory() bool
func (*PublishRequest) GetTags ¶
func (x *PublishRequest) GetTags() map[string]string
func (*PublishRequest) ProtoMessage ¶
func (*PublishRequest) ProtoMessage()
func (*PublishRequest) ProtoReflect ¶
func (x *PublishRequest) ProtoReflect() protoreflect.Message
func (*PublishRequest) Reset ¶
func (x *PublishRequest) Reset()
func (*PublishRequest) String ¶
func (x *PublishRequest) String() string
type PublishResponse ¶
type PublishResponse struct { Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Result *PublishResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*PublishResponse) Descriptor
deprecated
func (*PublishResponse) Descriptor() ([]byte, []int)
Deprecated: Use PublishResponse.ProtoReflect.Descriptor instead.
func (*PublishResponse) GetError ¶
func (x *PublishResponse) GetError() *Error
func (*PublishResponse) GetResult ¶
func (x *PublishResponse) GetResult() *PublishResult
func (*PublishResponse) ProtoMessage ¶
func (*PublishResponse) ProtoMessage()
func (*PublishResponse) ProtoReflect ¶
func (x *PublishResponse) ProtoReflect() protoreflect.Message
func (*PublishResponse) Reset ¶
func (x *PublishResponse) Reset()
func (*PublishResponse) String ¶
func (x *PublishResponse) String() string
type PublishResult ¶
type PublishResult struct { Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"` Epoch string `protobuf:"bytes,2,opt,name=epoch,proto3" json:"epoch,omitempty"` // contains filtered or unexported fields }
func (*PublishResult) Descriptor
deprecated
func (*PublishResult) Descriptor() ([]byte, []int)
Deprecated: Use PublishResult.ProtoReflect.Descriptor instead.
func (*PublishResult) GetEpoch ¶
func (x *PublishResult) GetEpoch() string
func (*PublishResult) GetOffset ¶
func (x *PublishResult) GetOffset() uint64
func (*PublishResult) ProtoMessage ¶
func (*PublishResult) ProtoMessage()
func (*PublishResult) ProtoReflect ¶
func (x *PublishResult) ProtoReflect() protoreflect.Message
func (*PublishResult) Reset ¶
func (x *PublishResult) Reset()
func (*PublishResult) String ¶
func (x *PublishResult) String() string
type RPCRequest ¶
type RPCRequest struct { Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"` Params []byte `protobuf:"bytes,2,opt,name=params,proto3" json:"params,omitempty"` // contains filtered or unexported fields }
func (*RPCRequest) Descriptor
deprecated
func (*RPCRequest) Descriptor() ([]byte, []int)
Deprecated: Use RPCRequest.ProtoReflect.Descriptor instead.
func (*RPCRequest) GetMethod ¶
func (x *RPCRequest) GetMethod() string
func (*RPCRequest) GetParams ¶
func (x *RPCRequest) GetParams() []byte
func (*RPCRequest) ProtoMessage ¶
func (*RPCRequest) ProtoMessage()
func (*RPCRequest) ProtoReflect ¶
func (x *RPCRequest) ProtoReflect() protoreflect.Message
func (*RPCRequest) Reset ¶
func (x *RPCRequest) Reset()
func (*RPCRequest) String ¶
func (x *RPCRequest) String() string
type RPCResponse ¶
type RPCResponse struct { Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Result *RPCResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*RPCResponse) Descriptor
deprecated
func (*RPCResponse) Descriptor() ([]byte, []int)
Deprecated: Use RPCResponse.ProtoReflect.Descriptor instead.
func (*RPCResponse) GetError ¶
func (x *RPCResponse) GetError() *Error
func (*RPCResponse) GetResult ¶
func (x *RPCResponse) GetResult() *RPCResult
func (*RPCResponse) ProtoMessage ¶
func (*RPCResponse) ProtoMessage()
func (*RPCResponse) ProtoReflect ¶
func (x *RPCResponse) ProtoReflect() protoreflect.Message
func (*RPCResponse) Reset ¶
func (x *RPCResponse) Reset()
func (*RPCResponse) String ¶
func (x *RPCResponse) String() string
type RPCResult ¶
type RPCResult struct { Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*RPCResult) ProtoReflect ¶
func (x *RPCResult) ProtoReflect() protoreflect.Message
type RefreshRequest ¶
type RefreshRequest struct { User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` Client string `protobuf:"bytes,2,opt,name=client,proto3" json:"client,omitempty"` Expired bool `protobuf:"varint,3,opt,name=expired,proto3" json:"expired,omitempty"` ExpireAt int64 `protobuf:"varint,4,opt,name=expire_at,json=expireAt,proto3" json:"expire_at,omitempty"` Info []byte `protobuf:"bytes,5,opt,name=info,proto3" json:"info,omitempty"` Session string `protobuf:"bytes,6,opt,name=session,proto3" json:"session,omitempty"` // contains filtered or unexported fields }
func (*RefreshRequest) Descriptor
deprecated
func (*RefreshRequest) Descriptor() ([]byte, []int)
Deprecated: Use RefreshRequest.ProtoReflect.Descriptor instead.
func (*RefreshRequest) GetClient ¶
func (x *RefreshRequest) GetClient() string
func (*RefreshRequest) GetExpireAt ¶
func (x *RefreshRequest) GetExpireAt() int64
func (*RefreshRequest) GetExpired ¶
func (x *RefreshRequest) GetExpired() bool
func (*RefreshRequest) GetInfo ¶
func (x *RefreshRequest) GetInfo() []byte
func (*RefreshRequest) GetSession ¶
func (x *RefreshRequest) GetSession() string
func (*RefreshRequest) GetUser ¶
func (x *RefreshRequest) GetUser() string
func (*RefreshRequest) ProtoMessage ¶
func (*RefreshRequest) ProtoMessage()
func (*RefreshRequest) ProtoReflect ¶
func (x *RefreshRequest) ProtoReflect() protoreflect.Message
func (*RefreshRequest) Reset ¶
func (x *RefreshRequest) Reset()
func (*RefreshRequest) String ¶
func (x *RefreshRequest) String() string
type RefreshResponse ¶
type RefreshResponse struct { Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Result *RefreshResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*RefreshResponse) Descriptor
deprecated
func (*RefreshResponse) Descriptor() ([]byte, []int)
Deprecated: Use RefreshResponse.ProtoReflect.Descriptor instead.
func (*RefreshResponse) GetError ¶
func (x *RefreshResponse) GetError() *Error
func (*RefreshResponse) GetResult ¶
func (x *RefreshResponse) GetResult() *RefreshResult
func (*RefreshResponse) ProtoMessage ¶
func (*RefreshResponse) ProtoMessage()
func (*RefreshResponse) ProtoReflect ¶
func (x *RefreshResponse) ProtoReflect() protoreflect.Message
func (*RefreshResponse) Reset ¶
func (x *RefreshResponse) Reset()
func (*RefreshResponse) String ¶
func (x *RefreshResponse) String() string
type RefreshResult ¶
type RefreshResult struct {
// contains filtered or unexported fields
}
func (*RefreshResult) Descriptor
deprecated
func (*RefreshResult) Descriptor() ([]byte, []int)
Deprecated: Use RefreshResult.ProtoReflect.Descriptor instead.
func (*RefreshResult) ProtoMessage ¶
func (*RefreshResult) ProtoMessage()
func (*RefreshResult) ProtoReflect ¶
func (x *RefreshResult) ProtoReflect() protoreflect.Message
func (*RefreshResult) Reset ¶
func (x *RefreshResult) Reset()
func (*RefreshResult) String ¶
func (x *RefreshResult) String() string
type Reply ¶
type Reply struct { Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` Result []byte `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*Reply) ProtoReflect ¶
func (x *Reply) ProtoReflect() protoreflect.Message
type RevokeTokenRequest ¶
type RevokeTokenRequest struct { ExpireAt int64 `protobuf:"varint,1,opt,name=expire_at,json=expireAt,proto3" json:"expire_at,omitempty"` Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"` // contains filtered or unexported fields }
func (*RevokeTokenRequest) Descriptor
deprecated
func (*RevokeTokenRequest) Descriptor() ([]byte, []int)
Deprecated: Use RevokeTokenRequest.ProtoReflect.Descriptor instead.
func (*RevokeTokenRequest) GetExpireAt ¶
func (x *RevokeTokenRequest) GetExpireAt() int64
func (*RevokeTokenRequest) GetUid ¶
func (x *RevokeTokenRequest) GetUid() string
func (*RevokeTokenRequest) ProtoMessage ¶
func (*RevokeTokenRequest) ProtoMessage()
func (*RevokeTokenRequest) ProtoReflect ¶
func (x *RevokeTokenRequest) ProtoReflect() protoreflect.Message
func (*RevokeTokenRequest) Reset ¶
func (x *RevokeTokenRequest) Reset()
func (*RevokeTokenRequest) String ¶
func (x *RevokeTokenRequest) String() string
type RevokeTokenResponse ¶
type RevokeTokenResponse struct { Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Result *RevokeTokenResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*RevokeTokenResponse) Descriptor
deprecated
func (*RevokeTokenResponse) Descriptor() ([]byte, []int)
Deprecated: Use RevokeTokenResponse.ProtoReflect.Descriptor instead.
func (*RevokeTokenResponse) GetError ¶
func (x *RevokeTokenResponse) GetError() *Error
func (*RevokeTokenResponse) GetResult ¶
func (x *RevokeTokenResponse) GetResult() *RevokeTokenResult
func (*RevokeTokenResponse) ProtoMessage ¶
func (*RevokeTokenResponse) ProtoMessage()
func (*RevokeTokenResponse) ProtoReflect ¶
func (x *RevokeTokenResponse) ProtoReflect() protoreflect.Message
func (*RevokeTokenResponse) Reset ¶
func (x *RevokeTokenResponse) Reset()
func (*RevokeTokenResponse) String ¶
func (x *RevokeTokenResponse) String() string
type RevokeTokenResult ¶
type RevokeTokenResult struct {
// contains filtered or unexported fields
}
func (*RevokeTokenResult) Descriptor
deprecated
func (*RevokeTokenResult) Descriptor() ([]byte, []int)
Deprecated: Use RevokeTokenResult.ProtoReflect.Descriptor instead.
func (*RevokeTokenResult) ProtoMessage ¶
func (*RevokeTokenResult) ProtoMessage()
func (*RevokeTokenResult) ProtoReflect ¶
func (x *RevokeTokenResult) ProtoReflect() protoreflect.Message
func (*RevokeTokenResult) Reset ¶
func (x *RevokeTokenResult) Reset()
func (*RevokeTokenResult) String ¶
func (x *RevokeTokenResult) String() string
type StreamPosition ¶
type StreamPosition struct { Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"` Epoch string `protobuf:"bytes,2,opt,name=epoch,proto3" json:"epoch,omitempty"` // contains filtered or unexported fields }
func (*StreamPosition) Descriptor
deprecated
func (*StreamPosition) Descriptor() ([]byte, []int)
Deprecated: Use StreamPosition.ProtoReflect.Descriptor instead.
func (*StreamPosition) GetEpoch ¶
func (x *StreamPosition) GetEpoch() string
func (*StreamPosition) GetOffset ¶
func (x *StreamPosition) GetOffset() uint64
func (*StreamPosition) ProtoMessage ¶
func (*StreamPosition) ProtoMessage()
func (*StreamPosition) ProtoReflect ¶
func (x *StreamPosition) ProtoReflect() protoreflect.Message
func (*StreamPosition) Reset ¶
func (x *StreamPosition) Reset()
func (*StreamPosition) String ¶
func (x *StreamPosition) String() string
type SubscribeOptionOverride ¶
type SubscribeOptionOverride struct { Presence *BoolValue `protobuf:"bytes,1,opt,name=presence,proto3" json:"presence,omitempty"` JoinLeave *BoolValue `protobuf:"bytes,2,opt,name=join_leave,json=joinLeave,proto3" json:"join_leave,omitempty"` ForceRecovery *BoolValue `protobuf:"bytes,3,opt,name=force_recovery,json=forceRecovery,proto3" json:"force_recovery,omitempty"` ForcePositioning *BoolValue `protobuf:"bytes,4,opt,name=force_positioning,json=forcePositioning,proto3" json:"force_positioning,omitempty"` ForcePushJoinLeave *BoolValue `protobuf:"bytes,5,opt,name=force_push_join_leave,json=forcePushJoinLeave,proto3" json:"force_push_join_leave,omitempty"` // contains filtered or unexported fields }
func (*SubscribeOptionOverride) Descriptor
deprecated
func (*SubscribeOptionOverride) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeOptionOverride.ProtoReflect.Descriptor instead.
func (*SubscribeOptionOverride) GetForcePositioning ¶
func (x *SubscribeOptionOverride) GetForcePositioning() *BoolValue
func (*SubscribeOptionOverride) GetForcePushJoinLeave ¶
func (x *SubscribeOptionOverride) GetForcePushJoinLeave() *BoolValue
func (*SubscribeOptionOverride) GetForceRecovery ¶
func (x *SubscribeOptionOverride) GetForceRecovery() *BoolValue
func (*SubscribeOptionOverride) GetJoinLeave ¶
func (x *SubscribeOptionOverride) GetJoinLeave() *BoolValue
func (*SubscribeOptionOverride) GetPresence ¶
func (x *SubscribeOptionOverride) GetPresence() *BoolValue
func (*SubscribeOptionOverride) ProtoMessage ¶
func (*SubscribeOptionOverride) ProtoMessage()
func (*SubscribeOptionOverride) ProtoReflect ¶
func (x *SubscribeOptionOverride) ProtoReflect() protoreflect.Message
func (*SubscribeOptionOverride) Reset ¶
func (x *SubscribeOptionOverride) Reset()
func (*SubscribeOptionOverride) String ¶
func (x *SubscribeOptionOverride) String() string
type SubscribeRequest ¶
type SubscribeRequest struct { Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"` User string `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"` ExpireAt int64 `protobuf:"varint,3,opt,name=expire_at,json=expireAt,proto3" json:"expire_at,omitempty"` Info []byte `protobuf:"bytes,4,opt,name=info,proto3" json:"info,omitempty"` B64Info string `protobuf:"bytes,5,opt,name=b64info,proto3" json:"b64info,omitempty"` Client string `protobuf:"bytes,6,opt,name=client,proto3" json:"client,omitempty"` Data []byte `protobuf:"bytes,7,opt,name=data,proto3" json:"data,omitempty"` B64Data string `protobuf:"bytes,8,opt,name=b64data,proto3" json:"b64data,omitempty"` RecoverSince *StreamPosition `protobuf:"bytes,9,opt,name=recover_since,json=recoverSince,proto3" json:"recover_since,omitempty"` Override *SubscribeOptionOverride `protobuf:"bytes,10,opt,name=override,proto3" json:"override,omitempty"` Session string `protobuf:"bytes,11,opt,name=session,proto3" json:"session,omitempty"` // contains filtered or unexported fields }
func (*SubscribeRequest) Descriptor
deprecated
func (*SubscribeRequest) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.
func (*SubscribeRequest) GetB64Data ¶
func (x *SubscribeRequest) GetB64Data() string
func (*SubscribeRequest) GetB64Info ¶
func (x *SubscribeRequest) GetB64Info() string
func (*SubscribeRequest) GetChannel ¶
func (x *SubscribeRequest) GetChannel() string
func (*SubscribeRequest) GetClient ¶
func (x *SubscribeRequest) GetClient() string
func (*SubscribeRequest) GetData ¶
func (x *SubscribeRequest) GetData() []byte
func (*SubscribeRequest) GetExpireAt ¶
func (x *SubscribeRequest) GetExpireAt() int64
func (*SubscribeRequest) GetInfo ¶
func (x *SubscribeRequest) GetInfo() []byte
func (*SubscribeRequest) GetOverride ¶
func (x *SubscribeRequest) GetOverride() *SubscribeOptionOverride
func (*SubscribeRequest) GetRecoverSince ¶
func (x *SubscribeRequest) GetRecoverSince() *StreamPosition
func (*SubscribeRequest) GetSession ¶
func (x *SubscribeRequest) GetSession() string
func (*SubscribeRequest) GetUser ¶
func (x *SubscribeRequest) GetUser() string
func (*SubscribeRequest) ProtoMessage ¶
func (*SubscribeRequest) ProtoMessage()
func (*SubscribeRequest) ProtoReflect ¶
func (x *SubscribeRequest) ProtoReflect() protoreflect.Message
func (*SubscribeRequest) Reset ¶
func (x *SubscribeRequest) Reset()
func (*SubscribeRequest) String ¶
func (x *SubscribeRequest) String() string
type SubscribeResponse ¶
type SubscribeResponse struct { Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Result *SubscribeResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*SubscribeResponse) Descriptor
deprecated
func (*SubscribeResponse) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeResponse.ProtoReflect.Descriptor instead.
func (*SubscribeResponse) GetError ¶
func (x *SubscribeResponse) GetError() *Error
func (*SubscribeResponse) GetResult ¶
func (x *SubscribeResponse) GetResult() *SubscribeResult
func (*SubscribeResponse) ProtoMessage ¶
func (*SubscribeResponse) ProtoMessage()
func (*SubscribeResponse) ProtoReflect ¶
func (x *SubscribeResponse) ProtoReflect() protoreflect.Message
func (*SubscribeResponse) Reset ¶
func (x *SubscribeResponse) Reset()
func (*SubscribeResponse) String ¶
func (x *SubscribeResponse) String() string
type SubscribeResult ¶
type SubscribeResult struct {
// contains filtered or unexported fields
}
func (*SubscribeResult) Descriptor
deprecated
func (*SubscribeResult) Descriptor() ([]byte, []int)
Deprecated: Use SubscribeResult.ProtoReflect.Descriptor instead.
func (*SubscribeResult) ProtoMessage ¶
func (*SubscribeResult) ProtoMessage()
func (*SubscribeResult) ProtoReflect ¶
func (x *SubscribeResult) ProtoReflect() protoreflect.Message
func (*SubscribeResult) Reset ¶
func (x *SubscribeResult) Reset()
func (*SubscribeResult) String ¶
func (x *SubscribeResult) String() string
type SubscriptionTokenInfo ¶
type SubscriptionTokenInfo struct { Uid string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"` IssuedAt int64 `protobuf:"varint,2,opt,name=issued_at,json=issuedAt,proto3" json:"issued_at,omitempty"` // contains filtered or unexported fields }
func (*SubscriptionTokenInfo) Descriptor
deprecated
func (*SubscriptionTokenInfo) Descriptor() ([]byte, []int)
Deprecated: Use SubscriptionTokenInfo.ProtoReflect.Descriptor instead.
func (*SubscriptionTokenInfo) GetIssuedAt ¶
func (x *SubscriptionTokenInfo) GetIssuedAt() int64
func (*SubscriptionTokenInfo) GetUid ¶
func (x *SubscriptionTokenInfo) GetUid() string
func (*SubscriptionTokenInfo) ProtoMessage ¶
func (*SubscriptionTokenInfo) ProtoMessage()
func (*SubscriptionTokenInfo) ProtoReflect ¶
func (x *SubscriptionTokenInfo) ProtoReflect() protoreflect.Message
func (*SubscriptionTokenInfo) Reset ¶
func (x *SubscriptionTokenInfo) Reset()
func (*SubscriptionTokenInfo) String ¶
func (x *SubscriptionTokenInfo) String() string
type UnblockUserRequest ¶
type UnblockUserRequest struct { User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` // contains filtered or unexported fields }
func (*UnblockUserRequest) Descriptor
deprecated
func (*UnblockUserRequest) Descriptor() ([]byte, []int)
Deprecated: Use UnblockUserRequest.ProtoReflect.Descriptor instead.
func (*UnblockUserRequest) GetUser ¶
func (x *UnblockUserRequest) GetUser() string
func (*UnblockUserRequest) ProtoMessage ¶
func (*UnblockUserRequest) ProtoMessage()
func (*UnblockUserRequest) ProtoReflect ¶
func (x *UnblockUserRequest) ProtoReflect() protoreflect.Message
func (*UnblockUserRequest) Reset ¶
func (x *UnblockUserRequest) Reset()
func (*UnblockUserRequest) String ¶
func (x *UnblockUserRequest) String() string
type UnblockUserResponse ¶
type UnblockUserResponse struct { Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Result *UnblockUserResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*UnblockUserResponse) Descriptor
deprecated
func (*UnblockUserResponse) Descriptor() ([]byte, []int)
Deprecated: Use UnblockUserResponse.ProtoReflect.Descriptor instead.
func (*UnblockUserResponse) GetError ¶
func (x *UnblockUserResponse) GetError() *Error
func (*UnblockUserResponse) GetResult ¶
func (x *UnblockUserResponse) GetResult() *UnblockUserResult
func (*UnblockUserResponse) ProtoMessage ¶
func (*UnblockUserResponse) ProtoMessage()
func (*UnblockUserResponse) ProtoReflect ¶
func (x *UnblockUserResponse) ProtoReflect() protoreflect.Message
func (*UnblockUserResponse) Reset ¶
func (x *UnblockUserResponse) Reset()
func (*UnblockUserResponse) String ¶
func (x *UnblockUserResponse) String() string
type UnblockUserResult ¶
type UnblockUserResult struct {
// contains filtered or unexported fields
}
func (*UnblockUserResult) Descriptor
deprecated
func (*UnblockUserResult) Descriptor() ([]byte, []int)
Deprecated: Use UnblockUserResult.ProtoReflect.Descriptor instead.
func (*UnblockUserResult) ProtoMessage ¶
func (*UnblockUserResult) ProtoMessage()
func (*UnblockUserResult) ProtoReflect ¶
func (x *UnblockUserResult) ProtoReflect() protoreflect.Message
func (*UnblockUserResult) Reset ¶
func (x *UnblockUserResult) Reset()
func (*UnblockUserResult) String ¶
func (x *UnblockUserResult) String() string
type UnsubscribeRequest ¶
type UnsubscribeRequest struct { Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"` User string `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"` Client string `protobuf:"bytes,3,opt,name=client,proto3" json:"client,omitempty"` Session string `protobuf:"bytes,4,opt,name=session,proto3" json:"session,omitempty"` // contains filtered or unexported fields }
func (*UnsubscribeRequest) Descriptor
deprecated
func (*UnsubscribeRequest) Descriptor() ([]byte, []int)
Deprecated: Use UnsubscribeRequest.ProtoReflect.Descriptor instead.
func (*UnsubscribeRequest) GetChannel ¶
func (x *UnsubscribeRequest) GetChannel() string
func (*UnsubscribeRequest) GetClient ¶
func (x *UnsubscribeRequest) GetClient() string
func (*UnsubscribeRequest) GetSession ¶
func (x *UnsubscribeRequest) GetSession() string
func (*UnsubscribeRequest) GetUser ¶
func (x *UnsubscribeRequest) GetUser() string
func (*UnsubscribeRequest) ProtoMessage ¶
func (*UnsubscribeRequest) ProtoMessage()
func (*UnsubscribeRequest) ProtoReflect ¶
func (x *UnsubscribeRequest) ProtoReflect() protoreflect.Message
func (*UnsubscribeRequest) Reset ¶
func (x *UnsubscribeRequest) Reset()
func (*UnsubscribeRequest) String ¶
func (x *UnsubscribeRequest) String() string
type UnsubscribeResponse ¶
type UnsubscribeResponse struct { Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Result *UnsubscribeResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*UnsubscribeResponse) Descriptor
deprecated
func (*UnsubscribeResponse) Descriptor() ([]byte, []int)
Deprecated: Use UnsubscribeResponse.ProtoReflect.Descriptor instead.
func (*UnsubscribeResponse) GetError ¶
func (x *UnsubscribeResponse) GetError() *Error
func (*UnsubscribeResponse) GetResult ¶
func (x *UnsubscribeResponse) GetResult() *UnsubscribeResult
func (*UnsubscribeResponse) ProtoMessage ¶
func (*UnsubscribeResponse) ProtoMessage()
func (*UnsubscribeResponse) ProtoReflect ¶
func (x *UnsubscribeResponse) ProtoReflect() protoreflect.Message
func (*UnsubscribeResponse) Reset ¶
func (x *UnsubscribeResponse) Reset()
func (*UnsubscribeResponse) String ¶
func (x *UnsubscribeResponse) String() string
type UnsubscribeResult ¶
type UnsubscribeResult struct {
// contains filtered or unexported fields
}
func (*UnsubscribeResult) Descriptor
deprecated
func (*UnsubscribeResult) Descriptor() ([]byte, []int)
Deprecated: Use UnsubscribeResult.ProtoReflect.Descriptor instead.
func (*UnsubscribeResult) ProtoMessage ¶
func (*UnsubscribeResult) ProtoMessage()
func (*UnsubscribeResult) ProtoReflect ¶
func (x *UnsubscribeResult) ProtoReflect() protoreflect.Message
func (*UnsubscribeResult) Reset ¶
func (x *UnsubscribeResult) Reset()
func (*UnsubscribeResult) String ¶
func (x *UnsubscribeResult) String() string
type UpdateUserStatusRequest ¶
type UpdateUserStatusRequest struct { Users []string `protobuf:"bytes,1,rep,name=users,proto3" json:"users,omitempty"` // contains filtered or unexported fields }
func (*UpdateUserStatusRequest) Descriptor
deprecated
func (*UpdateUserStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateUserStatusRequest.ProtoReflect.Descriptor instead.
func (*UpdateUserStatusRequest) GetUsers ¶
func (x *UpdateUserStatusRequest) GetUsers() []string
func (*UpdateUserStatusRequest) ProtoMessage ¶
func (*UpdateUserStatusRequest) ProtoMessage()
func (*UpdateUserStatusRequest) ProtoReflect ¶
func (x *UpdateUserStatusRequest) ProtoReflect() protoreflect.Message
func (*UpdateUserStatusRequest) Reset ¶
func (x *UpdateUserStatusRequest) Reset()
func (*UpdateUserStatusRequest) String ¶
func (x *UpdateUserStatusRequest) String() string
type UpdateUserStatusResponse ¶
type UpdateUserStatusResponse struct { Error *Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` Result *UpdateUserStatusResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*UpdateUserStatusResponse) Descriptor
deprecated
func (*UpdateUserStatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateUserStatusResponse.ProtoReflect.Descriptor instead.
func (*UpdateUserStatusResponse) GetError ¶
func (x *UpdateUserStatusResponse) GetError() *Error
func (*UpdateUserStatusResponse) GetResult ¶
func (x *UpdateUserStatusResponse) GetResult() *UpdateUserStatusResult
func (*UpdateUserStatusResponse) ProtoMessage ¶
func (*UpdateUserStatusResponse) ProtoMessage()
func (*UpdateUserStatusResponse) ProtoReflect ¶
func (x *UpdateUserStatusResponse) ProtoReflect() protoreflect.Message
func (*UpdateUserStatusResponse) Reset ¶
func (x *UpdateUserStatusResponse) Reset()
func (*UpdateUserStatusResponse) String ¶
func (x *UpdateUserStatusResponse) String() string
type UpdateUserStatusResult ¶
type UpdateUserStatusResult struct {
// contains filtered or unexported fields
}
func (*UpdateUserStatusResult) Descriptor
deprecated
func (*UpdateUserStatusResult) Descriptor() ([]byte, []int)
Deprecated: Use UpdateUserStatusResult.ProtoReflect.Descriptor instead.
func (*UpdateUserStatusResult) ProtoMessage ¶
func (*UpdateUserStatusResult) ProtoMessage()
func (*UpdateUserStatusResult) ProtoReflect ¶
func (x *UpdateUserStatusResult) ProtoReflect() protoreflect.Message
func (*UpdateUserStatusResult) Reset ¶
func (x *UpdateUserStatusResult) Reset()
func (*UpdateUserStatusResult) String ¶
func (x *UpdateUserStatusResult) String() string
type UserStatus ¶
type UserStatus struct { User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` Active int64 `protobuf:"varint,2,opt,name=active,proto3" json:"active,omitempty"` Online int64 `protobuf:"varint,3,opt,name=online,proto3" json:"online,omitempty"` // contains filtered or unexported fields }
func (*UserStatus) Descriptor
deprecated
func (*UserStatus) Descriptor() ([]byte, []int)
Deprecated: Use UserStatus.ProtoReflect.Descriptor instead.
func (*UserStatus) GetActive ¶
func (x *UserStatus) GetActive() int64
func (*UserStatus) GetOnline ¶
func (x *UserStatus) GetOnline() int64
func (*UserStatus) GetUser ¶
func (x *UserStatus) GetUser() string
func (*UserStatus) ProtoMessage ¶
func (*UserStatus) ProtoMessage()
func (*UserStatus) ProtoReflect ¶
func (x *UserStatus) ProtoReflect() protoreflect.Message
func (*UserStatus) Reset ¶
func (x *UserStatus) Reset()
func (*UserStatus) String ¶
func (x *UserStatus) String() string