v1

package
v1.30.0-20230317081204... Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: unknown License: MIT Imports: 4 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

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

Enum value maps for Command_MethodType.

View Source 
var 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) Descriptor deprecated 

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

Deprecated: Use BoolValue.ProtoReflect.Descriptor instead.

func (*BoolValue) GetValue 

func (x *BoolValue) GetValue() bool

func (*BoolValue) ProtoMessage 

func (*BoolValue) ProtoMessage()

func (*BoolValue) ProtoReflect 

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

func (*BoolValue) Reset 

func (x *BoolValue) Reset()

func (*BoolValue) String 

func (x *BoolValue) String() string

type BroadcastRequest 

type BroadcastRequest struct {
	Channels    []string          `protobuf:"bytes,1,rep,name=channels,proto3" json:"channels,omitempty"`
	Data        []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) Descriptor deprecated 

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

Deprecated: Use Command.ProtoReflect.Descriptor instead.

func (*Command) GetId 

func (x *Command) GetId() uint32

func (*Command) GetMethod 

func (x *Command) GetMethod() Command_MethodType

func (*Command) GetParams 

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

func (*Command) ProtoMessage 

func (*Command) ProtoMessage()

func (*Command) ProtoReflect 

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

func (*Command) Reset 

func (x *Command) Reset()

func (*Command) String 

func (x *Command) String() string

type 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) Descriptor deprecated 

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

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetCode 

func (x *Error) GetCode() uint32

func (*Error) GetMessage 

func (x *Error) GetMessage() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect 

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

func (*Error) Reset 

func (x *Error) Reset()

func (*Error) String 

func (x *Error) String() string

type GetUserStatusRequest 

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

func (*GetUserStatusRequest) Descriptor deprecated 

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

Deprecated: Use GetUserStatusRequest.ProtoReflect.Descriptor instead.

func (*GetUserStatusRequest) GetUsers 

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

func (*GetUserStatusRequest) ProtoMessage 

func (*GetUserStatusRequest) ProtoMessage()

func (*GetUserStatusRequest) ProtoReflect 

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

func (*GetUserStatusRequest) Reset 

func (x *GetUserStatusRequest) Reset()

func (*GetUserStatusRequest) String 

func (x *GetUserStatusRequest) String() string

type GetUserStatusResponse 

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

func (*GetUserStatusResponse) Descriptor deprecated 

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

Deprecated: Use GetUserStatusResponse.ProtoReflect.Descriptor instead.

func (*GetUserStatusResponse) GetError 

func (x *GetUserStatusResponse) GetError() *Error

func (*GetUserStatusResponse) GetResult 

func (x *GetUserStatusResponse) GetResult() *GetUserStatusResult

func (*GetUserStatusResponse) ProtoMessage 

func (*GetUserStatusResponse) ProtoMessage()

func (*GetUserStatusResponse) ProtoReflect 

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

func (*GetUserStatusResponse) Reset 

func (x *GetUserStatusResponse) Reset()

func (*GetUserStatusResponse) String 

func (x *GetUserStatusResponse) String() string

type GetUserStatusResult 

type GetUserStatusResult struct {
	Statuses []*UserStatus `protobuf:"bytes,1,rep,name=statuses,proto3" json:"statuses,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) Descriptor deprecated 

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

Deprecated: Use Metrics.ProtoReflect.Descriptor instead.

func (*Metrics) GetInterval 

func (x *Metrics) GetInterval() float64

func (*Metrics) GetItems 

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

func (*Metrics) ProtoMessage 

func (*Metrics) ProtoMessage()

func (*Metrics) ProtoReflect 

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

func (*Metrics) Reset 

func (x *Metrics) Reset()

func (*Metrics) String 

func (x *Metrics) String() string

type NodeResult 

type NodeResult struct {
	Uid         string   `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,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) Descriptor deprecated 

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

Deprecated: Use Process.ProtoReflect.Descriptor instead.

func (*Process) GetCpu 

func (x *Process) GetCpu() float64

func (*Process) GetRss 

func (x *Process) GetRss() int64

func (*Process) ProtoMessage 

func (*Process) ProtoMessage()

func (*Process) ProtoReflect 

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

func (*Process) Reset 

func (x *Process) Reset()

func (*Process) String 

func (x *Process) String() string

type Publication 

type Publication struct {
	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) Descriptor deprecated 

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

Deprecated: Use RPCResult.ProtoReflect.Descriptor instead.

func (*RPCResult) GetData 

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

func (*RPCResult) ProtoMessage 

func (*RPCResult) ProtoMessage()

func (*RPCResult) ProtoReflect 

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

func (*RPCResult) Reset 

func (x *RPCResult) Reset()

func (*RPCResult) String 

func (x *RPCResult) String() string

type 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) Descriptor deprecated 

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

Deprecated: Use Reply.ProtoReflect.Descriptor instead.

func (*Reply) GetError 

func (x *Reply) GetError() *Error

func (*Reply) GetId 

func (x *Reply) GetId() uint32

func (*Reply) GetResult 

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

func (*Reply) ProtoMessage 

func (*Reply) ProtoMessage()

func (*Reply) ProtoReflect 

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

func (*Reply) Reset 

func (x *Reply) Reset()

func (*Reply) String 

func (x *Reply) String() string

type 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.