v1

package
v4.13.0 Latest Latest
Warning

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

 Go to latest Published: Jun 25, 2024 License: MIT Imports: 8 Imported by: 2

Documentation

Index

Constants

View Source 
const (
	CentrifugoApi_Batch_FullMethodName                = "/centrifugal.centrifugo.api.CentrifugoApi/Batch"
	CentrifugoApi_Publish_FullMethodName              = "/centrifugal.centrifugo.api.CentrifugoApi/Publish"
	CentrifugoApi_Broadcast_FullMethodName            = "/centrifugal.centrifugo.api.CentrifugoApi/Broadcast"
	CentrifugoApi_Subscribe_FullMethodName            = "/centrifugal.centrifugo.api.CentrifugoApi/Subscribe"
	CentrifugoApi_Unsubscribe_FullMethodName          = "/centrifugal.centrifugo.api.CentrifugoApi/Unsubscribe"
	CentrifugoApi_Disconnect_FullMethodName           = "/centrifugal.centrifugo.api.CentrifugoApi/Disconnect"
	CentrifugoApi_Presence_FullMethodName             = "/centrifugal.centrifugo.api.CentrifugoApi/Presence"
	CentrifugoApi_PresenceStats_FullMethodName        = "/centrifugal.centrifugo.api.CentrifugoApi/PresenceStats"
	CentrifugoApi_History_FullMethodName              = "/centrifugal.centrifugo.api.CentrifugoApi/History"
	CentrifugoApi_HistoryRemove_FullMethodName        = "/centrifugal.centrifugo.api.CentrifugoApi/HistoryRemove"
	CentrifugoApi_Info_FullMethodName                 = "/centrifugal.centrifugo.api.CentrifugoApi/Info"
	CentrifugoApi_RPC_FullMethodName                  = "/centrifugal.centrifugo.api.CentrifugoApi/RPC"
	CentrifugoApi_Refresh_FullMethodName              = "/centrifugal.centrifugo.api.CentrifugoApi/Refresh"
	CentrifugoApi_Channels_FullMethodName             = "/centrifugal.centrifugo.api.CentrifugoApi/Channels"
	CentrifugoApi_Connections_FullMethodName          = "/centrifugal.centrifugo.api.CentrifugoApi/Connections"
	CentrifugoApi_UpdateUserStatus_FullMethodName     = "/centrifugal.centrifugo.api.CentrifugoApi/UpdateUserStatus"
	CentrifugoApi_GetUserStatus_FullMethodName        = "/centrifugal.centrifugo.api.CentrifugoApi/GetUserStatus"
	CentrifugoApi_DeleteUserStatus_FullMethodName     = "/centrifugal.centrifugo.api.CentrifugoApi/DeleteUserStatus"
	CentrifugoApi_BlockUser_FullMethodName            = "/centrifugal.centrifugo.api.CentrifugoApi/BlockUser"
	CentrifugoApi_UnblockUser_FullMethodName          = "/centrifugal.centrifugo.api.CentrifugoApi/UnblockUser"
	CentrifugoApi_RevokeToken_FullMethodName          = "/centrifugal.centrifugo.api.CentrifugoApi/RevokeToken"
	CentrifugoApi_InvalidateUserTokens_FullMethodName = "/centrifugal.centrifugo.api.CentrifugoApi/InvalidateUserTokens"
	CentrifugoApi_DeviceRegister_FullMethodName       = "/centrifugal.centrifugo.api.CentrifugoApi/DeviceRegister"
	CentrifugoApi_DeviceUpdate_FullMethodName         = "/centrifugal.centrifugo.api.CentrifugoApi/DeviceUpdate"
	CentrifugoApi_DeviceRemove_FullMethodName         = "/centrifugal.centrifugo.api.CentrifugoApi/DeviceRemove"
	CentrifugoApi_DeviceList_FullMethodName           = "/centrifugal.centrifugo.api.CentrifugoApi/DeviceList"
	CentrifugoApi_DeviceTopicList_FullMethodName      = "/centrifugal.centrifugo.api.CentrifugoApi/DeviceTopicList"
	CentrifugoApi_DeviceTopicUpdate_FullMethodName    = "/centrifugal.centrifugo.api.CentrifugoApi/DeviceTopicUpdate"
	CentrifugoApi_UserTopicList_FullMethodName        = "/centrifugal.centrifugo.api.CentrifugoApi/UserTopicList"
	CentrifugoApi_UserTopicUpdate_FullMethodName      = "/centrifugal.centrifugo.api.CentrifugoApi/UserTopicUpdate"
	CentrifugoApi_SendPushNotification_FullMethodName = "/centrifugal.centrifugo.api.CentrifugoApi/SendPushNotification"
	CentrifugoApi_UpdatePushStatus_FullMethodName     = "/centrifugal.centrifugo.api.CentrifugoApi/UpdatePushStatus"
	CentrifugoApi_CancelPush_FullMethodName           = "/centrifugal.centrifugo.api.CentrifugoApi/CancelPush"
	CentrifugoApi_RateLimit_FullMethodName            = "/centrifugal.centrifugo.api.CentrifugoApi/RateLimit"
)

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",
		32: "CANCEL_PUSH",
		47: "RATE_LIMIT",
	}
	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,
		"CANCEL_PUSH":            32,
		"RATE_LIMIT":             47,
	}
)

Enum value maps for Command_MethodType.

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,
		},
		{
			MethodName: "CancelPush",
			Handler:    _CentrifugoApi_CancelPush_Handler,
		},
		{
			MethodName: "RateLimit",
			Handler:    _CentrifugoApi_RateLimit_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "centrifugo/api/v1/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_centrifugo_api_v1_api_proto protoreflect.FileDescriptor

Functions

func RegisterCentrifugoApiServer 

func RegisterCentrifugoApiServer(s grpc.ServiceRegistrar, srv CentrifugoApiServer)

Types

type ApnsPushNotification 

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

func (*ApnsPushNotification) Descriptor deprecated 

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

Deprecated: Use ApnsPushNotification.ProtoReflect.Descriptor instead.

func (*ApnsPushNotification) GetHeaders 

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

func (*ApnsPushNotification) GetPayload 

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

func (*ApnsPushNotification) ProtoMessage 

func (*ApnsPushNotification) ProtoMessage()

func (*ApnsPushNotification) ProtoReflect 

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

func (*ApnsPushNotification) Reset 

func (x *ApnsPushNotification) Reset()

func (*ApnsPushNotification) String 

func (x *ApnsPushNotification) String() string

type BatchRequest 

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

func (*BatchRequest) Descriptor deprecated 

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

Deprecated: Use BatchRequest.ProtoReflect.Descriptor instead.

func (*BatchRequest) GetCommands 

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

func (*BatchRequest) GetParallel added in v4.11.0 

func (x *BatchRequest) GetParallel() bool

func (*BatchRequest) ProtoMessage 

func (*BatchRequest) ProtoMessage()

func (*BatchRequest) ProtoReflect 

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

func (*BatchRequest) Reset 

func (x *BatchRequest) Reset()

func (*BatchRequest) String 

func (x *BatchRequest) String() string

type BatchResponse 

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

func (*BatchResponse) Descriptor deprecated 

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

Deprecated: Use BatchResponse.ProtoReflect.Descriptor instead.

func (*BatchResponse) GetReplies 

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

func (*BatchResponse) ProtoMessage 

func (*BatchResponse) ProtoMessage()

func (*BatchResponse) ProtoReflect 

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

func (*BatchResponse) Reset 

func (x *BatchResponse) Reset()

func (*BatchResponse) String 

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           []byte            `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	B64Data        string            `protobuf:"bytes,3,opt,name=b64data,proto3" json:"b64data,omitempty"`
	SkipHistory    bool              `protobuf:"varint,4,opt,name=skip_history,json=skipHistory,proto3" json:"skip_history,omitempty"`
	Tags           map[string]string `` /* 149-byte string literal not displayed */
	IdempotencyKey string            `protobuf:"bytes,6,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
	// 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) GetIdempotencyKey added in v4.11.0 

func (x *BroadcastRequest) GetIdempotencyKey() string

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 CancelPushRequest added in v4.9.0 

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

func (*CancelPushRequest) Descriptor deprecated added in v4.9.0 

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

Deprecated: Use CancelPushRequest.ProtoReflect.Descriptor instead.

func (*CancelPushRequest) GetUid added in v4.9.0 

func (x *CancelPushRequest) GetUid() string

func (*CancelPushRequest) ProtoMessage added in v4.9.0 

func (*CancelPushRequest) ProtoMessage()

func (*CancelPushRequest) ProtoReflect added in v4.9.0 

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

func (*CancelPushRequest) Reset added in v4.9.0 

func (x *CancelPushRequest) Reset()

func (*CancelPushRequest) String added in v4.9.0 

func (x *CancelPushRequest) String() string

type CancelPushResponse added in v4.9.0 

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

func (*CancelPushResponse) Descriptor deprecated added in v4.9.0 

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

Deprecated: Use CancelPushResponse.ProtoReflect.Descriptor instead.

func (*CancelPushResponse) GetError added in v4.9.0 

func (x *CancelPushResponse) GetError() *Error

func (*CancelPushResponse) GetResult added in v4.9.0 

func (x *CancelPushResponse) GetResult() *CancelPushResult

func (*CancelPushResponse) ProtoMessage added in v4.9.0 

func (*CancelPushResponse) ProtoMessage()

func (*CancelPushResponse) ProtoReflect added in v4.9.0 

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

func (*CancelPushResponse) Reset added in v4.9.0 

func (x *CancelPushResponse) Reset()

func (*CancelPushResponse) String added in v4.9.0 

func (x *CancelPushResponse) String() string

type CancelPushResult added in v4.9.0 

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

func (*CancelPushResult) Descriptor deprecated added in v4.9.0 

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

Deprecated: Use CancelPushResult.ProtoReflect.Descriptor instead.

func (*CancelPushResult) ProtoMessage added in v4.9.0 

func (*CancelPushResult) ProtoMessage()

func (*CancelPushResult) ProtoReflect added in v4.9.0 

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

func (*CancelPushResult) Reset added in v4.9.0 

func (x *CancelPushResult) Reset()

func (*CancelPushResult) String added in v4.9.0 

func (x *CancelPushResult) 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)
	CancelPush(ctx context.Context, in *CancelPushRequest, opts ...grpc.CallOption) (*CancelPushResponse, error)
	RateLimit(ctx context.Context, in *RateLimitRequest, opts ...grpc.CallOption) (*RateLimitResponse, 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)
	CancelPush(context.Context, *CancelPushRequest) (*CancelPushResponse, error)
	RateLimit(context.Context, *RateLimitRequest) (*RateLimitResponse, error)
}

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

type ChannelContext 

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

func (*ChannelContext) Descriptor deprecated 

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

Deprecated: Use ChannelContext.ProtoReflect.Descriptor instead.

func (*ChannelContext) GetSource 

func (x *ChannelContext) GetSource() uint32

func (*ChannelContext) ProtoMessage 

func (*ChannelContext) ProtoMessage()

func (*ChannelContext) ProtoReflect 

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

func (*ChannelContext) Reset 

func (x *ChannelContext) Reset()

func (*ChannelContext) String 

func (x *ChannelContext) String() string

type ChannelInfo 

type ChannelInfo struct {
	NumClients uint32 `protobuf:"varint,1,opt,name=num_clients,json=numClients,proto3" json:"num_clients,omitempty"`
	// contains filtered or unexported fields
}

func (*ChannelInfo) Descriptor deprecated 

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

Deprecated: Use ChannelInfo.ProtoReflect.Descriptor instead.

func (*ChannelInfo) GetNumClients 

func (x *ChannelInfo) GetNumClients() uint32

func (*ChannelInfo) ProtoMessage 

func (*ChannelInfo) ProtoMessage()

func (*ChannelInfo) ProtoReflect 

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

func (*ChannelInfo) Reset 

func (x *ChannelInfo) Reset()

func (*ChannelInfo) String 

func (x *ChannelInfo) String() string

type ChannelsRequest 

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

func (*ChannelsRequest) Descriptor deprecated 

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

Deprecated: Use ChannelsRequest.ProtoReflect.Descriptor instead.

func (*ChannelsRequest) GetPattern 

func (x *ChannelsRequest) GetPattern() string

func (*ChannelsRequest) ProtoMessage 

func (*ChannelsRequest) ProtoMessage()

func (*ChannelsRequest) ProtoReflect 

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

func (*ChannelsRequest) Reset 

func (x *ChannelsRequest) Reset()

func (*ChannelsRequest) String 

func (x *ChannelsRequest) String() string

type ChannelsResponse 

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

func (*ChannelsResponse) Descriptor deprecated 

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

Deprecated: Use ChannelsResponse.ProtoReflect.Descriptor instead.

func (*ChannelsResponse) GetError 

func (x *ChannelsResponse) GetError() *Error

func (*ChannelsResponse) GetResult 

func (x *ChannelsResponse) GetResult() *ChannelsResult

func (*ChannelsResponse) ProtoMessage 

func (*ChannelsResponse) ProtoMessage()

func (*ChannelsResponse) ProtoReflect 

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

func (*ChannelsResponse) Reset 

func (x *ChannelsResponse) Reset()

func (*ChannelsResponse) String 

func (x *ChannelsResponse) String() string

type ChannelsResult 

type ChannelsResult struct {
	Channels map[string]*ChannelInfo `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ChannelsResult) Descriptor deprecated 

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

Deprecated: Use ChannelsResult.ProtoReflect.Descriptor instead.

func (*ChannelsResult) GetChannels 

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

func (*ChannelsResult) ProtoMessage 

func (*ChannelsResult) ProtoMessage()

func (*ChannelsResult) ProtoReflect 

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

func (*ChannelsResult) Reset 

func (x *ChannelsResult) Reset()

func (*ChannelsResult) String 

func (x *ChannelsResult) String() string

type ClientInfo 

type ClientInfo struct {
	User     string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Client   string `protobuf:"bytes,2,opt,name=client,proto3" json:"client,omitempty"`
	ConnInfo []byte `protobuf:"bytes,3,opt,name=conn_info,json=connInfo,proto3" json:"conn_info,omitempty"`
	ChanInfo []byte `protobuf:"bytes,4,opt,name=chan_info,json=chanInfo,proto3" json:"chan_info,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientInfo) Descriptor deprecated 

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

Deprecated: Use ClientInfo.ProtoReflect.Descriptor instead.

func (*ClientInfo) GetChanInfo 

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

func (*ClientInfo) GetClient 

func (x *ClientInfo) GetClient() string

func (*ClientInfo) GetConnInfo 

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

func (*ClientInfo) GetUser 

func (x *ClientInfo) GetUser() string

func (*ClientInfo) ProtoMessage 

func (*ClientInfo) ProtoMessage()

func (*ClientInfo) ProtoReflect 

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

func (*ClientInfo) Reset 

func (x *ClientInfo) Reset()

func (*ClientInfo) String 

func (x *ClientInfo) String() string

type Command 

type Command struct {
	Id                   uint32                       `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Method               Command_MethodType           `protobuf:"varint,2,opt,name=method,proto3,enum=centrifugal.centrifugo.api.Command_MethodType" json:"method,omitempty"`
	Params               []byte                       `protobuf:"bytes,3,opt,name=params,proto3" json:"params,omitempty"`
	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"`
	CancelPush           *CancelPushRequest           `protobuf:"bytes,35,opt,name=cancel_push,json=cancelPush,proto3" json:"cancel_push,omitempty"`
	RateLimit            *RateLimitRequest            `protobuf:"bytes,50,opt,name=rate_limit,json=rateLimit,proto3" json:"rate_limit,omitempty"`
	// contains filtered or unexported fields
}

func (*Command) Descriptor deprecated 

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

Deprecated: Use Command.ProtoReflect.Descriptor instead.

func (*Command) GetBlockUser 

func (x *Command) GetBlockUser() *BlockUserRequest

func (*Command) GetBroadcast 

func (x *Command) GetBroadcast() *BroadcastRequest

func (*Command) GetCancelPush added in v4.9.0 

func (x *Command) GetCancelPush() *CancelPushRequest

func (*Command) GetChannels 

func (x *Command) GetChannels() *ChannelsRequest

func (*Command) GetConnections 

func (x *Command) GetConnections() *ConnectionsRequest

func (*Command) GetDeleteUserStatus 

func (x *Command) GetDeleteUserStatus() *DeleteUserStatusRequest

func (*Command) GetDeviceList 

func (x *Command) GetDeviceList() *DeviceListRequest

func (*Command) GetDeviceRegister 

func (x *Command) GetDeviceRegister() *DeviceRegisterRequest

func (*Command) GetDeviceRemove 

func (x *Command) GetDeviceRemove() *DeviceRemoveRequest

func (*Command) GetDeviceTopicList added in v4.9.0 

func (x *Command) GetDeviceTopicList() *DeviceTopicListRequest

func (*Command) GetDeviceTopicUpdate added in v4.9.0 

func (x *Command) GetDeviceTopicUpdate() *DeviceTopicUpdateRequest

func (*Command) GetDeviceUpdate 

func (x *Command) GetDeviceUpdate() *DeviceUpdateRequest

func (*Command) GetDisconnect 

func (x *Command) GetDisconnect() *DisconnectRequest

func (*Command) GetGetUserStatus 

func (x *Command) GetGetUserStatus() *GetUserStatusRequest

func (*Command) GetHistory 

func (x *Command) GetHistory() *HistoryRequest

func (*Command) GetHistoryRemove 

func (x *Command) GetHistoryRemove() *HistoryRemoveRequest

func (*Command) GetId 

func (x *Command) GetId() uint32

func (*Command) GetInfo 

func (x *Command) GetInfo() *InfoRequest

func (*Command) GetInvalidateUserTokens 

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 

func (x *Command) GetPresence() *PresenceRequest

func (*Command) GetPresenceStats 

func (x *Command) GetPresenceStats() *PresenceStatsRequest

func (*Command) GetPublish 

func (x *Command) GetPublish() *PublishRequest

func (*Command) GetRateLimit added in v4.9.0 

func (x *Command) GetRateLimit() *RateLimitRequest

func (*Command) GetRefresh 

func (x *Command) GetRefresh() *RefreshRequest

func (*Command) GetRevokeToken 

func (x *Command) GetRevokeToken() *RevokeTokenRequest

func (*Command) GetRpc 

func (x *Command) GetRpc() *RPCRequest

func (*Command) GetSendPushNotification 

func (x *Command) GetSendPushNotification() *SendPushNotificationRequest

func (*Command) GetSubscribe 

func (x *Command) GetSubscribe() *SubscribeRequest

func (*Command) GetUnblockUser 

func (x *Command) GetUnblockUser() *UnblockUserRequest

func (*Command) GetUnsubscribe 

func (x *Command) GetUnsubscribe() *UnsubscribeRequest

func (*Command) GetUpdatePushStatus added in v4.9.0 

func (x *Command) GetUpdatePushStatus() *UpdatePushStatusRequest

func (*Command) GetUpdateUserStatus 

func (x *Command) GetUpdateUserStatus() *UpdateUserStatusRequest

func (*Command) GetUserTopicList added in v4.9.0 

func (x *Command) GetUserTopicList() *UserTopicListRequest

func (*Command) GetUserTopicUpdate added in v4.9.0 

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 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
	Command_CANCEL_PUSH            Command_MethodType = 32
	Command_RATE_LIMIT             Command_MethodType = 47
)

func (Command_MethodType) Descriptor 

func (Command_MethodType) Descriptor() protoreflect.EnumDescriptor

func (Command_MethodType) Enum 

func (x Command_MethodType) Enum() *Command_MethodType

func (Command_MethodType) EnumDescriptor deprecated 

func (Command_MethodType) EnumDescriptor() ([]byte, []int)

Deprecated: Use Command_MethodType.Descriptor instead.

func (Command_MethodType) Number 

func (x Command_MethodType) Number() protoreflect.EnumNumber

func (Command_MethodType) String 

func (x Command_MethodType) String() string

func (Command_MethodType) Type 

func (Command_MethodType) Type() protoreflect.EnumType

type ConnectionInfo 

type ConnectionInfo struct {
	AppName    string `protobuf:"bytes,1,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"`
	AppVersion string `protobuf:"bytes,2,opt,name=app_version,json=appVersion,proto3" json:"app_version,omitempty"`
	Transport  string `protobuf:"bytes,3,opt,name=transport,proto3" json:"transport,omitempty"`
	Protocol   string `protobuf:"bytes,4,opt,name=protocol,proto3" json:"protocol,omitempty"`
	// 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               []byte                            `protobuf:"bytes,4,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectionState) Descriptor deprecated 

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

Deprecated: Use ConnectionState.ProtoReflect.Descriptor instead.

func (*ConnectionState) GetChannels 

func (x *ConnectionState) GetChannels() map[string]*ChannelContext

func (*ConnectionState) GetConnectionToken 

func (x *ConnectionState) GetConnectionToken() *ConnectionTokenInfo

func (*ConnectionState) GetMeta 

func (x *ConnectionState) GetMeta() []byte

func (*ConnectionState) GetSubscriptionTokens 

func (x *ConnectionState) GetSubscriptionTokens() map[string]*SubscriptionTokenInfo

func (*ConnectionState) ProtoMessage 

func (*ConnectionState) ProtoMessage()

func (*ConnectionState) ProtoReflect 

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

func (*ConnectionState) Reset 

func (x *ConnectionState) Reset()

func (*ConnectionState) String 

func (x *ConnectionState) String() string

type ConnectionTokenInfo 

type ConnectionTokenInfo struct {
	Uid      string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
	IssuedAt int64  `protobuf:"varint,2,opt,name=issued_at,json=issuedAt,proto3" json:"issued_at,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectionTokenInfo) Descriptor deprecated 

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

Deprecated: Use ConnectionTokenInfo.ProtoReflect.Descriptor instead.

func (*ConnectionTokenInfo) GetIssuedAt 

func (x *ConnectionTokenInfo) GetIssuedAt() int64

func (*ConnectionTokenInfo) GetUid 

func (x *ConnectionTokenInfo) GetUid() string

func (*ConnectionTokenInfo) ProtoMessage 

func (*ConnectionTokenInfo) ProtoMessage()

func (*ConnectionTokenInfo) ProtoReflect 

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

func (*ConnectionTokenInfo) Reset 

func (x *ConnectionTokenInfo) Reset()

func (*ConnectionTokenInfo) String 

func (x *ConnectionTokenInfo) String() string

type ConnectionsRequest 

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

func (*ConnectionsRequest) Descriptor deprecated 

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

Deprecated: Use ConnectionsRequest.ProtoReflect.Descriptor instead.

func (*ConnectionsRequest) GetExpression 

func (x *ConnectionsRequest) GetExpression() string

func (*ConnectionsRequest) GetUser 

func (x *ConnectionsRequest) GetUser() string

func (*ConnectionsRequest) ProtoMessage 

func (*ConnectionsRequest) ProtoMessage()

func (*ConnectionsRequest) ProtoReflect 

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

func (*ConnectionsRequest) Reset 

func (x *ConnectionsRequest) Reset()

func (*ConnectionsRequest) String 

func (x *ConnectionsRequest) String() string

type ConnectionsResponse 

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

func (*ConnectionsResponse) Descriptor deprecated 

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

Deprecated: Use ConnectionsResponse.ProtoReflect.Descriptor instead.

func (*ConnectionsResponse) GetError 

func (x *ConnectionsResponse) GetError() *Error

func (*ConnectionsResponse) GetResult 

func (x *ConnectionsResponse) GetResult() *ConnectionsResult

func (*ConnectionsResponse) ProtoMessage 

func (*ConnectionsResponse) ProtoMessage()

func (*ConnectionsResponse) ProtoReflect 

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

func (*ConnectionsResponse) Reset 

func (x *ConnectionsResponse) Reset()

func (*ConnectionsResponse) String 

func (x *ConnectionsResponse) String() string

type ConnectionsResult 

type ConnectionsResult struct {
	Connections map[string]*ConnectionInfo `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ConnectionsResult) Descriptor deprecated 

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

Deprecated: Use ConnectionsResult.ProtoReflect.Descriptor instead.

func (*ConnectionsResult) GetConnections 

func (x *ConnectionsResult) GetConnections() map[string]*ConnectionInfo

func (*ConnectionsResult) ProtoMessage 

func (*ConnectionsResult) ProtoMessage()

func (*ConnectionsResult) ProtoReflect 

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

func (*ConnectionsResult) Reset 

func (x *ConnectionsResult) Reset()

func (*ConnectionsResult) String 

func (x *ConnectionsResult) String() string

type DeleteUserStatusRequest 

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

func (*DeleteUserStatusRequest) Descriptor deprecated 

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

Deprecated: Use DeleteUserStatusRequest.ProtoReflect.Descriptor instead.

func (*DeleteUserStatusRequest) GetUsers 

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

func (*DeleteUserStatusRequest) ProtoMessage 

func (*DeleteUserStatusRequest) ProtoMessage()

func (*DeleteUserStatusRequest) ProtoReflect 

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

func (*DeleteUserStatusRequest) Reset 

func (x *DeleteUserStatusRequest) Reset()

func (*DeleteUserStatusRequest) String 

func (x *DeleteUserStatusRequest) String() string

type DeleteUserStatusResponse 

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

func (*DeleteUserStatusResponse) Descriptor deprecated 

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

Deprecated: Use DeleteUserStatusResponse.ProtoReflect.Descriptor instead.

func (*DeleteUserStatusResponse) GetError 

func (x *DeleteUserStatusResponse) GetError() *Error

func (*DeleteUserStatusResponse) GetResult 

func (x *DeleteUserStatusResponse) GetResult() *DeleteUserStatusResult

func (*DeleteUserStatusResponse) ProtoMessage 

func (*DeleteUserStatusResponse) ProtoMessage()

func (*DeleteUserStatusResponse) ProtoReflect 

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

func (*DeleteUserStatusResponse) Reset 

func (x *DeleteUserStatusResponse) Reset()

func (*DeleteUserStatusResponse) String 

func (x *DeleteUserStatusResponse) String() string

type DeleteUserStatusResult 

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

func (*DeleteUserStatusResult) Descriptor deprecated 

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

Deprecated: Use DeleteUserStatusResult.ProtoReflect.Descriptor instead.

func (*DeleteUserStatusResult) ProtoMessage 

func (*DeleteUserStatusResult) ProtoMessage()

func (*DeleteUserStatusResult) ProtoReflect 

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

func (*DeleteUserStatusResult) Reset 

func (x *DeleteUserStatusResult) Reset()

func (*DeleteUserStatusResult) String 

func (x *DeleteUserStatusResult) String() string

type Device 

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"`
	CreatedAt int64             `protobuf:"varint,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt int64             `protobuf:"varint,7,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	Meta      map[string]string `` /* 150-byte string literal not displayed */
	Topics    []string          `protobuf:"bytes,11,rep,name=topics,proto3" json:"topics,omitempty"`
	// contains filtered or unexported fields
}

func (*Device) Descriptor deprecated 

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

Deprecated: Use Device.ProtoReflect.Descriptor instead.

func (*Device) GetCreatedAt added in v4.9.0 

func (x *Device) GetCreatedAt() int64

func (*Device) GetId 

func (x *Device) GetId() string

func (*Device) GetMeta 

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

func (*Device) GetPlatform 

func (x *Device) GetPlatform() string

func (*Device) GetProvider 

func (x *Device) GetProvider() string

func (*Device) GetToken 

func (x *Device) GetToken() string

func (*Device) GetTopics added in v4.9.0 

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

func (*Device) GetUpdatedAt added in v4.9.0 

func (x *Device) GetUpdatedAt() int64

func (*Device) GetUser 

func (x *Device) GetUser() string

func (*Device) ProtoMessage 

func (*Device) ProtoMessage()

func (*Device) ProtoReflect 

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

func (*Device) Reset 

func (x *Device) Reset()

func (*Device) String 

func (x *Device) String() string

type DeviceFilter added in v4.9.0 

type DeviceFilter 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"`
	Topics    []string `protobuf:"bytes,3,rep,name=topics,proto3" json:"topics,omitempty"`
	Providers []string `protobuf:"bytes,4,rep,name=providers,proto3" json:"providers,omitempty"`
	Platforms []string `protobuf:"bytes,5,rep,name=platforms,proto3" json:"platforms,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceFilter) Descriptor deprecated added in v4.9.0 

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

Deprecated: Use DeviceFilter.ProtoReflect.Descriptor instead.

func (*DeviceFilter) GetIds added in v4.9.0 

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

func (*DeviceFilter) GetPlatforms added in v4.9.0 

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

func (*DeviceFilter) GetProviders added in v4.9.0 

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

func (*DeviceFilter) GetTopics added in v4.9.0 

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

func (*DeviceFilter) GetUsers added in v4.9.0 

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

func (*DeviceFilter) ProtoMessage added in v4.9.0 

func (*DeviceFilter) ProtoMessage()

func (*DeviceFilter) ProtoReflect added in v4.9.0 

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

func (*DeviceFilter) Reset added in v4.9.0 

func (x *DeviceFilter) Reset()

func (*DeviceFilter) String added in v4.9.0 

func (x *DeviceFilter) String() string

type DeviceListRequest 

type DeviceListRequest struct {
	Filter            *DeviceFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	IncludeTotalCount bool          `protobuf:"varint,2,opt,name=include_total_count,json=includeTotalCount,proto3" json:"include_total_count,omitempty"`
	IncludeMeta       bool          `protobuf:"varint,3,opt,name=include_meta,json=includeMeta,proto3" json:"include_meta,omitempty"`
	IncludeTopics     bool          `protobuf:"varint,4,opt,name=include_topics,json=includeTopics,proto3" json:"include_topics,omitempty"`
	Cursor            string        `protobuf:"bytes,10,opt,name=cursor,proto3" json:"cursor,omitempty"`
	Limit             int32         `protobuf:"varint,11,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceListRequest) Descriptor deprecated 

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

Deprecated: Use DeviceListRequest.ProtoReflect.Descriptor instead.

func (*DeviceListRequest) GetCursor added in v4.9.0 

func (x *DeviceListRequest) GetCursor() string

func (*DeviceListRequest) GetFilter added in v4.9.0 

func (x *DeviceListRequest) GetFilter() *DeviceFilter

func (*DeviceListRequest) GetIncludeMeta 

func (x *DeviceListRequest) GetIncludeMeta() bool

func (*DeviceListRequest) GetIncludeTopics added in v4.9.0 

func (x *DeviceListRequest) GetIncludeTopics() bool

func (*DeviceListRequest) GetIncludeTotalCount added in v4.9.0 

func (x *DeviceListRequest) GetIncludeTotalCount() bool

func (*DeviceListRequest) GetLimit 

func (x *DeviceListRequest) GetLimit() int32

func (*DeviceListRequest) ProtoMessage 

func (*DeviceListRequest) ProtoMessage()

func (*DeviceListRequest) ProtoReflect 

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

func (*DeviceListRequest) Reset 

func (x *DeviceListRequest) Reset()

func (*DeviceListRequest) String 

func (x *DeviceListRequest) String() string

type DeviceListResponse 

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 

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

Deprecated: Use DeviceListResponse.ProtoReflect.Descriptor instead.

func (*DeviceListResponse) GetError 

func (x *DeviceListResponse) GetError() *Error

func (*DeviceListResponse) GetResult 

func (x *DeviceListResponse) GetResult() *DeviceListResult

func (*DeviceListResponse) ProtoMessage 

func (*DeviceListResponse) ProtoMessage()

func (*DeviceListResponse) ProtoReflect 

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

func (*DeviceListResponse) Reset 

func (x *DeviceListResponse) Reset()

func (*DeviceListResponse) String 

func (x *DeviceListResponse) String() string

type DeviceListResult 

type DeviceListResult struct {
	Items      []*Device `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	NextCursor string    `protobuf:"bytes,2,opt,name=next_cursor,json=nextCursor,proto3" json:"next_cursor,omitempty"`
	TotalCount int64     `protobuf:"varint,3,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceListResult) Descriptor deprecated 

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

Deprecated: Use DeviceListResult.ProtoReflect.Descriptor instead.

func (*DeviceListResult) GetItems 

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

func (*DeviceListResult) GetNextCursor added in v4.9.0 

func (x *DeviceListResult) GetNextCursor() string

func (*DeviceListResult) GetTotalCount added in v4.9.0 

func (x *DeviceListResult) GetTotalCount() int64

func (*DeviceListResult) ProtoMessage 

func (*DeviceListResult) ProtoMessage()

func (*DeviceListResult) ProtoReflect 

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

func (*DeviceListResult) Reset 

func (x *DeviceListResult) Reset()

func (*DeviceListResult) String 

func (x *DeviceListResult) String() string

type DeviceMetaUpdate 

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

func (*DeviceMetaUpdate) Descriptor deprecated 

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

Deprecated: Use DeviceMetaUpdate.ProtoReflect.Descriptor instead.

func (*DeviceMetaUpdate) GetMeta 

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

func (*DeviceMetaUpdate) ProtoMessage 

func (*DeviceMetaUpdate) ProtoMessage()

func (*DeviceMetaUpdate) ProtoReflect 

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

func (*DeviceMetaUpdate) Reset 

func (x *DeviceMetaUpdate) Reset()

func (*DeviceMetaUpdate) String 

func (x *DeviceMetaUpdate) String() string

type DeviceRegisterRequest 

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 */
	Topics   []string          `protobuf:"bytes,7,rep,name=topics,proto3" json:"topics,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceRegisterRequest) Descriptor deprecated 

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

Deprecated: Use DeviceRegisterRequest.ProtoReflect.Descriptor instead.

func (*DeviceRegisterRequest) GetId 

func (x *DeviceRegisterRequest) GetId() string

func (*DeviceRegisterRequest) GetMeta 

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

func (*DeviceRegisterRequest) GetPlatform 

func (x *DeviceRegisterRequest) GetPlatform() string

func (*DeviceRegisterRequest) GetProvider 

func (x *DeviceRegisterRequest) GetProvider() string

func (*DeviceRegisterRequest) GetToken 

func (x *DeviceRegisterRequest) GetToken() string

func (*DeviceRegisterRequest) GetTopics added in v4.9.0 

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

func (*DeviceRegisterRequest) GetUser 

func (x *DeviceRegisterRequest) GetUser() string

func (*DeviceRegisterRequest) ProtoMessage 

func (*DeviceRegisterRequest) ProtoMessage()

func (*DeviceRegisterRequest) ProtoReflect 

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

func (*DeviceRegisterRequest) Reset 

func (x *DeviceRegisterRequest) Reset()

func (*DeviceRegisterRequest) String 

func (x *DeviceRegisterRequest) String() string

type DeviceRegisterResponse 

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 

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

Deprecated: Use DeviceRegisterResponse.ProtoReflect.Descriptor instead.

func (*DeviceRegisterResponse) GetError 

func (x *DeviceRegisterResponse) GetError() *Error

func (*DeviceRegisterResponse) GetResult 

func (x *DeviceRegisterResponse) GetResult() *DeviceRegisterResult

func (*DeviceRegisterResponse) ProtoMessage 

func (*DeviceRegisterResponse) ProtoMessage()

func (*DeviceRegisterResponse) ProtoReflect 

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

func (*DeviceRegisterResponse) Reset 

func (x *DeviceRegisterResponse) Reset()

func (*DeviceRegisterResponse) String 

func (x *DeviceRegisterResponse) String() string

type DeviceRegisterResult 

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

func (*DeviceRegisterResult) Descriptor deprecated 

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

Deprecated: Use DeviceRegisterResult.ProtoReflect.Descriptor instead.

func (*DeviceRegisterResult) GetId added in v4.9.0 

func (x *DeviceRegisterResult) GetId() string

func (*DeviceRegisterResult) ProtoMessage 

func (*DeviceRegisterResult) ProtoMessage()

func (*DeviceRegisterResult) ProtoReflect 

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

func (*DeviceRegisterResult) Reset 

func (x *DeviceRegisterResult) Reset()

func (*DeviceRegisterResult) String 

func (x *DeviceRegisterResult) String() string

type DeviceRemoveRequest 

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"`
	// contains filtered or unexported fields
}

func (*DeviceRemoveRequest) Descriptor deprecated 

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

Deprecated: Use DeviceRemoveRequest.ProtoReflect.Descriptor instead.

func (*DeviceRemoveRequest) GetIds 

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

func (*DeviceRemoveRequest) GetUsers 

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

func (*DeviceRemoveRequest) ProtoMessage 

func (*DeviceRemoveRequest) ProtoMessage()

func (*DeviceRemoveRequest) ProtoReflect 

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

func (*DeviceRemoveRequest) Reset 

func (x *DeviceRemoveRequest) Reset()

func (*DeviceRemoveRequest) String 

func (x *DeviceRemoveRequest) String() string

type DeviceRemoveResponse 

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 

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

Deprecated: Use DeviceRemoveResponse.ProtoReflect.Descriptor instead.

func (*DeviceRemoveResponse) GetError 

func (x *DeviceRemoveResponse) GetError() *Error

func (*DeviceRemoveResponse) GetResult 

func (x *DeviceRemoveResponse) GetResult() *DeviceRemoveResult

func (*DeviceRemoveResponse) ProtoMessage 

func (*DeviceRemoveResponse) ProtoMessage()

func (*DeviceRemoveResponse) ProtoReflect 

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

func (*DeviceRemoveResponse) Reset 

func (x *DeviceRemoveResponse) Reset()

func (*DeviceRemoveResponse) String 

func (x *DeviceRemoveResponse) String() string

type DeviceRemoveResult 

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

func (*DeviceRemoveResult) Descriptor deprecated 

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

Deprecated: Use DeviceRemoveResult.ProtoReflect.Descriptor instead.

func (*DeviceRemoveResult) ProtoMessage 

func (*DeviceRemoveResult) ProtoMessage()

func (*DeviceRemoveResult) ProtoReflect 

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

func (*DeviceRemoveResult) Reset 

func (x *DeviceRemoveResult) Reset()

func (*DeviceRemoveResult) String 

func (x *DeviceRemoveResult) String() string

type DeviceTopic added in v4.9.0 

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.9.0 

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

Deprecated: Use DeviceTopic.ProtoReflect.Descriptor instead.

func (*DeviceTopic) GetDevice added in v4.9.0 

func (x *DeviceTopic) GetDevice() *Device

func (*DeviceTopic) GetId added in v4.9.0 

func (x *DeviceTopic) GetId() string

func (*DeviceTopic) GetTopic added in v4.9.0 

func (x *DeviceTopic) GetTopic() string

func (*DeviceTopic) ProtoMessage added in v4.9.0 

func (*DeviceTopic) ProtoMessage()

func (*DeviceTopic) ProtoReflect added in v4.9.0 

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

func (*DeviceTopic) Reset added in v4.9.0 

func (x *DeviceTopic) Reset()

func (*DeviceTopic) String added in v4.9.0 

func (x *DeviceTopic) String() string

type DeviceTopicFilter added in v4.9.0 

type DeviceTopicFilter 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"`
	DevicePlatforms []string `protobuf:"bytes,3,rep,name=device_platforms,json=devicePlatforms,proto3" json:"device_platforms,omitempty"`
	DeviceUsers     []string `protobuf:"bytes,4,rep,name=device_users,json=deviceUsers,proto3" json:"device_users,omitempty"`
	Topics          []string `protobuf:"bytes,5,rep,name=topics,proto3" json:"topics,omitempty"`
	TopicPrefix     string   `protobuf:"bytes,6,opt,name=topic_prefix,json=topicPrefix,proto3" json:"topic_prefix,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceTopicFilter) Descriptor deprecated added in v4.9.0 

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

Deprecated: Use DeviceTopicFilter.ProtoReflect.Descriptor instead.

func (*DeviceTopicFilter) GetDeviceIds added in v4.9.0 

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

func (*DeviceTopicFilter) GetDevicePlatforms added in v4.9.0 

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

func (*DeviceTopicFilter) GetDeviceProviders added in v4.9.0 

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

func (*DeviceTopicFilter) GetDeviceUsers added in v4.9.0 

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

func (*DeviceTopicFilter) GetTopicPrefix added in v4.9.0 

func (x *DeviceTopicFilter) GetTopicPrefix() string

func (*DeviceTopicFilter) GetTopics added in v4.9.0 

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

func (*DeviceTopicFilter) ProtoMessage added in v4.9.0 

func (*DeviceTopicFilter) ProtoMessage()

func (*DeviceTopicFilter) ProtoReflect added in v4.9.0 

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

func (*DeviceTopicFilter) Reset added in v4.9.0 

func (x *DeviceTopicFilter) Reset()

func (*DeviceTopicFilter) String added in v4.9.0 

func (x *DeviceTopicFilter) String() string

type DeviceTopicListRequest added in v4.9.0 

type DeviceTopicListRequest struct {
	Filter            *DeviceTopicFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	IncludeTotalCount bool               `protobuf:"varint,2,opt,name=include_total_count,json=includeTotalCount,proto3" json:"include_total_count,omitempty"`
	IncludeDevice     bool               `protobuf:"varint,3,opt,name=include_device,json=includeDevice,proto3" json:"include_device,omitempty"`
	Cursor            string             `protobuf:"bytes,10,opt,name=cursor,proto3" json:"cursor,omitempty"`
	Limit             int32              `protobuf:"varint,11,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use DeviceTopicListRequest.ProtoReflect.Descriptor instead.

func (*DeviceTopicListRequest) GetCursor added in v4.9.0 

func (x *DeviceTopicListRequest) GetCursor() string

func (*DeviceTopicListRequest) GetFilter added in v4.9.0 

func (x *DeviceTopicListRequest) GetFilter() *DeviceTopicFilter

func (*DeviceTopicListRequest) GetIncludeDevice added in v4.9.0 

func (x *DeviceTopicListRequest) GetIncludeDevice() bool

func (*DeviceTopicListRequest) GetIncludeTotalCount added in v4.9.0 

func (x *DeviceTopicListRequest) GetIncludeTotalCount() bool

func (*DeviceTopicListRequest) GetLimit added in v4.9.0 

func (x *DeviceTopicListRequest) GetLimit() int32

func (*DeviceTopicListRequest) ProtoMessage added in v4.9.0 

func (*DeviceTopicListRequest) ProtoMessage()

func (*DeviceTopicListRequest) ProtoReflect added in v4.9.0 

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

func (*DeviceTopicListRequest) Reset added in v4.9.0 

func (x *DeviceTopicListRequest) Reset()

func (*DeviceTopicListRequest) String added in v4.9.0 

func (x *DeviceTopicListRequest) String() string

type DeviceTopicListResponse added in v4.9.0 

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.9.0 

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

Deprecated: Use DeviceTopicListResponse.ProtoReflect.Descriptor instead.

func (*DeviceTopicListResponse) GetError added in v4.9.0 

func (x *DeviceTopicListResponse) GetError() *Error

func (*DeviceTopicListResponse) GetResult added in v4.9.0 

func (x *DeviceTopicListResponse) GetResult() *DeviceTopicListResult

func (*DeviceTopicListResponse) ProtoMessage added in v4.9.0 

func (*DeviceTopicListResponse) ProtoMessage()

func (*DeviceTopicListResponse) ProtoReflect added in v4.9.0 

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

func (*DeviceTopicListResponse) Reset added in v4.9.0 

func (x *DeviceTopicListResponse) Reset()

func (*DeviceTopicListResponse) String added in v4.9.0 

func (x *DeviceTopicListResponse) String() string

type DeviceTopicListResult added in v4.9.0 

type DeviceTopicListResult struct {
	Items      []*DeviceTopic `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	NextCursor string         `protobuf:"bytes,2,opt,name=next_cursor,json=nextCursor,proto3" json:"next_cursor,omitempty"`
	TotalCount int64          `protobuf:"varint,3,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use DeviceTopicListResult.ProtoReflect.Descriptor instead.

func (*DeviceTopicListResult) GetItems added in v4.9.0 

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

func (*DeviceTopicListResult) GetNextCursor added in v4.9.0 

func (x *DeviceTopicListResult) GetNextCursor() string

func (*DeviceTopicListResult) GetTotalCount added in v4.9.0 

func (x *DeviceTopicListResult) GetTotalCount() int64

func (*DeviceTopicListResult) ProtoMessage added in v4.9.0 

func (*DeviceTopicListResult) ProtoMessage()

func (*DeviceTopicListResult) ProtoReflect added in v4.9.0 

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

func (*DeviceTopicListResult) Reset added in v4.9.0 

func (x *DeviceTopicListResult) Reset()

func (*DeviceTopicListResult) String added in v4.9.0 

func (x *DeviceTopicListResult) String() string

type DeviceTopicUpdateRequest added in v4.9.0 

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.9.0 

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

Deprecated: Use DeviceTopicUpdateRequest.ProtoReflect.Descriptor instead.

func (*DeviceTopicUpdateRequest) GetDeviceId added in v4.9.0 

func (x *DeviceTopicUpdateRequest) GetDeviceId() string

func (*DeviceTopicUpdateRequest) GetOp added in v4.9.0 

func (x *DeviceTopicUpdateRequest) GetOp() string

func (*DeviceTopicUpdateRequest) GetTopics added in v4.9.0 

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

func (*DeviceTopicUpdateRequest) ProtoMessage added in v4.9.0 

func (*DeviceTopicUpdateRequest) ProtoMessage()

func (*DeviceTopicUpdateRequest) ProtoReflect added in v4.9.0 

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

func (*DeviceTopicUpdateRequest) Reset added in v4.9.0 

func (x *DeviceTopicUpdateRequest) Reset()

func (*DeviceTopicUpdateRequest) String added in v4.9.0 

func (x *DeviceTopicUpdateRequest) String() string

type DeviceTopicUpdateResponse added in v4.9.0 

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.9.0 

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

Deprecated: Use DeviceTopicUpdateResponse.ProtoReflect.Descriptor instead.

func (*DeviceTopicUpdateResponse) GetError added in v4.9.0 

func (x *DeviceTopicUpdateResponse) GetError() *Error

func (*DeviceTopicUpdateResponse) GetResult added in v4.9.0 

func (x *DeviceTopicUpdateResponse) GetResult() *DeviceTopicUpdateResult

func (*DeviceTopicUpdateResponse) ProtoMessage added in v4.9.0 

func (*DeviceTopicUpdateResponse) ProtoMessage()

func (*DeviceTopicUpdateResponse) ProtoReflect added in v4.9.0 

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

func (*DeviceTopicUpdateResponse) Reset added in v4.9.0 

func (x *DeviceTopicUpdateResponse) Reset()

func (*DeviceTopicUpdateResponse) String added in v4.9.0 

func (x *DeviceTopicUpdateResponse) String() string

type DeviceTopicUpdateResult added in v4.9.0 

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

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

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

Deprecated: Use DeviceTopicUpdateResult.ProtoReflect.Descriptor instead.

func (*DeviceTopicUpdateResult) ProtoMessage added in v4.9.0 

func (*DeviceTopicUpdateResult) ProtoMessage()

func (*DeviceTopicUpdateResult) ProtoReflect added in v4.9.0 

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

func (*DeviceTopicUpdateResult) Reset added in v4.9.0 

func (x *DeviceTopicUpdateResult) Reset()

func (*DeviceTopicUpdateResult) String added in v4.9.0 

func (x *DeviceTopicUpdateResult) String() string

type DeviceTopicsUpdate added in v4.9.0 

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.9.0 

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

Deprecated: Use DeviceTopicsUpdate.ProtoReflect.Descriptor instead.

func (*DeviceTopicsUpdate) GetOp added in v4.9.0 

func (x *DeviceTopicsUpdate) GetOp() string

func (*DeviceTopicsUpdate) GetTopics added in v4.9.0 

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

func (*DeviceTopicsUpdate) ProtoMessage added in v4.9.0 

func (*DeviceTopicsUpdate) ProtoMessage()

func (*DeviceTopicsUpdate) ProtoReflect added in v4.9.0 

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

func (*DeviceTopicsUpdate) Reset added in v4.9.0 

func (x *DeviceTopicsUpdate) Reset()

func (*DeviceTopicsUpdate) String added in v4.9.0 

func (x *DeviceTopicsUpdate) String() string

type DeviceUpdateRequest 

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"`
	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"`
	TopicsUpdate *DeviceTopicsUpdate `protobuf:"bytes,6,opt,name=topics_update,json=topicsUpdate,proto3" json:"topics_update,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceUpdateRequest) Descriptor deprecated 

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

Deprecated: Use DeviceUpdateRequest.ProtoReflect.Descriptor instead.

func (*DeviceUpdateRequest) GetIds 

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

func (*DeviceUpdateRequest) GetMetaUpdate 

func (x *DeviceUpdateRequest) GetMetaUpdate() *DeviceMetaUpdate

func (*DeviceUpdateRequest) GetTopicsUpdate added in v4.9.0 

func (x *DeviceUpdateRequest) GetTopicsUpdate() *DeviceTopicsUpdate

func (*DeviceUpdateRequest) GetUserUpdate 

func (x *DeviceUpdateRequest) GetUserUpdate() *DeviceUserUpdate

func (*DeviceUpdateRequest) GetUsers 

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

func (*DeviceUpdateRequest) ProtoMessage 

func (*DeviceUpdateRequest) ProtoMessage()

func (*DeviceUpdateRequest) ProtoReflect 

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

func (*DeviceUpdateRequest) Reset 

func (x *DeviceUpdateRequest) Reset()

func (*DeviceUpdateRequest) String 

func (x *DeviceUpdateRequest) String() string

type DeviceUpdateResponse 

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 

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

Deprecated: Use DeviceUpdateResponse.ProtoReflect.Descriptor instead.

func (*DeviceUpdateResponse) GetError 

func (x *DeviceUpdateResponse) GetError() *Error

func (*DeviceUpdateResponse) GetResult 

func (x *DeviceUpdateResponse) GetResult() *DeviceUpdateResult

func (*DeviceUpdateResponse) ProtoMessage 

func (*DeviceUpdateResponse) ProtoMessage()

func (*DeviceUpdateResponse) ProtoReflect 

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

func (*DeviceUpdateResponse) Reset 

func (x *DeviceUpdateResponse) Reset()

func (*DeviceUpdateResponse) String 

func (x *DeviceUpdateResponse) String() string

type DeviceUpdateResult 

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

func (*DeviceUpdateResult) Descriptor deprecated 

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

Deprecated: Use DeviceUpdateResult.ProtoReflect.Descriptor instead.

func (*DeviceUpdateResult) ProtoMessage 

func (*DeviceUpdateResult) ProtoMessage()

func (*DeviceUpdateResult) ProtoReflect 

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

func (*DeviceUpdateResult) Reset 

func (x *DeviceUpdateResult) Reset()

func (*DeviceUpdateResult) String 

func (x *DeviceUpdateResult) String() string

type DeviceUserUpdate 

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

func (*DeviceUserUpdate) Descriptor deprecated 

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

Deprecated: Use DeviceUserUpdate.ProtoReflect.Descriptor instead.

func (*DeviceUserUpdate) GetUser 

func (x *DeviceUserUpdate) GetUser() string

func (*DeviceUserUpdate) ProtoMessage 

func (*DeviceUserUpdate) ProtoMessage()

func (*DeviceUserUpdate) ProtoReflect 

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

func (*DeviceUserUpdate) Reset 

func (x *DeviceUserUpdate) Reset()

func (*DeviceUserUpdate) String 

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"`
	// 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) ProtoMessage 

func (*Disconnect) ProtoMessage()

func (*Disconnect) ProtoReflect 

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

func (*Disconnect) Reset 

func (x *Disconnect) Reset()

func (*Disconnect) String 

func (x *Disconnect) String() string

type DisconnectRequest 

type DisconnectRequest struct {
	User       string      `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Disconnect *Disconnect `protobuf:"bytes,2,opt,name=disconnect,proto3" json:"disconnect,omitempty"`
	Client     string      `protobuf:"bytes,3,opt,name=client,proto3" json:"client,omitempty"`
	Whitelist  []string    `protobuf:"bytes,4,rep,name=whitelist,proto3" json:"whitelist,omitempty"`
	Session    string      `protobuf:"bytes,5,opt,name=session,proto3" json:"session,omitempty"`
	// contains filtered or unexported fields
}

func (*DisconnectRequest) Descriptor deprecated 

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

Deprecated: Use DisconnectRequest.ProtoReflect.Descriptor instead.

func (*DisconnectRequest) GetClient 

func (x *DisconnectRequest) GetClient() string

func (*DisconnectRequest) GetDisconnect 

func (x *DisconnectRequest) GetDisconnect() *Disconnect

func (*DisconnectRequest) GetSession 

func (x *DisconnectRequest) GetSession() string

func (*DisconnectRequest) GetUser 

func (x *DisconnectRequest) GetUser() string

func (*DisconnectRequest) GetWhitelist 

func (x *DisconnectRequest) GetWhitelist() []string

func (*DisconnectRequest) ProtoMessage 

func (*DisconnectRequest) ProtoMessage()

func (*DisconnectRequest) ProtoReflect 

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

func (*DisconnectRequest) Reset 

func (x *DisconnectRequest) Reset()

func (*DisconnectRequest) String 

func (x *DisconnectRequest) String() string

type DisconnectResponse 

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

func (*DisconnectResponse) Descriptor deprecated 

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

Deprecated: Use DisconnectResponse.ProtoReflect.Descriptor instead.

func (*DisconnectResponse) GetError 

func (x *DisconnectResponse) GetError() *Error

func (*DisconnectResponse) GetResult 

func (x *DisconnectResponse) GetResult() *DisconnectResult

func (*DisconnectResponse) ProtoMessage 

func (*DisconnectResponse) ProtoMessage()

func (*DisconnectResponse) ProtoReflect 

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

func (*DisconnectResponse) Reset 

func (x *DisconnectResponse) Reset()

func (*DisconnectResponse) String 

func (x *DisconnectResponse) String() string

type DisconnectResult 

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

func (*DisconnectResult) Descriptor deprecated 

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

Deprecated: Use DisconnectResult.ProtoReflect.Descriptor instead.

func (*DisconnectResult) ProtoMessage 

func (*DisconnectResult) ProtoMessage()

func (*DisconnectResult) ProtoReflect 

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

func (*DisconnectResult) Reset 

func (x *DisconnectResult) Reset()

func (*DisconnectResult) String 

func (x *DisconnectResult) String() string

type Error 

type Error struct {
	Code    uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Error) Descriptor deprecated 

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

Deprecated: Use Error.ProtoReflect.Descriptor instead.

func (*Error) GetCode 

func (x *Error) GetCode() uint32

func (*Error) GetMessage 

func (x *Error) GetMessage() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect 

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

func (*Error) Reset 

func (x *Error) Reset()

func (*Error) String 

func (x *Error) String() string

type FcmPushNotification 

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

func (*FcmPushNotification) Descriptor deprecated 

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

Deprecated: Use FcmPushNotification.ProtoReflect.Descriptor instead.

func (*FcmPushNotification) GetMessage 

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

func (*FcmPushNotification) ProtoMessage 

func (*FcmPushNotification) ProtoMessage()

func (*FcmPushNotification) ProtoReflect 

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

func (*FcmPushNotification) Reset 

func (x *FcmPushNotification) Reset()

func (*FcmPushNotification) String 

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,omitempty"`
	// contains filtered or unexported fields
}

func (*GetUserStatusResult) Descriptor deprecated 

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

Deprecated: Use GetUserStatusResult.ProtoReflect.Descriptor instead.

func (*GetUserStatusResult) GetStatuses 

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

func (*GetUserStatusResult) ProtoMessage 

func (*GetUserStatusResult) ProtoMessage()

func (*GetUserStatusResult) ProtoReflect 

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

func (*GetUserStatusResult) Reset 

func (x *GetUserStatusResult) Reset()

func (*GetUserStatusResult) String 

func (x *GetUserStatusResult) String() string

type HistoryRemoveRequest 

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

func (*HistoryRemoveRequest) Descriptor deprecated 

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

Deprecated: Use HistoryRemoveRequest.ProtoReflect.Descriptor instead.

func (*HistoryRemoveRequest) GetChannel 

func (x *HistoryRemoveRequest) GetChannel() string

func (*HistoryRemoveRequest) ProtoMessage 

func (*HistoryRemoveRequest) ProtoMessage()

func (*HistoryRemoveRequest) ProtoReflect 

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

func (*HistoryRemoveRequest) Reset 

func (x *HistoryRemoveRequest) Reset()

func (*HistoryRemoveRequest) String 

func (x *HistoryRemoveRequest) String() string

type HistoryRemoveResponse 

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

func (*HistoryRemoveResponse) Descriptor deprecated 

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

Deprecated: Use HistoryRemoveResponse.ProtoReflect.Descriptor instead.

func (*HistoryRemoveResponse) GetError 

func (x *HistoryRemoveResponse) GetError() *Error

func (*HistoryRemoveResponse) GetResult 

func (x *HistoryRemoveResponse) GetResult() *HistoryRemoveResult

func (*HistoryRemoveResponse) ProtoMessage 

func (*HistoryRemoveResponse) ProtoMessage()

func (*HistoryRemoveResponse) ProtoReflect 

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

func (*HistoryRemoveResponse) Reset 

func (x *HistoryRemoveResponse) Reset()

func (*HistoryRemoveResponse) String 

func (x *HistoryRemoveResponse) String() string

type HistoryRemoveResult 

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

func (*HistoryRemoveResult) Descriptor deprecated 

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

Deprecated: Use HistoryRemoveResult.ProtoReflect.Descriptor instead.

func (*HistoryRemoveResult) ProtoMessage 

func (*HistoryRemoveResult) ProtoMessage()

func (*HistoryRemoveResult) ProtoReflect 

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

func (*HistoryRemoveResult) Reset 

func (x *HistoryRemoveResult) Reset()

func (*HistoryRemoveResult) String 

func (x *HistoryRemoveResult) String() string

type HistoryRequest 

type HistoryRequest struct {
	Channel string          `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	Limit   int32           `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	Since   *StreamPosition `protobuf:"bytes,3,opt,name=since,proto3" json:"since,omitempty"`
	Reverse bool            `protobuf:"varint,4,opt,name=reverse,proto3" json:"reverse,omitempty"`
	// contains filtered or unexported fields
}

func (*HistoryRequest) Descriptor deprecated 

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

Deprecated: Use HistoryRequest.ProtoReflect.Descriptor instead.

func (*HistoryRequest) GetChannel 

func (x *HistoryRequest) GetChannel() string

func (*HistoryRequest) GetLimit 

func (x *HistoryRequest) GetLimit() int32

func (*HistoryRequest) GetReverse 

func (x *HistoryRequest) GetReverse() bool

func (*HistoryRequest) GetSince 

func (x *HistoryRequest) GetSince() *StreamPosition

func (*HistoryRequest) ProtoMessage 

func (*HistoryRequest) ProtoMessage()

func (*HistoryRequest) ProtoReflect 

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

func (*HistoryRequest) Reset 

func (x *HistoryRequest) Reset()

func (*HistoryRequest) String 

func (x *HistoryRequest) String() string

type HistoryResponse 

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

func (*HistoryResponse) Descriptor deprecated 

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

Deprecated: Use HistoryResponse.ProtoReflect.Descriptor instead.

func (*HistoryResponse) GetError 

func (x *HistoryResponse) GetError() *Error

func (*HistoryResponse) GetResult 

func (x *HistoryResponse) GetResult() *HistoryResult

func (*HistoryResponse) ProtoMessage 

func (*HistoryResponse) ProtoMessage()

func (*HistoryResponse) ProtoReflect 

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

func (*HistoryResponse) Reset 

func (x *HistoryResponse) Reset()

func (*HistoryResponse) String 

func (x *HistoryResponse) String() string

type HistoryResult 

type HistoryResult struct {
	Publications []*Publication `protobuf:"bytes,1,rep,name=publications,proto3" json:"publications,omitempty"`
	Epoch        string         `protobuf:"bytes,2,opt,name=epoch,proto3" json:"epoch,omitempty"`
	Offset       uint64         `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*HistoryResult) Descriptor deprecated 

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

Deprecated: Use HistoryResult.ProtoReflect.Descriptor instead.

func (*HistoryResult) GetEpoch 

func (x *HistoryResult) GetEpoch() string

func (*HistoryResult) GetOffset 

func (x *HistoryResult) GetOffset() uint64

func (*HistoryResult) GetPublications 

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

func (*HistoryResult) ProtoMessage 

func (*HistoryResult) ProtoMessage()

func (*HistoryResult) ProtoReflect 

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

func (*HistoryResult) Reset 

func (x *HistoryResult) Reset()

func (*HistoryResult) String 

func (x *HistoryResult) String() string

type HmsPushNotification 

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

func (*HmsPushNotification) Descriptor deprecated 

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

Deprecated: Use HmsPushNotification.ProtoReflect.Descriptor instead.

func (*HmsPushNotification) GetMessage 

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

func (*HmsPushNotification) ProtoMessage 

func (*HmsPushNotification) ProtoMessage()

func (*HmsPushNotification) ProtoReflect 

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

func (*HmsPushNotification) Reset 

func (x *HmsPushNotification) Reset()

func (*HmsPushNotification) String 

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 Metrics 

type Metrics struct {
	Interval float64            `protobuf:"fixed64,1,opt,name=interval,proto3" json:"interval,omitempty"`
	Items    map[string]float64 `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Metrics) Descriptor deprecated 

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

Deprecated: Use Metrics.ProtoReflect.Descriptor instead.

func (*Metrics) GetInterval 

func (x *Metrics) GetInterval() float64

func (*Metrics) GetItems 

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

func (*Metrics) ProtoMessage 

func (*Metrics) ProtoMessage()

func (*Metrics) ProtoReflect 

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

func (*Metrics) Reset 

func (x *Metrics) Reset()

func (*Metrics) String 

func (x *Metrics) String() string

type NodeResult 

type NodeResult struct {
	Uid         string   `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
	Name        string   `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Version     string   `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	NumClients  uint32   `protobuf:"varint,4,opt,name=num_clients,json=numClients,proto3" json:"num_clients,omitempty"`
	NumUsers    uint32   `protobuf:"varint,5,opt,name=num_users,json=numUsers,proto3" json:"num_users,omitempty"`
	NumChannels uint32   `protobuf:"varint,6,opt,name=num_channels,json=numChannels,proto3" json:"num_channels,omitempty"`
	Uptime      uint32   `protobuf:"varint,7,opt,name=uptime,proto3" json:"uptime,omitempty"`
	Metrics     *Metrics `protobuf:"bytes,8,opt,name=metrics,proto3" json:"metrics,omitempty"`
	Process     *Process `protobuf:"bytes,9,opt,name=process,proto3" json:"process,omitempty"`
	NumSubs     uint32   `protobuf:"varint,10,opt,name=num_subs,json=numSubs,proto3" json:"num_subs,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeResult) Descriptor deprecated 

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

Deprecated: Use NodeResult.ProtoReflect.Descriptor instead.

func (*NodeResult) GetMetrics 

func (x *NodeResult) GetMetrics() *Metrics

func (*NodeResult) GetName 

func (x *NodeResult) GetName() string

func (*NodeResult) GetNumChannels 

func (x *NodeResult) GetNumChannels() uint32

func (*NodeResult) GetNumClients 

func (x *NodeResult) GetNumClients() uint32

func (*NodeResult) GetNumSubs 

func (x *NodeResult) GetNumSubs() uint32

func (*NodeResult) GetNumUsers 

func (x *NodeResult) GetNumUsers() uint32

func (*NodeResult) GetProcess 

func (x *NodeResult) GetProcess() *Process

func (*NodeResult) GetUid 

func (x *NodeResult) GetUid() string

func (*NodeResult) GetUptime 

func (x *NodeResult) GetUptime() uint32

func (*NodeResult) GetVersion 

func (x *NodeResult) GetVersion() string

func (*NodeResult) ProtoMessage 

func (*NodeResult) ProtoMessage()

func (*NodeResult) ProtoReflect 

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

func (*NodeResult) Reset 

func (x *NodeResult) Reset()

func (*NodeResult) String 

func (x *NodeResult) String() string

type PresenceRequest 

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

func (*PresenceRequest) Descriptor deprecated 

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

Deprecated: Use PresenceRequest.ProtoReflect.Descriptor instead.

func (*PresenceRequest) GetChannel 

func (x *PresenceRequest) GetChannel() string

func (*PresenceRequest) ProtoMessage 

func (*PresenceRequest) ProtoMessage()

func (*PresenceRequest) ProtoReflect 

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

func (*PresenceRequest) Reset 

func (x *PresenceRequest) Reset()

func (*PresenceRequest) String 

func (x *PresenceRequest) String() string

type PresenceResponse 

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

func (*PresenceResponse) Descriptor deprecated 

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

Deprecated: Use PresenceResponse.ProtoReflect.Descriptor instead.

func (*PresenceResponse) GetError 

func (x *PresenceResponse) GetError() *Error

func (*PresenceResponse) GetResult 

func (x *PresenceResponse) GetResult() *PresenceResult

func (*PresenceResponse) ProtoMessage 

func (*PresenceResponse) ProtoMessage()

func (*PresenceResponse) ProtoReflect 

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

func (*PresenceResponse) Reset 

func (x *PresenceResponse) Reset()

func (*PresenceResponse) String 

func (x *PresenceResponse) String() string

type PresenceResult 

type PresenceResult struct {
	Presence map[string]*ClientInfo `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PresenceResult) Descriptor deprecated 

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

Deprecated: Use PresenceResult.ProtoReflect.Descriptor instead.

func (*PresenceResult) GetPresence 

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

func (*PresenceResult) ProtoMessage 

func (*PresenceResult) ProtoMessage()

func (*PresenceResult) ProtoReflect 

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

func (*PresenceResult) Reset 

func (x *PresenceResult) Reset()

func (*PresenceResult) String 

func (x *PresenceResult) String() string

type PresenceStatsRequest 

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

func (*PresenceStatsRequest) Descriptor deprecated 

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

Deprecated: Use PresenceStatsRequest.ProtoReflect.Descriptor instead.

func (*PresenceStatsRequest) GetChannel 

func (x *PresenceStatsRequest) GetChannel() string

func (*PresenceStatsRequest) ProtoMessage 

func (*PresenceStatsRequest) ProtoMessage()

func (*PresenceStatsRequest) ProtoReflect 

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

func (*PresenceStatsRequest) Reset 

func (x *PresenceStatsRequest) Reset()

func (*PresenceStatsRequest) String 

func (x *PresenceStatsRequest) String() string

type PresenceStatsResponse 

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

func (*PresenceStatsResponse) Descriptor deprecated 

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

Deprecated: Use PresenceStatsResponse.ProtoReflect.Descriptor instead.

func (*PresenceStatsResponse) GetError 

func (x *PresenceStatsResponse) GetError() *Error

func (*PresenceStatsResponse) GetResult 

func (x *PresenceStatsResponse) GetResult() *PresenceStatsResult

func (*PresenceStatsResponse) ProtoMessage 

func (*PresenceStatsResponse) ProtoMessage()

func (*PresenceStatsResponse) ProtoReflect 

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

func (*PresenceStatsResponse) Reset 

func (x *PresenceStatsResponse) Reset()

func (*PresenceStatsResponse) String 

func (x *PresenceStatsResponse) String() string

type PresenceStatsResult 

type PresenceStatsResult struct {
	NumClients uint32 `protobuf:"varint,1,opt,name=num_clients,json=numClients,proto3" json:"num_clients,omitempty"`
	NumUsers   uint32 `protobuf:"varint,2,opt,name=num_users,json=numUsers,proto3" json:"num_users,omitempty"`
	// contains filtered or unexported fields
}

func (*PresenceStatsResult) Descriptor deprecated 

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

Deprecated: Use PresenceStatsResult.ProtoReflect.Descriptor instead.

func (*PresenceStatsResult) GetNumClients 

func (x *PresenceStatsResult) GetNumClients() uint32

func (*PresenceStatsResult) GetNumUsers 

func (x *PresenceStatsResult) GetNumUsers() uint32

func (*PresenceStatsResult) ProtoMessage 

func (*PresenceStatsResult) ProtoMessage()

func (*PresenceStatsResult) ProtoReflect 

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

func (*PresenceStatsResult) Reset 

func (x *PresenceStatsResult) Reset()

func (*PresenceStatsResult) String 

func (x *PresenceStatsResult) String() string

type Process 

type Process struct {
	Cpu float64 `protobuf:"fixed64,1,opt,name=cpu,proto3" json:"cpu,omitempty"`
	Rss int64   `protobuf:"varint,2,opt,name=rss,proto3" json:"rss,omitempty"`
	// contains filtered or unexported fields
}

func (*Process) Descriptor deprecated 

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

Deprecated: Use Process.ProtoReflect.Descriptor instead.

func (*Process) GetCpu 

func (x *Process) GetCpu() float64

func (*Process) GetRss 

func (x *Process) GetRss() int64

func (*Process) ProtoMessage 

func (*Process) ProtoMessage()

func (*Process) ProtoReflect 

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

func (*Process) Reset 

func (x *Process) Reset()

func (*Process) String 

func (x *Process) String() string

type Publication 

type Publication struct {

	// Removed: string uid = 1;
	Data   []byte            `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Info   *ClientInfo       `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
	Offset uint64            `protobuf:"varint,4,opt,name=offset,proto3" json:"offset,omitempty"`
	Tags   map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Publication) Descriptor deprecated 

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

Deprecated: Use Publication.ProtoReflect.Descriptor instead.

func (*Publication) GetData 

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

func (*Publication) GetInfo 

func (x *Publication) GetInfo() *ClientInfo

func (*Publication) GetOffset 

func (x *Publication) GetOffset() uint64

func (*Publication) GetTags 

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

func (*Publication) ProtoMessage 

func (*Publication) ProtoMessage()

func (*Publication) ProtoReflect 

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

func (*Publication) Reset 

func (x *Publication) Reset()

func (*Publication) String 

func (x *Publication) String() string

type PublishRequest 

type PublishRequest struct {
	Channel        string            `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	Data           []byte            `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	B64Data        string            `protobuf:"bytes,3,opt,name=b64data,proto3" json:"b64data,omitempty"`
	SkipHistory    bool              `protobuf:"varint,4,opt,name=skip_history,json=skipHistory,proto3" json:"skip_history,omitempty"`
	Tags           map[string]string `` /* 149-byte string literal not displayed */
	IdempotencyKey string            `protobuf:"bytes,6,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
	// 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) GetIdempotencyKey added in v4.11.0 

func (x *PublishRequest) GetIdempotencyKey() string

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 

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"`
	ExpireAt int64                 `protobuf:"varint,5,opt,name=expire_at,json=expireAt,proto3" json:"expire_at,omitempty"` // timestamp in the future when Centrifugo should stop trying to send push notification.
	// contains filtered or unexported fields
}

func (*PushNotification) Descriptor deprecated 

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

Deprecated: Use PushNotification.ProtoReflect.Descriptor instead.

func (*PushNotification) GetApns 

func (x *PushNotification) GetApns() *ApnsPushNotification

func (*PushNotification) GetExpireAt 

func (x *PushNotification) GetExpireAt() int64

func (*PushNotification) GetFcm 

func (x *PushNotification) GetFcm() *FcmPushNotification

func (*PushNotification) GetHms 

func (x *PushNotification) GetHms() *HmsPushNotification

func (*PushNotification) ProtoMessage 

func (*PushNotification) ProtoMessage()

func (*PushNotification) ProtoReflect 

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

func (*PushNotification) Reset 

func (x *PushNotification) Reset()

func (*PushNotification) String 

func (x *PushNotification) String() string

type PushRecipient 

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

func (*PushRecipient) Descriptor deprecated 

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

Deprecated: Use PushRecipient.ProtoReflect.Descriptor instead.

func (*PushRecipient) GetApnsTokens 

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

func (*PushRecipient) GetFcmCondition 

func (x *PushRecipient) GetFcmCondition() string

func (*PushRecipient) GetFcmTokens 

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

func (*PushRecipient) GetFcmTopic 

func (x *PushRecipient) GetFcmTopic() string

func (*PushRecipient) GetFilter added in v4.9.0 

func (x *PushRecipient) GetFilter() *DeviceFilter

func (*PushRecipient) GetHmsCondition 

func (x *PushRecipient) GetHmsCondition() string

func (*PushRecipient) GetHmsTokens 

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

func (*PushRecipient) GetHmsTopic 

func (x *PushRecipient) GetHmsTopic() string

func (*PushRecipient) ProtoMessage 

func (*PushRecipient) ProtoMessage()

func (*PushRecipient) ProtoReflect 

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

func (*PushRecipient) Reset 

func (x *PushRecipient) Reset()

func (*PushRecipient) String 

func (x *PushRecipient) String() string

type RPCRequest 

type RPCRequest struct {
	Method string `protobuf:"bytes,1,opt,name=method,proto3" json:"method,omitempty"`
	Params []byte `protobuf:"bytes,2,opt,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

func (*RPCRequest) Descriptor deprecated 

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

Deprecated: Use RPCRequest.ProtoReflect.Descriptor instead.

func (*RPCRequest) GetMethod 

func (x *RPCRequest) GetMethod() string

func (*RPCRequest) GetParams 

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

func (*RPCRequest) ProtoMessage 

func (*RPCRequest) ProtoMessage()

func (*RPCRequest) ProtoReflect 

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

func (*RPCRequest) Reset 

func (x *RPCRequest) Reset()

func (*RPCRequest) String 

func (x *RPCRequest) String() string

type RPCResponse 

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

func (*RPCResponse) Descriptor deprecated 

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

Deprecated: Use RPCResponse.ProtoReflect.Descriptor instead.

func (*RPCResponse) GetError 

func (x *RPCResponse) GetError() *Error

func (*RPCResponse) GetResult 

func (x *RPCResponse) GetResult() *RPCResult

func (*RPCResponse) ProtoMessage 

func (*RPCResponse) ProtoMessage()

func (*RPCResponse) ProtoReflect 

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

func (*RPCResponse) Reset 

func (x *RPCResponse) Reset()

func (*RPCResponse) String 

func (x *RPCResponse) String() string

type RPCResult 

type RPCResult struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*RPCResult) Descriptor deprecated 

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

Deprecated: Use RPCResult.ProtoReflect.Descriptor instead.

func (*RPCResult) GetData 

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

func (*RPCResult) ProtoMessage 

func (*RPCResult) ProtoMessage()

func (*RPCResult) ProtoReflect 

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

func (*RPCResult) Reset 

func (x *RPCResult) Reset()

func (*RPCResult) String 

func (x *RPCResult) String() string

type RateLimitRequest added in v4.9.0 

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

func (*RateLimitRequest) Descriptor deprecated added in v4.9.0 

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

Deprecated: Use RateLimitRequest.ProtoReflect.Descriptor instead.

func (*RateLimitRequest) ProtoMessage added in v4.9.0 

func (*RateLimitRequest) ProtoMessage()

func (*RateLimitRequest) ProtoReflect added in v4.9.0 

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

func (*RateLimitRequest) Reset added in v4.9.0 

func (x *RateLimitRequest) Reset()

func (*RateLimitRequest) String added in v4.9.0 

func (x *RateLimitRequest) String() string

type RateLimitResponse added in v4.9.0 

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

func (*RateLimitResponse) Descriptor deprecated added in v4.9.0 

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

Deprecated: Use RateLimitResponse.ProtoReflect.Descriptor instead.

func (*RateLimitResponse) GetError added in v4.9.0 

func (x *RateLimitResponse) GetError() *Error

func (*RateLimitResponse) GetResult added in v4.9.0 

func (x *RateLimitResponse) GetResult() *RateLimitResult

func (*RateLimitResponse) ProtoMessage added in v4.9.0 

func (*RateLimitResponse) ProtoMessage()

func (*RateLimitResponse) ProtoReflect added in v4.9.0 

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

func (*RateLimitResponse) Reset added in v4.9.0 

func (x *RateLimitResponse) Reset()

func (*RateLimitResponse) String added in v4.9.0 

func (x *RateLimitResponse) String() string

type RateLimitResult added in v4.9.0 

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

func (*RateLimitResult) Descriptor deprecated added in v4.9.0 

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

Deprecated: Use RateLimitResult.ProtoReflect.Descriptor instead.

func (*RateLimitResult) ProtoMessage added in v4.9.0 

func (*RateLimitResult) ProtoMessage()

func (*RateLimitResult) ProtoReflect added in v4.9.0 

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

func (*RateLimitResult) Reset added in v4.9.0 

func (x *RateLimitResult) Reset()

func (*RateLimitResult) String added in v4.9.0 

func (x *RateLimitResult) String() string

type RefreshRequest 

type RefreshRequest struct {
	User     string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Client   string `protobuf:"bytes,2,opt,name=client,proto3" json:"client,omitempty"`
	Expired  bool   `protobuf:"varint,3,opt,name=expired,proto3" json:"expired,omitempty"`
	ExpireAt int64  `protobuf:"varint,4,opt,name=expire_at,json=expireAt,proto3" json:"expire_at,omitempty"`
	Info     []byte `protobuf:"bytes,5,opt,name=info,proto3" json:"info,omitempty"`
	Session  string `protobuf:"bytes,6,opt,name=session,proto3" json:"session,omitempty"`
	// contains filtered or unexported fields
}

func (*RefreshRequest) Descriptor deprecated 

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

Deprecated: Use RefreshRequest.ProtoReflect.Descriptor instead.

func (*RefreshRequest) GetClient 

func (x *RefreshRequest) GetClient() string

func (*RefreshRequest) GetExpireAt 

func (x *RefreshRequest) GetExpireAt() int64

func (*RefreshRequest) GetExpired 

func (x *RefreshRequest) GetExpired() bool

func (*RefreshRequest) GetInfo 

func (x *RefreshRequest) GetInfo() []byte

func (*RefreshRequest) GetSession 

func (x *RefreshRequest) GetSession() string

func (*RefreshRequest) GetUser 

func (x *RefreshRequest) GetUser() string

func (*RefreshRequest) ProtoMessage 

func (*RefreshRequest) ProtoMessage()

func (*RefreshRequest) ProtoReflect 

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

func (*RefreshRequest) Reset 

func (x *RefreshRequest) Reset()

func (*RefreshRequest) String 

func (x *RefreshRequest) String() string

type RefreshResponse 

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

func (*RefreshResponse) Descriptor deprecated 

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

Deprecated: Use RefreshResponse.ProtoReflect.Descriptor instead.

func (*RefreshResponse) GetError 

func (x *RefreshResponse) GetError() *Error

func (*RefreshResponse) GetResult 

func (x *RefreshResponse) GetResult() *RefreshResult

func (*RefreshResponse) ProtoMessage 

func (*RefreshResponse) ProtoMessage()

func (*RefreshResponse) ProtoReflect 

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

func (*RefreshResponse) Reset 

func (x *RefreshResponse) Reset()

func (*RefreshResponse) String 

func (x *RefreshResponse) String() string

type RefreshResult 

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

func (*RefreshResult) Descriptor deprecated 

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

Deprecated: Use RefreshResult.ProtoReflect.Descriptor instead.

func (*RefreshResult) ProtoMessage 

func (*RefreshResult) ProtoMessage()

func (*RefreshResult) ProtoReflect 

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

func (*RefreshResult) Reset 

func (x *RefreshResult) Reset()

func (*RefreshResult) String 

func (x *RefreshResult) String() string

type Reply 

type Reply struct {
	Id                   uint32                      `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Error                *Error                      `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Result               []byte                      `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
	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"`
	CancelPush           *CancelPushResult           `protobuf:"bytes,35,opt,name=cancel_push,json=cancelPush,proto3" json:"cancel_push,omitempty"`
	RateLimit            *RateLimitResult            `protobuf:"bytes,50,opt,name=rate_limit,json=rateLimit,proto3" json:"rate_limit,omitempty"`
	// contains filtered or unexported fields
}

func (*Reply) Descriptor deprecated 

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

Deprecated: Use Reply.ProtoReflect.Descriptor instead.

func (*Reply) GetBlockUser 

func (x *Reply) GetBlockUser() *BlockUserResult

func (*Reply) GetBroadcast 

func (x *Reply) GetBroadcast() *BroadcastResult

func (*Reply) GetCancelPush added in v4.9.0 

func (x *Reply) GetCancelPush() *CancelPushResult

func (*Reply) GetChannels 

func (x *Reply) GetChannels() *ChannelsResult

func (*Reply) GetConnections 

func (x *Reply) GetConnections() *ConnectionsResult

func (*Reply) GetDeleteUserStatus 

func (x *Reply) GetDeleteUserStatus() *DeleteUserStatusResult

func (*Reply) GetDeviceList 

func (x *Reply) GetDeviceList() *DeviceListResult

func (*Reply) GetDeviceRegister 

func (x *Reply) GetDeviceRegister() *DeviceRegisterResult

func (*Reply) GetDeviceRemove 

func (x *Reply) GetDeviceRemove() *DeviceRemoveResult

func (*Reply) GetDeviceTopicList added in v4.9.0 

func (x *Reply) GetDeviceTopicList() *DeviceTopicListResult

func (*Reply) GetDeviceTopicUpdate added in v4.9.0 

func (x *Reply) GetDeviceTopicUpdate() *DeviceTopicUpdateResult

func (*Reply) GetDeviceUpdate 

func (x *Reply) GetDeviceUpdate() *DeviceUpdateResult

func (*Reply) GetDisconnect 

func (x *Reply) GetDisconnect() *DisconnectResult

func (*Reply) GetError 

func (x *Reply) GetError() *Error

func (*Reply) GetGetUserStatus 

func (x *Reply) GetGetUserStatus() *GetUserStatusResult

func (*Reply) GetHistory 

func (x *Reply) GetHistory() *HistoryResult

func (*Reply) GetHistoryRemove 

func (x *Reply) GetHistoryRemove() *HistoryRemoveResult

func (*Reply) GetId 

func (x *Reply) GetId() uint32

func (*Reply) GetInfo 

func (x *Reply) GetInfo() *InfoResult

func (*Reply) GetInvalidateUserTokens 

func (x *Reply) GetInvalidateUserTokens() *InvalidateUserTokensResult

func (*Reply) GetPresence 

func (x *Reply) GetPresence() *PresenceResult

func (*Reply) GetPresenceStats 

func (x *Reply) GetPresenceStats() *PresenceStatsResult

func (*Reply) GetPublish 

func (x *Reply) GetPublish() *PublishResult

func (*Reply) GetRateLimit added in v4.9.0 

func (x *Reply) GetRateLimit() *RateLimitResult

func (*Reply) GetRefresh 

func (x *Reply) GetRefresh() *RefreshResult

func (*Reply) GetResult 

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

func (*Reply) GetRevokeToken 

func (x *Reply) GetRevokeToken() *RevokeTokenResult

func (*Reply) GetRpc 

func (x *Reply) GetRpc() *RPCResult

func (*Reply) GetSendPushNotification 

func (x *Reply) GetSendPushNotification() *SendPushNotificationResult

func (*Reply) GetSubscribe 

func (x *Reply) GetSubscribe() *SubscribeResult

func (*Reply) GetUnblockUser 

func (x *Reply) GetUnblockUser() *UnblockUserResult

func (*Reply) GetUnsubscribe 

func (x *Reply) GetUnsubscribe() *UnsubscribeResult

func (*Reply) GetUpdatePushStatus added in v4.9.0 

func (x *Reply) GetUpdatePushStatus() *UpdatePushStatusResult

func (*Reply) GetUpdateUserStatus 

func (x *Reply) GetUpdateUserStatus() *UpdateUserStatusResult

func (*Reply) GetUserTopicList added in v4.9.0 

func (x *Reply) GetUserTopicList() *UserTopicListResult

func (*Reply) GetUserTopicUpdate added in v4.9.0 

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

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"`
	Uid          string            `protobuf:"bytes,3,opt,name=uid,proto3" json:"uid,omitempty"` // unique identifier for push notification, used for matching in Centrifugo analytics.
	SendAt       int64             `protobuf:"varint,4,opt,name=send_at,json=sendAt,proto3" json:"send_at,omitempty"`
	// contains filtered or unexported fields
}

func (*SendPushNotificationRequest) Descriptor deprecated 

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

Deprecated: Use SendPushNotificationRequest.ProtoReflect.Descriptor instead.

func (*SendPushNotificationRequest) GetNotification 

func (x *SendPushNotificationRequest) GetNotification() *PushNotification

func (*SendPushNotificationRequest) GetRecipient 

func (x *SendPushNotificationRequest) GetRecipient() *PushRecipient

func (*SendPushNotificationRequest) GetSendAt added in v4.9.0 

func (x *SendPushNotificationRequest) GetSendAt() int64

func (*SendPushNotificationRequest) GetUid added in v4.9.0 

func (x *SendPushNotificationRequest) GetUid() string

func (*SendPushNotificationRequest) ProtoMessage 

func (*SendPushNotificationRequest) ProtoMessage()

func (*SendPushNotificationRequest) ProtoReflect 

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

func (*SendPushNotificationRequest) Reset 

func (x *SendPushNotificationRequest) Reset()

func (*SendPushNotificationRequest) String 

func (x *SendPushNotificationRequest) String() string

type SendPushNotificationResponse 

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 

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

Deprecated: Use SendPushNotificationResponse.ProtoReflect.Descriptor instead.

func (*SendPushNotificationResponse) GetError 

func (x *SendPushNotificationResponse) GetError() *Error

func (*SendPushNotificationResponse) GetResult 

func (x *SendPushNotificationResponse) GetResult() *SendPushNotificationResult

func (*SendPushNotificationResponse) ProtoMessage 

func (*SendPushNotificationResponse) ProtoMessage()

func (*SendPushNotificationResponse) ProtoReflect 

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

func (*SendPushNotificationResponse) Reset 

func (x *SendPushNotificationResponse) Reset()

func (*SendPushNotificationResponse) String 

func (x *SendPushNotificationResponse) String() string

type SendPushNotificationResult 

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

func (*SendPushNotificationResult) Descriptor deprecated 

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

Deprecated: Use SendPushNotificationResult.ProtoReflect.Descriptor instead.

func (*SendPushNotificationResult) GetUid 

func (x *SendPushNotificationResult) GetUid() string

func (*SendPushNotificationResult) ProtoMessage 

func (*SendPushNotificationResult) ProtoMessage()

func (*SendPushNotificationResult) ProtoReflect 

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

func (*SendPushNotificationResult) Reset 

func (x *SendPushNotificationResult) Reset()

func (*SendPushNotificationResult) String 

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         []byte                   `protobuf:"bytes,4,opt,name=info,proto3" json:"info,omitempty"`
	B64Info      string                   `protobuf:"bytes,5,opt,name=b64info,proto3" json:"b64info,omitempty"`
	Client       string                   `protobuf:"bytes,6,opt,name=client,proto3" json:"client,omitempty"`
	Data         []byte                   `protobuf:"bytes,7,opt,name=data,proto3" json:"data,omitempty"`
	B64Data      string                   `protobuf:"bytes,8,opt,name=b64data,proto3" json:"b64data,omitempty"`
	RecoverSince *StreamPosition          `protobuf:"bytes,9,opt,name=recover_since,json=recoverSince,proto3" json:"recover_since,omitempty"`
	Override     *SubscribeOptionOverride `protobuf:"bytes,10,opt,name=override,proto3" json:"override,omitempty"`
	Session      string                   `protobuf:"bytes,11,opt,name=session,proto3" json:"session,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.

func (*SubscribeRequest) GetB64Data 

func (x *SubscribeRequest) GetB64Data() string

func (*SubscribeRequest) GetB64Info 

func (x *SubscribeRequest) GetB64Info() string

func (*SubscribeRequest) GetChannel 

func (x *SubscribeRequest) GetChannel() string

func (*SubscribeRequest) GetClient 

func (x *SubscribeRequest) GetClient() string

func (*SubscribeRequest) GetData 

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

func (*SubscribeRequest) GetExpireAt 

func (x *SubscribeRequest) GetExpireAt() int64

func (*SubscribeRequest) GetInfo 

func (x *SubscribeRequest) GetInfo() []byte

func (*SubscribeRequest) GetOverride 

func (x *SubscribeRequest) GetOverride() *SubscribeOptionOverride

func (*SubscribeRequest) GetRecoverSince 

func (x *SubscribeRequest) GetRecoverSince() *StreamPosition

func (*SubscribeRequest) GetSession 

func (x *SubscribeRequest) GetSession() string

func (*SubscribeRequest) GetUser 

func (x *SubscribeRequest) GetUser() string

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) ProtoReflect 

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

func (*SubscribeRequest) Reset 

func (x *SubscribeRequest) Reset()

func (*SubscribeRequest) String 

func (x *SubscribeRequest) String() string

type SubscribeResponse 

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

func (*SubscribeResponse) Descriptor deprecated 

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

Deprecated: Use SubscribeResponse.ProtoReflect.Descriptor instead.

func (*SubscribeResponse) GetError 

func (x *SubscribeResponse) GetError() *Error

func (*SubscribeResponse) GetResult 

func (x *SubscribeResponse) GetResult() *SubscribeResult

func (*SubscribeResponse) ProtoMessage 

func (*SubscribeResponse) ProtoMessage()

func (*SubscribeResponse) ProtoReflect 

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

func (*SubscribeResponse) Reset 

func (x *SubscribeResponse) Reset()

func (*SubscribeResponse) String 

func (x *SubscribeResponse) String() string

type SubscribeResult 

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

func (*SubscribeResult) Descriptor deprecated 

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

Deprecated: Use SubscribeResult.ProtoReflect.Descriptor instead.

func (*SubscribeResult) ProtoMessage 

func (*SubscribeResult) ProtoMessage()

func (*SubscribeResult) ProtoReflect 

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

func (*SubscribeResult) Reset 

func (x *SubscribeResult) Reset()

func (*SubscribeResult) String 

func (x *SubscribeResult) String() string

type SubscriptionTokenInfo 

type SubscriptionTokenInfo struct {
	Uid      string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
	IssuedAt int64  `protobuf:"varint,2,opt,name=issued_at,json=issuedAt,proto3" json:"issued_at,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscriptionTokenInfo) Descriptor deprecated 

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

Deprecated: Use SubscriptionTokenInfo.ProtoReflect.Descriptor instead.

func (*SubscriptionTokenInfo) GetIssuedAt 

func (x *SubscriptionTokenInfo) GetIssuedAt() int64

func (*SubscriptionTokenInfo) GetUid 

func (x *SubscriptionTokenInfo) GetUid() string

func (*SubscriptionTokenInfo) ProtoMessage 

func (*SubscriptionTokenInfo) ProtoMessage()

func (*SubscriptionTokenInfo) ProtoReflect 

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

func (*SubscriptionTokenInfo) Reset 

func (x *SubscriptionTokenInfo) Reset()

func (*SubscriptionTokenInfo) String 

func (x *SubscriptionTokenInfo) String() string

type UnblockUserRequest 

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

func (*UnblockUserRequest) Descriptor deprecated 

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

Deprecated: Use UnblockUserRequest.ProtoReflect.Descriptor instead.

func (*UnblockUserRequest) GetUser 

func (x *UnblockUserRequest) GetUser() string

func (*UnblockUserRequest) ProtoMessage 

func (*UnblockUserRequest) ProtoMessage()

func (*UnblockUserRequest) ProtoReflect 

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

func (*UnblockUserRequest) Reset 

func (x *UnblockUserRequest) Reset()

func (*UnblockUserRequest) String 

func (x *UnblockUserRequest) String() string

type UnblockUserResponse 

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

func (*UnblockUserResponse) Descriptor deprecated 

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

Deprecated: Use UnblockUserResponse.ProtoReflect.Descriptor instead.

func (*UnblockUserResponse) GetError 

func (x *UnblockUserResponse) GetError() *Error

func (*UnblockUserResponse) GetResult 

func (x *UnblockUserResponse) GetResult() *UnblockUserResult

func (*UnblockUserResponse) ProtoMessage 

func (*UnblockUserResponse) ProtoMessage()

func (*UnblockUserResponse) ProtoReflect 

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

func (*UnblockUserResponse) Reset 

func (x *UnblockUserResponse) Reset()

func (*UnblockUserResponse) String 

func (x *UnblockUserResponse) String() string

type UnblockUserResult 

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

func (*UnblockUserResult) Descriptor deprecated 

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

Deprecated: Use UnblockUserResult.ProtoReflect.Descriptor instead.

func (*UnblockUserResult) ProtoMessage 

func (*UnblockUserResult) ProtoMessage()

func (*UnblockUserResult) ProtoReflect 

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

func (*UnblockUserResult) Reset 

func (x *UnblockUserResult) Reset()

func (*UnblockUserResult) String 

func (x *UnblockUserResult) String() string

type UnimplementedCentrifugoApiServer 

type UnimplementedCentrifugoApiServer struct {
}

UnimplementedCentrifugoApiServer should be embedded to have forward compatible implementations.

func (UnimplementedCentrifugoApiServer) Batch 

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) CancelPush added in v4.9.0 

func (UnimplementedCentrifugoApiServer) CancelPush(context.Context, *CancelPushRequest) (*CancelPushResponse, 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 

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

func (UnimplementedCentrifugoApiServer) DeviceRegister 

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

func (UnimplementedCentrifugoApiServer) DeviceRemove 

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

func (UnimplementedCentrifugoApiServer) DeviceTopicList added in v4.9.0 

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

func (UnimplementedCentrifugoApiServer) DeviceTopicUpdate added in v4.9.0 

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

func (UnimplementedCentrifugoApiServer) DeviceUpdate 

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) RateLimit added in v4.9.0 

func (UnimplementedCentrifugoApiServer) RateLimit(context.Context, *RateLimitRequest) (*RateLimitResponse, 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 

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.9.0 

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.9.0 

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

func (UnimplementedCentrifugoApiServer) UserTopicUpdate added in v4.9.0 

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.9.0 

type UpdatePushStatusRequest struct {
	Uid      string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`                           // uid of push notification (matches SendPushNotificationResult.uid)
	Status   string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`                     // failed | sent | delivered | interacted
	DeviceId string `protobuf:"bytes,3,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"` // Centrifugo device id.
	MsgId    string `protobuf:"bytes,4,opt,name=msg_id,json=msgId,proto3" json:"msg_id,omitempty"`          // Provider issued message id.
	// contains filtered or unexported fields
}

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

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

Deprecated: Use UpdatePushStatusRequest.ProtoReflect.Descriptor instead.

func (*UpdatePushStatusRequest) GetDeviceId added in v4.9.0 

func (x *UpdatePushStatusRequest) GetDeviceId() string

func (*UpdatePushStatusRequest) GetMsgId added in v4.9.0 

func (x *UpdatePushStatusRequest) GetMsgId() string

func (*UpdatePushStatusRequest) GetStatus added in v4.9.0 

func (x *UpdatePushStatusRequest) GetStatus() string

func (*UpdatePushStatusRequest) GetUid added in v4.9.0 

func (x *UpdatePushStatusRequest) GetUid() string

func (*UpdatePushStatusRequest) ProtoMessage added in v4.9.0 

func (*UpdatePushStatusRequest) ProtoMessage()

func (*UpdatePushStatusRequest) ProtoReflect added in v4.9.0 

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

func (*UpdatePushStatusRequest) Reset added in v4.9.0 

func (x *UpdatePushStatusRequest) Reset()

func (*UpdatePushStatusRequest) String added in v4.9.0 

func (x *UpdatePushStatusRequest) String() string

type UpdatePushStatusResponse added in v4.9.0 

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.9.0 

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

Deprecated: Use UpdatePushStatusResponse.ProtoReflect.Descriptor instead.

func (*UpdatePushStatusResponse) GetError added in v4.9.0 

func (x *UpdatePushStatusResponse) GetError() *Error

func (*UpdatePushStatusResponse) GetResult added in v4.9.0 

func (x *UpdatePushStatusResponse) GetResult() *UpdatePushStatusResult

func (*UpdatePushStatusResponse) ProtoMessage added in v4.9.0 

func (*UpdatePushStatusResponse) ProtoMessage()

func (*UpdatePushStatusResponse) ProtoReflect added in v4.9.0 

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

func (*UpdatePushStatusResponse) Reset added in v4.9.0 

func (x *UpdatePushStatusResponse) Reset()

func (*UpdatePushStatusResponse) String added in v4.9.0 

func (x *UpdatePushStatusResponse) String() string

type UpdatePushStatusResult added in v4.9.0 

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

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

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

Deprecated: Use UpdatePushStatusResult.ProtoReflect.Descriptor instead.

func (*UpdatePushStatusResult) ProtoMessage added in v4.9.0 

func (*UpdatePushStatusResult) ProtoMessage()

func (*UpdatePushStatusResult) ProtoReflect added in v4.9.0 

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

func (*UpdatePushStatusResult) Reset added in v4.9.0 

func (x *UpdatePushStatusResult) Reset()

func (*UpdatePushStatusResult) String added in v4.9.0 

func (x *UpdatePushStatusResult) String() string

type UpdateUserStatusRequest 

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

func (*UpdateUserStatusRequest) Descriptor deprecated 

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

Deprecated: Use UpdateUserStatusRequest.ProtoReflect.Descriptor instead.

func (*UpdateUserStatusRequest) GetState added in v4.11.0 

func (x *UpdateUserStatusRequest) GetState() string

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"`
	State  string `protobuf:"bytes,4,opt,name=state,proto3" json:"state,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) GetState added in v4.11.0 

func (x *UserStatus) GetState() string

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.9.0 

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.9.0 

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

Deprecated: Use UserTopic.ProtoReflect.Descriptor instead.

func (*UserTopic) GetId added in v4.9.0 

func (x *UserTopic) GetId() string

func (*UserTopic) GetTopic added in v4.9.0 

func (x *UserTopic) GetTopic() string

func (*UserTopic) GetUser added in v4.9.0 

func (x *UserTopic) GetUser() string

func (*UserTopic) ProtoMessage added in v4.9.0 

func (*UserTopic) ProtoMessage()

func (*UserTopic) ProtoReflect added in v4.9.0 

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

func (*UserTopic) Reset added in v4.9.0 

func (x *UserTopic) Reset()

func (*UserTopic) String added in v4.9.0 

func (x *UserTopic) String() string

type UserTopicFilter added in v4.9.0 

type UserTopicFilter 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"`
	// contains filtered or unexported fields
}

func (*UserTopicFilter) Descriptor deprecated added in v4.9.0 

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

Deprecated: Use UserTopicFilter.ProtoReflect.Descriptor instead.

func (*UserTopicFilter) GetTopicPrefix added in v4.9.0 

func (x *UserTopicFilter) GetTopicPrefix() string

func (*UserTopicFilter) GetTopics added in v4.9.0 

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

func (*UserTopicFilter) GetUsers added in v4.9.0 

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

func (*UserTopicFilter) ProtoMessage added in v4.9.0 

func (*UserTopicFilter) ProtoMessage()

func (*UserTopicFilter) ProtoReflect added in v4.9.0 

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

func (*UserTopicFilter) Reset added in v4.9.0 

func (x *UserTopicFilter) Reset()

func (*UserTopicFilter) String added in v4.9.0 

func (x *UserTopicFilter) String() string

type UserTopicListRequest added in v4.9.0 

type UserTopicListRequest struct {
	Filter            *UserTopicFilter `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	IncludeTotalCount bool             `protobuf:"varint,2,opt,name=include_total_count,json=includeTotalCount,proto3" json:"include_total_count,omitempty"`
	Cursor            string           `protobuf:"bytes,10,opt,name=cursor,proto3" json:"cursor,omitempty"`
	Limit             int32            `protobuf:"varint,11,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use UserTopicListRequest.ProtoReflect.Descriptor instead.

func (*UserTopicListRequest) GetCursor added in v4.9.0 

func (x *UserTopicListRequest) GetCursor() string

func (*UserTopicListRequest) GetFilter added in v4.9.0 

func (x *UserTopicListRequest) GetFilter() *UserTopicFilter

func (*UserTopicListRequest) GetIncludeTotalCount added in v4.9.0 

func (x *UserTopicListRequest) GetIncludeTotalCount() bool

func (*UserTopicListRequest) GetLimit added in v4.9.0 

func (x *UserTopicListRequest) GetLimit() int32

func (*UserTopicListRequest) ProtoMessage added in v4.9.0 

func (*UserTopicListRequest) ProtoMessage()

func (*UserTopicListRequest) ProtoReflect added in v4.9.0 

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

func (*UserTopicListRequest) Reset added in v4.9.0 

func (x *UserTopicListRequest) Reset()

func (*UserTopicListRequest) String added in v4.9.0 

func (x *UserTopicListRequest) String() string

type UserTopicListResponse added in v4.9.0 

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.9.0 

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

Deprecated: Use UserTopicListResponse.ProtoReflect.Descriptor instead.

func (*UserTopicListResponse) GetError added in v4.9.0 

func (x *UserTopicListResponse) GetError() *Error

func (*UserTopicListResponse) GetResult added in v4.9.0 

func (x *UserTopicListResponse) GetResult() *UserTopicListResult

func (*UserTopicListResponse) ProtoMessage added in v4.9.0 

func (*UserTopicListResponse) ProtoMessage()

func (*UserTopicListResponse) ProtoReflect added in v4.9.0 

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

func (*UserTopicListResponse) Reset added in v4.9.0 

func (x *UserTopicListResponse) Reset()

func (*UserTopicListResponse) String added in v4.9.0 

func (x *UserTopicListResponse) String() string

type UserTopicListResult added in v4.9.0 

type UserTopicListResult struct {
	Items      []*UserTopic `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	NextCursor string       `protobuf:"bytes,2,opt,name=next_cursor,json=nextCursor,proto3" json:"next_cursor,omitempty"`
	TotalCount int64        `protobuf:"varint,3,opt,name=total_count,json=totalCount,proto3" json:"total_count,omitempty"`
	// contains filtered or unexported fields
}

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

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

Deprecated: Use UserTopicListResult.ProtoReflect.Descriptor instead.

func (*UserTopicListResult) GetItems added in v4.9.0 

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

func (*UserTopicListResult) GetNextCursor added in v4.9.0 

func (x *UserTopicListResult) GetNextCursor() string

func (*UserTopicListResult) GetTotalCount added in v4.9.0 

func (x *UserTopicListResult) GetTotalCount() int64

func (*UserTopicListResult) ProtoMessage added in v4.9.0 

func (*UserTopicListResult) ProtoMessage()

func (*UserTopicListResult) ProtoReflect added in v4.9.0 

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

func (*UserTopicListResult) Reset added in v4.9.0 

func (x *UserTopicListResult) Reset()

func (*UserTopicListResult) String added in v4.9.0 

func (x *UserTopicListResult) String() string

type UserTopicUpdateRequest added in v4.9.0 

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.9.0 

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

Deprecated: Use UserTopicUpdateRequest.ProtoReflect.Descriptor instead.

func (*UserTopicUpdateRequest) GetOp added in v4.9.0 

func (x *UserTopicUpdateRequest) GetOp() string

func (*UserTopicUpdateRequest) GetTopics added in v4.9.0 

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

func (*UserTopicUpdateRequest) GetUser added in v4.9.0 

func (x *UserTopicUpdateRequest) GetUser() string

func (*UserTopicUpdateRequest) ProtoMessage added in v4.9.0 

func (*UserTopicUpdateRequest) ProtoMessage()

func (*UserTopicUpdateRequest) ProtoReflect added in v4.9.0 

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

func (*UserTopicUpdateRequest) Reset added in v4.9.0 

func (x *UserTopicUpdateRequest) Reset()

func (*UserTopicUpdateRequest) String added in v4.9.0 

func (x *UserTopicUpdateRequest) String() string

type UserTopicUpdateResponse added in v4.9.0 

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.9.0 

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

Deprecated: Use UserTopicUpdateResponse.ProtoReflect.Descriptor instead.

func (*UserTopicUpdateResponse) GetError added in v4.9.0 

func (x *UserTopicUpdateResponse) GetError() *Error

func (*UserTopicUpdateResponse) GetResult added in v4.9.0 

func (x *UserTopicUpdateResponse) GetResult() *UserTopicUpdateResult

func (*UserTopicUpdateResponse) ProtoMessage added in v4.9.0 

func (*UserTopicUpdateResponse) ProtoMessage()

func (*UserTopicUpdateResponse) ProtoReflect added in v4.9.0 

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

func (*UserTopicUpdateResponse) Reset added in v4.9.0 

func (x *UserTopicUpdateResponse) Reset()

func (*UserTopicUpdateResponse) String added in v4.9.0 

func (x *UserTopicUpdateResponse) String() string

type UserTopicUpdateResult added in v4.9.0 

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

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

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

Deprecated: Use UserTopicUpdateResult.ProtoReflect.Descriptor instead.

func (*UserTopicUpdateResult) ProtoMessage added in v4.9.0 

func (*UserTopicUpdateResult) ProtoMessage()

func (*UserTopicUpdateResult) ProtoReflect added in v4.9.0 

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

func (*UserTopicUpdateResult) Reset added in v4.9.0 

func (x *UserTopicUpdateResult) Reset()

func (*UserTopicUpdateResult) String added in v4.9.0 

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.