apiproto

package
v4.1.5 Latest Latest
Warning

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

 Go to latest Published: Jun 24, 2023 License: Apache-2.0 Imports: 14 Imported by: 0

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",
		22: "DEVICE_REGISTER",
		23: "DEVICE_UPDATE",
		24: "DEVICE_REMOVE",
		25: "DEVICE_LIST",
		26: "DEVICE_TOPIC_LIST",
		27: "DEVICE_TOPIC_UPDATE",
		28: "USER_TOPIC_LIST",
		29: "USER_TOPIC_UPDATE",
		30: "SEND_PUSH_NOTIFICATION",
		31: "UPDATE_PUSH_STATUS",
	}
	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,
		"DEVICE_REGISTER":        22,
		"DEVICE_UPDATE":          23,
		"DEVICE_REMOVE":          24,
		"DEVICE_LIST":            25,
		"DEVICE_TOPIC_LIST":      26,
		"DEVICE_TOPIC_UPDATE":    27,
		"USER_TOPIC_LIST":        28,
		"USER_TOPIC_UPDATE":      29,
		"SEND_PUSH_NOTIFICATION": 30,
		"UPDATE_PUSH_STATUS":     31,
	}
)

Enum value maps for Command_MethodType.

View Source 
var (
	// ErrorInternal means server error, if returned this is a signal
	// that something went wrong with Centrifugo itself.
	ErrorInternal = &Error{
		Code:    100,
		Message: "internal server error",
	}
	// ErrorUnknownChannel means that namespace in channel name does not exist.
	ErrorUnknownChannel = &Error{
		Code:    102,
		Message: "unknown channel",
	}
	// ErrorMethodNotFound means that method sent in command does not exist.
	ErrorMethodNotFound = &Error{
		Code:    104,
		Message: "method not found",
	}
	// ErrorBadRequest says that Centrifugo can not parse received data
	// because it is malformed.
	ErrorBadRequest = &Error{
		Code:    107,
		Message: "bad request",
	}
	// ErrorNotAvailable means that resource is not enabled.
	ErrorNotAvailable = &Error{
		Code:    108,
		Message: "not available",
	}
	// ErrorUnrecoverablePosition means that stream does not contain required
	// range of publications to fulfill a history query. This can be happen to
	// expiration, size limitation or due to wrong epoch.
	ErrorUnrecoverablePosition = &Error{
		Code:    112,
		Message: "unrecoverable position",
	}
)

Here we define errors that can be exposed in server API replies.

View Source 
var CentrifugoApi_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "centrifugal.centrifugo.api.CentrifugoApi",
	HandlerType: (*CentrifugoApiServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Batch",
			Handler:    _CentrifugoApi_Batch_Handler,
		},
		{
			MethodName: "Publish",
			Handler:    _CentrifugoApi_Publish_Handler,
		},
		{
			MethodName: "Broadcast",
			Handler:    _CentrifugoApi_Broadcast_Handler,
		},
		{
			MethodName: "Subscribe",
			Handler:    _CentrifugoApi_Subscribe_Handler,
		},
		{
			MethodName: "Unsubscribe",
			Handler:    _CentrifugoApi_Unsubscribe_Handler,
		},
		{
			MethodName: "Disconnect",
			Handler:    _CentrifugoApi_Disconnect_Handler,
		},
		{
			MethodName: "Presence",
			Handler:    _CentrifugoApi_Presence_Handler,
		},
		{
			MethodName: "PresenceStats",
			Handler:    _CentrifugoApi_PresenceStats_Handler,
		},
		{
			MethodName: "History",
			Handler:    _CentrifugoApi_History_Handler,
		},
		{
			MethodName: "HistoryRemove",
			Handler:    _CentrifugoApi_HistoryRemove_Handler,
		},
		{
			MethodName: "Info",
			Handler:    _CentrifugoApi_Info_Handler,
		},
		{
			MethodName: "RPC",
			Handler:    _CentrifugoApi_RPC_Handler,
		},
		{
			MethodName: "Refresh",
			Handler:    _CentrifugoApi_Refresh_Handler,
		},
		{
			MethodName: "Channels",
			Handler:    _CentrifugoApi_Channels_Handler,
		},
		{
			MethodName: "Connections",
			Handler:    _CentrifugoApi_Connections_Handler,
		},
		{
			MethodName: "UpdateUserStatus",
			Handler:    _CentrifugoApi_UpdateUserStatus_Handler,
		},
		{
			MethodName: "GetUserStatus",
			Handler:    _CentrifugoApi_GetUserStatus_Handler,
		},
		{
			MethodName: "DeleteUserStatus",
			Handler:    _CentrifugoApi_DeleteUserStatus_Handler,
		},
		{
			MethodName: "BlockUser",
			Handler:    _CentrifugoApi_BlockUser_Handler,
		},
		{
			MethodName: "UnblockUser",
			Handler:    _CentrifugoApi_UnblockUser_Handler,
		},
		{
			MethodName: "RevokeToken",
			Handler:    _CentrifugoApi_RevokeToken_Handler,
		},
		{
			MethodName: "InvalidateUserTokens",
			Handler:    _CentrifugoApi_InvalidateUserTokens_Handler,
		},
		{
			MethodName: "DeviceRegister",
			Handler:    _CentrifugoApi_DeviceRegister_Handler,
		},
		{
			MethodName: "DeviceUpdate",
			Handler:    _CentrifugoApi_DeviceUpdate_Handler,
		},
		{
			MethodName: "DeviceRemove",
			Handler:    _CentrifugoApi_DeviceRemove_Handler,
		},
		{
			MethodName: "DeviceList",
			Handler:    _CentrifugoApi_DeviceList_Handler,
		},
		{
			MethodName: "DeviceTopicList",
			Handler:    _CentrifugoApi_DeviceTopicList_Handler,
		},
		{
			MethodName: "DeviceTopicUpdate",
			Handler:    _CentrifugoApi_DeviceTopicUpdate_Handler,
		},
		{
			MethodName: "UserTopicList",
			Handler:    _CentrifugoApi_UserTopicList_Handler,
		},
		{
			MethodName: "UserTopicUpdate",
			Handler:    _CentrifugoApi_UserTopicUpdate_Handler,
		},
		{
			MethodName: "SendPushNotification",
			Handler:    _CentrifugoApi_SendPushNotification_Handler,
		},
		{
			MethodName: "UpdatePushStatus",
			Handler:    _CentrifugoApi_UpdatePushStatus_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api.proto",
}

CentrifugoApi_ServiceDesc is the grpc.ServiceDesc for CentrifugoApi service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_api_proto protoreflect.FileDescriptor

Functions

func PutCommandDecoder 

func PutCommandDecoder(d CommandDecoder)

PutCommandDecoder ...

func PutParamsDecoder 

func PutParamsDecoder(_ RequestDecoder)

PutParamsDecoder ...

func PutReplyEncoder 

func PutReplyEncoder(e ReplyEncoder)

PutReplyEncoder ...

func PutResultEncoder 

func PutResultEncoder(_ ResultEncoder)

PutResultEncoder ...

func RegisterCentrifugoApiServer 

func RegisterCentrifugoApiServer(s grpc.ServiceRegistrar, srv CentrifugoApiServer)

Types

type ApnsPushNotification added in v4.1.3 

type ApnsPushNotification struct {
	Headers map[string]string `` /* 155-byte string literal not displayed */
	Payload Raw               `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*ApnsPushNotification) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use ApnsPushNotification.ProtoReflect.Descriptor instead.

func (*ApnsPushNotification) GetHeaders added in v4.1.3 

func (x *ApnsPushNotification) GetHeaders() map[string]string

func (*ApnsPushNotification) GetPayload added in v4.1.3 

func (x *ApnsPushNotification) GetPayload() []byte

func (*ApnsPushNotification) ProtoMessage added in v4.1.3 

func (*ApnsPushNotification) ProtoMessage()

func (*ApnsPushNotification) ProtoReflect added in v4.1.3 

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

func (*ApnsPushNotification) Reset added in v4.1.3 

func (x *ApnsPushNotification) Reset()

func (*ApnsPushNotification) String added in v4.1.3 

func (x *ApnsPushNotification) String() string

type BatchRequest added in v4.1.3 

type BatchRequest struct {
	Commands []*Command `protobuf:"bytes,1,rep,name=commands,proto3" json:"commands,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchRequest) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use BatchRequest.ProtoReflect.Descriptor instead.

func (*BatchRequest) GetCommands added in v4.1.3 

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

func (*BatchRequest) ProtoMessage added in v4.1.3 

func (*BatchRequest) ProtoMessage()

func (*BatchRequest) ProtoReflect added in v4.1.3 

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

func (*BatchRequest) Reset added in v4.1.3 

func (x *BatchRequest) Reset()

func (*BatchRequest) String added in v4.1.3 

func (x *BatchRequest) String() string

type BatchResponse added in v4.1.3 

type BatchResponse struct {
	Replies []*Reply `protobuf:"bytes,1,rep,name=replies,proto3" json:"replies,omitempty"`
	// contains filtered or unexported fields
}

func (*BatchResponse) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use BatchResponse.ProtoReflect.Descriptor instead.

func (*BatchResponse) GetReplies added in v4.1.3 

func (x *BatchResponse) GetReplies() []*Reply

func (*BatchResponse) ProtoMessage added in v4.1.3 

func (*BatchResponse) ProtoMessage()

func (*BatchResponse) ProtoReflect added in v4.1.3 

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

func (*BatchResponse) Reset added in v4.1.3 

func (x *BatchResponse) Reset()

func (*BatchResponse) String added in v4.1.3 

func (x *BatchResponse) String() string

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        Raw               `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 CentrifugoApiClient 

type CentrifugoApiClient interface {
	Batch(ctx context.Context, in *BatchRequest, opts ...grpc.CallOption) (*BatchResponse, error)
	Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error)
	Broadcast(ctx context.Context, in *BroadcastRequest, opts ...grpc.CallOption) (*BroadcastResponse, error)
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (*SubscribeResponse, error)
	Unsubscribe(ctx context.Context, in *UnsubscribeRequest, opts ...grpc.CallOption) (*UnsubscribeResponse, error)
	Disconnect(ctx context.Context, in *DisconnectRequest, opts ...grpc.CallOption) (*DisconnectResponse, error)
	Presence(ctx context.Context, in *PresenceRequest, opts ...grpc.CallOption) (*PresenceResponse, error)
	PresenceStats(ctx context.Context, in *PresenceStatsRequest, opts ...grpc.CallOption) (*PresenceStatsResponse, error)
	History(ctx context.Context, in *HistoryRequest, opts ...grpc.CallOption) (*HistoryResponse, error)
	HistoryRemove(ctx context.Context, in *HistoryRemoveRequest, opts ...grpc.CallOption) (*HistoryRemoveResponse, error)
	Info(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error)
	RPC(ctx context.Context, in *RPCRequest, opts ...grpc.CallOption) (*RPCResponse, error)
	Refresh(ctx context.Context, in *RefreshRequest, opts ...grpc.CallOption) (*RefreshResponse, error)
	Channels(ctx context.Context, in *ChannelsRequest, opts ...grpc.CallOption) (*ChannelsResponse, error)
	Connections(ctx context.Context, in *ConnectionsRequest, opts ...grpc.CallOption) (*ConnectionsResponse, error)
	UpdateUserStatus(ctx context.Context, in *UpdateUserStatusRequest, opts ...grpc.CallOption) (*UpdateUserStatusResponse, error)
	GetUserStatus(ctx context.Context, in *GetUserStatusRequest, opts ...grpc.CallOption) (*GetUserStatusResponse, error)
	DeleteUserStatus(ctx context.Context, in *DeleteUserStatusRequest, opts ...grpc.CallOption) (*DeleteUserStatusResponse, error)
	BlockUser(ctx context.Context, in *BlockUserRequest, opts ...grpc.CallOption) (*BlockUserResponse, error)
	UnblockUser(ctx context.Context, in *UnblockUserRequest, opts ...grpc.CallOption) (*UnblockUserResponse, error)
	RevokeToken(ctx context.Context, in *RevokeTokenRequest, opts ...grpc.CallOption) (*RevokeTokenResponse, error)
	InvalidateUserTokens(ctx context.Context, in *InvalidateUserTokensRequest, opts ...grpc.CallOption) (*InvalidateUserTokensResponse, error)
	DeviceRegister(ctx context.Context, in *DeviceRegisterRequest, opts ...grpc.CallOption) (*DeviceRegisterResponse, error)
	DeviceUpdate(ctx context.Context, in *DeviceUpdateRequest, opts ...grpc.CallOption) (*DeviceUpdateResponse, error)
	DeviceRemove(ctx context.Context, in *DeviceRemoveRequest, opts ...grpc.CallOption) (*DeviceRemoveResponse, error)
	DeviceList(ctx context.Context, in *DeviceListRequest, opts ...grpc.CallOption) (*DeviceListResponse, error)
	DeviceTopicList(ctx context.Context, in *DeviceTopicListRequest, opts ...grpc.CallOption) (*DeviceTopicListResponse, error)
	DeviceTopicUpdate(ctx context.Context, in *DeviceTopicUpdateRequest, opts ...grpc.CallOption) (*DeviceTopicUpdateResponse, error)
	UserTopicList(ctx context.Context, in *UserTopicListRequest, opts ...grpc.CallOption) (*UserTopicListResponse, error)
	UserTopicUpdate(ctx context.Context, in *UserTopicUpdateRequest, opts ...grpc.CallOption) (*UserTopicUpdateResponse, error)
	SendPushNotification(ctx context.Context, in *SendPushNotificationRequest, opts ...grpc.CallOption) (*SendPushNotificationResponse, error)
	UpdatePushStatus(ctx context.Context, in *UpdatePushStatusRequest, opts ...grpc.CallOption) (*UpdatePushStatusResponse, error)
}

CentrifugoApiClient is the client API for CentrifugoApi service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewCentrifugoApiClient 

func NewCentrifugoApiClient(cc grpc.ClientConnInterface) CentrifugoApiClient

type CentrifugoApiServer 

type CentrifugoApiServer interface {
	Batch(context.Context, *BatchRequest) (*BatchResponse, error)
	Publish(context.Context, *PublishRequest) (*PublishResponse, error)
	Broadcast(context.Context, *BroadcastRequest) (*BroadcastResponse, error)
	Subscribe(context.Context, *SubscribeRequest) (*SubscribeResponse, error)
	Unsubscribe(context.Context, *UnsubscribeRequest) (*UnsubscribeResponse, error)
	Disconnect(context.Context, *DisconnectRequest) (*DisconnectResponse, error)
	Presence(context.Context, *PresenceRequest) (*PresenceResponse, error)
	PresenceStats(context.Context, *PresenceStatsRequest) (*PresenceStatsResponse, error)
	History(context.Context, *HistoryRequest) (*HistoryResponse, error)
	HistoryRemove(context.Context, *HistoryRemoveRequest) (*HistoryRemoveResponse, error)
	Info(context.Context, *InfoRequest) (*InfoResponse, error)
	RPC(context.Context, *RPCRequest) (*RPCResponse, error)
	Refresh(context.Context, *RefreshRequest) (*RefreshResponse, error)
	Channels(context.Context, *ChannelsRequest) (*ChannelsResponse, error)
	Connections(context.Context, *ConnectionsRequest) (*ConnectionsResponse, error)
	UpdateUserStatus(context.Context, *UpdateUserStatusRequest) (*UpdateUserStatusResponse, error)
	GetUserStatus(context.Context, *GetUserStatusRequest) (*GetUserStatusResponse, error)
	DeleteUserStatus(context.Context, *DeleteUserStatusRequest) (*DeleteUserStatusResponse, error)
	BlockUser(context.Context, *BlockUserRequest) (*BlockUserResponse, error)
	UnblockUser(context.Context, *UnblockUserRequest) (*UnblockUserResponse, error)
	RevokeToken(context.Context, *RevokeTokenRequest) (*RevokeTokenResponse, error)
	InvalidateUserTokens(context.Context, *InvalidateUserTokensRequest) (*InvalidateUserTokensResponse, error)
	DeviceRegister(context.Context, *DeviceRegisterRequest) (*DeviceRegisterResponse, error)
	DeviceUpdate(context.Context, *DeviceUpdateRequest) (*DeviceUpdateResponse, error)
	DeviceRemove(context.Context, *DeviceRemoveRequest) (*DeviceRemoveResponse, error)
	DeviceList(context.Context, *DeviceListRequest) (*DeviceListResponse, error)
	DeviceTopicList(context.Context, *DeviceTopicListRequest) (*DeviceTopicListResponse, error)
	DeviceTopicUpdate(context.Context, *DeviceTopicUpdateRequest) (*DeviceTopicUpdateResponse, error)
	UserTopicList(context.Context, *UserTopicListRequest) (*UserTopicListResponse, error)
	UserTopicUpdate(context.Context, *UserTopicUpdateRequest) (*UserTopicUpdateResponse, error)
	SendPushNotification(context.Context, *SendPushNotificationRequest) (*SendPushNotificationResponse, error)
	UpdatePushStatus(context.Context, *UpdatePushStatusRequest) (*UpdatePushStatusResponse, error)
	// contains filtered or unexported methods
}

CentrifugoApiServer is the server API for CentrifugoApi service. All implementations must embed UnimplementedCentrifugoApiServer for forward compatibility

type ChannelContext added in v4.0.1 

type ChannelContext struct {
	Source uint32 `protobuf:"varint,1,opt,name=source,proto3" json:"source,omitempty"`
	// contains filtered or unexported fields
}

func (*ChannelContext) Descriptor deprecated added in v4.0.1 

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

Deprecated: Use ChannelContext.ProtoReflect.Descriptor instead.

func (*ChannelContext) GetSource added in v4.0.1 

func (x *ChannelContext) GetSource() uint32

func (*ChannelContext) ProtoMessage added in v4.0.1 

func (*ChannelContext) ProtoMessage()

func (*ChannelContext) ProtoReflect added in v4.0.1 

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

func (*ChannelContext) Reset added in v4.0.1 

func (x *ChannelContext) Reset()

func (*ChannelContext) String added in v4.0.1 

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 `` /* 147-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"`
	Client   string `protobuf:"bytes,2,opt,name=client,proto3" json:"client"`
	ConnInfo Raw    `protobuf:"bytes,3,opt,name=conn_info,json=connInfo,proto3" json:"conn_info,omitempty"`
	ChanInfo Raw    `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               Raw                          `protobuf:"bytes,3,opt,name=params,proto3" json:"params,omitempty"`
	Publish              *PublishRequest              `protobuf:"bytes,4,opt,name=publish,proto3" json:"publish,omitempty"`
	Broadcast            *BroadcastRequest            `protobuf:"bytes,5,opt,name=broadcast,proto3" json:"broadcast,omitempty"`
	Subscribe            *SubscribeRequest            `protobuf:"bytes,6,opt,name=subscribe,proto3" json:"subscribe,omitempty"`
	Unsubscribe          *UnsubscribeRequest          `protobuf:"bytes,7,opt,name=unsubscribe,proto3" json:"unsubscribe,omitempty"`
	Disconnect           *DisconnectRequest           `protobuf:"bytes,8,opt,name=disconnect,proto3" json:"disconnect,omitempty"`
	Presence             *PresenceRequest             `protobuf:"bytes,9,opt,name=presence,proto3" json:"presence,omitempty"`
	PresenceStats        *PresenceStatsRequest        `protobuf:"bytes,10,opt,name=presence_stats,json=presenceStats,proto3" json:"presence_stats,omitempty"`
	History              *HistoryRequest              `protobuf:"bytes,11,opt,name=history,proto3" json:"history,omitempty"`
	HistoryRemove        *HistoryRemoveRequest        `protobuf:"bytes,12,opt,name=history_remove,json=historyRemove,proto3" json:"history_remove,omitempty"`
	Info                 *InfoRequest                 `protobuf:"bytes,13,opt,name=info,proto3" json:"info,omitempty"`
	Rpc                  *RPCRequest                  `protobuf:"bytes,14,opt,name=rpc,proto3" json:"rpc,omitempty"`
	Refresh              *RefreshRequest              `protobuf:"bytes,15,opt,name=refresh,proto3" json:"refresh,omitempty"`
	Channels             *ChannelsRequest             `protobuf:"bytes,16,opt,name=channels,proto3" json:"channels,omitempty"`
	Connections          *ConnectionsRequest          `protobuf:"bytes,17,opt,name=connections,proto3" json:"connections,omitempty"`
	UpdateUserStatus     *UpdateUserStatusRequest     `protobuf:"bytes,18,opt,name=update_user_status,json=updateUserStatus,proto3" json:"update_user_status,omitempty"`
	GetUserStatus        *GetUserStatusRequest        `protobuf:"bytes,19,opt,name=get_user_status,json=getUserStatus,proto3" json:"get_user_status,omitempty"`
	DeleteUserStatus     *DeleteUserStatusRequest     `protobuf:"bytes,20,opt,name=delete_user_status,json=deleteUserStatus,proto3" json:"delete_user_status,omitempty"`
	BlockUser            *BlockUserRequest            `protobuf:"bytes,21,opt,name=block_user,json=blockUser,proto3" json:"block_user,omitempty"`
	UnblockUser          *UnblockUserRequest          `protobuf:"bytes,22,opt,name=unblock_user,json=unblockUser,proto3" json:"unblock_user,omitempty"`
	RevokeToken          *RevokeTokenRequest          `protobuf:"bytes,23,opt,name=revoke_token,json=revokeToken,proto3" json:"revoke_token,omitempty"`
	InvalidateUserTokens *InvalidateUserTokensRequest `protobuf:"bytes,24,opt,name=invalidate_user_tokens,json=invalidateUserTokens,proto3" json:"invalidate_user_tokens,omitempty"`
	DeviceRegister       *DeviceRegisterRequest       `protobuf:"bytes,25,opt,name=device_register,json=deviceRegister,proto3" json:"device_register,omitempty"`
	DeviceUpdate         *DeviceUpdateRequest         `protobuf:"bytes,26,opt,name=device_update,json=deviceUpdate,proto3" json:"device_update,omitempty"`
	DeviceRemove         *DeviceRemoveRequest         `protobuf:"bytes,27,opt,name=device_remove,json=deviceRemove,proto3" json:"device_remove,omitempty"`
	DeviceList           *DeviceListRequest           `protobuf:"bytes,28,opt,name=device_list,json=deviceList,proto3" json:"device_list,omitempty"`
	DeviceTopicList      *DeviceTopicListRequest      `protobuf:"bytes,29,opt,name=device_topic_list,json=deviceTopicList,proto3" json:"device_topic_list,omitempty"`
	DeviceTopicUpdate    *DeviceTopicUpdateRequest    `protobuf:"bytes,30,opt,name=device_topic_update,json=deviceTopicUpdate,proto3" json:"device_topic_update,omitempty"`
	UserTopicList        *UserTopicListRequest        `protobuf:"bytes,31,opt,name=user_topic_list,json=userTopicList,proto3" json:"user_topic_list,omitempty"`
	UserTopicUpdate      *UserTopicUpdateRequest      `protobuf:"bytes,32,opt,name=user_topic_update,json=userTopicUpdate,proto3" json:"user_topic_update,omitempty"`
	SendPushNotification *SendPushNotificationRequest `protobuf:"bytes,33,opt,name=send_push_notification,json=sendPushNotification,proto3" json:"send_push_notification,omitempty"`
	UpdatePushStatus     *UpdatePushStatusRequest     `protobuf:"bytes,34,opt,name=update_push_status,json=updatePushStatus,proto3" json:"update_push_status,omitempty"`
	// contains filtered or unexported fields
}

func (*Command) Descriptor deprecated 

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

Deprecated: Use Command.ProtoReflect.Descriptor instead.

func (*Command) GetBlockUser added in v4.1.3 

func (x *Command) GetBlockUser() *BlockUserRequest

func (*Command) GetBroadcast added in v4.1.3 

func (x *Command) GetBroadcast() *BroadcastRequest

func (*Command) GetChannels added in v4.1.3 

func (x *Command) GetChannels() *ChannelsRequest

func (*Command) GetConnections added in v4.1.3 

func (x *Command) GetConnections() *ConnectionsRequest

func (*Command) GetDeleteUserStatus added in v4.1.3 

func (x *Command) GetDeleteUserStatus() *DeleteUserStatusRequest

func (*Command) GetDeviceList added in v4.1.3 

func (x *Command) GetDeviceList() *DeviceListRequest

func (*Command) GetDeviceRegister added in v4.1.3 

func (x *Command) GetDeviceRegister() *DeviceRegisterRequest

func (*Command) GetDeviceRemove added in v4.1.3 

func (x *Command) GetDeviceRemove() *DeviceRemoveRequest

func (*Command) GetDeviceTopicList added in v4.1.3 

func (x *Command) GetDeviceTopicList() *DeviceTopicListRequest

func (*Command) GetDeviceTopicUpdate added in v4.1.3 

func (x *Command) GetDeviceTopicUpdate() *DeviceTopicUpdateRequest

func (*Command) GetDeviceUpdate added in v4.1.3 

func (x *Command) GetDeviceUpdate() *DeviceUpdateRequest

func (*Command) GetDisconnect added in v4.1.3 

func (x *Command) GetDisconnect() *DisconnectRequest

func (*Command) GetGetUserStatus added in v4.1.3 

func (x *Command) GetGetUserStatus() *GetUserStatusRequest

func (*Command) GetHistory added in v4.1.3 

func (x *Command) GetHistory() *HistoryRequest

func (*Command) GetHistoryRemove added in v4.1.3 

func (x *Command) GetHistoryRemove() *HistoryRemoveRequest

func (*Command) GetId 

func (x *Command) GetId() uint32

func (*Command) GetInfo added in v4.1.3 

func (x *Command) GetInfo() *InfoRequest

func (*Command) GetInvalidateUserTokens added in v4.1.3 

func (x *Command) GetInvalidateUserTokens() *InvalidateUserTokensRequest

func (*Command) GetMethod 

func (x *Command) GetMethod() Command_MethodType

func (*Command) GetParams 

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

func (*Command) GetPresence added in v4.1.3 

func (x *Command) GetPresence() *PresenceRequest

func (*Command) GetPresenceStats added in v4.1.3 

func (x *Command) GetPresenceStats() *PresenceStatsRequest

func (*Command) GetPublish added in v4.1.3 

func (x *Command) GetPublish() *PublishRequest

func (*Command) GetRefresh added in v4.1.3 

func (x *Command) GetRefresh() *RefreshRequest

func (*Command) GetRevokeToken added in v4.1.3 

func (x *Command) GetRevokeToken() *RevokeTokenRequest

func (*Command) GetRpc added in v4.1.3 

func (x *Command) GetRpc() *RPCRequest

func (*Command) GetSendPushNotification added in v4.1.3 

func (x *Command) GetSendPushNotification() *SendPushNotificationRequest

func (*Command) GetSubscribe added in v4.1.3 

func (x *Command) GetSubscribe() *SubscribeRequest

func (*Command) GetUnblockUser added in v4.1.3 

func (x *Command) GetUnblockUser() *UnblockUserRequest

func (*Command) GetUnsubscribe added in v4.1.3 

func (x *Command) GetUnsubscribe() *UnsubscribeRequest

func (*Command) GetUpdatePushStatus added in v4.1.3 

func (x *Command) GetUpdatePushStatus() *UpdatePushStatusRequest

func (*Command) GetUpdateUserStatus added in v4.1.3 

func (x *Command) GetUpdateUserStatus() *UpdateUserStatusRequest

func (*Command) GetUserTopicList added in v4.1.3 

func (x *Command) GetUserTopicList() *UserTopicListRequest

func (*Command) GetUserTopicUpdate added in v4.1.3 

func (x *Command) GetUserTopicUpdate() *UserTopicUpdateRequest

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 CommandDecoder 

type CommandDecoder interface {
	Reset([]byte)
	Decode() (*Command, error)
}

CommandDecoder ...

func GetCommandDecoder 

func GetCommandDecoder(data []byte) CommandDecoder

GetCommandDecoder ...

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
	Command_DEVICE_REGISTER        Command_MethodType = 22
	Command_DEVICE_UPDATE          Command_MethodType = 23
	Command_DEVICE_REMOVE          Command_MethodType = 24
	Command_DEVICE_LIST            Command_MethodType = 25
	Command_DEVICE_TOPIC_LIST      Command_MethodType = 26
	Command_DEVICE_TOPIC_UPDATE    Command_MethodType = 27
	Command_USER_TOPIC_LIST        Command_MethodType = 28
	Command_USER_TOPIC_UPDATE      Command_MethodType = 29
	Command_SEND_PUSH_NOTIFICATION Command_MethodType = 30
	Command_UPDATE_PUSH_STATUS     Command_MethodType = 31
)

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

func (*Command_MethodType) UnmarshalJSON 

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

UnmarshalJSON helps to unmarshal command method when set as string.

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"`
	// 5-7 dropped for backwards compatibility.
	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               Raw                               `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 `` /* 153-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 Device added in v4.1.3 

type Device struct {
	Id       string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Platform string            `protobuf:"bytes,2,opt,name=platform,proto3" json:"platform,omitempty"`
	Provider string            `protobuf:"bytes,3,opt,name=provider,proto3" json:"provider,omitempty"`
	Token    string            `protobuf:"bytes,4,opt,name=token,proto3" json:"token,omitempty"`
	User     string            `protobuf:"bytes,5,opt,name=user,proto3" json:"user,omitempty"`
	Meta     map[string]string `` /* 149-byte string literal not displayed */
	Topics   []string          `protobuf:"bytes,7,rep,name=topics,proto3" json:"topics,omitempty"`
	Tags     map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Device) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use Device.ProtoReflect.Descriptor instead.

func (*Device) GetId added in v4.1.3 

func (x *Device) GetId() string

func (*Device) GetMeta added in v4.1.3 

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

func (*Device) GetPlatform added in v4.1.3 

func (x *Device) GetPlatform() string

func (*Device) GetProvider added in v4.1.3 

func (x *Device) GetProvider() string

func (*Device) GetTags added in v4.1.3 

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

func (*Device) GetToken added in v4.1.3 

func (x *Device) GetToken() string

func (*Device) GetTopics added in v4.1.3 

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

func (*Device) GetUser added in v4.1.3 

func (x *Device) GetUser() string

func (*Device) ProtoMessage added in v4.1.3 

func (*Device) ProtoMessage()

func (*Device) ProtoReflect added in v4.1.3 

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

func (*Device) Reset added in v4.1.3 

func (x *Device) Reset()

func (*Device) String added in v4.1.3 

func (x *Device) String() string

type DeviceListRequest added in v4.1.3 

type DeviceListRequest struct {
	Ids            []string                `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	Providers      []string                `protobuf:"bytes,2,rep,name=providers,proto3" json:"providers,omitempty"`
	ProviderTokens []*DeviceProviderTokens `protobuf:"bytes,3,rep,name=provider_tokens,json=providerTokens,proto3" json:"provider_tokens,omitempty"`
	Platforms      []string                `protobuf:"bytes,4,rep,name=platforms,proto3" json:"platforms,omitempty"`
	Users          []string                `protobuf:"bytes,5,rep,name=users,proto3" json:"users,omitempty"`
	Topics         []string                `protobuf:"bytes,6,rep,name=topics,proto3" json:"topics,omitempty"`
	Since          string                  `protobuf:"bytes,7,opt,name=since,proto3" json:"since,omitempty"`
	Limit          int32                   `protobuf:"varint,8,opt,name=limit,proto3" json:"limit,omitempty"`
	IncludeTopics  bool                    `protobuf:"varint,10,opt,name=include_topics,json=includeTopics,proto3" json:"include_topics,omitempty"`
	IncludeMeta    bool                    `protobuf:"varint,11,opt,name=include_meta,json=includeMeta,proto3" json:"include_meta,omitempty"`
	IncludeTags    bool                    `protobuf:"varint,12,opt,name=include_tags,json=includeTags,proto3" json:"include_tags,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceListRequest) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use DeviceListRequest.ProtoReflect.Descriptor instead.

func (*DeviceListRequest) GetIds added in v4.1.3 

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

func (*DeviceListRequest) GetIncludeMeta added in v4.1.3 

func (x *DeviceListRequest) GetIncludeMeta() bool

func (*DeviceListRequest) GetIncludeTags added in v4.1.3 

func (x *DeviceListRequest) GetIncludeTags() bool

func (*DeviceListRequest) GetIncludeTopics added in v4.1.3 

func (x *DeviceListRequest) GetIncludeTopics() bool

func (*DeviceListRequest) GetLimit added in v4.1.3 

func (x *DeviceListRequest) GetLimit() int32

func (*DeviceListRequest) GetPlatforms added in v4.1.3 

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

func (*DeviceListRequest) GetProviderTokens added in v4.1.3 

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

func (*DeviceListRequest) GetProviders added in v4.1.3 

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

func (*DeviceListRequest) GetSince added in v4.1.3 

func (x *DeviceListRequest) GetSince() string

func (*DeviceListRequest) GetTopics added in v4.1.3 

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

func (*DeviceListRequest) GetUsers added in v4.1.3 

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

func (*DeviceListRequest) ProtoMessage added in v4.1.3 

func (*DeviceListRequest) ProtoMessage()

func (*DeviceListRequest) ProtoReflect added in v4.1.3 

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

func (*DeviceListRequest) Reset added in v4.1.3 

func (x *DeviceListRequest) Reset()

func (*DeviceListRequest) String added in v4.1.3 

func (x *DeviceListRequest) String() string

type DeviceListResponse added in v4.1.3 

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

func (*DeviceListResponse) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use DeviceListResponse.ProtoReflect.Descriptor instead.

func (*DeviceListResponse) GetError added in v4.1.3 

func (x *DeviceListResponse) GetError() *Error

func (*DeviceListResponse) GetResult added in v4.1.3 

func (x *DeviceListResponse) GetResult() *DeviceListResult

func (*DeviceListResponse) ProtoMessage added in v4.1.3 

func (*DeviceListResponse) ProtoMessage()

func (*DeviceListResponse) ProtoReflect added in v4.1.3 

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

func (*DeviceListResponse) Reset added in v4.1.3 

func (x *DeviceListResponse) Reset()

func (*DeviceListResponse) String added in v4.1.3 

func (x *DeviceListResponse) String() string

type DeviceListResult added in v4.1.3 

type DeviceListResult struct {
	Items   []*Device `protobuf:"bytes,1,rep,name=items,proto3" json:"items"`
	HasMore bool      `protobuf:"varint,2,opt,name=has_more,json=hasMore,proto3" json:"has_more"`
	// contains filtered or unexported fields
}

func (*DeviceListResult) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use DeviceListResult.ProtoReflect.Descriptor instead.

func (*DeviceListResult) GetHasMore added in v4.1.3 

func (x *DeviceListResult) GetHasMore() bool

func (*DeviceListResult) GetItems added in v4.1.3 

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

func (*DeviceListResult) ProtoMessage added in v4.1.3 

func (*DeviceListResult) ProtoMessage()

func (*DeviceListResult) ProtoReflect added in v4.1.3 

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

func (*DeviceListResult) Reset added in v4.1.3 

func (x *DeviceListResult) Reset()

func (*DeviceListResult) String added in v4.1.3 

func (x *DeviceListResult) String() string

type DeviceMetaUpdate added in v4.1.3 

type DeviceMetaUpdate struct {
	Meta map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DeviceMetaUpdate) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use DeviceMetaUpdate.ProtoReflect.Descriptor instead.

func (*DeviceMetaUpdate) GetMeta added in v4.1.3 

func (x *DeviceMetaUpdate) GetMeta() map[string]string

func (*DeviceMetaUpdate) ProtoMessage added in v4.1.3 

func (*DeviceMetaUpdate) ProtoMessage()

func (*DeviceMetaUpdate) ProtoReflect added in v4.1.3 

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

func (*DeviceMetaUpdate) Reset added in v4.1.3 

func (x *DeviceMetaUpdate) Reset()

func (*DeviceMetaUpdate) String added in v4.1.3 

func (x *DeviceMetaUpdate) String() string

type DeviceProviderTokens added in v4.1.3 

type DeviceProviderTokens struct {
	Provider string   `protobuf:"bytes,1,opt,name=provider,proto3" json:"provider,omitempty"`
	Tokens   []string `protobuf:"bytes,2,rep,name=tokens,proto3" json:"tokens,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceProviderTokens) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use DeviceProviderTokens.ProtoReflect.Descriptor instead.

func (*DeviceProviderTokens) GetProvider added in v4.1.3 

func (x *DeviceProviderTokens) GetProvider() string

func (*DeviceProviderTokens) GetTokens added in v4.1.3 

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

func (*DeviceProviderTokens) ProtoMessage added in v4.1.3 

func (*DeviceProviderTokens) ProtoMessage()

func (*DeviceProviderTokens) ProtoReflect added in v4.1.3 

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

func (*DeviceProviderTokens) Reset added in v4.1.3 

func (x *DeviceProviderTokens) Reset()

func (*DeviceProviderTokens) String added in v4.1.3 

func (x *DeviceProviderTokens) String() string

type DeviceRegisterRequest added in v4.1.3 

type DeviceRegisterRequest struct {
	Id       string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Provider string            `protobuf:"bytes,2,opt,name=provider,proto3" json:"provider,omitempty"`
	Token    string            `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
	Platform string            `protobuf:"bytes,4,opt,name=platform,proto3" json:"platform,omitempty"`
	User     string            `protobuf:"bytes,5,opt,name=user,proto3" json:"user,omitempty"`
	Meta     map[string]string `` /* 149-byte string literal not displayed */
	Tags     map[string]string `` /* 149-byte string literal not displayed */
	Topics   []string          `protobuf:"bytes,8,rep,name=topics,proto3" json:"topics,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceRegisterRequest) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use DeviceRegisterRequest.ProtoReflect.Descriptor instead.

func (*DeviceRegisterRequest) GetId added in v4.1.3 

func (x *DeviceRegisterRequest) GetId() string

func (*DeviceRegisterRequest) GetMeta added in v4.1.3 

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

func (*DeviceRegisterRequest) GetPlatform added in v4.1.3 

func (x *DeviceRegisterRequest) GetPlatform() string

func (*DeviceRegisterRequest) GetProvider added in v4.1.3 

func (x *DeviceRegisterRequest) GetProvider() string

func (*DeviceRegisterRequest) GetTags added in v4.1.3 

func (x *DeviceRegisterRequest) GetTags() map[string]string

func (*DeviceRegisterRequest) GetToken added in v4.1.3 

func (x *DeviceRegisterRequest) GetToken() string

func (*DeviceRegisterRequest) GetTopics added in v4.1.3 

func (x *DeviceRegisterRequest) GetTopics() []string

func (*DeviceRegisterRequest) GetUser added in v4.1.3 

func (x *DeviceRegisterRequest) GetUser() string

func (*DeviceRegisterRequest) ProtoMessage added in v4.1.3 

func (*DeviceRegisterRequest) ProtoMessage()

func (*DeviceRegisterRequest) ProtoReflect added in v4.1.3 

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

func (*DeviceRegisterRequest) Reset added in v4.1.3 

func (x *DeviceRegisterRequest) Reset()

func (*DeviceRegisterRequest) String added in v4.1.3 

func (x *DeviceRegisterRequest) String() string

type DeviceRegisterResponse added in v4.1.3 

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

func (*DeviceRegisterResponse) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use DeviceRegisterResponse.ProtoReflect.Descriptor instead.

func (*DeviceRegisterResponse) GetError added in v4.1.3 

func (x *DeviceRegisterResponse) GetError() *Error

func (*DeviceRegisterResponse) GetResult added in v4.1.3 

func (x *DeviceRegisterResponse) GetResult() *DeviceRegisterResult

func (*DeviceRegisterResponse) ProtoMessage added in v4.1.3 

func (*DeviceRegisterResponse) ProtoMessage()

func (*DeviceRegisterResponse) ProtoReflect added in v4.1.3 

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

func (*DeviceRegisterResponse) Reset added in v4.1.3 

func (x *DeviceRegisterResponse) Reset()

func (*DeviceRegisterResponse) String added in v4.1.3 

func (x *DeviceRegisterResponse) String() string

type DeviceRegisterResult added in v4.1.3 

type DeviceRegisterResult struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceRegisterResult) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use DeviceRegisterResult.ProtoReflect.Descriptor instead.

func (*DeviceRegisterResult) GetId added in v4.1.3 

func (x *DeviceRegisterResult) GetId() string

func (*DeviceRegisterResult) ProtoMessage added in v4.1.3 

func (*DeviceRegisterResult) ProtoMessage()

func (*DeviceRegisterResult) ProtoReflect added in v4.1.3 

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

func (*DeviceRegisterResult) Reset added in v4.1.3 

func (x *DeviceRegisterResult) Reset()

func (*DeviceRegisterResult) String added in v4.1.3 

func (x *DeviceRegisterResult) String() string

type DeviceRemoveRequest added in v4.1.3 

type DeviceRemoveRequest struct {
	Ids            []string                `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	Users          []string                `protobuf:"bytes,2,rep,name=users,proto3" json:"users,omitempty"`
	ProviderTokens []*DeviceProviderTokens `protobuf:"bytes,3,rep,name=provider_tokens,json=providerTokens,proto3" json:"provider_tokens,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceRemoveRequest) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use DeviceRemoveRequest.ProtoReflect.Descriptor instead.

func (*DeviceRemoveRequest) GetIds added in v4.1.3 

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

func (*DeviceRemoveRequest) GetProviderTokens added in v4.1.3 

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

func (*DeviceRemoveRequest) GetUsers added in v4.1.3 

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

func (*DeviceRemoveRequest) ProtoMessage added in v4.1.3 

func (*DeviceRemoveRequest) ProtoMessage()

func (*DeviceRemoveRequest) ProtoReflect added in v4.1.3 

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

func (*DeviceRemoveRequest) Reset added in v4.1.3 

func (x *DeviceRemoveRequest) Reset()

func (*DeviceRemoveRequest) String added in v4.1.3 

func (x *DeviceRemoveRequest) String() string

type DeviceRemoveResponse added in v4.1.3 

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

func (*DeviceRemoveResponse) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use DeviceRemoveResponse.ProtoReflect.Descriptor instead.

func (*DeviceRemoveResponse) GetError added in v4.1.3 

func (x *DeviceRemoveResponse) GetError() *Error

func (*DeviceRemoveResponse) GetResult added in v4.1.3 

func (x *DeviceRemoveResponse) GetResult() *DeviceRemoveResult

func (*DeviceRemoveResponse) ProtoMessage added in v4.1.3 

func (*DeviceRemoveResponse) ProtoMessage()

func (*DeviceRemoveResponse) ProtoReflect added in v4.1.3 

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

func (*DeviceRemoveResponse) Reset added in v4.1.3 

func (x *DeviceRemoveResponse) Reset()

func (*DeviceRemoveResponse) String added in v4.1.3 

func (x *DeviceRemoveResponse) String() string

type DeviceRemoveResult added in v4.1.3 

type DeviceRemoveResult struct {
	// contains filtered or unexported fields
}

func (*DeviceRemoveResult) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use DeviceRemoveResult.ProtoReflect.Descriptor instead.

func (*DeviceRemoveResult) ProtoMessage added in v4.1.3 

func (*DeviceRemoveResult) ProtoMessage()

func (*DeviceRemoveResult) ProtoReflect added in v4.1.3 

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

func (*DeviceRemoveResult) Reset added in v4.1.3 

func (x *DeviceRemoveResult) Reset()

func (*DeviceRemoveResult) String added in v4.1.3 

func (x *DeviceRemoveResult) String() string

type DeviceTag added in v4.1.3 

type DeviceTag struct {
	Id     string  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Key    string  `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value  string  `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Device *Device `protobuf:"bytes,4,opt,name=device,proto3" json:"device,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceTag) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use DeviceTag.ProtoReflect.Descriptor instead.

func (*DeviceTag) GetDevice added in v4.1.3 

func (x *DeviceTag) GetDevice() *Device

func (*DeviceTag) GetId added in v4.1.3 

func (x *DeviceTag) GetId() string

func (*DeviceTag) GetKey added in v4.1.3 

func (x *DeviceTag) GetKey() string

func (*DeviceTag) GetValue added in v4.1.3 

func (x *DeviceTag) GetValue() string

func (*DeviceTag) ProtoMessage added in v4.1.3 

func (*DeviceTag) ProtoMessage()

func (*DeviceTag) ProtoReflect added in v4.1.3 

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

func (*DeviceTag) Reset added in v4.1.3 

func (x *DeviceTag) Reset()

func (*DeviceTag) String added in v4.1.3 

func (x *DeviceTag) String() string

type DeviceTagListResult added in v4.1.3 

type DeviceTagListResult struct {
	Items   []*DeviceTag `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	HasMore bool         `protobuf:"varint,2,opt,name=has_more,json=hasMore,proto3" json:"has_more,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceTagListResult) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use DeviceTagListResult.ProtoReflect.Descriptor instead.

func (*DeviceTagListResult) GetHasMore added in v4.1.3 

func (x *DeviceTagListResult) GetHasMore() bool

func (*DeviceTagListResult) GetItems added in v4.1.3 

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

func (*DeviceTagListResult) ProtoMessage added in v4.1.3 

func (*DeviceTagListResult) ProtoMessage()

func (*DeviceTagListResult) ProtoReflect added in v4.1.3 

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

func (*DeviceTagListResult) Reset added in v4.1.3 

func (x *DeviceTagListResult) Reset()

func (*DeviceTagListResult) String added in v4.1.3 

func (x *DeviceTagListResult) String() string

type DeviceTagsUpdate added in v4.1.3 

type DeviceTagsUpdate struct {
	Op   string            `protobuf:"bytes,1,opt,name=op,proto3" json:"op,omitempty"` // add | remove | set
	Tags map[string]string ``                                                          /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DeviceTagsUpdate) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use DeviceTagsUpdate.ProtoReflect.Descriptor instead.

func (*DeviceTagsUpdate) GetOp added in v4.1.3 

func (x *DeviceTagsUpdate) GetOp() string

func (*DeviceTagsUpdate) GetTags added in v4.1.3 

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

func (*DeviceTagsUpdate) ProtoMessage added in v4.1.3 

func (*DeviceTagsUpdate) ProtoMessage()

func (*DeviceTagsUpdate) ProtoReflect added in v4.1.3 

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

func (*DeviceTagsUpdate) Reset added in v4.1.3 

func (x *DeviceTagsUpdate) Reset()

func (*DeviceTagsUpdate) String added in v4.1.3 

func (x *DeviceTagsUpdate) String() string

type DeviceTopic added in v4.1.3 

type DeviceTopic struct {
	Id     string  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Topic  string  `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Device *Device `protobuf:"bytes,3,opt,name=device,proto3" json:"device,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceTopic) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use DeviceTopic.ProtoReflect.Descriptor instead.

func (*DeviceTopic) GetDevice added in v4.1.3 

func (x *DeviceTopic) GetDevice() *Device

func (*DeviceTopic) GetId added in v4.1.3 

func (x *DeviceTopic) GetId() string

func (*DeviceTopic) GetTopic added in v4.1.3 

func (x *DeviceTopic) GetTopic() string

func (*DeviceTopic) ProtoMessage added in v4.1.3 

func (*DeviceTopic) ProtoMessage()

func (*DeviceTopic) ProtoReflect added in v4.1.3 

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

func (*DeviceTopic) Reset added in v4.1.3 

func (x *DeviceTopic) Reset()

func (*DeviceTopic) String added in v4.1.3 

func (x *DeviceTopic) String() string

type DeviceTopicListRequest added in v4.1.3 

type DeviceTopicListRequest struct {
	DeviceIds            []string                `protobuf:"bytes,1,rep,name=device_ids,json=deviceIds,proto3" json:"device_ids,omitempty"`
	DeviceProviders      []string                `protobuf:"bytes,2,rep,name=device_providers,json=deviceProviders,proto3" json:"device_providers,omitempty"`
	DeviceProviderTokens []*DeviceProviderTokens `protobuf:"bytes,3,rep,name=device_provider_tokens,json=deviceProviderTokens,proto3" json:"device_provider_tokens,omitempty"`
	DevicePlatforms      []string                `protobuf:"bytes,4,rep,name=device_platforms,json=devicePlatforms,proto3" json:"device_platforms,omitempty"`
	DeviceUsers          []string                `protobuf:"bytes,5,rep,name=device_users,json=deviceUsers,proto3" json:"device_users,omitempty"`
	Topics               []string                `protobuf:"bytes,6,rep,name=topics,proto3" json:"topics,omitempty"`
	TopicPrefix          string                  `protobuf:"bytes,7,opt,name=topic_prefix,json=topicPrefix,proto3" json:"topic_prefix,omitempty"`
	Since                string                  `protobuf:"bytes,8,opt,name=since,proto3" json:"since,omitempty"`
	Limit                int32                   `protobuf:"varint,9,opt,name=limit,proto3" json:"limit,omitempty"`
	IncludeDevice        bool                    `protobuf:"varint,10,opt,name=include_device,json=includeDevice,proto3" json:"include_device,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceTopicListRequest) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use DeviceTopicListRequest.ProtoReflect.Descriptor instead.

func (*DeviceTopicListRequest) GetDeviceIds added in v4.1.3 

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

func (*DeviceTopicListRequest) GetDevicePlatforms added in v4.1.3 

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

func (*DeviceTopicListRequest) GetDeviceProviderTokens added in v4.1.3 

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

func (*DeviceTopicListRequest) GetDeviceProviders added in v4.1.3 

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

func (*DeviceTopicListRequest) GetDeviceUsers added in v4.1.3 

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

func (*DeviceTopicListRequest) GetIncludeDevice added in v4.1.3 

func (x *DeviceTopicListRequest) GetIncludeDevice() bool

func (*DeviceTopicListRequest) GetLimit added in v4.1.3 

func (x *DeviceTopicListRequest) GetLimit() int32

func (*DeviceTopicListRequest) GetSince added in v4.1.3 

func (x *DeviceTopicListRequest) GetSince() string

func (*DeviceTopicListRequest) GetTopicPrefix added in v4.1.3 

func (x *DeviceTopicListRequest) GetTopicPrefix() string

func (*DeviceTopicListRequest) GetTopics added in v4.1.3 

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

func (*DeviceTopicListRequest) ProtoMessage added in v4.1.3 

func (*DeviceTopicListRequest) ProtoMessage()

func (*DeviceTopicListRequest) ProtoReflect added in v4.1.3 

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

func (*DeviceTopicListRequest) Reset added in v4.1.3 

func (x *DeviceTopicListRequest) Reset()

func (*DeviceTopicListRequest) String added in v4.1.3 

func (x *DeviceTopicListRequest) String() string

type DeviceTopicListResponse added in v4.1.3 

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

func (*DeviceTopicListResponse) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use DeviceTopicListResponse.ProtoReflect.Descriptor instead.

func (*DeviceTopicListResponse) GetError added in v4.1.3 

func (x *DeviceTopicListResponse) GetError() *Error

func (*DeviceTopicListResponse) GetResult added in v4.1.3 

func (x *DeviceTopicListResponse) GetResult() *DeviceTopicListResult

func (*DeviceTopicListResponse) ProtoMessage added in v4.1.3 

func (*DeviceTopicListResponse) ProtoMessage()

func (*DeviceTopicListResponse) ProtoReflect added in v4.1.3 

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

func (*DeviceTopicListResponse) Reset added in v4.1.3 

func (x *DeviceTopicListResponse) Reset()

func (*DeviceTopicListResponse) String added in v4.1.3 

func (x *DeviceTopicListResponse) String() string

type DeviceTopicListResult added in v4.1.3 

type DeviceTopicListResult struct {
	Items   []*DeviceTopic `protobuf:"bytes,1,rep,name=items,proto3" json:"items"`
	HasMore bool           `protobuf:"varint,2,opt,name=has_more,json=hasMore,proto3" json:"has_more"`
	// contains filtered or unexported fields
}

func (*DeviceTopicListResult) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use DeviceTopicListResult.ProtoReflect.Descriptor instead.

func (*DeviceTopicListResult) GetHasMore added in v4.1.3 

func (x *DeviceTopicListResult) GetHasMore() bool

func (*DeviceTopicListResult) GetItems added in v4.1.3 

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

func (*DeviceTopicListResult) ProtoMessage added in v4.1.3 

func (*DeviceTopicListResult) ProtoMessage()

func (*DeviceTopicListResult) ProtoReflect added in v4.1.3 

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

func (*DeviceTopicListResult) Reset added in v4.1.3 

func (x *DeviceTopicListResult) Reset()

func (*DeviceTopicListResult) String added in v4.1.3 

func (x *DeviceTopicListResult) String() string

type DeviceTopicUpdateRequest added in v4.1.3 

type DeviceTopicUpdateRequest struct {
	DeviceId string   `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	Op       string   `protobuf:"bytes,2,opt,name=op,proto3" json:"op,omitempty"` // add | remove | set
	Topics   []string `protobuf:"bytes,3,rep,name=topics,proto3" json:"topics,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceTopicUpdateRequest) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use DeviceTopicUpdateRequest.ProtoReflect.Descriptor instead.

func (*DeviceTopicUpdateRequest) GetDeviceId added in v4.1.3 

func (x *DeviceTopicUpdateRequest) GetDeviceId() string

func (*DeviceTopicUpdateRequest) GetOp added in v4.1.3 

func (x *DeviceTopicUpdateRequest) GetOp() string

func (*DeviceTopicUpdateRequest) GetTopics added in v4.1.3 

func (x *DeviceTopicUpdateRequest) GetTopics() []string

func (*DeviceTopicUpdateRequest) ProtoMessage added in v4.1.3 

func (*DeviceTopicUpdateRequest) ProtoMessage()

func (*DeviceTopicUpdateRequest) ProtoReflect added in v4.1.3 

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

func (*DeviceTopicUpdateRequest) Reset added in v4.1.3 

func (x *DeviceTopicUpdateRequest) Reset()

func (*DeviceTopicUpdateRequest) String added in v4.1.3 

func (x *DeviceTopicUpdateRequest) String() string

type DeviceTopicUpdateResponse added in v4.1.3 

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

func (*DeviceTopicUpdateResponse) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use DeviceTopicUpdateResponse.ProtoReflect.Descriptor instead.

func (*DeviceTopicUpdateResponse) GetError added in v4.1.3 

func (x *DeviceTopicUpdateResponse) GetError() *Error

func (*DeviceTopicUpdateResponse) GetResult added in v4.1.3 

func (x *DeviceTopicUpdateResponse) GetResult() *DeviceTopicUpdateResult

func (*DeviceTopicUpdateResponse) ProtoMessage added in v4.1.3 

func (*DeviceTopicUpdateResponse) ProtoMessage()

func (*DeviceTopicUpdateResponse) ProtoReflect added in v4.1.3 

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

func (*DeviceTopicUpdateResponse) Reset added in v4.1.3 

func (x *DeviceTopicUpdateResponse) Reset()

func (*DeviceTopicUpdateResponse) String added in v4.1.3 

func (x *DeviceTopicUpdateResponse) String() string

type DeviceTopicUpdateResult added in v4.1.3 

type DeviceTopicUpdateResult struct {
	// contains filtered or unexported fields
}

func (*DeviceTopicUpdateResult) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use DeviceTopicUpdateResult.ProtoReflect.Descriptor instead.

func (*DeviceTopicUpdateResult) ProtoMessage added in v4.1.3 

func (*DeviceTopicUpdateResult) ProtoMessage()

func (*DeviceTopicUpdateResult) ProtoReflect added in v4.1.3 

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

func (*DeviceTopicUpdateResult) Reset added in v4.1.3 

func (x *DeviceTopicUpdateResult) Reset()

func (*DeviceTopicUpdateResult) String added in v4.1.3 

func (x *DeviceTopicUpdateResult) String() string

type DeviceTopicsUpdate added in v4.1.3 

type DeviceTopicsUpdate struct {
	Op     string   `protobuf:"bytes,1,opt,name=op,proto3" json:"op,omitempty"` // add | remove | set
	Topics []string `protobuf:"bytes,2,rep,name=topics,proto3" json:"topics,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceTopicsUpdate) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use DeviceTopicsUpdate.ProtoReflect.Descriptor instead.

func (*DeviceTopicsUpdate) GetOp added in v4.1.3 

func (x *DeviceTopicsUpdate) GetOp() string

func (*DeviceTopicsUpdate) GetTopics added in v4.1.3 

func (x *DeviceTopicsUpdate) GetTopics() []string

func (*DeviceTopicsUpdate) ProtoMessage added in v4.1.3 

func (*DeviceTopicsUpdate) ProtoMessage()

func (*DeviceTopicsUpdate) ProtoReflect added in v4.1.3 

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

func (*DeviceTopicsUpdate) Reset added in v4.1.3 

func (x *DeviceTopicsUpdate) Reset()

func (*DeviceTopicsUpdate) String added in v4.1.3 

func (x *DeviceTopicsUpdate) String() string

type DeviceUpdateRequest added in v4.1.3 

type DeviceUpdateRequest struct {
	Ids            []string                `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	Users          []string                `protobuf:"bytes,2,rep,name=users,proto3" json:"users,omitempty"`
	ProviderTokens []*DeviceProviderTokens `protobuf:"bytes,3,rep,name=provider_tokens,json=providerTokens,proto3" json:"provider_tokens,omitempty"`
	UserUpdate     *DeviceUserUpdate       `protobuf:"bytes,4,opt,name=user_update,json=userUpdate,proto3" json:"user_update,omitempty"`
	MetaUpdate     *DeviceMetaUpdate       `protobuf:"bytes,5,opt,name=meta_update,json=metaUpdate,proto3" json:"meta_update,omitempty"`
	TagsUpdate     *DeviceTagsUpdate       `protobuf:"bytes,6,opt,name=tags_update,json=tagsUpdate,proto3" json:"tags_update,omitempty"`
	TopicsUpdate   *DeviceTopicsUpdate     `protobuf:"bytes,7,opt,name=topics_update,json=topicsUpdate,proto3" json:"topics_update,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceUpdateRequest) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use DeviceUpdateRequest.ProtoReflect.Descriptor instead.

func (*DeviceUpdateRequest) GetIds added in v4.1.3 

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

func (*DeviceUpdateRequest) GetMetaUpdate added in v4.1.3 

func (x *DeviceUpdateRequest) GetMetaUpdate() *DeviceMetaUpdate

func (*DeviceUpdateRequest) GetProviderTokens added in v4.1.3 

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

func (*DeviceUpdateRequest) GetTagsUpdate added in v4.1.3 

func (x *DeviceUpdateRequest) GetTagsUpdate() *DeviceTagsUpdate

func (*DeviceUpdateRequest) GetTopicsUpdate added in v4.1.3 

func (x *DeviceUpdateRequest) GetTopicsUpdate() *DeviceTopicsUpdate

func (*DeviceUpdateRequest) GetUserUpdate added in v4.1.3 

func (x *DeviceUpdateRequest) GetUserUpdate() *DeviceUserUpdate

func (*DeviceUpdateRequest) GetUsers added in v4.1.3 

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

func (*DeviceUpdateRequest) ProtoMessage added in v4.1.3 

func (*DeviceUpdateRequest) ProtoMessage()

func (*DeviceUpdateRequest) ProtoReflect added in v4.1.3 

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

func (*DeviceUpdateRequest) Reset added in v4.1.3 

func (x *DeviceUpdateRequest) Reset()

func (*DeviceUpdateRequest) String added in v4.1.3 

func (x *DeviceUpdateRequest) String() string

type DeviceUpdateResponse added in v4.1.3 

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

func (*DeviceUpdateResponse) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use DeviceUpdateResponse.ProtoReflect.Descriptor instead.

func (*DeviceUpdateResponse) GetError added in v4.1.3 

func (x *DeviceUpdateResponse) GetError() *Error

func (*DeviceUpdateResponse) GetResult added in v4.1.3 

func (x *DeviceUpdateResponse) GetResult() *DeviceUpdateResult

func (*DeviceUpdateResponse) ProtoMessage added in v4.1.3 

func (*DeviceUpdateResponse) ProtoMessage()

func (*DeviceUpdateResponse) ProtoReflect added in v4.1.3 

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

func (*DeviceUpdateResponse) Reset added in v4.1.3 

func (x *DeviceUpdateResponse) Reset()

func (*DeviceUpdateResponse) String added in v4.1.3 

func (x *DeviceUpdateResponse) String() string

type DeviceUpdateResult added in v4.1.3 

type DeviceUpdateResult struct {
	// contains filtered or unexported fields
}

func (*DeviceUpdateResult) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use DeviceUpdateResult.ProtoReflect.Descriptor instead.

func (*DeviceUpdateResult) ProtoMessage added in v4.1.3 

func (*DeviceUpdateResult) ProtoMessage()

func (*DeviceUpdateResult) ProtoReflect added in v4.1.3 

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

func (*DeviceUpdateResult) Reset added in v4.1.3 

func (x *DeviceUpdateResult) Reset()

func (*DeviceUpdateResult) String added in v4.1.3 

func (x *DeviceUpdateResult) String() string

type DeviceUserUpdate added in v4.1.3 

type DeviceUserUpdate struct {
	User string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceUserUpdate) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use DeviceUserUpdate.ProtoReflect.Descriptor instead.

func (*DeviceUserUpdate) GetUser added in v4.1.3 

func (x *DeviceUserUpdate) GetUser() string

func (*DeviceUserUpdate) ProtoMessage added in v4.1.3 

func (*DeviceUserUpdate) ProtoMessage()

func (*DeviceUserUpdate) ProtoReflect added in v4.1.3 

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

func (*DeviceUserUpdate) Reset added in v4.1.3 

func (x *DeviceUserUpdate) Reset()

func (*DeviceUserUpdate) String added in v4.1.3 

func (x *DeviceUserUpdate) 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) Error 

func (x *Error) Error() string

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 FcmPushNotification added in v4.1.3 

type FcmPushNotification struct {
	Message Raw `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*FcmPushNotification) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use FcmPushNotification.ProtoReflect.Descriptor instead.

func (*FcmPushNotification) GetMessage added in v4.1.3 

func (x *FcmPushNotification) GetMessage() []byte

func (*FcmPushNotification) ProtoMessage added in v4.1.3 

func (*FcmPushNotification) ProtoMessage()

func (*FcmPushNotification) ProtoReflect added in v4.1.3 

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

func (*FcmPushNotification) Reset added in v4.1.3 

func (x *FcmPushNotification) Reset()

func (*FcmPushNotification) String added in v4.1.3 

func (x *FcmPushNotification) 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"`
	// 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"`
	Epoch        string         `protobuf:"bytes,2,opt,name=epoch,proto3" json:"epoch"`
	Offset       uint64         `protobuf:"varint,3,opt,name=offset,proto3" json:"offset"`
	// 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 HmsPushNotification added in v4.1.3 

type HmsPushNotification struct {
	Message Raw `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*HmsPushNotification) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use HmsPushNotification.ProtoReflect.Descriptor instead.

func (*HmsPushNotification) GetMessage added in v4.1.3 

func (x *HmsPushNotification) GetMessage() []byte

func (*HmsPushNotification) ProtoMessage added in v4.1.3 

func (*HmsPushNotification) ProtoMessage()

func (*HmsPushNotification) ProtoReflect added in v4.1.3 

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

func (*HmsPushNotification) Reset added in v4.1.3 

func (x *HmsPushNotification) Reset()

func (*HmsPushNotification) String added in v4.1.3 

func (x *HmsPushNotification) 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 JSONCommandDecoder 

type JSONCommandDecoder struct {
	// contains filtered or unexported fields
}

JSONCommandDecoder ...

func NewJSONCommandDecoder 

func NewJSONCommandDecoder(data []byte) *JSONCommandDecoder

NewJSONCommandDecoder ...

func (*JSONCommandDecoder) Decode 

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

Decode ...

func (*JSONCommandDecoder) Reset 

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

Reset ...

type JSONReplyEncoder 

type JSONReplyEncoder struct {
	// contains filtered or unexported fields
}

JSONReplyEncoder ...

func NewJSONReplyEncoder 

func NewJSONReplyEncoder() *JSONReplyEncoder

NewJSONReplyEncoder ...

func (*JSONReplyEncoder) Encode 

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

Encode ...

func (*JSONReplyEncoder) Finish 

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

Finish ...

func (*JSONReplyEncoder) Reset 

func (e *JSONReplyEncoder) Reset()

Reset ...

type JSONRequestDecoder added in v4.1.3 

type JSONRequestDecoder struct{}

JSONRequestDecoder ...

func NewJSONRequestDecoder added in v4.1.3 

func NewJSONRequestDecoder() *JSONRequestDecoder

NewJSONRequestDecoder ...

func (*JSONRequestDecoder) DecodeBatch added in v4.1.3 

func (d *JSONRequestDecoder) DecodeBatch(data []byte) (*BatchRequest, error)

DecodeBatch ...

func (*JSONRequestDecoder) DecodeBroadcast added in v4.1.3 

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

DecodeBroadcast ...

func (*JSONRequestDecoder) DecodeChannels added in v4.1.3 

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

DecodeChannels ...

func (*JSONRequestDecoder) DecodeDisconnect added in v4.1.3 

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

DecodeDisconnect ...

func (*JSONRequestDecoder) DecodeHistory added in v4.1.3 

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

DecodeHistory ...

func (*JSONRequestDecoder) DecodeHistoryRemove added in v4.1.3 

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

DecodeHistoryRemove ...

func (*JSONRequestDecoder) DecodeInfo added in v4.1.3 

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

DecodeInfo ...

func (*JSONRequestDecoder) DecodePresence added in v4.1.3 

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

DecodePresence ...

func (*JSONRequestDecoder) DecodePresenceStats added in v4.1.3 

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

DecodePresenceStats ...

func (*JSONRequestDecoder) DecodePublish added in v4.1.3 

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

DecodePublish ...

func (*JSONRequestDecoder) DecodeRPC added in v4.1.3 

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

DecodeRPC ...

func (*JSONRequestDecoder) DecodeRefresh added in v4.1.3 

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

DecodeRefresh ...

func (*JSONRequestDecoder) DecodeSubscribe added in v4.1.3 

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

DecodeSubscribe ...

func (*JSONRequestDecoder) DecodeUnsubscribe added in v4.1.3 

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

DecodeUnsubscribe ...

type JSONResponseEncoder added in v4.1.3 

type JSONResponseEncoder struct{}

JSONResponseEncoder ...

func NewJSONResponseEncoder added in v4.1.3 

func NewJSONResponseEncoder() *JSONResponseEncoder

func (*JSONResponseEncoder) EncodeBatch added in v4.1.3 

func (e *JSONResponseEncoder) EncodeBatch(response *BatchResponse) ([]byte, error)

EncodeBatch ...

func (*JSONResponseEncoder) EncodeBroadcast added in v4.1.3 

func (e *JSONResponseEncoder) EncodeBroadcast(response *BroadcastResponse) ([]byte, error)

EncodeBroadcast ...

func (*JSONResponseEncoder) EncodeChannels added in v4.1.3 

func (e *JSONResponseEncoder) EncodeChannels(response *ChannelsResponse) ([]byte, error)

EncodeChannels ...

func (*JSONResponseEncoder) EncodeDisconnect added in v4.1.3 

func (e *JSONResponseEncoder) EncodeDisconnect(response *DisconnectResponse) ([]byte, error)

EncodeDisconnect ...

func (*JSONResponseEncoder) EncodeHistory added in v4.1.3 

func (e *JSONResponseEncoder) EncodeHistory(response *HistoryResponse) ([]byte, error)

EncodeHistory ...

func (*JSONResponseEncoder) EncodeHistoryRemove added in v4.1.3 

func (e *JSONResponseEncoder) EncodeHistoryRemove(response *HistoryRemoveResponse) ([]byte, error)

EncodeHistoryRemove ...

func (*JSONResponseEncoder) EncodeInfo added in v4.1.3 

func (e *JSONResponseEncoder) EncodeInfo(response *InfoResponse) ([]byte, error)

EncodeInfo ...

func (*JSONResponseEncoder) EncodePresence added in v4.1.3 

func (e *JSONResponseEncoder) EncodePresence(response *PresenceResponse) ([]byte, error)

EncodePresence ...

func (*JSONResponseEncoder) EncodePresenceStats added in v4.1.3 

func (e *JSONResponseEncoder) EncodePresenceStats(response *PresenceStatsResponse) ([]byte, error)

EncodePresenceStats ...

func (*JSONResponseEncoder) EncodePublish added in v4.1.3 

func (e *JSONResponseEncoder) EncodePublish(response *PublishResponse) ([]byte, error)

EncodePublish ...

func (*JSONResponseEncoder) EncodeRPC added in v4.1.3 

func (e *JSONResponseEncoder) EncodeRPC(response *RPCResponse) ([]byte, error)

EncodeRPC ...

func (*JSONResponseEncoder) EncodeRefresh added in v4.1.3 

func (e *JSONResponseEncoder) EncodeRefresh(response *RefreshResponse) ([]byte, error)

EncodeRefresh ...

func (*JSONResponseEncoder) EncodeSubscribe added in v4.1.3 

func (e *JSONResponseEncoder) EncodeSubscribe(response *SubscribeResponse) ([]byte, error)

EncodeSubscribe ...

func (*JSONResponseEncoder) EncodeUnsubscribe added in v4.1.3 

func (e *JSONResponseEncoder) EncodeUnsubscribe(response *UnsubscribeResponse) ([]byte, error)

EncodeUnsubscribe ...

type JSONResultEncoder 

type JSONResultEncoder struct{}

JSONResultEncoder ...

func NewJSONResultEncoder added in v4.1.3 

func NewJSONResultEncoder() *JSONResultEncoder

NewJSONResultEncoder ...

func (*JSONResultEncoder) EncodeBroadcast 

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

EncodeBroadcast ...

func (*JSONResultEncoder) EncodeChannels 

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

EncodeChannels ...

func (*JSONResultEncoder) EncodeDisconnect 

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

EncodeDisconnect ...

func (*JSONResultEncoder) EncodeHistory 

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

EncodeHistory ...

func (*JSONResultEncoder) EncodeHistoryRemove 

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

EncodeHistoryRemove ...

func (*JSONResultEncoder) EncodeInfo 

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

EncodeInfo ...

func (*JSONResultEncoder) EncodePresence 

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

EncodePresence ...

func (*JSONResultEncoder) EncodePresenceStats 

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

EncodePresenceStats ...

func (*JSONResultEncoder) EncodePublish 

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

EncodePublish ...

func (*JSONResultEncoder) EncodeRPC 

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

EncodeRPC ...

func (*JSONResultEncoder) EncodeRefresh 

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

EncodeRefresh ...

func (*JSONResultEncoder) EncodeSubscribe 

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

EncodeSubscribe ...

func (*JSONResultEncoder) EncodeUnsubscribe 

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

EncodeUnsubscribe ...

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"`
	Name        string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name"`
	Version     string   `protobuf:"bytes,3,opt,name=version,proto3" json:"version"`
	NumClients  uint32   `protobuf:"varint,4,opt,name=num_clients,json=numClients,proto3" json:"num_clients"`
	NumUsers    uint32   `protobuf:"varint,5,opt,name=num_users,json=numUsers,proto3" json:"num_users"`
	NumChannels uint32   `protobuf:"varint,6,opt,name=num_channels,json=numChannels,proto3" json:"num_channels"`
	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"`
	// 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 `` /* 147-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"`
	NumUsers   uint32 `protobuf:"varint,2,opt,name=num_users,json=numUsers,proto3" json:"num_users"`
	// 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 {

	// Removed: string uid = 1;
	Data   Raw               `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        Raw               `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 PushNotification added in v4.1.3 

type PushNotification struct {
	Fcm      *FcmPushNotification  `protobuf:"bytes,1,opt,name=fcm,proto3" json:"fcm,omitempty"`
	Hms      *HmsPushNotification  `protobuf:"bytes,2,opt,name=hms,proto3" json:"hms,omitempty"`
	Apns     *ApnsPushNotification `protobuf:"bytes,3,opt,name=apns,proto3" json:"apns,omitempty"`
	Uid      string                `protobuf:"bytes,4,opt,name=uid,proto3" json:"uid,omitempty"`
	ExpireAt int64                 `protobuf:"varint,5,opt,name=expire_at,json=expireAt,proto3" json:"expire_at,omitempty"`
	// contains filtered or unexported fields
}

func (*PushNotification) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use PushNotification.ProtoReflect.Descriptor instead.

func (*PushNotification) GetApns added in v4.1.3 

func (x *PushNotification) GetApns() *ApnsPushNotification

func (*PushNotification) GetExpireAt added in v4.1.3 

func (x *PushNotification) GetExpireAt() int64

func (*PushNotification) GetFcm added in v4.1.3 

func (x *PushNotification) GetFcm() *FcmPushNotification

func (*PushNotification) GetHms added in v4.1.3 

func (x *PushNotification) GetHms() *HmsPushNotification

func (*PushNotification) GetUid added in v4.1.3 

func (x *PushNotification) GetUid() string

func (*PushNotification) ProtoMessage added in v4.1.3 

func (*PushNotification) ProtoMessage()

func (*PushNotification) ProtoReflect added in v4.1.3 

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

func (*PushNotification) Reset added in v4.1.3 

func (x *PushNotification) Reset()

func (*PushNotification) String added in v4.1.3 

func (x *PushNotification) String() string

type PushRecipient added in v4.1.3 

type PushRecipient struct {
	DeviceIds    []string `protobuf:"bytes,1,rep,name=device_ids,json=deviceIds,proto3" json:"device_ids,omitempty"`
	Topics       []string `protobuf:"bytes,2,rep,name=topics,proto3" json:"topics,omitempty"`
	FcmTokens    []string `protobuf:"bytes,3,rep,name=fcm_tokens,json=fcmTokens,proto3" json:"fcm_tokens,omitempty"`
	FcmTopic     string   `protobuf:"bytes,4,opt,name=fcm_topic,json=fcmTopic,proto3" json:"fcm_topic,omitempty"`
	FcmCondition string   `protobuf:"bytes,5,opt,name=fcm_condition,json=fcmCondition,proto3" json:"fcm_condition,omitempty"`
	HmsTokens    []string `protobuf:"bytes,6,rep,name=hms_tokens,json=hmsTokens,proto3" json:"hms_tokens,omitempty"`
	HmsTopic     string   `protobuf:"bytes,7,opt,name=hms_topic,json=hmsTopic,proto3" json:"hms_topic,omitempty"`
	HmsCondition string   `protobuf:"bytes,8,opt,name=hms_condition,json=hmsCondition,proto3" json:"hms_condition,omitempty"`
	ApnsTokens   []string `protobuf:"bytes,9,rep,name=apns_tokens,json=apnsTokens,proto3" json:"apns_tokens,omitempty"`
	// contains filtered or unexported fields
}

func (*PushRecipient) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use PushRecipient.ProtoReflect.Descriptor instead.

func (*PushRecipient) GetApnsTokens added in v4.1.3 

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

func (*PushRecipient) GetDeviceIds added in v4.1.3 

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

func (*PushRecipient) GetFcmCondition added in v4.1.3 

func (x *PushRecipient) GetFcmCondition() string

func (*PushRecipient) GetFcmTokens added in v4.1.3 

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

func (*PushRecipient) GetFcmTopic added in v4.1.3 

func (x *PushRecipient) GetFcmTopic() string

func (*PushRecipient) GetHmsCondition added in v4.1.3 

func (x *PushRecipient) GetHmsCondition() string

func (*PushRecipient) GetHmsTokens added in v4.1.3 

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

func (*PushRecipient) GetHmsTopic added in v4.1.3 

func (x *PushRecipient) GetHmsTopic() string

func (*PushRecipient) GetTopics added in v4.1.3 

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

func (*PushRecipient) ProtoMessage added in v4.1.3 

func (*PushRecipient) ProtoMessage()

func (*PushRecipient) ProtoReflect added in v4.1.3 

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

func (*PushRecipient) Reset added in v4.1.3 

func (x *PushRecipient) Reset()

func (*PushRecipient) String added in v4.1.3 

func (x *PushRecipient) String() string

type RPCRequest 

type RPCRequest struct {
	Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	Params Raw    `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 Raw `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 Raw 

type Raw []byte

Raw type used by Centrifugo as type for fields in structs which value we want to left untouched. For example custom application specific JSON payload data in published message. This is very similar to json.RawMessage type.

func (Raw) MarshalJSON 

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

MarshalJSON returns *r as the JSON encoding of r.

func (*Raw) UnmarshalJSON 

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

UnmarshalJSON sets *r to a copy of data.

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     Raw    `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               Raw                         `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	Publish              *PublishResult              `protobuf:"bytes,4,opt,name=publish,proto3" json:"publish,omitempty"`
	Broadcast            *BroadcastResult            `protobuf:"bytes,5,opt,name=broadcast,proto3" json:"broadcast,omitempty"`
	Subscribe            *SubscribeResult            `protobuf:"bytes,6,opt,name=subscribe,proto3" json:"subscribe,omitempty"`
	Unsubscribe          *UnsubscribeResult          `protobuf:"bytes,7,opt,name=unsubscribe,proto3" json:"unsubscribe,omitempty"`
	Disconnect           *DisconnectResult           `protobuf:"bytes,8,opt,name=disconnect,proto3" json:"disconnect,omitempty"`
	Presence             *PresenceResult             `protobuf:"bytes,9,opt,name=presence,proto3" json:"presence,omitempty"`
	PresenceStats        *PresenceStatsResult        `protobuf:"bytes,10,opt,name=presence_stats,json=presenceStats,proto3" json:"presence_stats,omitempty"`
	History              *HistoryResult              `protobuf:"bytes,11,opt,name=history,proto3" json:"history,omitempty"`
	HistoryRemove        *HistoryRemoveResult        `protobuf:"bytes,12,opt,name=history_remove,json=historyRemove,proto3" json:"history_remove,omitempty"`
	Info                 *InfoResult                 `protobuf:"bytes,13,opt,name=info,proto3" json:"info,omitempty"`
	Rpc                  *RPCResult                  `protobuf:"bytes,14,opt,name=rpc,proto3" json:"rpc,omitempty"`
	Refresh              *RefreshResult              `protobuf:"bytes,15,opt,name=refresh,proto3" json:"refresh,omitempty"`
	Channels             *ChannelsResult             `protobuf:"bytes,16,opt,name=channels,proto3" json:"channels,omitempty"`
	Connections          *ConnectionsResult          `protobuf:"bytes,17,opt,name=connections,proto3" json:"connections,omitempty"`
	UpdateUserStatus     *UpdateUserStatusResult     `protobuf:"bytes,18,opt,name=update_user_status,json=updateUserStatus,proto3" json:"update_user_status,omitempty"`
	GetUserStatus        *GetUserStatusResult        `protobuf:"bytes,19,opt,name=get_user_status,json=getUserStatus,proto3" json:"get_user_status,omitempty"`
	DeleteUserStatus     *DeleteUserStatusResult     `protobuf:"bytes,20,opt,name=delete_user_status,json=deleteUserStatus,proto3" json:"delete_user_status,omitempty"`
	BlockUser            *BlockUserResult            `protobuf:"bytes,21,opt,name=block_user,json=blockUser,proto3" json:"block_user,omitempty"`
	UnblockUser          *UnblockUserResult          `protobuf:"bytes,22,opt,name=unblock_user,json=unblockUser,proto3" json:"unblock_user,omitempty"`
	RevokeToken          *RevokeTokenResult          `protobuf:"bytes,23,opt,name=revoke_token,json=revokeToken,proto3" json:"revoke_token,omitempty"`
	InvalidateUserTokens *InvalidateUserTokensResult `protobuf:"bytes,24,opt,name=invalidate_user_tokens,json=invalidateUserTokens,proto3" json:"invalidate_user_tokens,omitempty"`
	DeviceRegister       *DeviceRegisterResult       `protobuf:"bytes,25,opt,name=device_register,json=deviceRegister,proto3" json:"device_register,omitempty"`
	DeviceUpdate         *DeviceUpdateResult         `protobuf:"bytes,26,opt,name=device_update,json=deviceUpdate,proto3" json:"device_update,omitempty"`
	DeviceRemove         *DeviceRemoveResult         `protobuf:"bytes,27,opt,name=device_remove,json=deviceRemove,proto3" json:"device_remove,omitempty"`
	DeviceList           *DeviceListResult           `protobuf:"bytes,28,opt,name=device_list,json=deviceList,proto3" json:"device_list,omitempty"`
	DeviceTopicList      *DeviceTopicListResult      `protobuf:"bytes,29,opt,name=device_topic_list,json=deviceTopicList,proto3" json:"device_topic_list,omitempty"`
	DeviceTopicUpdate    *DeviceTopicUpdateResult    `protobuf:"bytes,30,opt,name=device_topic_update,json=deviceTopicUpdate,proto3" json:"device_topic_update,omitempty"`
	UserTopicList        *UserTopicListResult        `protobuf:"bytes,31,opt,name=user_topic_list,json=userTopicList,proto3" json:"user_topic_list,omitempty"`
	UserTopicUpdate      *UserTopicUpdateResult      `protobuf:"bytes,32,opt,name=user_topic_update,json=userTopicUpdate,proto3" json:"user_topic_update,omitempty"`
	SendPushNotification *SendPushNotificationResult `protobuf:"bytes,33,opt,name=send_push_notification,json=sendPushNotification,proto3" json:"send_push_notification,omitempty"`
	UpdatePushStatus     *UpdatePushStatusResult     `protobuf:"bytes,34,opt,name=update_push_status,json=updatePushStatus,proto3" json:"update_push_status,omitempty"`
	// contains filtered or unexported fields
}

func (*Reply) Descriptor deprecated 

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

Deprecated: Use Reply.ProtoReflect.Descriptor instead.

func (*Reply) GetBlockUser added in v4.1.3 

func (x *Reply) GetBlockUser() *BlockUserResult

func (*Reply) GetBroadcast added in v4.1.3 

func (x *Reply) GetBroadcast() *BroadcastResult

func (*Reply) GetChannels added in v4.1.3 

func (x *Reply) GetChannels() *ChannelsResult

func (*Reply) GetConnections added in v4.1.3 

func (x *Reply) GetConnections() *ConnectionsResult

func (*Reply) GetDeleteUserStatus added in v4.1.3 

func (x *Reply) GetDeleteUserStatus() *DeleteUserStatusResult

func (*Reply) GetDeviceList added in v4.1.3 

func (x *Reply) GetDeviceList() *DeviceListResult

func (*Reply) GetDeviceRegister added in v4.1.3 

func (x *Reply) GetDeviceRegister() *DeviceRegisterResult

func (*Reply) GetDeviceRemove added in v4.1.3 

func (x *Reply) GetDeviceRemove() *DeviceRemoveResult

func (*Reply) GetDeviceTopicList added in v4.1.3 

func (x *Reply) GetDeviceTopicList() *DeviceTopicListResult

func (*Reply) GetDeviceTopicUpdate added in v4.1.3 

func (x *Reply) GetDeviceTopicUpdate() *DeviceTopicUpdateResult

func (*Reply) GetDeviceUpdate added in v4.1.3 

func (x *Reply) GetDeviceUpdate() *DeviceUpdateResult

func (*Reply) GetDisconnect added in v4.1.3 

func (x *Reply) GetDisconnect() *DisconnectResult

func (*Reply) GetError 

func (x *Reply) GetError() *Error

func (*Reply) GetGetUserStatus added in v4.1.3 

func (x *Reply) GetGetUserStatus() *GetUserStatusResult

func (*Reply) GetHistory added in v4.1.3 

func (x *Reply) GetHistory() *HistoryResult

func (*Reply) GetHistoryRemove added in v4.1.3 

func (x *Reply) GetHistoryRemove() *HistoryRemoveResult

func (*Reply) GetId 

func (x *Reply) GetId() uint32

func (*Reply) GetInfo added in v4.1.3 

func (x *Reply) GetInfo() *InfoResult

func (*Reply) GetInvalidateUserTokens added in v4.1.3 

func (x *Reply) GetInvalidateUserTokens() *InvalidateUserTokensResult

func (*Reply) GetPresence added in v4.1.3 

func (x *Reply) GetPresence() *PresenceResult

func (*Reply) GetPresenceStats added in v4.1.3 

func (x *Reply) GetPresenceStats() *PresenceStatsResult

func (*Reply) GetPublish added in v4.1.3 

func (x *Reply) GetPublish() *PublishResult

func (*Reply) GetRefresh added in v4.1.3 

func (x *Reply) GetRefresh() *RefreshResult

func (*Reply) GetResult 

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

func (*Reply) GetRevokeToken added in v4.1.3 

func (x *Reply) GetRevokeToken() *RevokeTokenResult

func (*Reply) GetRpc added in v4.1.3 

func (x *Reply) GetRpc() *RPCResult

func (*Reply) GetSendPushNotification added in v4.1.3 

func (x *Reply) GetSendPushNotification() *SendPushNotificationResult

func (*Reply) GetSubscribe added in v4.1.3 

func (x *Reply) GetSubscribe() *SubscribeResult

func (*Reply) GetUnblockUser added in v4.1.3 

func (x *Reply) GetUnblockUser() *UnblockUserResult

func (*Reply) GetUnsubscribe added in v4.1.3 

func (x *Reply) GetUnsubscribe() *UnsubscribeResult

func (*Reply) GetUpdatePushStatus added in v4.1.3 

func (x *Reply) GetUpdatePushStatus() *UpdatePushStatusResult

func (*Reply) GetUpdateUserStatus added in v4.1.3 

func (x *Reply) GetUpdateUserStatus() *UpdateUserStatusResult

func (*Reply) GetUserTopicList added in v4.1.3 

func (x *Reply) GetUserTopicList() *UserTopicListResult

func (*Reply) GetUserTopicUpdate added in v4.1.3 

func (x *Reply) GetUserTopicUpdate() *UserTopicUpdateResult

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 ReplyEncoder 

type ReplyEncoder interface {
	Reset()
	Encode(*Reply) error
	Finish() []byte
}

ReplyEncoder ...

func GetReplyEncoder 

func GetReplyEncoder() ReplyEncoder

GetReplyEncoder ...

type RequestDecoder added in v4.1.3 

type RequestDecoder interface {
	DecodeBatch([]byte) (*BatchRequest, error)
	DecodePublish([]byte) (*PublishRequest, error)
	DecodeBroadcast([]byte) (*BroadcastRequest, error)
	DecodeSubscribe([]byte) (*SubscribeRequest, error)
	DecodeUnsubscribe([]byte) (*UnsubscribeRequest, error)
	DecodeDisconnect([]byte) (*DisconnectRequest, error)
	DecodePresence([]byte) (*PresenceRequest, error)
	DecodePresenceStats([]byte) (*PresenceStatsRequest, error)
	DecodeHistory([]byte) (*HistoryRequest, error)
	DecodeHistoryRemove([]byte) (*HistoryRemoveRequest, error)
	DecodeInfo([]byte) (*InfoRequest, error)
	DecodeRPC([]byte) (*RPCRequest, error)
	DecodeRefresh([]byte) (*RefreshRequest, error)
	DecodeChannels([]byte) (*ChannelsRequest, error)
}

RequestDecoder ...

func GetParamsDecoder 

func GetParamsDecoder() RequestDecoder

GetParamsDecoder ...

type ResponseEncoder added in v4.1.3 

type ResponseEncoder interface {
	EncodePublish(*PublishResponse) ([]byte, error)
	EncodeBroadcast(*BroadcastResponse) ([]byte, error)
	EncodeSubscribe(*SubscribeResponse) ([]byte, error)
	EncodeUnsubscribe(*UnsubscribeResponse) ([]byte, error)
	EncodeDisconnect(*DisconnectResponse) ([]byte, error)
	EncodePresence(*PresenceResponse) ([]byte, error)
	EncodePresenceStats(*PresenceStatsResponse) ([]byte, error)
	EncodeHistory(*HistoryResponse) ([]byte, error)
	EncodeHistoryRemove(*HistoryRemoveResponse) ([]byte, error)
	EncodeInfo(*InfoResponse) ([]byte, error)
	EncodeRPC(*RPCResponse) ([]byte, error)
	EncodeRefresh(*RefreshResponse) ([]byte, error)
	EncodeChannels(*ChannelsResponse) ([]byte, error)
	EncodeBatch(response *BatchResponse) ([]byte, error)
}

ResponseEncoder ...

type ResultEncoder 

type ResultEncoder interface {
	EncodePublish(*PublishResult) ([]byte, error)
	EncodeBroadcast(*BroadcastResult) ([]byte, error)
	EncodeSubscribe(*SubscribeResult) ([]byte, error)
	EncodeUnsubscribe(*UnsubscribeResult) ([]byte, error)
	EncodeDisconnect(*DisconnectResult) ([]byte, error)
	EncodePresence(*PresenceResult) ([]byte, error)
	EncodePresenceStats(*PresenceStatsResult) ([]byte, error)
	EncodeHistory(*HistoryResult) ([]byte, error)
	EncodeHistoryRemove(*HistoryRemoveResult) ([]byte, error)
	EncodeInfo(*InfoResult) ([]byte, error)
	EncodeRPC(*RPCResult) ([]byte, error)
	EncodeRefresh(*RefreshResult) ([]byte, error)
	EncodeChannels(*ChannelsResult) ([]byte, error)
}

ResultEncoder ...

func GetResultEncoder 

func GetResultEncoder() ResultEncoder

GetResultEncoder ...

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 SendPushNotificationRequest added in v4.1.3 

type SendPushNotificationRequest struct {
	Recipient    *PushRecipient    `protobuf:"bytes,1,opt,name=recipient,proto3" json:"recipient,omitempty"`
	Notification *PushNotification `protobuf:"bytes,2,opt,name=notification,proto3" json:"notification,omitempty"`
	// contains filtered or unexported fields
}

func (*SendPushNotificationRequest) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use SendPushNotificationRequest.ProtoReflect.Descriptor instead.

func (*SendPushNotificationRequest) GetNotification added in v4.1.3 

func (x *SendPushNotificationRequest) GetNotification() *PushNotification

func (*SendPushNotificationRequest) GetRecipient added in v4.1.3 

func (x *SendPushNotificationRequest) GetRecipient() *PushRecipient

func (*SendPushNotificationRequest) ProtoMessage added in v4.1.3 

func (*SendPushNotificationRequest) ProtoMessage()

func (*SendPushNotificationRequest) ProtoReflect added in v4.1.3 

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

func (*SendPushNotificationRequest) Reset added in v4.1.3 

func (x *SendPushNotificationRequest) Reset()

func (*SendPushNotificationRequest) String added in v4.1.3 

func (x *SendPushNotificationRequest) String() string

type SendPushNotificationResponse added in v4.1.3 

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

func (*SendPushNotificationResponse) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use SendPushNotificationResponse.ProtoReflect.Descriptor instead.

func (*SendPushNotificationResponse) GetError added in v4.1.3 

func (x *SendPushNotificationResponse) GetError() *Error

func (*SendPushNotificationResponse) GetResult added in v4.1.3 

func (x *SendPushNotificationResponse) GetResult() *SendPushNotificationResult

func (*SendPushNotificationResponse) ProtoMessage added in v4.1.3 

func (*SendPushNotificationResponse) ProtoMessage()

func (*SendPushNotificationResponse) ProtoReflect added in v4.1.3 

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

func (*SendPushNotificationResponse) Reset added in v4.1.3 

func (x *SendPushNotificationResponse) Reset()

func (*SendPushNotificationResponse) String added in v4.1.3 

func (x *SendPushNotificationResponse) String() string

type SendPushNotificationResult added in v4.1.3 

type SendPushNotificationResult struct {
	Uid string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"` // Unique identifier of notification send request (not a FCM message id).
	// contains filtered or unexported fields
}

func (*SendPushNotificationResult) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use SendPushNotificationResult.ProtoReflect.Descriptor instead.

func (*SendPushNotificationResult) GetUid added in v4.1.3 

func (x *SendPushNotificationResult) GetUid() string

func (*SendPushNotificationResult) ProtoMessage added in v4.1.3 

func (*SendPushNotificationResult) ProtoMessage()

func (*SendPushNotificationResult) ProtoReflect added in v4.1.3 

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

func (*SendPushNotificationResult) Reset added in v4.1.3 

func (x *SendPushNotificationResult) Reset()

func (*SendPushNotificationResult) String added in v4.1.3 

func (x *SendPushNotificationResult) 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         Raw                      `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         Raw                      `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 UnimplementedCentrifugoApiServer 

type UnimplementedCentrifugoApiServer struct {
}

UnimplementedCentrifugoApiServer must be embedded to have forward compatible implementations.

func (UnimplementedCentrifugoApiServer) Batch added in v4.1.3 

func (UnimplementedCentrifugoApiServer) Batch(context.Context, *BatchRequest) (*BatchResponse, error)

func (UnimplementedCentrifugoApiServer) BlockUser 

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

func (UnimplementedCentrifugoApiServer) Broadcast 

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

func (UnimplementedCentrifugoApiServer) Channels 

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

func (UnimplementedCentrifugoApiServer) Connections 

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

func (UnimplementedCentrifugoApiServer) DeleteUserStatus 

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

func (UnimplementedCentrifugoApiServer) DeviceList added in v4.1.3 

func (UnimplementedCentrifugoApiServer) DeviceList(context.Context, *DeviceListRequest) (*DeviceListResponse, error)

func (UnimplementedCentrifugoApiServer) DeviceRegister added in v4.1.3 

func (UnimplementedCentrifugoApiServer) DeviceRegister(context.Context, *DeviceRegisterRequest) (*DeviceRegisterResponse, error)

func (UnimplementedCentrifugoApiServer) DeviceRemove added in v4.1.3 

func (UnimplementedCentrifugoApiServer) DeviceRemove(context.Context, *DeviceRemoveRequest) (*DeviceRemoveResponse, error)

func (UnimplementedCentrifugoApiServer) DeviceTopicList added in v4.1.3 

func (UnimplementedCentrifugoApiServer) DeviceTopicList(context.Context, *DeviceTopicListRequest) (*DeviceTopicListResponse, error)

func (UnimplementedCentrifugoApiServer) DeviceTopicUpdate added in v4.1.3 

func (UnimplementedCentrifugoApiServer) DeviceTopicUpdate(context.Context, *DeviceTopicUpdateRequest) (*DeviceTopicUpdateResponse, error)

func (UnimplementedCentrifugoApiServer) DeviceUpdate added in v4.1.3 

func (UnimplementedCentrifugoApiServer) DeviceUpdate(context.Context, *DeviceUpdateRequest) (*DeviceUpdateResponse, error)

func (UnimplementedCentrifugoApiServer) Disconnect 

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

func (UnimplementedCentrifugoApiServer) GetUserStatus 

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

func (UnimplementedCentrifugoApiServer) History 

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

func (UnimplementedCentrifugoApiServer) HistoryRemove 

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

func (UnimplementedCentrifugoApiServer) Info 

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

func (UnimplementedCentrifugoApiServer) InvalidateUserTokens 

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

func (UnimplementedCentrifugoApiServer) Presence 

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

func (UnimplementedCentrifugoApiServer) PresenceStats 

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

func (UnimplementedCentrifugoApiServer) Publish 

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

func (UnimplementedCentrifugoApiServer) RPC 

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

func (UnimplementedCentrifugoApiServer) Refresh 

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

func (UnimplementedCentrifugoApiServer) RevokeToken 

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

func (UnimplementedCentrifugoApiServer) SendPushNotification added in v4.1.3 

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

func (UnimplementedCentrifugoApiServer) Subscribe 

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

func (UnimplementedCentrifugoApiServer) UnblockUser 

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

func (UnimplementedCentrifugoApiServer) Unsubscribe 

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

func (UnimplementedCentrifugoApiServer) UpdatePushStatus added in v4.1.4 

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

func (UnimplementedCentrifugoApiServer) UpdateUserStatus 

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

func (UnimplementedCentrifugoApiServer) UserTopicList added in v4.1.3 

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

func (UnimplementedCentrifugoApiServer) UserTopicUpdate added in v4.1.3 

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

type UnsafeCentrifugoApiServer 

type UnsafeCentrifugoApiServer interface {
	// contains filtered or unexported methods
}

UnsafeCentrifugoApiServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CentrifugoApiServer will result in compilation errors.

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 UpdatePushStatusRequest added in v4.1.3 

type UpdatePushStatusRequest struct {
	Uid      string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
	Status   string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	DeviceId string `protobuf:"bytes,3,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	MsgId    string `protobuf:"bytes,4,opt,name=msg_id,json=msgId,proto3" json:"msg_id,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdatePushStatusRequest) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use UpdatePushStatusRequest.ProtoReflect.Descriptor instead.

func (*UpdatePushStatusRequest) GetDeviceId added in v4.1.3 

func (x *UpdatePushStatusRequest) GetDeviceId() string

func (*UpdatePushStatusRequest) GetMsgId added in v4.1.3 

func (x *UpdatePushStatusRequest) GetMsgId() string

func (*UpdatePushStatusRequest) GetStatus added in v4.1.3 

func (x *UpdatePushStatusRequest) GetStatus() string

func (*UpdatePushStatusRequest) GetUid added in v4.1.3 

func (x *UpdatePushStatusRequest) GetUid() string

func (*UpdatePushStatusRequest) ProtoMessage added in v4.1.3 

func (*UpdatePushStatusRequest) ProtoMessage()

func (*UpdatePushStatusRequest) ProtoReflect added in v4.1.3 

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

func (*UpdatePushStatusRequest) Reset added in v4.1.3 

func (x *UpdatePushStatusRequest) Reset()

func (*UpdatePushStatusRequest) String added in v4.1.3 

func (x *UpdatePushStatusRequest) String() string

type UpdatePushStatusResponse added in v4.1.3 

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

func (*UpdatePushStatusResponse) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use UpdatePushStatusResponse.ProtoReflect.Descriptor instead.

func (*UpdatePushStatusResponse) GetError added in v4.1.3 

func (x *UpdatePushStatusResponse) GetError() *Error

func (*UpdatePushStatusResponse) GetResult added in v4.1.3 

func (x *UpdatePushStatusResponse) GetResult() *UpdatePushStatusResult

func (*UpdatePushStatusResponse) ProtoMessage added in v4.1.3 

func (*UpdatePushStatusResponse) ProtoMessage()

func (*UpdatePushStatusResponse) ProtoReflect added in v4.1.3 

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

func (*UpdatePushStatusResponse) Reset added in v4.1.3 

func (x *UpdatePushStatusResponse) Reset()

func (*UpdatePushStatusResponse) String added in v4.1.3 

func (x *UpdatePushStatusResponse) String() string

type UpdatePushStatusResult added in v4.1.3 

type UpdatePushStatusResult struct {
	// contains filtered or unexported fields
}

func (*UpdatePushStatusResult) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use UpdatePushStatusResult.ProtoReflect.Descriptor instead.

func (*UpdatePushStatusResult) ProtoMessage added in v4.1.3 

func (*UpdatePushStatusResult) ProtoMessage()

func (*UpdatePushStatusResult) ProtoReflect added in v4.1.3 

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

func (*UpdatePushStatusResult) Reset added in v4.1.3 

func (x *UpdatePushStatusResult) Reset()

func (*UpdatePushStatusResult) String added in v4.1.3 

func (x *UpdatePushStatusResult) 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

type UserTopic added in v4.1.3 

type UserTopic struct {
	Id    string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	User  string `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	Topic string `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

func (*UserTopic) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use UserTopic.ProtoReflect.Descriptor instead.

func (*UserTopic) GetId added in v4.1.3 

func (x *UserTopic) GetId() string

func (*UserTopic) GetTopic added in v4.1.3 

func (x *UserTopic) GetTopic() string

func (*UserTopic) GetUser added in v4.1.3 

func (x *UserTopic) GetUser() string

func (*UserTopic) ProtoMessage added in v4.1.3 

func (*UserTopic) ProtoMessage()

func (*UserTopic) ProtoReflect added in v4.1.3 

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

func (*UserTopic) Reset added in v4.1.3 

func (x *UserTopic) Reset()

func (*UserTopic) String added in v4.1.3 

func (x *UserTopic) String() string

type UserTopicListRequest added in v4.1.3 

type UserTopicListRequest struct {
	Users       []string `protobuf:"bytes,1,rep,name=users,proto3" json:"users,omitempty"`
	Topics      []string `protobuf:"bytes,2,rep,name=topics,proto3" json:"topics,omitempty"`
	TopicPrefix string   `protobuf:"bytes,3,opt,name=topic_prefix,json=topicPrefix,proto3" json:"topic_prefix,omitempty"`
	Since       string   `protobuf:"bytes,4,opt,name=since,proto3" json:"since,omitempty"`
	Limit       int32    `protobuf:"varint,5,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*UserTopicListRequest) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use UserTopicListRequest.ProtoReflect.Descriptor instead.

func (*UserTopicListRequest) GetLimit added in v4.1.3 

func (x *UserTopicListRequest) GetLimit() int32

func (*UserTopicListRequest) GetSince added in v4.1.3 

func (x *UserTopicListRequest) GetSince() string

func (*UserTopicListRequest) GetTopicPrefix added in v4.1.3 

func (x *UserTopicListRequest) GetTopicPrefix() string

func (*UserTopicListRequest) GetTopics added in v4.1.3 

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

func (*UserTopicListRequest) GetUsers added in v4.1.3 

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

func (*UserTopicListRequest) ProtoMessage added in v4.1.3 

func (*UserTopicListRequest) ProtoMessage()

func (*UserTopicListRequest) ProtoReflect added in v4.1.3 

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

func (*UserTopicListRequest) Reset added in v4.1.3 

func (x *UserTopicListRequest) Reset()

func (*UserTopicListRequest) String added in v4.1.3 

func (x *UserTopicListRequest) String() string

type UserTopicListResponse added in v4.1.3 

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

func (*UserTopicListResponse) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use UserTopicListResponse.ProtoReflect.Descriptor instead.

func (*UserTopicListResponse) GetError added in v4.1.3 

func (x *UserTopicListResponse) GetError() *Error

func (*UserTopicListResponse) GetResult added in v4.1.3 

func (x *UserTopicListResponse) GetResult() *UserTopicListResult

func (*UserTopicListResponse) ProtoMessage added in v4.1.3 

func (*UserTopicListResponse) ProtoMessage()

func (*UserTopicListResponse) ProtoReflect added in v4.1.3 

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

func (*UserTopicListResponse) Reset added in v4.1.3 

func (x *UserTopicListResponse) Reset()

func (*UserTopicListResponse) String added in v4.1.3 

func (x *UserTopicListResponse) String() string

type UserTopicListResult added in v4.1.3 

type UserTopicListResult struct {
	Items   []*UserTopic `protobuf:"bytes,1,rep,name=items,proto3" json:"items"`
	HasMore bool         `protobuf:"varint,2,opt,name=has_more,json=hasMore,proto3" json:"has_more"`
	// contains filtered or unexported fields
}

func (*UserTopicListResult) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use UserTopicListResult.ProtoReflect.Descriptor instead.

func (*UserTopicListResult) GetHasMore added in v4.1.3 

func (x *UserTopicListResult) GetHasMore() bool

func (*UserTopicListResult) GetItems added in v4.1.3 

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

func (*UserTopicListResult) ProtoMessage added in v4.1.3 

func (*UserTopicListResult) ProtoMessage()

func (*UserTopicListResult) ProtoReflect added in v4.1.3 

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

func (*UserTopicListResult) Reset added in v4.1.3 

func (x *UserTopicListResult) Reset()

func (*UserTopicListResult) String added in v4.1.3 

func (x *UserTopicListResult) String() string

type UserTopicUpdateRequest added in v4.1.3 

type UserTopicUpdateRequest struct {
	User   string   `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Op     string   `protobuf:"bytes,2,opt,name=op,proto3" json:"op,omitempty"` // add | remove | set
	Topics []string `protobuf:"bytes,3,rep,name=topics,proto3" json:"topics,omitempty"`
	// contains filtered or unexported fields
}

func (*UserTopicUpdateRequest) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use UserTopicUpdateRequest.ProtoReflect.Descriptor instead.

func (*UserTopicUpdateRequest) GetOp added in v4.1.3 

func (x *UserTopicUpdateRequest) GetOp() string

func (*UserTopicUpdateRequest) GetTopics added in v4.1.3 

func (x *UserTopicUpdateRequest) GetTopics() []string

func (*UserTopicUpdateRequest) GetUser added in v4.1.3 

func (x *UserTopicUpdateRequest) GetUser() string

func (*UserTopicUpdateRequest) ProtoMessage added in v4.1.3 

func (*UserTopicUpdateRequest) ProtoMessage()

func (*UserTopicUpdateRequest) ProtoReflect added in v4.1.3 

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

func (*UserTopicUpdateRequest) Reset added in v4.1.3 

func (x *UserTopicUpdateRequest) Reset()

func (*UserTopicUpdateRequest) String added in v4.1.3 

func (x *UserTopicUpdateRequest) String() string

type UserTopicUpdateResponse added in v4.1.3 

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

func (*UserTopicUpdateResponse) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use UserTopicUpdateResponse.ProtoReflect.Descriptor instead.

func (*UserTopicUpdateResponse) GetError added in v4.1.3 

func (x *UserTopicUpdateResponse) GetError() *Error

func (*UserTopicUpdateResponse) GetResult added in v4.1.3 

func (x *UserTopicUpdateResponse) GetResult() *UserTopicUpdateResult

func (*UserTopicUpdateResponse) ProtoMessage added in v4.1.3 

func (*UserTopicUpdateResponse) ProtoMessage()

func (*UserTopicUpdateResponse) ProtoReflect added in v4.1.3 

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

func (*UserTopicUpdateResponse) Reset added in v4.1.3 

func (x *UserTopicUpdateResponse) Reset()

func (*UserTopicUpdateResponse) String added in v4.1.3 

func (x *UserTopicUpdateResponse) String() string

type UserTopicUpdateResult added in v4.1.3 

type UserTopicUpdateResult struct {
	// contains filtered or unexported fields
}

func (*UserTopicUpdateResult) Descriptor deprecated added in v4.1.3 

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

Deprecated: Use UserTopicUpdateResult.ProtoReflect.Descriptor instead.

func (*UserTopicUpdateResult) ProtoMessage added in v4.1.3 

func (*UserTopicUpdateResult) ProtoMessage()

func (*UserTopicUpdateResult) ProtoReflect added in v4.1.3 

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

func (*UserTopicUpdateResult) Reset added in v4.1.3 

func (x *UserTopicUpdateResult) Reset()

func (*UserTopicUpdateResult) String added in v4.1.3 

func (x *UserTopicUpdateResult) 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.