Versions in this module Expand all Collapse all v1 v1.0.1 Jul 17, 2023 Changes in this version + var ErrIntOverflow = fmt.Errorf("proto: integer overflow") + var ErrInvalidLength = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group") + var File_control_proto protoreflect.FileDescriptor + type Command struct + Disconnect *Disconnect + Node *Node + Notification *Notification + Refresh *Refresh + Shutdown *Shutdown + Subscribe *Subscribe + SurveyRequest *SurveyRequest + SurveyResponse *SurveyResponse + Uid string + Unsubscribe *Unsubscribe + func (*Command) Descriptor() ([]byte, []int) + func (*Command) ProtoMessage() + func (m *Command) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *Command) MarshalToVT(dAtA []byte) (int, error) + func (m *Command) MarshalVT() (dAtA []byte, err error) + func (m *Command) SizeVT() (n int) + func (m *Command) UnmarshalVT(dAtA []byte) error + func (x *Command) GetDisconnect() *Disconnect + func (x *Command) GetNode() *Node + func (x *Command) GetNotification() *Notification + func (x *Command) GetRefresh() *Refresh + func (x *Command) GetShutdown() *Shutdown + func (x *Command) GetSubscribe() *Subscribe + func (x *Command) GetSurveyRequest() *SurveyRequest + func (x *Command) GetSurveyResponse() *SurveyResponse + func (x *Command) GetUid() string + func (x *Command) GetUnsubscribe() *Unsubscribe + func (x *Command) ProtoReflect() protoreflect.Message + func (x *Command) Reset() + func (x *Command) String() string + type Disconnect struct + Client string + Code uint32 + Reason string + Reconnect bool + Session string + User string + Whitelist []string + func (*Disconnect) Descriptor() ([]byte, []int) + func (*Disconnect) ProtoMessage() + func (m *Disconnect) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *Disconnect) MarshalToVT(dAtA []byte) (int, error) + func (m *Disconnect) MarshalVT() (dAtA []byte, err error) + func (m *Disconnect) SizeVT() (n int) + func (m *Disconnect) UnmarshalVT(dAtA []byte) error + func (x *Disconnect) GetClient() string + func (x *Disconnect) GetCode() uint32 + func (x *Disconnect) GetReason() string + func (x *Disconnect) GetReconnect() bool + func (x *Disconnect) GetSession() string + func (x *Disconnect) GetUser() string + func (x *Disconnect) GetWhitelist() []string + func (x *Disconnect) ProtoReflect() protoreflect.Message + func (x *Disconnect) Reset() + func (x *Disconnect) String() string + type Metrics struct + Interval float64 + Items map[string]float64 + func (*Metrics) Descriptor() ([]byte, []int) + func (*Metrics) ProtoMessage() + func (m *Metrics) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *Metrics) MarshalToVT(dAtA []byte) (int, error) + func (m *Metrics) MarshalVT() (dAtA []byte, err error) + func (m *Metrics) SizeVT() (n int) + func (m *Metrics) UnmarshalVT(dAtA []byte) error + func (x *Metrics) GetInterval() float64 + func (x *Metrics) GetItems() map[string]float64 + func (x *Metrics) ProtoReflect() protoreflect.Message + func (x *Metrics) Reset() + func (x *Metrics) String() string + type Node struct + Data []byte + Metrics *Metrics + Name string + NumChannels uint32 + NumClients uint32 + NumSubs uint32 + NumUsers uint32 + Uid string + Uptime uint32 + Version string + func (*Node) Descriptor() ([]byte, []int) + func (*Node) ProtoMessage() + func (m *Node) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *Node) MarshalToVT(dAtA []byte) (int, error) + func (m *Node) MarshalVT() (dAtA []byte, err error) + func (m *Node) SizeVT() (n int) + func (m *Node) UnmarshalVT(dAtA []byte) error + func (x *Node) GetData() []byte + func (x *Node) GetMetrics() *Metrics + func (x *Node) GetName() string + func (x *Node) GetNumChannels() uint32 + func (x *Node) GetNumClients() uint32 + func (x *Node) GetNumSubs() uint32 + func (x *Node) GetNumUsers() uint32 + func (x *Node) GetUid() string + func (x *Node) GetUptime() uint32 + func (x *Node) GetVersion() string + func (x *Node) ProtoReflect() protoreflect.Message + func (x *Node) Reset() + func (x *Node) String() string + type Notification struct + Data []byte + Op string + func (*Notification) Descriptor() ([]byte, []int) + func (*Notification) ProtoMessage() + func (m *Notification) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *Notification) MarshalToVT(dAtA []byte) (int, error) + func (m *Notification) MarshalVT() (dAtA []byte, err error) + func (m *Notification) SizeVT() (n int) + func (m *Notification) UnmarshalVT(dAtA []byte) error + func (x *Notification) GetData() []byte + func (x *Notification) GetOp() string + func (x *Notification) ProtoReflect() protoreflect.Message + func (x *Notification) Reset() + func (x *Notification) String() string + type Refresh struct + Client string + ExpireAt int64 + Expired bool + Info []byte + Session string + User string + func (*Refresh) Descriptor() ([]byte, []int) + func (*Refresh) ProtoMessage() + func (m *Refresh) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *Refresh) MarshalToVT(dAtA []byte) (int, error) + func (m *Refresh) MarshalVT() (dAtA []byte, err error) + func (m *Refresh) SizeVT() (n int) + func (m *Refresh) UnmarshalVT(dAtA []byte) error + func (x *Refresh) GetClient() string + func (x *Refresh) GetExpireAt() int64 + func (x *Refresh) GetExpired() bool + func (x *Refresh) GetInfo() []byte + func (x *Refresh) GetSession() string + func (x *Refresh) GetUser() string + func (x *Refresh) ProtoReflect() protoreflect.Message + func (x *Refresh) Reset() + func (x *Refresh) String() string + type Shutdown struct + func (*Shutdown) Descriptor() ([]byte, []int) + func (*Shutdown) ProtoMessage() + func (m *Shutdown) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *Shutdown) MarshalToVT(dAtA []byte) (int, error) + func (m *Shutdown) MarshalVT() (dAtA []byte, err error) + func (m *Shutdown) SizeVT() (n int) + func (m *Shutdown) UnmarshalVT(dAtA []byte) error + func (x *Shutdown) ProtoReflect() protoreflect.Message + func (x *Shutdown) Reset() + func (x *Shutdown) String() string + type StreamPosition struct + Epoch string + Offset uint64 + func (*StreamPosition) Descriptor() ([]byte, []int) + func (*StreamPosition) ProtoMessage() + func (m *StreamPosition) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *StreamPosition) MarshalToVT(dAtA []byte) (int, error) + func (m *StreamPosition) MarshalVT() (dAtA []byte, err error) + func (m *StreamPosition) SizeVT() (n int) + func (m *StreamPosition) UnmarshalVT(dAtA []byte) error + func (x *StreamPosition) GetEpoch() string + func (x *StreamPosition) GetOffset() uint64 + func (x *StreamPosition) ProtoReflect() protoreflect.Message + func (x *StreamPosition) Reset() + func (x *StreamPosition) String() string + type Subscribe struct + Channel string + ChannelInfo []byte + Client string + Data []byte + EmitJoinLeave bool + EmitPresence bool + ExpireAt int64 + Position bool + PushJoinLeave bool + Recover bool + RecoverSince *StreamPosition + Session string + Source uint32 + User string + func (*Subscribe) Descriptor() ([]byte, []int) + func (*Subscribe) ProtoMessage() + func (m *Subscribe) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *Subscribe) MarshalToVT(dAtA []byte) (int, error) + func (m *Subscribe) MarshalVT() (dAtA []byte, err error) + func (m *Subscribe) SizeVT() (n int) + func (m *Subscribe) UnmarshalVT(dAtA []byte) error + func (x *Subscribe) GetChannel() string + func (x *Subscribe) GetChannelInfo() []byte + func (x *Subscribe) GetClient() string + func (x *Subscribe) GetData() []byte + func (x *Subscribe) GetEmitJoinLeave() bool + func (x *Subscribe) GetEmitPresence() bool + func (x *Subscribe) GetExpireAt() int64 + func (x *Subscribe) GetPosition() bool + func (x *Subscribe) GetPushJoinLeave() bool + func (x *Subscribe) GetRecover() bool + func (x *Subscribe) GetRecoverSince() *StreamPosition + func (x *Subscribe) GetSession() string + func (x *Subscribe) GetSource() uint32 + func (x *Subscribe) GetUser() string + func (x *Subscribe) ProtoReflect() protoreflect.Message + func (x *Subscribe) Reset() + func (x *Subscribe) String() string + type SurveyRequest struct + Data []byte + Id uint64 + Op string + func (*SurveyRequest) Descriptor() ([]byte, []int) + func (*SurveyRequest) ProtoMessage() + func (m *SurveyRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *SurveyRequest) MarshalToVT(dAtA []byte) (int, error) + func (m *SurveyRequest) MarshalVT() (dAtA []byte, err error) + func (m *SurveyRequest) SizeVT() (n int) + func (m *SurveyRequest) UnmarshalVT(dAtA []byte) error + func (x *SurveyRequest) GetData() []byte + func (x *SurveyRequest) GetId() uint64 + func (x *SurveyRequest) GetOp() string + func (x *SurveyRequest) ProtoReflect() protoreflect.Message + func (x *SurveyRequest) Reset() + func (x *SurveyRequest) String() string + type SurveyResponse struct + Code uint32 + Data []byte + Id uint64 + func (*SurveyResponse) Descriptor() ([]byte, []int) + func (*SurveyResponse) ProtoMessage() + func (m *SurveyResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *SurveyResponse) MarshalToVT(dAtA []byte) (int, error) + func (m *SurveyResponse) MarshalVT() (dAtA []byte, err error) + func (m *SurveyResponse) SizeVT() (n int) + func (m *SurveyResponse) UnmarshalVT(dAtA []byte) error + func (x *SurveyResponse) GetCode() uint32 + func (x *SurveyResponse) GetData() []byte + func (x *SurveyResponse) GetId() uint64 + func (x *SurveyResponse) ProtoReflect() protoreflect.Message + func (x *SurveyResponse) Reset() + func (x *SurveyResponse) String() string + type Unsubscribe struct + Channel string + Client string + Code uint32 + Reason string + Session string + User string + func (*Unsubscribe) Descriptor() ([]byte, []int) + func (*Unsubscribe) ProtoMessage() + func (m *Unsubscribe) MarshalToSizedBufferVT(dAtA []byte) (int, error) + func (m *Unsubscribe) MarshalToVT(dAtA []byte) (int, error) + func (m *Unsubscribe) MarshalVT() (dAtA []byte, err error) + func (m *Unsubscribe) SizeVT() (n int) + func (m *Unsubscribe) UnmarshalVT(dAtA []byte) error + func (x *Unsubscribe) GetChannel() string + func (x *Unsubscribe) GetClient() string + func (x *Unsubscribe) GetCode() uint32 + func (x *Unsubscribe) GetReason() string + func (x *Unsubscribe) GetSession() string + func (x *Unsubscribe) GetUser() string + func (x *Unsubscribe) ProtoReflect() protoreflect.Message + func (x *Unsubscribe) Reset() + func (x *Unsubscribe) String() string