apiproto

package
v5.0.3 Latest Latest
Warning

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

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

README

Generate HTTP API libraries from swagger spec:

git clone --depth 1 -b master https://github.com/swagger-api/swagger-codegen.git
cd swagger-codegen
cp /path/to/api.swagger.json ./api.swagger.json

Go library:

./run-in-docker.sh generate -i api.swagger.json -l go -o /gen/out/go-centrifugo -DpackageName=centrifugo
ls out/go-centrifugo

Then:

package main

import (
	"context"
	"fmt"
	"net/http"
	"time"

	"test_project/centrifugo"
)

func main() {
	httpClient := &http.Client{Transport: &http.Transport{
		MaxIdleConnsPerHost: 100,
	}, Timeout: time.Second}
	client := centrifugo.NewAPIClient(&centrifugo.Configuration{
		BasePath:      "http://localhost:8000/api",
		DefaultHeader: map[string]string{"Authorization": "apikey "},
		HTTPClient:    httpClient,
	})
	reply, resp, err := client.PublicationApi.CentrifugoApiPublish(context.Background(), centrifugo.PublishRequest{
		Channel: "test",
		Data:    map[string]string{},
	})
	if err != nil {
		panic(err)
	}
	if resp.StatusCode != 200 {
		panic(resp.StatusCode)
	}
	if reply.Error_ != nil {
		panic(reply.Error_.Message)
	}
	fmt.Println("ok")
}

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Command_MethodType_name = map[int32]string{
		0:  "PUBLISH",
		1:  "BROADCAST",
		2:  "UNSUBSCRIBE",
		3:  "DISCONNECT",
		4:  "PRESENCE",
		5:  "PRESENCE_STATS",
		6:  "HISTORY",
		7:  "HISTORY_REMOVE",
		8:  "CHANNELS",
		9:  "INFO",
		10: "RPC",
		11: "SUBSCRIBE",
		12: "REFRESH",
		14: "CONNECTIONS",
		15: "UPDATE_USER_STATUS",
		16: "GET_USER_STATUS",
		17: "DELETE_USER_STATUS",
		18: "BLOCK_USER",
		19: "UNBLOCK_USER",
		20: "REVOKE_TOKEN",
		21: "INVALIDATE_USER_TOKENS",
		22: "DEVICE_REGISTER",
		23: "DEVICE_UPDATE",
		24: "DEVICE_REMOVE",
		25: "DEVICE_LIST",
		26: "DEVICE_TOPIC_LIST",
		27: "DEVICE_TOPIC_UPDATE",
		28: "USER_TOPIC_LIST",
		29: "USER_TOPIC_UPDATE",
		30: "SEND_PUSH_NOTIFICATION",
		31: "UPDATE_PUSH_STATUS",
	}
	Command_MethodType_value = map[string]int32{
		"PUBLISH":                0,
		"BROADCAST":              1,
		"UNSUBSCRIBE":            2,
		"DISCONNECT":             3,
		"PRESENCE":               4,
		"PRESENCE_STATS":         5,
		"HISTORY":                6,
		"HISTORY_REMOVE":         7,
		"CHANNELS":               8,
		"INFO":                   9,
		"RPC":                    10,
		"SUBSCRIBE":              11,
		"REFRESH":                12,
		"CONNECTIONS":            14,
		"UPDATE_USER_STATUS":     15,
		"GET_USER_STATUS":        16,
		"DELETE_USER_STATUS":     17,
		"BLOCK_USER":             18,
		"UNBLOCK_USER":           19,
		"REVOKE_TOKEN":           20,
		"INVALIDATE_USER_TOKENS": 21,
		"DEVICE_REGISTER":        22,
		"DEVICE_UPDATE":          23,
		"DEVICE_REMOVE":          24,
		"DEVICE_LIST":            25,
		"DEVICE_TOPIC_LIST":      26,
		"DEVICE_TOPIC_UPDATE":    27,
		"USER_TOPIC_LIST":        28,
		"USER_TOPIC_UPDATE":      29,
		"SEND_PUSH_NOTIFICATION": 30,
		"UPDATE_PUSH_STATUS":     31,
	}
)

Enum value maps for Command_MethodType.

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

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

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

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

View Source 
var File_api_proto protoreflect.FileDescriptor

Functions

func PutCommandDecoder 

func PutCommandDecoder(d CommandDecoder)

PutCommandDecoder ...

func PutParamsDecoder 

func PutParamsDecoder(_ RequestDecoder)

PutParamsDecoder ...

func PutReplyEncoder 

func PutReplyEncoder(e ReplyEncoder)

PutReplyEncoder ...

func PutResultEncoder 

func PutResultEncoder(_ ResultEncoder)

PutResultEncoder ...

func RegisterCentrifugoApiServer 

func RegisterCentrifugoApiServer(s grpc.ServiceRegistrar, srv CentrifugoApiServer)

Types

type ApnsPushNotification 

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

func (*ApnsPushNotification) Descriptor deprecated 

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"`
	// 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) 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        Raw               `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	B64Data     string            `protobuf:"bytes,3,opt,name=b64data,proto3" json:"b64data,omitempty"`
	SkipHistory bool              `protobuf:"varint,4,opt,name=skip_history,json=skipHistory,proto3" json:"skip_history,omitempty"`
	Tags        map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*BroadcastRequest) Descriptor deprecated 

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

Deprecated: Use BroadcastRequest.ProtoReflect.Descriptor instead.

func (*BroadcastRequest) GetB64Data 

func (x *BroadcastRequest) GetB64Data() string

func (*BroadcastRequest) GetChannels 

func (x *BroadcastRequest) GetChannels() []string

func (*BroadcastRequest) GetData 

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

func (*BroadcastRequest) GetSkipHistory 

func (x *BroadcastRequest) GetSkipHistory() bool

func (*BroadcastRequest) GetTags 

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

func (*BroadcastRequest) ProtoMessage 

func (*BroadcastRequest) ProtoMessage()

func (*BroadcastRequest) ProtoReflect 

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

func (*BroadcastRequest) Reset 

func (x *BroadcastRequest) Reset()

func (*BroadcastRequest) String 

func (x *BroadcastRequest) String() string

type BroadcastResponse 

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

func (*BroadcastResponse) Descriptor deprecated 

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

Deprecated: Use BroadcastResponse.ProtoReflect.Descriptor instead.

func (*BroadcastResponse) GetError 

func (x *BroadcastResponse) GetError() *Error

func (*BroadcastResponse) GetResult 

func (x *BroadcastResponse) GetResult() *BroadcastResult

func (*BroadcastResponse) ProtoMessage 

func (*BroadcastResponse) ProtoMessage()

func (*BroadcastResponse) ProtoReflect 

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

func (*BroadcastResponse) Reset 

func (x *BroadcastResponse) Reset()

func (*BroadcastResponse) String 

func (x *BroadcastResponse) String() string

type BroadcastResult 

type BroadcastResult struct {
	Responses []*PublishResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

func (*BroadcastResult) Descriptor deprecated 

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

Deprecated: Use BroadcastResult.ProtoReflect.Descriptor instead.

func (*BroadcastResult) GetResponses 

func (x *BroadcastResult) GetResponses() []*PublishResponse

func (*BroadcastResult) ProtoMessage 

func (*BroadcastResult) ProtoMessage()

func (*BroadcastResult) ProtoReflect 

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

func (*BroadcastResult) Reset 

func (x *BroadcastResult) Reset()

func (*BroadcastResult) String 

func (x *BroadcastResult) String() string

type CancelPushRequest added in v5.0.3 

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 v5.0.3 

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

Deprecated: Use CancelPushRequest.ProtoReflect.Descriptor instead.

func (*CancelPushRequest) GetUid added in v5.0.3 

func (x *CancelPushRequest) GetUid() string

func (*CancelPushRequest) ProtoMessage added in v5.0.3 

func (*CancelPushRequest) ProtoMessage()

func (*CancelPushRequest) ProtoReflect added in v5.0.3 

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

func (*CancelPushRequest) Reset added in v5.0.3 

func (x *CancelPushRequest) Reset()

func (*CancelPushRequest) String added in v5.0.3 

func (x *CancelPushRequest) String() string

type CancelPushResponse added in v5.0.3 

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 v5.0.3 

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

Deprecated: Use CancelPushResponse.ProtoReflect.Descriptor instead.

func (*CancelPushResponse) GetError added in v5.0.3 

func (x *CancelPushResponse) GetError() *Error

func (*CancelPushResponse) GetResult added in v5.0.3 

func (x *CancelPushResponse) GetResult() *CancelPushResult

func (*CancelPushResponse) ProtoMessage added in v5.0.3 

func (*CancelPushResponse) ProtoMessage()

func (*CancelPushResponse) ProtoReflect added in v5.0.3 

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

func (*CancelPushResponse) Reset added in v5.0.3 

func (x *CancelPushResponse) Reset()

func (*CancelPushResponse) String added in v5.0.3 

func (x *CancelPushResponse) String() string

type CancelPushResult added in v5.0.3 

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

func (*CancelPushResult) Descriptor deprecated added in v5.0.3 

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

Deprecated: Use CancelPushResult.ProtoReflect.Descriptor instead.

func (*CancelPushResult) ProtoMessage added in v5.0.3 

func (*CancelPushResult) ProtoMessage()

func (*CancelPushResult) ProtoReflect added in v5.0.3 

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

func (*CancelPushResult) Reset added in v5.0.3 

func (x *CancelPushResult) Reset()

func (*CancelPushResult) String added in v5.0.3 

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

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)
	// contains filtered or unexported methods
}

CentrifugoApiServer is the server API for CentrifugoApi service. All implementations must 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 `` /* 147-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ChannelsResult) Descriptor deprecated 

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

Deprecated: Use ChannelsResult.ProtoReflect.Descriptor instead.

func (*ChannelsResult) GetChannels 

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

func (*ChannelsResult) ProtoMessage 

func (*ChannelsResult) ProtoMessage()

func (*ChannelsResult) ProtoReflect 

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

func (*ChannelsResult) Reset 

func (x *ChannelsResult) Reset()

func (*ChannelsResult) String 

func (x *ChannelsResult) String() string

type ClientInfo 

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

func (*ClientInfo) Descriptor deprecated 

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

Deprecated: Use ClientInfo.ProtoReflect.Descriptor instead.

func (*ClientInfo) GetChanInfo 

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

func (*ClientInfo) GetClient 

func (x *ClientInfo) GetClient() string

func (*ClientInfo) GetConnInfo 

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

func (*ClientInfo) GetUser 

func (x *ClientInfo) GetUser() string

func (*ClientInfo) ProtoMessage 

func (*ClientInfo) ProtoMessage()

func (*ClientInfo) ProtoReflect 

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

func (*ClientInfo) Reset 

func (x *ClientInfo) Reset()

func (*ClientInfo) String 

func (x *ClientInfo) String() string

type Command 

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

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 

func (x *Command) GetDeviceTopicList() *DeviceTopicListRequest

func (*Command) GetDeviceTopicUpdate 

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

func (x *Command) GetUpdatePushStatus() *UpdatePushStatusRequest

func (*Command) GetUpdateUserStatus 

func (x *Command) GetUpdateUserStatus() *UpdateUserStatusRequest

func (*Command) GetUserTopicList 

func (x *Command) GetUserTopicList() *UserTopicListRequest

func (*Command) GetUserTopicUpdate 

func (x *Command) GetUserTopicUpdate() *UserTopicUpdateRequest

func (*Command) ProtoMessage 

func (*Command) ProtoMessage()

func (*Command) ProtoReflect 

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

func (*Command) Reset 

func (x *Command) Reset()

func (*Command) String 

func (x *Command) String() string

type CommandDecoder 

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

CommandDecoder ...

func GetCommandDecoder 

func GetCommandDecoder(data []byte) CommandDecoder

GetCommandDecoder ...

type Command_MethodType 

type Command_MethodType int32
const (
	Command_PUBLISH                Command_MethodType = 0
	Command_BROADCAST              Command_MethodType = 1
	Command_UNSUBSCRIBE            Command_MethodType = 2
	Command_DISCONNECT             Command_MethodType = 3
	Command_PRESENCE               Command_MethodType = 4
	Command_PRESENCE_STATS         Command_MethodType = 5
	Command_HISTORY                Command_MethodType = 6
	Command_HISTORY_REMOVE         Command_MethodType = 7
	Command_CHANNELS               Command_MethodType = 8
	Command_INFO                   Command_MethodType = 9
	Command_RPC                    Command_MethodType = 10
	Command_SUBSCRIBE              Command_MethodType = 11
	Command_REFRESH                Command_MethodType = 12
	Command_CONNECTIONS            Command_MethodType = 14
	Command_UPDATE_USER_STATUS     Command_MethodType = 15
	Command_GET_USER_STATUS        Command_MethodType = 16
	Command_DELETE_USER_STATUS     Command_MethodType = 17
	Command_BLOCK_USER             Command_MethodType = 18
	Command_UNBLOCK_USER           Command_MethodType = 19
	Command_REVOKE_TOKEN           Command_MethodType = 20
	Command_INVALIDATE_USER_TOKENS Command_MethodType = 21
	Command_DEVICE_REGISTER        Command_MethodType = 22
	Command_DEVICE_UPDATE          Command_MethodType = 23
	Command_DEVICE_REMOVE          Command_MethodType = 24
	Command_DEVICE_LIST            Command_MethodType = 25
	Command_DEVICE_TOPIC_LIST      Command_MethodType = 26
	Command_DEVICE_TOPIC_UPDATE    Command_MethodType = 27
	Command_USER_TOPIC_LIST        Command_MethodType = 28
	Command_USER_TOPIC_UPDATE      Command_MethodType = 29
	Command_SEND_PUSH_NOTIFICATION Command_MethodType = 30
	Command_UPDATE_PUSH_STATUS     Command_MethodType = 31
)

func (Command_MethodType) Descriptor 

func (Command_MethodType) Descriptor() protoreflect.EnumDescriptor

func (Command_MethodType) Enum 

func (x Command_MethodType) Enum() *Command_MethodType

func (Command_MethodType) EnumDescriptor deprecated 

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

Deprecated: Use Command_MethodType.Descriptor instead.

func (Command_MethodType) Number 

func (x Command_MethodType) Number() protoreflect.EnumNumber

func (Command_MethodType) String 

func (x Command_MethodType) String() string

func (Command_MethodType) Type 

func (Command_MethodType) Type() protoreflect.EnumType

func (*Command_MethodType) UnmarshalJSON 

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

UnmarshalJSON helps to unmarshal command method when set as string.

type ConnectionInfo 

type ConnectionInfo struct {
	AppName    string `protobuf:"bytes,1,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"`
	AppVersion string `protobuf:"bytes,2,opt,name=app_version,json=appVersion,proto3" json:"app_version,omitempty"`
	Transport  string `protobuf:"bytes,3,opt,name=transport,proto3" json:"transport,omitempty"`
	Protocol   string `protobuf:"bytes,4,opt,name=protocol,proto3" json:"protocol,omitempty"`
	// 5-7 dropped for backwards compatibility.
	User  string           `protobuf:"bytes,8,opt,name=user,proto3" json:"user,omitempty"`
	State *ConnectionState `protobuf:"bytes,9,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectionInfo) Descriptor deprecated 

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

Deprecated: Use ConnectionInfo.ProtoReflect.Descriptor instead.

func (*ConnectionInfo) GetAppName 

func (x *ConnectionInfo) GetAppName() string

func (*ConnectionInfo) GetAppVersion 

func (x *ConnectionInfo) GetAppVersion() string

func (*ConnectionInfo) GetProtocol 

func (x *ConnectionInfo) GetProtocol() string

func (*ConnectionInfo) GetState 

func (x *ConnectionInfo) GetState() *ConnectionState

func (*ConnectionInfo) GetTransport 

func (x *ConnectionInfo) GetTransport() string

func (*ConnectionInfo) GetUser 

func (x *ConnectionInfo) GetUser() string

func (*ConnectionInfo) ProtoMessage 

func (*ConnectionInfo) ProtoMessage()

func (*ConnectionInfo) ProtoReflect 

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

func (*ConnectionInfo) Reset 

func (x *ConnectionInfo) Reset()

func (*ConnectionInfo) String 

func (x *ConnectionInfo) String() string

type ConnectionState 

type ConnectionState struct {
	Channels           map[string]*ChannelContext        `` /* 157-byte string literal not displayed */
	ConnectionToken    *ConnectionTokenInfo              `protobuf:"bytes,2,opt,name=connection_token,json=connectionToken,proto3" json:"connection_token,omitempty"`
	SubscriptionTokens map[string]*SubscriptionTokenInfo `` /* 203-byte string literal not displayed */
	Meta               Raw                               `protobuf:"bytes,4,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectionState) Descriptor deprecated 

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

Deprecated: Use ConnectionState.ProtoReflect.Descriptor instead.

func (*ConnectionState) GetChannels 

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

func (*ConnectionState) GetConnectionToken 

func (x *ConnectionState) GetConnectionToken() *ConnectionTokenInfo

func (*ConnectionState) GetMeta 

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

func (*ConnectionState) GetSubscriptionTokens 

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

func (*ConnectionState) ProtoMessage 

func (*ConnectionState) ProtoMessage()

func (*ConnectionState) ProtoReflect 

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

func (*ConnectionState) Reset 

func (x *ConnectionState) Reset()

func (*ConnectionState) String 

func (x *ConnectionState) String() string

type ConnectionTokenInfo 

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

func (*ConnectionTokenInfo) Descriptor deprecated 

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

Deprecated: Use ConnectionTokenInfo.ProtoReflect.Descriptor instead.

func (*ConnectionTokenInfo) GetIssuedAt 

func (x *ConnectionTokenInfo) GetIssuedAt() int64

func (*ConnectionTokenInfo) GetUid 

func (x *ConnectionTokenInfo) GetUid() string

func (*ConnectionTokenInfo) ProtoMessage 

func (*ConnectionTokenInfo) ProtoMessage()

func (*ConnectionTokenInfo) ProtoReflect 

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

func (*ConnectionTokenInfo) Reset 

func (x *ConnectionTokenInfo) Reset()

func (*ConnectionTokenInfo) String 

func (x *ConnectionTokenInfo) String() string

type ConnectionsRequest 

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

func (*ConnectionsRequest) Descriptor deprecated 

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

Deprecated: Use ConnectionsRequest.ProtoReflect.Descriptor instead.

func (*ConnectionsRequest) GetExpression 

func (x *ConnectionsRequest) GetExpression() string

func (*ConnectionsRequest) GetUser 

func (x *ConnectionsRequest) GetUser() string

func (*ConnectionsRequest) ProtoMessage 

func (*ConnectionsRequest) ProtoMessage()

func (*ConnectionsRequest) ProtoReflect 

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

func (*ConnectionsRequest) Reset 

func (x *ConnectionsRequest) Reset()

func (*ConnectionsRequest) String 

func (x *ConnectionsRequest) String() string

type ConnectionsResponse 

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

func (*ConnectionsResponse) Descriptor deprecated 

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

Deprecated: Use ConnectionsResponse.ProtoReflect.Descriptor instead.

func (*ConnectionsResponse) GetError 

func (x *ConnectionsResponse) GetError() *Error

func (*ConnectionsResponse) GetResult 

func (x *ConnectionsResponse) GetResult() *ConnectionsResult

func (*ConnectionsResponse) ProtoMessage 

func (*ConnectionsResponse) ProtoMessage()

func (*ConnectionsResponse) ProtoReflect 

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

func (*ConnectionsResponse) Reset 

func (x *ConnectionsResponse) Reset()

func (*ConnectionsResponse) String 

func (x *ConnectionsResponse) String() string

type ConnectionsResult 

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

func (*ConnectionsResult) Descriptor deprecated 

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

Deprecated: Use ConnectionsResult.ProtoReflect.Descriptor instead.

func (*ConnectionsResult) GetConnections 

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

func (*ConnectionsResult) ProtoMessage 

func (*ConnectionsResult) ProtoMessage()

func (*ConnectionsResult) ProtoReflect 

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

func (*ConnectionsResult) Reset 

func (x *ConnectionsResult) Reset()

func (*ConnectionsResult) String 

func (x *ConnectionsResult) String() string

type DeleteUserStatusRequest 

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

func (*DeleteUserStatusRequest) Descriptor deprecated 

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

Deprecated: Use DeleteUserStatusRequest.ProtoReflect.Descriptor instead.

func (*DeleteUserStatusRequest) GetUsers 

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

func (*DeleteUserStatusRequest) ProtoMessage 

func (*DeleteUserStatusRequest) ProtoMessage()

func (*DeleteUserStatusRequest) ProtoReflect 

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

func (*DeleteUserStatusRequest) Reset 

func (x *DeleteUserStatusRequest) Reset()

func (*DeleteUserStatusRequest) String 

func (x *DeleteUserStatusRequest) String() string

type DeleteUserStatusResponse 

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

func (*DeleteUserStatusResponse) Descriptor deprecated 

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

Deprecated: Use DeleteUserStatusResponse.ProtoReflect.Descriptor instead.

func (*DeleteUserStatusResponse) GetError 

func (x *DeleteUserStatusResponse) GetError() *Error

func (*DeleteUserStatusResponse) GetResult 

func (x *DeleteUserStatusResponse) GetResult() *DeleteUserStatusResult

func (*DeleteUserStatusResponse) ProtoMessage 

func (*DeleteUserStatusResponse) ProtoMessage()

func (*DeleteUserStatusResponse) ProtoReflect 

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

func (*DeleteUserStatusResponse) Reset 

func (x *DeleteUserStatusResponse) Reset()

func (*DeleteUserStatusResponse) String 

func (x *DeleteUserStatusResponse) String() string

type DeleteUserStatusResult 

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

func (*DeleteUserStatusResult) Descriptor deprecated 

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

Deprecated: Use DeleteUserStatusResult.ProtoReflect.Descriptor instead.

func (*DeleteUserStatusResult) ProtoMessage 

func (*DeleteUserStatusResult) ProtoMessage()

func (*DeleteUserStatusResult) ProtoReflect 

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

func (*DeleteUserStatusResult) Reset 

func (x *DeleteUserStatusResult) Reset()

func (*DeleteUserStatusResult) String 

func (x *DeleteUserStatusResult) String() string

type Device 

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 

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 

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

func (*Device) GetUpdatedAt 

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 

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 

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

Deprecated: Use DeviceFilter.ProtoReflect.Descriptor instead.

func (*DeviceFilter) GetIds 

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

func (*DeviceFilter) GetPlatforms 

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

func (*DeviceFilter) GetProviders 

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

func (*DeviceFilter) GetTopics 

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

func (*DeviceFilter) GetUsers 

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

func (*DeviceFilter) ProtoMessage 

func (*DeviceFilter) ProtoMessage()

func (*DeviceFilter) ProtoReflect 

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

func (*DeviceFilter) Reset 

func (x *DeviceFilter) Reset()

func (*DeviceFilter) String 

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 

func (x *DeviceListRequest) GetCursor() string

func (*DeviceListRequest) GetFilter 

func (x *DeviceListRequest) GetFilter() *DeviceFilter

func (*DeviceListRequest) GetIncludeMeta 

func (x *DeviceListRequest) GetIncludeMeta() bool

func (*DeviceListRequest) GetIncludeTopics 

func (x *DeviceListRequest) GetIncludeTopics() bool

func (*DeviceListRequest) GetIncludeTotalCount 

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

func (x *DeviceListResult) GetNextCursor() string

func (*DeviceListResult) GetTotalCount 

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 

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 

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 

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 

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

Deprecated: Use DeviceTopic.ProtoReflect.Descriptor instead.

func (*DeviceTopic) GetDevice 

func (x *DeviceTopic) GetDevice() *Device

func (*DeviceTopic) GetId 

func (x *DeviceTopic) GetId() string

func (*DeviceTopic) GetTopic 

func (x *DeviceTopic) GetTopic() string

func (*DeviceTopic) ProtoMessage 

func (*DeviceTopic) ProtoMessage()

func (*DeviceTopic) ProtoReflect 

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

func (*DeviceTopic) Reset 

func (x *DeviceTopic) Reset()

func (*DeviceTopic) String 

func (x *DeviceTopic) String() string

type DeviceTopicFilter 

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 

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

Deprecated: Use DeviceTopicFilter.ProtoReflect.Descriptor instead.

func (*DeviceTopicFilter) GetDeviceIds 

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

func (*DeviceTopicFilter) GetDevicePlatforms 

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

func (*DeviceTopicFilter) GetDeviceProviders 

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

func (*DeviceTopicFilter) GetDeviceUsers 

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

func (*DeviceTopicFilter) GetTopicPrefix 

func (x *DeviceTopicFilter) GetTopicPrefix() string

func (*DeviceTopicFilter) GetTopics 

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

func (*DeviceTopicFilter) ProtoMessage 

func (*DeviceTopicFilter) ProtoMessage()

func (*DeviceTopicFilter) ProtoReflect 

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

func (*DeviceTopicFilter) Reset 

func (x *DeviceTopicFilter) Reset()

func (*DeviceTopicFilter) String 

func (x *DeviceTopicFilter) String() string

type DeviceTopicListRequest 

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 

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

Deprecated: Use DeviceTopicListRequest.ProtoReflect.Descriptor instead.

func (*DeviceTopicListRequest) GetCursor 

func (x *DeviceTopicListRequest) GetCursor() string

func (*DeviceTopicListRequest) GetFilter 

func (x *DeviceTopicListRequest) GetFilter() *DeviceTopicFilter

func (*DeviceTopicListRequest) GetIncludeDevice 

func (x *DeviceTopicListRequest) GetIncludeDevice() bool

func (*DeviceTopicListRequest) GetIncludeTotalCount 

func (x *DeviceTopicListRequest) GetIncludeTotalCount() bool

func (*DeviceTopicListRequest) GetLimit 

func (x *DeviceTopicListRequest) GetLimit() int32

func (*DeviceTopicListRequest) ProtoMessage 

func (*DeviceTopicListRequest) ProtoMessage()

func (*DeviceTopicListRequest) ProtoReflect 

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

func (*DeviceTopicListRequest) Reset 

func (x *DeviceTopicListRequest) Reset()

func (*DeviceTopicListRequest) String 

func (x *DeviceTopicListRequest) String() string

type DeviceTopicListResponse 

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 

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

Deprecated: Use DeviceTopicListResponse.ProtoReflect.Descriptor instead.

func (*DeviceTopicListResponse) GetError 

func (x *DeviceTopicListResponse) GetError() *Error

func (*DeviceTopicListResponse) GetResult 

func (x *DeviceTopicListResponse) GetResult() *DeviceTopicListResult

func (*DeviceTopicListResponse) ProtoMessage 

func (*DeviceTopicListResponse) ProtoMessage()

func (*DeviceTopicListResponse) ProtoReflect 

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

func (*DeviceTopicListResponse) Reset 

func (x *DeviceTopicListResponse) Reset()

func (*DeviceTopicListResponse) String 

func (x *DeviceTopicListResponse) String() string

type DeviceTopicListResult 

type DeviceTopicListResult struct {
	Items      []*DeviceTopic `protobuf:"bytes,1,rep,name=items,proto3" json:"items"`
	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 

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

Deprecated: Use DeviceTopicListResult.ProtoReflect.Descriptor instead.

func (*DeviceTopicListResult) GetItems 

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

func (*DeviceTopicListResult) GetNextCursor 

func (x *DeviceTopicListResult) GetNextCursor() string

func (*DeviceTopicListResult) GetTotalCount 

func (x *DeviceTopicListResult) GetTotalCount() int64

func (*DeviceTopicListResult) ProtoMessage 

func (*DeviceTopicListResult) ProtoMessage()

func (*DeviceTopicListResult) ProtoReflect 

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

func (*DeviceTopicListResult) Reset 

func (x *DeviceTopicListResult) Reset()

func (*DeviceTopicListResult) String 

func (x *DeviceTopicListResult) String() string

type DeviceTopicUpdateRequest 

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 

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

Deprecated: Use DeviceTopicUpdateRequest.ProtoReflect.Descriptor instead.

func (*DeviceTopicUpdateRequest) GetDeviceId 

func (x *DeviceTopicUpdateRequest) GetDeviceId() string

func (*DeviceTopicUpdateRequest) GetOp 

func (x *DeviceTopicUpdateRequest) GetOp() string

func (*DeviceTopicUpdateRequest) GetTopics 

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

func (*DeviceTopicUpdateRequest) ProtoMessage 

func (*DeviceTopicUpdateRequest) ProtoMessage()

func (*DeviceTopicUpdateRequest) ProtoReflect 

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

func (*DeviceTopicUpdateRequest) Reset 

func (x *DeviceTopicUpdateRequest) Reset()

func (*DeviceTopicUpdateRequest) String 

func (x *DeviceTopicUpdateRequest) String() string

type DeviceTopicUpdateResponse 

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 

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

Deprecated: Use DeviceTopicUpdateResponse.ProtoReflect.Descriptor instead.

func (*DeviceTopicUpdateResponse) GetError 

func (x *DeviceTopicUpdateResponse) GetError() *Error

func (*DeviceTopicUpdateResponse) GetResult 

func (x *DeviceTopicUpdateResponse) GetResult() *DeviceTopicUpdateResult

func (*DeviceTopicUpdateResponse) ProtoMessage 

func (*DeviceTopicUpdateResponse) ProtoMessage()

func (*DeviceTopicUpdateResponse) ProtoReflect 

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

func (*DeviceTopicUpdateResponse) Reset 

func (x *DeviceTopicUpdateResponse) Reset()

func (*DeviceTopicUpdateResponse) String 

func (x *DeviceTopicUpdateResponse) String() string

type DeviceTopicUpdateResult 

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

func (*DeviceTopicUpdateResult) Descriptor deprecated 

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

Deprecated: Use DeviceTopicUpdateResult.ProtoReflect.Descriptor instead.

func (*DeviceTopicUpdateResult) ProtoMessage 

func (*DeviceTopicUpdateResult) ProtoMessage()

func (*DeviceTopicUpdateResult) ProtoReflect 

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

func (*DeviceTopicUpdateResult) Reset 

func (x *DeviceTopicUpdateResult) Reset()

func (*DeviceTopicUpdateResult) String 

func (x *DeviceTopicUpdateResult) String() string

type DeviceTopicsUpdate 

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 

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

Deprecated: Use DeviceTopicsUpdate.ProtoReflect.Descriptor instead.

func (*DeviceTopicsUpdate) GetOp 

func (x *DeviceTopicsUpdate) GetOp() string

func (*DeviceTopicsUpdate) GetTopics 

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

func (*DeviceTopicsUpdate) ProtoMessage 

func (*DeviceTopicsUpdate) ProtoMessage()

func (*DeviceTopicsUpdate) ProtoReflect 

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

func (*DeviceTopicsUpdate) Reset 

func (x *DeviceTopicsUpdate) Reset()

func (*DeviceTopicsUpdate) String 

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 

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

func (x *Error) Error() string

func (*Error) GetCode 

func (x *Error) GetCode() uint32

func (*Error) GetMessage 

func (x *Error) GetMessage() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) ProtoReflect 

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

func (*Error) Reset 

func (x *Error) Reset()

func (*Error) String 

func (x *Error) String() string

type FcmPushNotification 

type FcmPushNotification struct {
	Message Raw `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"`
	// contains filtered or unexported fields
}

func (*GetUserStatusResult) Descriptor deprecated 

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

Deprecated: Use GetUserStatusResult.ProtoReflect.Descriptor instead.

func (*GetUserStatusResult) GetStatuses 

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

func (*GetUserStatusResult) ProtoMessage 

func (*GetUserStatusResult) ProtoMessage()

func (*GetUserStatusResult) ProtoReflect 

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

func (*GetUserStatusResult) Reset 

func (x *GetUserStatusResult) Reset()

func (*GetUserStatusResult) String 

func (x *GetUserStatusResult) String() string

type HistoryRemoveRequest 

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

func (*HistoryRemoveRequest) Descriptor deprecated 

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

Deprecated: Use HistoryRemoveRequest.ProtoReflect.Descriptor instead.

func (*HistoryRemoveRequest) GetChannel 

func (x *HistoryRemoveRequest) GetChannel() string

func (*HistoryRemoveRequest) ProtoMessage 

func (*HistoryRemoveRequest) ProtoMessage()

func (*HistoryRemoveRequest) ProtoReflect 

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

func (*HistoryRemoveRequest) Reset 

func (x *HistoryRemoveRequest) Reset()

func (*HistoryRemoveRequest) String 

func (x *HistoryRemoveRequest) String() string

type HistoryRemoveResponse 

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

func (*HistoryRemoveResponse) Descriptor deprecated 

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

Deprecated: Use HistoryRemoveResponse.ProtoReflect.Descriptor instead.

func (*HistoryRemoveResponse) GetError 

func (x *HistoryRemoveResponse) GetError() *Error

func (*HistoryRemoveResponse) GetResult 

func (x *HistoryRemoveResponse) GetResult() *HistoryRemoveResult

func (*HistoryRemoveResponse) ProtoMessage 

func (*HistoryRemoveResponse) ProtoMessage()

func (*HistoryRemoveResponse) ProtoReflect 

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

func (*HistoryRemoveResponse) Reset 

func (x *HistoryRemoveResponse) Reset()

func (*HistoryRemoveResponse) String 

func (x *HistoryRemoveResponse) String() string

type HistoryRemoveResult 

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

func (*HistoryRemoveResult) Descriptor deprecated 

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

Deprecated: Use HistoryRemoveResult.ProtoReflect.Descriptor instead.

func (*HistoryRemoveResult) ProtoMessage 

func (*HistoryRemoveResult) ProtoMessage()

func (*HistoryRemoveResult) ProtoReflect 

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

func (*HistoryRemoveResult) Reset 

func (x *HistoryRemoveResult) Reset()

func (*HistoryRemoveResult) String 

func (x *HistoryRemoveResult) String() string

type HistoryRequest 

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

func (*HistoryRequest) Descriptor deprecated 

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

Deprecated: Use HistoryRequest.ProtoReflect.Descriptor instead.

func (*HistoryRequest) GetChannel 

func (x *HistoryRequest) GetChannel() string

func (*HistoryRequest) GetLimit 

func (x *HistoryRequest) GetLimit() int32

func (*HistoryRequest) GetReverse 

func (x *HistoryRequest) GetReverse() bool

func (*HistoryRequest) GetSince 

func (x *HistoryRequest) GetSince() *StreamPosition

func (*HistoryRequest) ProtoMessage 

func (*HistoryRequest) ProtoMessage()

func (*HistoryRequest) ProtoReflect 

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

func (*HistoryRequest) Reset 

func (x *HistoryRequest) Reset()

func (*HistoryRequest) String 

func (x *HistoryRequest) String() string

type HistoryResponse 

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

func (*HistoryResponse) Descriptor deprecated 

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

Deprecated: Use HistoryResponse.ProtoReflect.Descriptor instead.

func (*HistoryResponse) GetError 

func (x *HistoryResponse) GetError() *Error

func (*HistoryResponse) GetResult 

func (x *HistoryResponse) GetResult() *HistoryResult

func (*HistoryResponse) ProtoMessage 

func (*HistoryResponse) ProtoMessage()

func (*HistoryResponse) ProtoReflect 

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

func (*HistoryResponse) Reset 

func (x *HistoryResponse) Reset()

func (*HistoryResponse) String 

func (x *HistoryResponse) String() string

type HistoryResult 

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

func (*HistoryResult) Descriptor deprecated 

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

Deprecated: Use HistoryResult.ProtoReflect.Descriptor instead.

func (*HistoryResult) GetEpoch 

func (x *HistoryResult) GetEpoch() string

func (*HistoryResult) GetOffset 

func (x *HistoryResult) GetOffset() uint64

func (*HistoryResult) GetPublications 

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

func (*HistoryResult) ProtoMessage 

func (*HistoryResult) ProtoMessage()

func (*HistoryResult) ProtoReflect 

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

func (*HistoryResult) Reset 

func (x *HistoryResult) Reset()

func (*HistoryResult) String 

func (x *HistoryResult) String() string

type HmsPushNotification 

type HmsPushNotification struct {
	Message Raw `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 JSONCommandDecoder 

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

JSONCommandDecoder ...

func NewJSONCommandDecoder 

func NewJSONCommandDecoder(data []byte) *JSONCommandDecoder

NewJSONCommandDecoder ...

func (*JSONCommandDecoder) Decode 

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

Decode ...

func (*JSONCommandDecoder) Reset 

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

Reset ...

type JSONReplyEncoder 

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

JSONReplyEncoder ...

func NewJSONReplyEncoder 

func NewJSONReplyEncoder() *JSONReplyEncoder

NewJSONReplyEncoder ...

func (*JSONReplyEncoder) Encode 

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

Encode ...

func (*JSONReplyEncoder) Finish 

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

Finish ...

func (*JSONReplyEncoder) Reset 

func (e *JSONReplyEncoder) Reset()

Reset ...

type JSONRequestDecoder 

type JSONRequestDecoder struct{}

JSONRequestDecoder ...

func NewJSONRequestDecoder 

func NewJSONRequestDecoder() *JSONRequestDecoder

NewJSONRequestDecoder ...

func (*JSONRequestDecoder) DecodeBatch 

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

DecodeBatch ...

func (*JSONRequestDecoder) DecodeBroadcast 

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

DecodeBroadcast ...

func (*JSONRequestDecoder) DecodeChannels 

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

DecodeChannels ...

func (*JSONRequestDecoder) DecodeDisconnect 

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

DecodeDisconnect ...

func (*JSONRequestDecoder) DecodeHistory 

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

DecodeHistory ...

func (*JSONRequestDecoder) DecodeHistoryRemove 

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

DecodeHistoryRemove ...

func (*JSONRequestDecoder) DecodeInfo 

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

DecodeInfo ...

func (*JSONRequestDecoder) DecodePresence 

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

DecodePresence ...

func (*JSONRequestDecoder) DecodePresenceStats 

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

DecodePresenceStats ...

func (*JSONRequestDecoder) DecodePublish 

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

DecodePublish ...

func (*JSONRequestDecoder) DecodeRPC 

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

DecodeRPC ...

func (*JSONRequestDecoder) DecodeRefresh 

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

DecodeRefresh ...

func (*JSONRequestDecoder) DecodeSubscribe 

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

DecodeSubscribe ...

func (*JSONRequestDecoder) DecodeUnsubscribe 

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

DecodeUnsubscribe ...

type JSONResponseEncoder 

type JSONResponseEncoder struct{}

JSONResponseEncoder ...

func NewJSONResponseEncoder 

func NewJSONResponseEncoder() *JSONResponseEncoder

func (*JSONResponseEncoder) EncodeBatch 

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

EncodeBatch ...

func (*JSONResponseEncoder) EncodeBroadcast 

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

EncodeBroadcast ...

func (*JSONResponseEncoder) EncodeChannels 

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

EncodeChannels ...

func (*JSONResponseEncoder) EncodeDisconnect 

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

EncodeDisconnect ...

func (*JSONResponseEncoder) EncodeHistory 

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

EncodeHistory ...

func (*JSONResponseEncoder) EncodeHistoryRemove 

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

EncodeHistoryRemove ...

func (*JSONResponseEncoder) EncodeInfo 

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

EncodeInfo ...

func (*JSONResponseEncoder) EncodePresence 

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

EncodePresence ...

func (*JSONResponseEncoder) EncodePresenceStats 

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

EncodePresenceStats ...

func (*JSONResponseEncoder) EncodePublish 

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

EncodePublish ...

func (*JSONResponseEncoder) EncodeRPC 

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

EncodeRPC ...

func (*JSONResponseEncoder) EncodeRefresh 

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

EncodeRefresh ...

func (*JSONResponseEncoder) EncodeSubscribe 

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

EncodeSubscribe ...

func (*JSONResponseEncoder) EncodeUnsubscribe 

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

EncodeUnsubscribe ...

type JSONResultEncoder 

type JSONResultEncoder struct{}

JSONResultEncoder ...

func NewJSONResultEncoder 

func NewJSONResultEncoder() *JSONResultEncoder

NewJSONResultEncoder ...

func (*JSONResultEncoder) EncodeBroadcast 

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

EncodeBroadcast ...

func (*JSONResultEncoder) EncodeChannels 

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

EncodeChannels ...

func (*JSONResultEncoder) EncodeDisconnect 

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

EncodeDisconnect ...

func (*JSONResultEncoder) EncodeHistory 

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

EncodeHistory ...

func (*JSONResultEncoder) EncodeHistoryRemove 

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

EncodeHistoryRemove ...

func (*JSONResultEncoder) EncodeInfo 

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

EncodeInfo ...

func (*JSONResultEncoder) EncodePresence 

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

EncodePresence ...

func (*JSONResultEncoder) EncodePresenceStats 

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

EncodePresenceStats ...

func (*JSONResultEncoder) EncodePublish 

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

EncodePublish ...

func (*JSONResultEncoder) EncodeRPC 

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

EncodeRPC ...

func (*JSONResultEncoder) EncodeRefresh 

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

EncodeRefresh ...

func (*JSONResultEncoder) EncodeSubscribe 

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

EncodeSubscribe ...

func (*JSONResultEncoder) EncodeUnsubscribe 

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

EncodeUnsubscribe ...

type Metrics 

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

func (*Metrics) Descriptor deprecated 

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

Deprecated: Use Metrics.ProtoReflect.Descriptor instead.

func (*Metrics) GetInterval 

func (x *Metrics) GetInterval() float64

func (*Metrics) GetItems 

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

func (*Metrics) ProtoMessage 

func (*Metrics) ProtoMessage()

func (*Metrics) ProtoReflect 

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

func (*Metrics) Reset 

func (x *Metrics) Reset()

func (*Metrics) String 

func (x *Metrics) String() string

type NodeResult 

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

func (*NodeResult) Descriptor deprecated 

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

Deprecated: Use NodeResult.ProtoReflect.Descriptor instead.

func (*NodeResult) GetMetrics 

func (x *NodeResult) GetMetrics() *Metrics

func (*NodeResult) GetName 

func (x *NodeResult) GetName() string

func (*NodeResult) GetNumChannels 

func (x *NodeResult) GetNumChannels() uint32

func (*NodeResult) GetNumClients 

func (x *NodeResult) GetNumClients() uint32

func (*NodeResult) GetNumSubs 

func (x *NodeResult) GetNumSubs() uint32

func (*NodeResult) GetNumUsers 

func (x *NodeResult) GetNumUsers() uint32

func (*NodeResult) GetProcess 

func (x *NodeResult) GetProcess() *Process

func (*NodeResult) GetUid 

func (x *NodeResult) GetUid() string

func (*NodeResult) GetUptime 

func (x *NodeResult) GetUptime() uint32

func (*NodeResult) GetVersion 

func (x *NodeResult) GetVersion() string

func (*NodeResult) ProtoMessage 

func (*NodeResult) ProtoMessage()

func (*NodeResult) ProtoReflect 

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

func (*NodeResult) Reset 

func (x *NodeResult) Reset()

func (*NodeResult) String 

func (x *NodeResult) String() string

type PresenceRequest 

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

func (*PresenceRequest) Descriptor deprecated 

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

Deprecated: Use PresenceRequest.ProtoReflect.Descriptor instead.

func (*PresenceRequest) GetChannel 

func (x *PresenceRequest) GetChannel() string

func (*PresenceRequest) ProtoMessage 

func (*PresenceRequest) ProtoMessage()

func (*PresenceRequest) ProtoReflect 

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

func (*PresenceRequest) Reset 

func (x *PresenceRequest) Reset()

func (*PresenceRequest) String 

func (x *PresenceRequest) String() string

type PresenceResponse 

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

func (*PresenceResponse) Descriptor deprecated 

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

Deprecated: Use PresenceResponse.ProtoReflect.Descriptor instead.

func (*PresenceResponse) GetError 

func (x *PresenceResponse) GetError() *Error

func (*PresenceResponse) GetResult 

func (x *PresenceResponse) GetResult() *PresenceResult

func (*PresenceResponse) ProtoMessage 

func (*PresenceResponse) ProtoMessage()

func (*PresenceResponse) ProtoReflect 

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

func (*PresenceResponse) Reset 

func (x *PresenceResponse) Reset()

func (*PresenceResponse) String 

func (x *PresenceResponse) String() string

type PresenceResult 

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

func (*PresenceResult) Descriptor deprecated 

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

Deprecated: Use PresenceResult.ProtoReflect.Descriptor instead.

func (*PresenceResult) GetPresence 

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

func (*PresenceResult) ProtoMessage 

func (*PresenceResult) ProtoMessage()

func (*PresenceResult) ProtoReflect 

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

func (*PresenceResult) Reset 

func (x *PresenceResult) Reset()

func (*PresenceResult) String 

func (x *PresenceResult) String() string

type PresenceStatsRequest 

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

func (*PresenceStatsRequest) Descriptor deprecated 

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

Deprecated: Use PresenceStatsRequest.ProtoReflect.Descriptor instead.

func (*PresenceStatsRequest) GetChannel 

func (x *PresenceStatsRequest) GetChannel() string

func (*PresenceStatsRequest) ProtoMessage 

func (*PresenceStatsRequest) ProtoMessage()

func (*PresenceStatsRequest) ProtoReflect 

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

func (*PresenceStatsRequest) Reset 

func (x *PresenceStatsRequest) Reset()

func (*PresenceStatsRequest) String 

func (x *PresenceStatsRequest) String() string

type PresenceStatsResponse 

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

func (*PresenceStatsResponse) Descriptor deprecated 

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

Deprecated: Use PresenceStatsResponse.ProtoReflect.Descriptor instead.

func (*PresenceStatsResponse) GetError 

func (x *PresenceStatsResponse) GetError() *Error

func (*PresenceStatsResponse) GetResult 

func (x *PresenceStatsResponse) GetResult() *PresenceStatsResult

func (*PresenceStatsResponse) ProtoMessage 

func (*PresenceStatsResponse) ProtoMessage()

func (*PresenceStatsResponse) ProtoReflect 

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

func (*PresenceStatsResponse) Reset 

func (x *PresenceStatsResponse) Reset()

func (*PresenceStatsResponse) String 

func (x *PresenceStatsResponse) String() string

type PresenceStatsResult 

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

func (*PresenceStatsResult) Descriptor deprecated 

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

Deprecated: Use PresenceStatsResult.ProtoReflect.Descriptor instead.

func (*PresenceStatsResult) GetNumClients 

func (x *PresenceStatsResult) GetNumClients() uint32

func (*PresenceStatsResult) GetNumUsers 

func (x *PresenceStatsResult) GetNumUsers() uint32

func (*PresenceStatsResult) ProtoMessage 

func (*PresenceStatsResult) ProtoMessage()

func (*PresenceStatsResult) ProtoReflect 

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

func (*PresenceStatsResult) Reset 

func (x *PresenceStatsResult) Reset()

func (*PresenceStatsResult) String 

func (x *PresenceStatsResult) String() string

type Process 

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

func (*Process) Descriptor deprecated 

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

Deprecated: Use Process.ProtoReflect.Descriptor instead.

func (*Process) GetCpu 

func (x *Process) GetCpu() float64

func (*Process) GetRss 

func (x *Process) GetRss() int64

func (*Process) ProtoMessage 

func (*Process) ProtoMessage()

func (*Process) ProtoReflect 

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

func (*Process) Reset 

func (x *Process) Reset()

func (*Process) String 

func (x *Process) String() string

type Publication 

type Publication struct {

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

func (*Publication) Descriptor deprecated 

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

Deprecated: Use Publication.ProtoReflect.Descriptor instead.

func (*Publication) GetData 

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

func (*Publication) GetInfo 

func (x *Publication) GetInfo() *ClientInfo

func (*Publication) GetOffset 

func (x *Publication) GetOffset() uint64

func (*Publication) GetTags 

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

func (*Publication) ProtoMessage 

func (*Publication) ProtoMessage()

func (*Publication) ProtoReflect 

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

func (*Publication) Reset 

func (x *Publication) Reset()

func (*Publication) String 

func (x *Publication) String() string

type PublishRequest 

type PublishRequest struct {
	Channel     string            `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	Data        Raw               `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	B64Data     string            `protobuf:"bytes,3,opt,name=b64data,proto3" json:"b64data,omitempty"`
	SkipHistory bool              `protobuf:"varint,4,opt,name=skip_history,json=skipHistory,proto3" json:"skip_history,omitempty"`
	Tags        map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PublishRequest) Descriptor deprecated 

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

Deprecated: Use PublishRequest.ProtoReflect.Descriptor instead.

func (*PublishRequest) GetB64Data 

func (x *PublishRequest) GetB64Data() string

func (*PublishRequest) GetChannel 

func (x *PublishRequest) GetChannel() string

func (*PublishRequest) GetData 

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

func (*PublishRequest) GetSkipHistory 

func (x *PublishRequest) GetSkipHistory() bool

func (*PublishRequest) GetTags 

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

func (*PublishRequest) ProtoMessage 

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) ProtoReflect 

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

func (*PublishRequest) Reset 

func (x *PublishRequest) Reset()

func (*PublishRequest) String 

func (x *PublishRequest) String() string

type PublishResponse 

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

func (*PublishResponse) Descriptor deprecated 

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

Deprecated: Use PublishResponse.ProtoReflect.Descriptor instead.

func (*PublishResponse) GetError 

func (x *PublishResponse) GetError() *Error

func (*PublishResponse) GetResult 

func (x *PublishResponse) GetResult() *PublishResult

func (*PublishResponse) ProtoMessage 

func (*PublishResponse) ProtoMessage()

func (*PublishResponse) ProtoReflect 

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

func (*PublishResponse) Reset 

func (x *PublishResponse) Reset()

func (*PublishResponse) String 

func (x *PublishResponse) String() string

type PublishResult 

type PublishResult struct {
	Offset uint64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	Epoch  string `protobuf:"bytes,2,opt,name=epoch,proto3" json:"epoch,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishResult) Descriptor deprecated 

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

Deprecated: Use PublishResult.ProtoReflect.Descriptor instead.

func (*PublishResult) GetEpoch 

func (x *PublishResult) GetEpoch() string

func (*PublishResult) GetOffset 

func (x *PublishResult) GetOffset() uint64

func (*PublishResult) ProtoMessage 

func (*PublishResult) ProtoMessage()

func (*PublishResult) ProtoReflect 

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

func (*PublishResult) Reset 

func (x *PublishResult) Reset()

func (*PublishResult) String 

func (x *PublishResult) String() string

type PushNotification 

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 

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 Raw    `protobuf:"bytes,2,opt,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

func (*RPCRequest) Descriptor deprecated 

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

Deprecated: Use RPCRequest.ProtoReflect.Descriptor instead.

func (*RPCRequest) GetMethod 

func (x *RPCRequest) GetMethod() string

func (*RPCRequest) GetParams 

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

func (*RPCRequest) ProtoMessage 

func (*RPCRequest) ProtoMessage()

func (*RPCRequest) ProtoReflect 

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

func (*RPCRequest) Reset 

func (x *RPCRequest) Reset()

func (*RPCRequest) String 

func (x *RPCRequest) String() string

type RPCResponse 

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

func (*RPCResponse) Descriptor deprecated 

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

Deprecated: Use RPCResponse.ProtoReflect.Descriptor instead.

func (*RPCResponse) GetError 

func (x *RPCResponse) GetError() *Error

func (*RPCResponse) GetResult 

func (x *RPCResponse) GetResult() *RPCResult

func (*RPCResponse) ProtoMessage 

func (*RPCResponse) ProtoMessage()

func (*RPCResponse) ProtoReflect 

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

func (*RPCResponse) Reset 

func (x *RPCResponse) Reset()

func (*RPCResponse) String 

func (x *RPCResponse) String() string

type RPCResult 

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

func (*RPCResult) Descriptor deprecated 

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

Deprecated: Use RPCResult.ProtoReflect.Descriptor instead.

func (*RPCResult) GetData 

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

func (*RPCResult) ProtoMessage 

func (*RPCResult) ProtoMessage()

func (*RPCResult) ProtoReflect 

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

func (*RPCResult) Reset 

func (x *RPCResult) Reset()

func (*RPCResult) String 

func (x *RPCResult) String() string

type Raw 

type Raw []byte

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

func (Raw) MarshalJSON 

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

MarshalJSON returns *r as the JSON encoding of r.

func (*Raw) UnmarshalJSON 

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

UnmarshalJSON sets *r to a copy of data.

type RefreshRequest 

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

func (*RefreshRequest) Descriptor deprecated 

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

Deprecated: Use RefreshRequest.ProtoReflect.Descriptor instead.

func (*RefreshRequest) GetClient 

func (x *RefreshRequest) GetClient() string

func (*RefreshRequest) GetExpireAt 

func (x *RefreshRequest) GetExpireAt() int64

func (*RefreshRequest) GetExpired 

func (x *RefreshRequest) GetExpired() bool

func (*RefreshRequest) GetInfo 

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

func (*RefreshRequest) GetSession 

func (x *RefreshRequest) GetSession() string

func (*RefreshRequest) GetUser 

func (x *RefreshRequest) GetUser() string

func (*RefreshRequest) ProtoMessage 

func (*RefreshRequest) ProtoMessage()

func (*RefreshRequest) ProtoReflect 

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

func (*RefreshRequest) Reset 

func (x *RefreshRequest) Reset()

func (*RefreshRequest) String 

func (x *RefreshRequest) String() string

type RefreshResponse 

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

func (*RefreshResponse) Descriptor deprecated 

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

Deprecated: Use RefreshResponse.ProtoReflect.Descriptor instead.

func (*RefreshResponse) GetError 

func (x *RefreshResponse) GetError() *Error

func (*RefreshResponse) GetResult 

func (x *RefreshResponse) GetResult() *RefreshResult

func (*RefreshResponse) ProtoMessage 

func (*RefreshResponse) ProtoMessage()

func (*RefreshResponse) ProtoReflect 

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

func (*RefreshResponse) Reset 

func (x *RefreshResponse) Reset()

func (*RefreshResponse) String 

func (x *RefreshResponse) String() string

type RefreshResult 

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

func (*RefreshResult) Descriptor deprecated 

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

Deprecated: Use RefreshResult.ProtoReflect.Descriptor instead.

func (*RefreshResult) ProtoMessage 

func (*RefreshResult) ProtoMessage()

func (*RefreshResult) ProtoReflect 

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

func (*RefreshResult) Reset 

func (x *RefreshResult) Reset()

func (*RefreshResult) String 

func (x *RefreshResult) String() string

type Reply 

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

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 

func (x *Reply) GetDeviceTopicList() *DeviceTopicListResult

func (*Reply) GetDeviceTopicUpdate 

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

func (x *Reply) GetUpdatePushStatus() *UpdatePushStatusResult

func (*Reply) GetUpdateUserStatus 

func (x *Reply) GetUpdateUserStatus() *UpdateUserStatusResult

func (*Reply) GetUserTopicList 

func (x *Reply) GetUserTopicList() *UserTopicListResult

func (*Reply) GetUserTopicUpdate 

func (x *Reply) GetUserTopicUpdate() *UserTopicUpdateResult

func (*Reply) ProtoMessage 

func (*Reply) ProtoMessage()

func (*Reply) ProtoReflect 

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

func (*Reply) Reset 

func (x *Reply) Reset()

func (*Reply) String 

func (x *Reply) String() string

type ReplyEncoder 

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

ReplyEncoder ...

func GetReplyEncoder 

func GetReplyEncoder() ReplyEncoder

GetReplyEncoder ...

type RequestDecoder 

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

RequestDecoder ...

func GetParamsDecoder 

func GetParamsDecoder() RequestDecoder

GetParamsDecoder ...

type ResponseEncoder 

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

ResponseEncoder ...

type ResultEncoder 

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

ResultEncoder ...

func GetResultEncoder 

func GetResultEncoder() ResultEncoder

GetResultEncoder ...

type RevokeTokenRequest 

type RevokeTokenRequest struct {
	ExpireAt int64  `protobuf:"varint,1,opt,name=expire_at,json=expireAt,proto3" json:"expire_at,omitempty"`
	Uid      string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	// contains filtered or unexported fields
}

func (*RevokeTokenRequest) Descriptor deprecated 

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

Deprecated: Use RevokeTokenRequest.ProtoReflect.Descriptor instead.

func (*RevokeTokenRequest) GetExpireAt 

func (x *RevokeTokenRequest) GetExpireAt() int64

func (*RevokeTokenRequest) GetUid 

func (x *RevokeTokenRequest) GetUid() string

func (*RevokeTokenRequest) ProtoMessage 

func (*RevokeTokenRequest) ProtoMessage()

func (*RevokeTokenRequest) ProtoReflect 

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

func (*RevokeTokenRequest) Reset 

func (x *RevokeTokenRequest) Reset()

func (*RevokeTokenRequest) String 

func (x *RevokeTokenRequest) String() string

type RevokeTokenResponse 

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

func (*RevokeTokenResponse) Descriptor deprecated 

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

Deprecated: Use RevokeTokenResponse.ProtoReflect.Descriptor instead.

func (*RevokeTokenResponse) GetError 

func (x *RevokeTokenResponse) GetError() *Error

func (*RevokeTokenResponse) GetResult 

func (x *RevokeTokenResponse) GetResult() *RevokeTokenResult

func (*RevokeTokenResponse) ProtoMessage 

func (*RevokeTokenResponse) ProtoMessage()

func (*RevokeTokenResponse) ProtoReflect 

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

func (*RevokeTokenResponse) Reset 

func (x *RevokeTokenResponse) Reset()

func (*RevokeTokenResponse) String 

func (x *RevokeTokenResponse) String() string

type RevokeTokenResult 

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

func (*RevokeTokenResult) Descriptor deprecated 

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

Deprecated: Use RevokeTokenResult.ProtoReflect.Descriptor instead.

func (*RevokeTokenResult) ProtoMessage 

func (*RevokeTokenResult) ProtoMessage()

func (*RevokeTokenResult) ProtoReflect 

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

func (*RevokeTokenResult) Reset 

func (x *RevokeTokenResult) Reset()

func (*RevokeTokenResult) String 

func (x *RevokeTokenResult) String() string

type SendPushNotificationRequest 

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 v5.0.3 

func (x *SendPushNotificationRequest) GetSendAt() int64

func (*SendPushNotificationRequest) GetUid added in v5.0.3 

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

func (*SubscribeRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.

func (*SubscribeRequest) GetB64Data 

func (x *SubscribeRequest) GetB64Data() string

func (*SubscribeRequest) GetB64Info 

func (x *SubscribeRequest) GetB64Info() string

func (*SubscribeRequest) GetChannel 

func (x *SubscribeRequest) GetChannel() string

func (*SubscribeRequest) GetClient 

func (x *SubscribeRequest) GetClient() string

func (*SubscribeRequest) GetData 

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

func (*SubscribeRequest) GetExpireAt 

func (x *SubscribeRequest) GetExpireAt() int64

func (*SubscribeRequest) GetInfo 

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

func (*SubscribeRequest) GetOverride 

func (x *SubscribeRequest) GetOverride() *SubscribeOptionOverride

func (*SubscribeRequest) GetRecoverSince 

func (x *SubscribeRequest) GetRecoverSince() *StreamPosition

func (*SubscribeRequest) GetSession 

func (x *SubscribeRequest) GetSession() string

func (*SubscribeRequest) GetUser 

func (x *SubscribeRequest) GetUser() string

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) ProtoReflect 

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

func (*SubscribeRequest) Reset 

func (x *SubscribeRequest) Reset()

func (*SubscribeRequest) String 

func (x *SubscribeRequest) String() string

type SubscribeResponse 

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

func (*SubscribeResponse) Descriptor deprecated 

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

Deprecated: Use SubscribeResponse.ProtoReflect.Descriptor instead.

func (*SubscribeResponse) GetError 

func (x *SubscribeResponse) GetError() *Error

func (*SubscribeResponse) GetResult 

func (x *SubscribeResponse) GetResult() *SubscribeResult

func (*SubscribeResponse) ProtoMessage 

func (*SubscribeResponse) ProtoMessage()

func (*SubscribeResponse) ProtoReflect 

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

func (*SubscribeResponse) Reset 

func (x *SubscribeResponse) Reset()

func (*SubscribeResponse) String 

func (x *SubscribeResponse) String() string

type SubscribeResult 

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

func (*SubscribeResult) Descriptor deprecated 

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

Deprecated: Use SubscribeResult.ProtoReflect.Descriptor instead.

func (*SubscribeResult) ProtoMessage 

func (*SubscribeResult) ProtoMessage()

func (*SubscribeResult) ProtoReflect 

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

func (*SubscribeResult) Reset 

func (x *SubscribeResult) Reset()

func (*SubscribeResult) String 

func (x *SubscribeResult) String() string

type SubscriptionTokenInfo 

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

func (*SubscriptionTokenInfo) Descriptor deprecated 

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

Deprecated: Use SubscriptionTokenInfo.ProtoReflect.Descriptor instead.

func (*SubscriptionTokenInfo) GetIssuedAt 

func (x *SubscriptionTokenInfo) GetIssuedAt() int64

func (*SubscriptionTokenInfo) GetUid 

func (x *SubscriptionTokenInfo) GetUid() string

func (*SubscriptionTokenInfo) ProtoMessage 

func (*SubscriptionTokenInfo) ProtoMessage()

func (*SubscriptionTokenInfo) ProtoReflect 

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

func (*SubscriptionTokenInfo) Reset 

func (x *SubscriptionTokenInfo) Reset()

func (*SubscriptionTokenInfo) String 

func (x *SubscriptionTokenInfo) String() string

type UnblockUserRequest 

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

func (*UnblockUserRequest) Descriptor deprecated 

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

Deprecated: Use UnblockUserRequest.ProtoReflect.Descriptor instead.

func (*UnblockUserRequest) GetUser 

func (x *UnblockUserRequest) GetUser() string

func (*UnblockUserRequest) ProtoMessage 

func (*UnblockUserRequest) ProtoMessage()

func (*UnblockUserRequest) ProtoReflect 

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

func (*UnblockUserRequest) Reset 

func (x *UnblockUserRequest) Reset()

func (*UnblockUserRequest) String 

func (x *UnblockUserRequest) String() string

type UnblockUserResponse 

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

func (*UnblockUserResponse) Descriptor deprecated 

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

Deprecated: Use UnblockUserResponse.ProtoReflect.Descriptor instead.

func (*UnblockUserResponse) GetError 

func (x *UnblockUserResponse) GetError() *Error

func (*UnblockUserResponse) GetResult 

func (x *UnblockUserResponse) GetResult() *UnblockUserResult

func (*UnblockUserResponse) ProtoMessage 

func (*UnblockUserResponse) ProtoMessage()

func (*UnblockUserResponse) ProtoReflect 

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

func (*UnblockUserResponse) Reset 

func (x *UnblockUserResponse) Reset()

func (*UnblockUserResponse) String 

func (x *UnblockUserResponse) String() string

type UnblockUserResult 

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

func (*UnblockUserResult) Descriptor deprecated 

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

Deprecated: Use UnblockUserResult.ProtoReflect.Descriptor instead.

func (*UnblockUserResult) ProtoMessage 

func (*UnblockUserResult) ProtoMessage()

func (*UnblockUserResult) ProtoReflect 

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

func (*UnblockUserResult) Reset 

func (x *UnblockUserResult) Reset()

func (*UnblockUserResult) String 

func (x *UnblockUserResult) String() string

type UnimplementedCentrifugoApiServer 

type UnimplementedCentrifugoApiServer struct {
}

UnimplementedCentrifugoApiServer must be embedded to have forward compatible implementations.

func (UnimplementedCentrifugoApiServer) Batch 

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 v5.0.3 

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 

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

func (UnimplementedCentrifugoApiServer) DeviceTopicUpdate 

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

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

func (UnimplementedCentrifugoApiServer) UpdateUserStatus 

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

func (UnimplementedCentrifugoApiServer) UserTopicList 

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

func (UnimplementedCentrifugoApiServer) UserTopicUpdate 

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 

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 

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

Deprecated: Use UpdatePushStatusRequest.ProtoReflect.Descriptor instead.

func (*UpdatePushStatusRequest) GetDeviceId 

func (x *UpdatePushStatusRequest) GetDeviceId() string

func (*UpdatePushStatusRequest) GetMsgId 

func (x *UpdatePushStatusRequest) GetMsgId() string

func (*UpdatePushStatusRequest) GetStatus 

func (x *UpdatePushStatusRequest) GetStatus() string

func (*UpdatePushStatusRequest) GetUid 

func (x *UpdatePushStatusRequest) GetUid() string

func (*UpdatePushStatusRequest) ProtoMessage 

func (*UpdatePushStatusRequest) ProtoMessage()

func (*UpdatePushStatusRequest) ProtoReflect 

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

func (*UpdatePushStatusRequest) Reset 

func (x *UpdatePushStatusRequest) Reset()

func (*UpdatePushStatusRequest) String 

func (x *UpdatePushStatusRequest) String() string

type UpdatePushStatusResponse 

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 

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

Deprecated: Use UpdatePushStatusResponse.ProtoReflect.Descriptor instead.

func (*UpdatePushStatusResponse) GetError 

func (x *UpdatePushStatusResponse) GetError() *Error

func (*UpdatePushStatusResponse) GetResult 

func (x *UpdatePushStatusResponse) GetResult() *UpdatePushStatusResult

func (*UpdatePushStatusResponse) ProtoMessage 

func (*UpdatePushStatusResponse) ProtoMessage()

func (*UpdatePushStatusResponse) ProtoReflect 

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

func (*UpdatePushStatusResponse) Reset 

func (x *UpdatePushStatusResponse) Reset()

func (*UpdatePushStatusResponse) String 

func (x *UpdatePushStatusResponse) String() string

type UpdatePushStatusResult 

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

func (*UpdatePushStatusResult) Descriptor deprecated 

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

Deprecated: Use UpdatePushStatusResult.ProtoReflect.Descriptor instead.

func (*UpdatePushStatusResult) ProtoMessage 

func (*UpdatePushStatusResult) ProtoMessage()

func (*UpdatePushStatusResult) ProtoReflect 

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

func (*UpdatePushStatusResult) Reset 

func (x *UpdatePushStatusResult) Reset()

func (*UpdatePushStatusResult) String 

func (x *UpdatePushStatusResult) String() string

type UpdateUserStatusRequest 

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

func (*UpdateUserStatusRequest) Descriptor deprecated 

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

Deprecated: Use UpdateUserStatusRequest.ProtoReflect.Descriptor instead.

func (*UpdateUserStatusRequest) GetUsers 

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

func (*UpdateUserStatusRequest) ProtoMessage 

func (*UpdateUserStatusRequest) ProtoMessage()

func (*UpdateUserStatusRequest) ProtoReflect 

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

func (*UpdateUserStatusRequest) Reset 

func (x *UpdateUserStatusRequest) Reset()

func (*UpdateUserStatusRequest) String 

func (x *UpdateUserStatusRequest) String() string

type UpdateUserStatusResponse 

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

func (*UpdateUserStatusResponse) Descriptor deprecated 

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

Deprecated: Use UpdateUserStatusResponse.ProtoReflect.Descriptor instead.

func (*UpdateUserStatusResponse) GetError 

func (x *UpdateUserStatusResponse) GetError() *Error

func (*UpdateUserStatusResponse) GetResult 

func (x *UpdateUserStatusResponse) GetResult() *UpdateUserStatusResult

func (*UpdateUserStatusResponse) ProtoMessage 

func (*UpdateUserStatusResponse) ProtoMessage()

func (*UpdateUserStatusResponse) ProtoReflect 

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

func (*UpdateUserStatusResponse) Reset 

func (x *UpdateUserStatusResponse) Reset()

func (*UpdateUserStatusResponse) String 

func (x *UpdateUserStatusResponse) String() string

type UpdateUserStatusResult 

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

func (*UpdateUserStatusResult) Descriptor deprecated 

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

Deprecated: Use UpdateUserStatusResult.ProtoReflect.Descriptor instead.

func (*UpdateUserStatusResult) ProtoMessage 

func (*UpdateUserStatusResult) ProtoMessage()

func (*UpdateUserStatusResult) ProtoReflect 

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

func (*UpdateUserStatusResult) Reset 

func (x *UpdateUserStatusResult) Reset()

func (*UpdateUserStatusResult) String 

func (x *UpdateUserStatusResult) String() string

type UserStatus 

type UserStatus struct {
	User   string `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Active int64  `protobuf:"varint,2,opt,name=active,proto3" json:"active,omitempty"`
	Online int64  `protobuf:"varint,3,opt,name=online,proto3" json:"online,omitempty"`
	// contains filtered or unexported fields
}

func (*UserStatus) Descriptor deprecated 

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

Deprecated: Use UserStatus.ProtoReflect.Descriptor instead.

func (*UserStatus) GetActive 

func (x *UserStatus) GetActive() int64

func (*UserStatus) GetOnline 

func (x *UserStatus) GetOnline() int64

func (*UserStatus) GetUser 

func (x *UserStatus) GetUser() string

func (*UserStatus) ProtoMessage 

func (*UserStatus) ProtoMessage()

func (*UserStatus) ProtoReflect 

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

func (*UserStatus) Reset 

func (x *UserStatus) Reset()

func (*UserStatus) String 

func (x *UserStatus) String() string

type UserTopic 

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 

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

Deprecated: Use UserTopic.ProtoReflect.Descriptor instead.

func (*UserTopic) GetId 

func (x *UserTopic) GetId() string

func (*UserTopic) GetTopic 

func (x *UserTopic) GetTopic() string

func (*UserTopic) GetUser 

func (x *UserTopic) GetUser() string

func (*UserTopic) ProtoMessage 

func (*UserTopic) ProtoMessage()

func (*UserTopic) ProtoReflect 

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

func (*UserTopic) Reset 

func (x *UserTopic) Reset()

func (*UserTopic) String 

func (x *UserTopic) String() string

type UserTopicFilter 

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 

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

Deprecated: Use UserTopicFilter.ProtoReflect.Descriptor instead.

func (*UserTopicFilter) GetTopicPrefix 

func (x *UserTopicFilter) GetTopicPrefix() string

func (*UserTopicFilter) GetTopics 

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

func (*UserTopicFilter) GetUsers 

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

func (*UserTopicFilter) ProtoMessage 

func (*UserTopicFilter) ProtoMessage()

func (*UserTopicFilter) ProtoReflect 

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

func (*UserTopicFilter) Reset 

func (x *UserTopicFilter) Reset()

func (*UserTopicFilter) String 

func (x *UserTopicFilter) String() string

type UserTopicListRequest 

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 

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

Deprecated: Use UserTopicListRequest.ProtoReflect.Descriptor instead.

func (*UserTopicListRequest) GetCursor 

func (x *UserTopicListRequest) GetCursor() string

func (*UserTopicListRequest) GetFilter 

func (x *UserTopicListRequest) GetFilter() *UserTopicFilter

func (*UserTopicListRequest) GetIncludeTotalCount 

func (x *UserTopicListRequest) GetIncludeTotalCount() bool

func (*UserTopicListRequest) GetLimit 

func (x *UserTopicListRequest) GetLimit() int32

func (*UserTopicListRequest) ProtoMessage 

func (*UserTopicListRequest) ProtoMessage()

func (*UserTopicListRequest) ProtoReflect 

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

func (*UserTopicListRequest) Reset 

func (x *UserTopicListRequest) Reset()

func (*UserTopicListRequest) String 

func (x *UserTopicListRequest) String() string

type UserTopicListResponse 

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 

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

Deprecated: Use UserTopicListResponse.ProtoReflect.Descriptor instead.

func (*UserTopicListResponse) GetError 

func (x *UserTopicListResponse) GetError() *Error

func (*UserTopicListResponse) GetResult 

func (x *UserTopicListResponse) GetResult() *UserTopicListResult

func (*UserTopicListResponse) ProtoMessage 

func (*UserTopicListResponse) ProtoMessage()

func (*UserTopicListResponse) ProtoReflect 

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

func (*UserTopicListResponse) Reset 

func (x *UserTopicListResponse) Reset()

func (*UserTopicListResponse) String 

func (x *UserTopicListResponse) String() string

type UserTopicListResult 

type UserTopicListResult struct {
	Items      []*UserTopic `protobuf:"bytes,1,rep,name=items,proto3" json:"items"`
	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 

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

Deprecated: Use UserTopicListResult.ProtoReflect.Descriptor instead.

func (*UserTopicListResult) GetItems 

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

func (*UserTopicListResult) GetNextCursor 

func (x *UserTopicListResult) GetNextCursor() string

func (*UserTopicListResult) GetTotalCount 

func (x *UserTopicListResult) GetTotalCount() int64

func (*UserTopicListResult) ProtoMessage 

func (*UserTopicListResult) ProtoMessage()

func (*UserTopicListResult) ProtoReflect 

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

func (*UserTopicListResult) Reset 

func (x *UserTopicListResult) Reset()

func (*UserTopicListResult) String 

func (x *UserTopicListResult) String() string

type UserTopicUpdateRequest 

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 

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

Deprecated: Use UserTopicUpdateRequest.ProtoReflect.Descriptor instead.

func (*UserTopicUpdateRequest) GetOp 

func (x *UserTopicUpdateRequest) GetOp() string

func (*UserTopicUpdateRequest) GetTopics 

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

func (*UserTopicUpdateRequest) GetUser 

func (x *UserTopicUpdateRequest) GetUser() string

func (*UserTopicUpdateRequest) ProtoMessage 

func (*UserTopicUpdateRequest) ProtoMessage()

func (*UserTopicUpdateRequest) ProtoReflect 

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

func (*UserTopicUpdateRequest) Reset 

func (x *UserTopicUpdateRequest) Reset()

func (*UserTopicUpdateRequest) String 

func (x *UserTopicUpdateRequest) String() string

type UserTopicUpdateResponse 

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 

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

Deprecated: Use UserTopicUpdateResponse.ProtoReflect.Descriptor instead.

func (*UserTopicUpdateResponse) GetError 

func (x *UserTopicUpdateResponse) GetError() *Error

func (*UserTopicUpdateResponse) GetResult 

func (x *UserTopicUpdateResponse) GetResult() *UserTopicUpdateResult

func (*UserTopicUpdateResponse) ProtoMessage 

func (*UserTopicUpdateResponse) ProtoMessage()

func (*UserTopicUpdateResponse) ProtoReflect 

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

func (*UserTopicUpdateResponse) Reset 

func (x *UserTopicUpdateResponse) Reset()

func (*UserTopicUpdateResponse) String 

func (x *UserTopicUpdateResponse) String() string

type UserTopicUpdateResult 

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

func (*UserTopicUpdateResult) Descriptor deprecated 

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

Deprecated: Use UserTopicUpdateResult.ProtoReflect.Descriptor instead.

func (*UserTopicUpdateResult) ProtoMessage 

func (*UserTopicUpdateResult) ProtoMessage()

func (*UserTopicUpdateResult) ProtoReflect 

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

func (*UserTopicUpdateResult) Reset 

func (x *UserTopicUpdateResult) Reset()

func (*UserTopicUpdateResult) String 

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.