Versions in this module Expand all Collapse all v1 v1.6.0 Jun 15, 2023 v1.5.0 Jun 4, 2023 Changes in this version + var File_api_proto protoreflect.FileDescriptor + var File_sub_proto protoreflect.FileDescriptor + var Response_ResponseCode_name = map[int32]string + var Response_ResponseCode_value = map[string]int32 + var UpdateClient_UpdateType_name = map[int32]string + var UpdateClient_UpdateType_value = map[string]int32 + type ChannelInfo struct + Blocked bool + Children []string + Closed bool + ID string + Muted bool + Parent string + Type int32 + func (*ChannelInfo) Descriptor() ([]byte, []int) + func (*ChannelInfo) ProtoMessage() + func (x *ChannelInfo) GetBlocked() bool + func (x *ChannelInfo) GetChildren() []string + func (x *ChannelInfo) GetClosed() bool + func (x *ChannelInfo) GetID() string + func (x *ChannelInfo) GetMuted() bool + func (x *ChannelInfo) GetParent() string + func (x *ChannelInfo) GetType() int32 + func (x *ChannelInfo) ProtoReflect() protoreflect.Message + func (x *ChannelInfo) Reset() + func (x *ChannelInfo) String() string + type CreateChannelRequest struct + ChannelID string + ChannelInfo *ChannelInfo + func (*CreateChannelRequest) Descriptor() ([]byte, []int) + func (*CreateChannelRequest) ProtoMessage() + func (x *CreateChannelRequest) GetChannelID() string + func (x *CreateChannelRequest) GetChannelInfo() *ChannelInfo + func (x *CreateChannelRequest) ProtoReflect() protoreflect.Message + func (x *CreateChannelRequest) Reset() + func (x *CreateChannelRequest) String() string + type EnqueueMessageRequest struct + Id string + Msg []byte + func (*EnqueueMessageRequest) Descriptor() ([]byte, []int) + func (*EnqueueMessageRequest) ProtoMessage() + func (x *EnqueueMessageRequest) GetId() string + func (x *EnqueueMessageRequest) GetMsg() []byte + func (x *EnqueueMessageRequest) ProtoReflect() protoreflect.Message + func (x *EnqueueMessageRequest) Reset() + func (x *EnqueueMessageRequest) String() string + type PublishRequest struct + ChannelID string + Message []byte + func (*PublishRequest) Descriptor() ([]byte, []int) + func (*PublishRequest) ProtoMessage() + func (x *PublishRequest) GetChannelID() string + func (x *PublishRequest) GetMessage() []byte + func (x *PublishRequest) ProtoReflect() protoreflect.Message + func (x *PublishRequest) Reset() + func (x *PublishRequest) String() string + type RemoveChannelRequest struct + ChannelID string + func (*RemoveChannelRequest) Descriptor() ([]byte, []int) + func (*RemoveChannelRequest) ProtoMessage() + func (x *RemoveChannelRequest) GetChannelID() string + func (x *RemoveChannelRequest) ProtoReflect() protoreflect.Message + func (x *RemoveChannelRequest) Reset() + func (x *RemoveChannelRequest) String() string + type Response struct + Code int32 + Msg string + func (*Response) Descriptor() ([]byte, []int) + func (*Response) ProtoMessage() + func (x *Response) GetCode() int32 + func (x *Response) GetMsg() string + func (x *Response) ProtoReflect() protoreflect.Message + func (x *Response) Reset() + func (x *Response) String() string + type Response_ResponseCode int32 + const Response_ERROR + const Response_OK + func (Response_ResponseCode) Descriptor() protoreflect.EnumDescriptor + func (Response_ResponseCode) EnumDescriptor() ([]byte, []int) + func (Response_ResponseCode) Type() protoreflect.EnumType + func (x Response_ResponseCode) Enum() *Response_ResponseCode + func (x Response_ResponseCode) Number() protoreflect.EnumNumber + func (x Response_ResponseCode) String() string + type SubscribeRequest struct + ChannelID string + Extra []byte + SubscriberID string + func (*SubscribeRequest) Descriptor() ([]byte, []int) + func (*SubscribeRequest) ProtoMessage() + func (x *SubscribeRequest) GetChannelID() string + func (x *SubscribeRequest) GetExtra() []byte + func (x *SubscribeRequest) GetSubscriberID() string + func (x *SubscribeRequest) ProtoReflect() protoreflect.Message + func (x *SubscribeRequest) Reset() + func (x *SubscribeRequest) String() string + type UnsubscribeRequest struct + ChannelID string + SubscriberID string + func (*UnsubscribeRequest) Descriptor() ([]byte, []int) + func (*UnsubscribeRequest) ProtoMessage() + func (x *UnsubscribeRequest) GetChannelID() string + func (x *UnsubscribeRequest) GetSubscriberID() string + func (x *UnsubscribeRequest) ProtoReflect() protoreflect.Message + func (x *UnsubscribeRequest) Reset() + func (x *UnsubscribeRequest) String() string + type UpdateChannelRequest struct + ChannelID string + ChannelInfo *ChannelInfo + func (*UpdateChannelRequest) Descriptor() ([]byte, []int) + func (*UpdateChannelRequest) ProtoMessage() + func (x *UpdateChannelRequest) GetChannelID() string + func (x *UpdateChannelRequest) GetChannelInfo() *ChannelInfo + func (x *UpdateChannelRequest) ProtoReflect() protoreflect.Message + func (x *UpdateChannelRequest) Reset() + func (x *UpdateChannelRequest) String() string + type UpdateClient struct + Close bool + Id string + Message string + NewId string + Secret string + Type UpdateClient_UpdateType + func (*UpdateClient) Descriptor() ([]byte, []int) + func (*UpdateClient) ProtoMessage() + func (x *UpdateClient) GetClose() bool + func (x *UpdateClient) GetId() string + func (x *UpdateClient) GetMessage() string + func (x *UpdateClient) GetNewId() string + func (x *UpdateClient) GetSecret() string + func (x *UpdateClient) GetType() UpdateClient_UpdateType + func (x *UpdateClient) ProtoReflect() protoreflect.Message + func (x *UpdateClient) Reset() + func (x *UpdateClient) String() string + type UpdateClient_UpdateType int32 + const UpdateClient_Close + const UpdateClient_Kick + const UpdateClient_UpdateID + const UpdateClient_UpdateSecret + const UpdateClient__ + func (UpdateClient_UpdateType) Descriptor() protoreflect.EnumDescriptor + func (UpdateClient_UpdateType) EnumDescriptor() ([]byte, []int) + func (UpdateClient_UpdateType) Type() protoreflect.EnumType + func (x UpdateClient_UpdateType) Enum() *UpdateClient_UpdateType + func (x UpdateClient_UpdateType) Number() protoreflect.EnumNumber + func (x UpdateClient_UpdateType) String() string + type UpdateSubscriberRequest struct + ChannelID string + Extra []byte + SubscriberID string + func (*UpdateSubscriberRequest) Descriptor() ([]byte, []int) + func (*UpdateSubscriberRequest) ProtoMessage() + func (x *UpdateSubscriberRequest) GetChannelID() string + func (x *UpdateSubscriberRequest) GetExtra() []byte + func (x *UpdateSubscriberRequest) GetSubscriberID() string + func (x *UpdateSubscriberRequest) ProtoReflect() protoreflect.Message + func (x *UpdateSubscriberRequest) Reset() + func (x *UpdateSubscriberRequest) String() string