controlpb

package
v0.32.1 Latest Latest
Warning

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

 Go to latest Published: Apr 7, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLength        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflow          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var File_control_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Command 

type Command struct {
	Uid string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
	// 2,3 removed.
	Node           *Node           `protobuf:"bytes,4,opt,name=node,proto3" json:"node,omitempty"`
	Unsubscribe    *Unsubscribe    `protobuf:"bytes,5,opt,name=unsubscribe,proto3" json:"unsubscribe,omitempty"`
	Disconnect     *Disconnect     `protobuf:"bytes,6,opt,name=disconnect,proto3" json:"disconnect,omitempty"`
	Shutdown       *Shutdown       `protobuf:"bytes,7,opt,name=shutdown,proto3" json:"shutdown,omitempty"`
	SurveyRequest  *SurveyRequest  `protobuf:"bytes,8,opt,name=survey_request,json=surveyRequest,proto3" json:"survey_request,omitempty"`
	SurveyResponse *SurveyResponse `protobuf:"bytes,9,opt,name=survey_response,json=surveyResponse,proto3" json:"survey_response,omitempty"`
	Subscribe      *Subscribe      `protobuf:"bytes,10,opt,name=subscribe,proto3" json:"subscribe,omitempty"`
	Notification   *Notification   `protobuf:"bytes,11,opt,name=notification,proto3" json:"notification,omitempty"`
	Refresh        *Refresh        `protobuf:"bytes,12,opt,name=refresh,proto3" json:"refresh,omitempty"`
	// contains filtered or unexported fields
}

func (*Command) Descriptor deprecated 

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

Deprecated: Use Command.ProtoReflect.Descriptor instead.

func (*Command) GetDisconnect added in v0.29.0 

func (x *Command) GetDisconnect() *Disconnect

func (*Command) GetNode added in v0.29.0 

func (x *Command) GetNode() *Node

func (*Command) GetNotification added in v0.29.0 

func (x *Command) GetNotification() *Notification

func (*Command) GetRefresh added in v0.29.0 

func (x *Command) GetRefresh() *Refresh

func (*Command) GetShutdown added in v0.29.0 

func (x *Command) GetShutdown() *Shutdown

func (*Command) GetSubscribe added in v0.29.0 

func (x *Command) GetSubscribe() *Subscribe

func (*Command) GetSurveyRequest added in v0.29.0 

func (x *Command) GetSurveyRequest() *SurveyRequest

func (*Command) GetSurveyResponse added in v0.29.0 

func (x *Command) GetSurveyResponse() *SurveyResponse

func (*Command) GetUid added in v0.18.0 

func (x *Command) GetUid() string

func (*Command) GetUnsubscribe added in v0.29.0 

func (x *Command) GetUnsubscribe() *Unsubscribe

func (*Command) MarshalToSizedBufferVT added in v0.18.0 

func (m *Command) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Command) MarshalToVT added in v0.18.0 

func (m *Command) MarshalToVT(dAtA []byte) (int, error)

func (*Command) MarshalVT added in v0.18.0 

func (m *Command) MarshalVT() (dAtA []byte, err error)

func (*Command) ProtoMessage 

func (*Command) ProtoMessage()

func (*Command) ProtoReflect added in v0.18.0 

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

func (*Command) Reset 

func (x *Command) Reset()

func (*Command) SizeVT added in v0.18.0 

func (m *Command) SizeVT() (n int)

func (*Command) String 

func (x *Command) String() string

func (*Command) UnmarshalVT added in v0.18.0 

func (m *Command) UnmarshalVT(dAtA []byte) error

type Disconnect 

type Disconnect struct {
	User      string   `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Whitelist []string `protobuf:"bytes,2,rep,name=whitelist,proto3" json:"whitelist,omitempty"`
	Code      uint32   `protobuf:"varint,3,opt,name=code,proto3" json:"code,omitempty"`
	Reason    string   `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,omitempty"`
	Reconnect bool     `protobuf:"varint,5,opt,name=reconnect,proto3" json:"reconnect,omitempty"`
	Client    string   `protobuf:"bytes,6,opt,name=client,proto3" json:"client,omitempty"`
	Session   string   `protobuf:"bytes,7,opt,name=session,proto3" json:"session,omitempty"`
	// contains filtered or unexported fields
}

func (*Disconnect) Descriptor deprecated 

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

Deprecated: Use Disconnect.ProtoReflect.Descriptor instead.

func (*Disconnect) GetClient added in v0.18.0 

func (x *Disconnect) GetClient() string

func (*Disconnect) GetCode added in v0.14.0 

func (x *Disconnect) GetCode() uint32

func (*Disconnect) GetReason added in v0.14.0 

func (x *Disconnect) GetReason() string

func (*Disconnect) GetReconnect added in v0.14.0 

func (x *Disconnect) GetReconnect() bool

func (*Disconnect) GetSession added in v0.21.1 

func (x *Disconnect) GetSession() string

func (*Disconnect) GetUser 

func (x *Disconnect) GetUser() string

func (*Disconnect) GetWhitelist added in v0.14.0 

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

func (*Disconnect) MarshalToSizedBufferVT added in v0.18.0 

func (m *Disconnect) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Disconnect) MarshalToVT added in v0.18.0 

func (m *Disconnect) MarshalToVT(dAtA []byte) (int, error)

func (*Disconnect) MarshalVT added in v0.18.0 

func (m *Disconnect) MarshalVT() (dAtA []byte, err error)

func (*Disconnect) ProtoMessage 

func (*Disconnect) ProtoMessage()

func (*Disconnect) ProtoReflect added in v0.18.0 

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

func (*Disconnect) Reset 

func (x *Disconnect) Reset()

func (*Disconnect) SizeVT added in v0.18.0 

func (m *Disconnect) SizeVT() (n int)

func (*Disconnect) String 

func (x *Disconnect) String() string

func (*Disconnect) UnmarshalVT added in v0.18.0 

func (m *Disconnect) UnmarshalVT(dAtA []byte) error

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) MarshalToSizedBufferVT added in v0.18.0 

func (m *Metrics) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Metrics) MarshalToVT added in v0.18.0 

func (m *Metrics) MarshalToVT(dAtA []byte) (int, error)

func (*Metrics) MarshalVT added in v0.18.0 

func (m *Metrics) MarshalVT() (dAtA []byte, err error)

func (*Metrics) ProtoMessage 

func (*Metrics) ProtoMessage()

func (*Metrics) ProtoReflect added in v0.18.0 

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

func (*Metrics) Reset 

func (x *Metrics) Reset()

func (*Metrics) SizeVT added in v0.18.0 

func (m *Metrics) SizeVT() (n int)

func (*Metrics) String 

func (x *Metrics) String() string

func (*Metrics) UnmarshalVT added in v0.18.0 

func (m *Metrics) UnmarshalVT(dAtA []byte) error

type Node 

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

func (*Node) Descriptor deprecated 

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

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetData added in v0.18.0 

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

func (*Node) GetMetrics 

func (x *Node) GetMetrics() *Metrics

func (*Node) GetName 

func (x *Node) GetName() string

func (*Node) GetNumChannels 

func (x *Node) GetNumChannels() uint32

func (*Node) GetNumClients 

func (x *Node) GetNumClients() uint32

func (*Node) GetNumSubs added in v0.18.0 

func (x *Node) GetNumSubs() uint32

func (*Node) GetNumUsers 

func (x *Node) GetNumUsers() uint32

func (*Node) GetUid added in v0.18.0 

func (x *Node) GetUid() string

func (*Node) GetUptime 

func (x *Node) GetUptime() uint32

func (*Node) GetVersion 

func (x *Node) GetVersion() string

func (*Node) MarshalToSizedBufferVT added in v0.18.0 

func (m *Node) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Node) MarshalToVT added in v0.18.0 

func (m *Node) MarshalToVT(dAtA []byte) (int, error)

func (*Node) MarshalVT added in v0.18.0 

func (m *Node) MarshalVT() (dAtA []byte, err error)

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect added in v0.18.0 

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

func (*Node) Reset 

func (x *Node) Reset()

func (*Node) SizeVT added in v0.18.0 

func (m *Node) SizeVT() (n int)

func (*Node) String 

func (x *Node) String() string

func (*Node) UnmarshalVT added in v0.18.0 

func (m *Node) UnmarshalVT(dAtA []byte) error

type Notification added in v0.17.0 

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

func (*Notification) Descriptor deprecated added in v0.17.0 

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

Deprecated: Use Notification.ProtoReflect.Descriptor instead.

func (*Notification) GetData added in v0.17.0 

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

func (*Notification) GetOp added in v0.17.0 

func (x *Notification) GetOp() string

func (*Notification) MarshalToSizedBufferVT added in v0.18.0 

func (m *Notification) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Notification) MarshalToVT added in v0.18.0 

func (m *Notification) MarshalToVT(dAtA []byte) (int, error)

func (*Notification) MarshalVT added in v0.18.0 

func (m *Notification) MarshalVT() (dAtA []byte, err error)

func (*Notification) ProtoMessage added in v0.17.0 

func (*Notification) ProtoMessage()

func (*Notification) ProtoReflect added in v0.18.0 

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

func (*Notification) Reset added in v0.17.0 

func (x *Notification) Reset()

func (*Notification) SizeVT added in v0.18.0 

func (m *Notification) SizeVT() (n int)

func (*Notification) String added in v0.17.0 

func (x *Notification) String() string

func (*Notification) UnmarshalVT added in v0.18.0 

func (m *Notification) UnmarshalVT(dAtA []byte) error

type Refresh added in v0.18.0 

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

func (*Refresh) Descriptor deprecated added in v0.18.0 

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

Deprecated: Use Refresh.ProtoReflect.Descriptor instead.

func (*Refresh) GetClient added in v0.18.0 

func (x *Refresh) GetClient() string

func (*Refresh) GetExpireAt added in v0.18.0 

func (x *Refresh) GetExpireAt() int64

func (*Refresh) GetExpired added in v0.18.0 

func (x *Refresh) GetExpired() bool

func (*Refresh) GetInfo added in v0.18.0 

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

func (*Refresh) GetSession added in v0.21.1 

func (x *Refresh) GetSession() string

func (*Refresh) GetUser added in v0.18.0 

func (x *Refresh) GetUser() string

func (*Refresh) MarshalToSizedBufferVT added in v0.18.0 

func (m *Refresh) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Refresh) MarshalToVT added in v0.18.0 

func (m *Refresh) MarshalToVT(dAtA []byte) (int, error)

func (*Refresh) MarshalVT added in v0.18.0 

func (m *Refresh) MarshalVT() (dAtA []byte, err error)

func (*Refresh) ProtoMessage added in v0.18.0 

func (*Refresh) ProtoMessage()

func (*Refresh) ProtoReflect added in v0.18.0 

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

func (*Refresh) Reset added in v0.18.0 

func (x *Refresh) Reset()

func (*Refresh) SizeVT added in v0.18.0 

func (m *Refresh) SizeVT() (n int)

func (*Refresh) String added in v0.18.0 

func (x *Refresh) String() string

func (*Refresh) UnmarshalVT added in v0.18.0 

func (m *Refresh) UnmarshalVT(dAtA []byte) error

type Shutdown added in v0.29.0 

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

func (*Shutdown) Descriptor deprecated added in v0.29.0 

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

Deprecated: Use Shutdown.ProtoReflect.Descriptor instead.

func (*Shutdown) MarshalToSizedBufferVT added in v0.29.0 

func (m *Shutdown) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Shutdown) MarshalToVT added in v0.29.0 

func (m *Shutdown) MarshalToVT(dAtA []byte) (int, error)

func (*Shutdown) MarshalVT added in v0.29.0 

func (m *Shutdown) MarshalVT() (dAtA []byte, err error)

func (*Shutdown) ProtoMessage added in v0.29.0 

func (*Shutdown) ProtoMessage()

func (*Shutdown) ProtoReflect added in v0.29.0 

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

func (*Shutdown) Reset added in v0.29.0 

func (x *Shutdown) Reset()

func (*Shutdown) SizeVT added in v0.29.0 

func (m *Shutdown) SizeVT() (n int)

func (*Shutdown) String added in v0.29.0 

func (x *Shutdown) String() string

func (*Shutdown) UnmarshalVT added in v0.29.0 

func (m *Shutdown) UnmarshalVT(dAtA []byte) error

type StreamPosition added in v0.18.0 

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 added in v0.18.0 

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

Deprecated: Use StreamPosition.ProtoReflect.Descriptor instead.

func (*StreamPosition) GetEpoch added in v0.18.0 

func (x *StreamPosition) GetEpoch() string

func (*StreamPosition) GetOffset added in v0.18.0 

func (x *StreamPosition) GetOffset() uint64

func (*StreamPosition) MarshalToSizedBufferVT added in v0.18.0 

func (m *StreamPosition) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*StreamPosition) MarshalToVT added in v0.18.0 

func (m *StreamPosition) MarshalToVT(dAtA []byte) (int, error)

func (*StreamPosition) MarshalVT added in v0.18.0 

func (m *StreamPosition) MarshalVT() (dAtA []byte, err error)

func (*StreamPosition) ProtoMessage added in v0.18.0 

func (*StreamPosition) ProtoMessage()

func (*StreamPosition) ProtoReflect added in v0.18.0 

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

func (*StreamPosition) Reset added in v0.18.0 

func (x *StreamPosition) Reset()

func (*StreamPosition) SizeVT added in v0.18.0 

func (m *StreamPosition) SizeVT() (n int)

func (*StreamPosition) String added in v0.18.0 

func (x *StreamPosition) String() string

func (*StreamPosition) UnmarshalVT added in v0.18.0 

func (m *StreamPosition) UnmarshalVT(dAtA []byte) error

type Subscribe added in v0.16.0 

type Subscribe struct {
	User          string          `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	Channel       string          `protobuf:"bytes,2,opt,name=channel,proto3" json:"channel,omitempty"`
	EmitPresence  bool            `protobuf:"varint,3,opt,name=emit_presence,json=emitPresence,proto3" json:"emit_presence,omitempty"`
	EmitJoinLeave bool            `protobuf:"varint,4,opt,name=emit_join_leave,json=emitJoinLeave,proto3" json:"emit_join_leave,omitempty"`
	ExpireAt      int64           `protobuf:"varint,5,opt,name=expire_at,json=expireAt,proto3" json:"expire_at,omitempty"`
	Position      bool            `protobuf:"varint,6,opt,name=position,proto3" json:"position,omitempty"`
	Recover       bool            `protobuf:"varint,7,opt,name=recover,proto3" json:"recover,omitempty"`
	ChannelInfo   []byte          `protobuf:"bytes,8,opt,name=channel_info,json=channelInfo,proto3" json:"channel_info,omitempty"`
	Client        string          `protobuf:"bytes,9,opt,name=client,proto3" json:"client,omitempty"`
	Data          []byte          `protobuf:"bytes,10,opt,name=data,proto3" json:"data,omitempty"`
	RecoverSince  *StreamPosition `protobuf:"bytes,11,opt,name=recover_since,json=recoverSince,proto3" json:"recover_since,omitempty"`
	Session       string          `protobuf:"bytes,12,opt,name=session,proto3" json:"session,omitempty"`
	PushJoinLeave bool            `protobuf:"varint,13,opt,name=push_join_leave,json=pushJoinLeave,proto3" json:"push_join_leave,omitempty"`
	Source        uint32          `protobuf:"varint,14,opt,name=source,proto3" json:"source,omitempty"`
	// contains filtered or unexported fields
}

func (*Subscribe) Descriptor deprecated added in v0.16.0 

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

Deprecated: Use Subscribe.ProtoReflect.Descriptor instead.

func (*Subscribe) GetChannel added in v0.16.0 

func (x *Subscribe) GetChannel() string

func (*Subscribe) GetChannelInfo added in v0.18.0 

func (x *Subscribe) GetChannelInfo() []byte

func (*Subscribe) GetClient added in v0.16.0 

func (x *Subscribe) GetClient() string

func (*Subscribe) GetData added in v0.18.0 

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

func (*Subscribe) GetEmitJoinLeave added in v0.24.0 

func (x *Subscribe) GetEmitJoinLeave() bool

func (*Subscribe) GetEmitPresence added in v0.24.0 

func (x *Subscribe) GetEmitPresence() bool

func (*Subscribe) GetExpireAt added in v0.16.0 

func (x *Subscribe) GetExpireAt() int64

func (*Subscribe) GetPosition added in v0.16.0 

func (x *Subscribe) GetPosition() bool

func (*Subscribe) GetPushJoinLeave added in v0.24.0 

func (x *Subscribe) GetPushJoinLeave() bool

func (*Subscribe) GetRecover added in v0.16.0 

func (x *Subscribe) GetRecover() bool

func (*Subscribe) GetRecoverSince added in v0.18.0 

func (x *Subscribe) GetRecoverSince() *StreamPosition

func (*Subscribe) GetSession added in v0.21.1 

func (x *Subscribe) GetSession() string

func (*Subscribe) GetSource added in v0.26.0 

func (x *Subscribe) GetSource() uint32

func (*Subscribe) GetUser added in v0.16.0 

func (x *Subscribe) GetUser() string

func (*Subscribe) MarshalToSizedBufferVT added in v0.18.0 

func (m *Subscribe) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Subscribe) MarshalToVT added in v0.18.0 

func (m *Subscribe) MarshalToVT(dAtA []byte) (int, error)

func (*Subscribe) MarshalVT added in v0.18.0 

func (m *Subscribe) MarshalVT() (dAtA []byte, err error)

func (*Subscribe) ProtoMessage added in v0.16.0 

func (*Subscribe) ProtoMessage()

func (*Subscribe) ProtoReflect added in v0.18.0 

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

func (*Subscribe) Reset added in v0.16.0 

func (x *Subscribe) Reset()

func (*Subscribe) SizeVT added in v0.18.0 

func (m *Subscribe) SizeVT() (n int)

func (*Subscribe) String added in v0.16.0 

func (x *Subscribe) String() string

func (*Subscribe) UnmarshalVT added in v0.18.0 

func (m *Subscribe) UnmarshalVT(dAtA []byte) error

type SurveyRequest added in v0.15.0 

type SurveyRequest struct {
	Id   uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Op   string `protobuf:"bytes,2,opt,name=op,proto3" json:"op,omitempty"`
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*SurveyRequest) Descriptor deprecated added in v0.15.0 

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

Deprecated: Use SurveyRequest.ProtoReflect.Descriptor instead.

func (*SurveyRequest) GetData added in v0.15.0 

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

func (*SurveyRequest) GetId added in v0.18.0 

func (x *SurveyRequest) GetId() uint64

func (*SurveyRequest) GetOp added in v0.15.0 

func (x *SurveyRequest) GetOp() string

func (*SurveyRequest) MarshalToSizedBufferVT added in v0.18.0 

func (m *SurveyRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SurveyRequest) MarshalToVT added in v0.18.0 

func (m *SurveyRequest) MarshalToVT(dAtA []byte) (int, error)

func (*SurveyRequest) MarshalVT added in v0.18.0 

func (m *SurveyRequest) MarshalVT() (dAtA []byte, err error)

func (*SurveyRequest) ProtoMessage added in v0.15.0 

func (*SurveyRequest) ProtoMessage()

func (*SurveyRequest) ProtoReflect added in v0.18.0 

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

func (*SurveyRequest) Reset added in v0.15.0 

func (x *SurveyRequest) Reset()

func (*SurveyRequest) SizeVT added in v0.18.0 

func (m *SurveyRequest) SizeVT() (n int)

func (*SurveyRequest) String added in v0.15.0 

func (x *SurveyRequest) String() string

func (*SurveyRequest) UnmarshalVT added in v0.18.0 

func (m *SurveyRequest) UnmarshalVT(dAtA []byte) error

type SurveyResponse added in v0.15.0 

type SurveyResponse struct {
	Id   uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Code uint32 `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"`
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*SurveyResponse) Descriptor deprecated added in v0.15.0 

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

Deprecated: Use SurveyResponse.ProtoReflect.Descriptor instead.

func (*SurveyResponse) GetCode added in v0.15.0 

func (x *SurveyResponse) GetCode() uint32

func (*SurveyResponse) GetData added in v0.15.0 

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

func (*SurveyResponse) GetId added in v0.18.0 

func (x *SurveyResponse) GetId() uint64

func (*SurveyResponse) MarshalToSizedBufferVT added in v0.18.0 

func (m *SurveyResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*SurveyResponse) MarshalToVT added in v0.18.0 

func (m *SurveyResponse) MarshalToVT(dAtA []byte) (int, error)

func (*SurveyResponse) MarshalVT added in v0.18.0 

func (m *SurveyResponse) MarshalVT() (dAtA []byte, err error)

func (*SurveyResponse) ProtoMessage added in v0.15.0 

func (*SurveyResponse) ProtoMessage()

func (*SurveyResponse) ProtoReflect added in v0.18.0 

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

func (*SurveyResponse) Reset added in v0.15.0 

func (x *SurveyResponse) Reset()

func (*SurveyResponse) SizeVT added in v0.18.0 

func (m *SurveyResponse) SizeVT() (n int)

func (*SurveyResponse) String added in v0.15.0 

func (x *SurveyResponse) String() string

func (*SurveyResponse) UnmarshalVT added in v0.18.0 

func (m *SurveyResponse) UnmarshalVT(dAtA []byte) error

type Unsubscribe 

type Unsubscribe 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"`
	Code    uint32 `protobuf:"varint,5,opt,name=code,proto3" json:"code,omitempty"`
	Reason  string `protobuf:"bytes,6,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*Unsubscribe) Descriptor deprecated 

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

Deprecated: Use Unsubscribe.ProtoReflect.Descriptor instead.

func (*Unsubscribe) GetChannel 

func (x *Unsubscribe) GetChannel() string

func (*Unsubscribe) GetClient added in v0.16.0 

func (x *Unsubscribe) GetClient() string

func (*Unsubscribe) GetCode added in v0.23.0 

func (x *Unsubscribe) GetCode() uint32

func (*Unsubscribe) GetReason added in v0.23.0 

func (x *Unsubscribe) GetReason() string

func (*Unsubscribe) GetSession added in v0.21.1 

func (x *Unsubscribe) GetSession() string

func (*Unsubscribe) GetUser 

func (x *Unsubscribe) GetUser() string

func (*Unsubscribe) MarshalToSizedBufferVT added in v0.18.0 

func (m *Unsubscribe) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Unsubscribe) MarshalToVT added in v0.18.0 

func (m *Unsubscribe) MarshalToVT(dAtA []byte) (int, error)

func (*Unsubscribe) MarshalVT added in v0.18.0 

func (m *Unsubscribe) MarshalVT() (dAtA []byte, err error)

func (*Unsubscribe) ProtoMessage 

func (*Unsubscribe) ProtoMessage()

func (*Unsubscribe) ProtoReflect added in v0.18.0 

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

func (*Unsubscribe) Reset 

func (x *Unsubscribe) Reset()

func (*Unsubscribe) SizeVT added in v0.18.0 

func (m *Unsubscribe) SizeVT() (n int)

func (*Unsubscribe) String 

func (x *Unsubscribe) String() string

func (*Unsubscribe) UnmarshalVT added in v0.18.0 

func (m *Unsubscribe) UnmarshalVT(dAtA []byte) error

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.