controlpb

package
v0.18.4 Latest Latest
Warning

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

 Go to latest Published: Sep 11, 2021 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Command_MethodType_name = map[int32]string{
		0: "NODE",
		1: "UNSUBSCRIBE",
		2: "DISCONNECT",
		3: "SHUTDOWN",
		4: "SURVEY_REQUEST",
		5: "SURVEY_RESPONSE",
		6: "SUBSCRIBE",
		7: "NOTIFICATION",
		8: "REFRESH",
	}
	Command_MethodType_value = map[string]int32{
		"NODE":            0,
		"UNSUBSCRIBE":     1,
		"DISCONNECT":      2,
		"SHUTDOWN":        3,
		"SURVEY_REQUEST":  4,
		"SURVEY_RESPONSE": 5,
		"SUBSCRIBE":       6,
		"NOTIFICATION":    7,
		"REFRESH":         8,
	}
)

Enum value maps for Command_MethodType.

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"`
	Method Command_MethodType `protobuf:"varint,2,opt,name=method,proto3,enum=controlpb.Command_MethodType" json:"method,omitempty"`
	Params []byte             `protobuf:"bytes,3,opt,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

func (*Command) Descriptor deprecated 

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

Deprecated: Use Command.ProtoReflect.Descriptor instead.

func (*Command) GetMethod 

func (x *Command) GetMethod() Command_MethodType

func (*Command) GetParams added in v0.18.0 

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

func (*Command) GetUid added in v0.18.0 

func (x *Command) GetUid() string

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

type Command_MethodType int32
const (
	Command_NODE            Command_MethodType = 0
	Command_UNSUBSCRIBE     Command_MethodType = 1
	Command_DISCONNECT      Command_MethodType = 2
	Command_SHUTDOWN        Command_MethodType = 3
	Command_SURVEY_REQUEST  Command_MethodType = 4
	Command_SURVEY_RESPONSE Command_MethodType = 5
	Command_SUBSCRIBE       Command_MethodType = 6
	Command_NOTIFICATION    Command_MethodType = 7
	Command_REFRESH         Command_MethodType = 8
)

func (Command_MethodType) Descriptor added in v0.18.0 

func (Command_MethodType) Descriptor() protoreflect.EnumDescriptor

func (Command_MethodType) Enum added in v0.18.0 

func (x Command_MethodType) Enum() *Command_MethodType

func (Command_MethodType) EnumDescriptor deprecated added in v0.18.0 

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

Deprecated: Use Command_MethodType.Descriptor instead.

func (Command_MethodType) Number added in v0.18.0 

func (x Command_MethodType) Number() protoreflect.EnumNumber

func (Command_MethodType) String added in v0.18.0 

func (x Command_MethodType) String() string

func (Command_MethodType) Type added in v0.18.0 

func (Command_MethodType) Type() protoreflect.EnumType

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"`
	// 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) 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"`
	// 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) 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 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"`
	Presence     bool            `protobuf:"varint,3,opt,name=presence,proto3" json:"presence,omitempty"`
	JoinLeave    bool            `protobuf:"varint,4,opt,name=join_leave,json=joinLeave,proto3" json:"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"`
	// 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) GetExpireAt added in v0.16.0 

func (x *Subscribe) GetExpireAt() int64

func (*Subscribe) GetJoinLeave added in v0.16.0 

func (x *Subscribe) GetJoinLeave() bool

func (*Subscribe) GetPosition added in v0.16.0 

func (x *Subscribe) GetPosition() bool

func (*Subscribe) GetPresence added in v0.16.0 

func (x *Subscribe) GetPresence() 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) 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"`
	// 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) 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.