controlpb

package
v0.17.0 Latest Latest
Warning

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

 Go to latest Published: Apr 10, 2021 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthControl        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowControl          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupControl = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var MethodType_name = map[int32]string{
	0: "NODE",
	1: "UNSUBSCRIBE",
	2: "DISCONNECT",
	3: "SHUTDOWN",
	4: "SURVEY_REQUEST",
	5: "SURVEY_RESPONSE",
	6: "SUBSCRIBE",
	7: "NOTIFICATION",
}
View Source 
var MethodType_value = map[string]int32{
	"NODE":            0,
	"UNSUBSCRIBE":     1,
	"DISCONNECT":      2,
	"SHUTDOWN":        3,
	"SURVEY_REQUEST":  4,
	"SURVEY_RESPONSE": 5,
	"SUBSCRIBE":       6,
	"NOTIFICATION":    7,
}

Functions

This section is empty.

Types

type Command 

type Command struct {
	UID    string     `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid"`
	Method MethodType `protobuf:"varint,2,opt,name=method,proto3,enum=controlpb.MethodType" json:"method"`
	Params Raw        `protobuf:"bytes,3,opt,name=params,proto3,customtype=Raw" json:"params"`
}

func NewPopulatedCommand 

func NewPopulatedCommand(r randyControl, easy bool) *Command

func (*Command) Descriptor 

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

func (*Command) Equal 

func (this *Command) Equal(that interface{}) bool

func (*Command) GetMethod 

func (m *Command) GetMethod() MethodType

func (*Command) GetUID 

func (m *Command) GetUID() string

func (*Command) Marshal 

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

func (*Command) MarshalTo 

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

func (*Command) MarshalToSizedBuffer added in v0.16.0 

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

func (*Command) ProtoMessage 

func (*Command) ProtoMessage()

func (*Command) Reset 

func (m *Command) Reset()

func (*Command) Size 

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

func (*Command) String 

func (m *Command) String() string

func (*Command) Unmarshal 

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

func (*Command) XXX_DiscardUnknown added in v0.16.0 

func (m *Command) XXX_DiscardUnknown()

func (*Command) XXX_Marshal added in v0.16.0 

func (m *Command) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Command) XXX_Merge added in v0.16.0 

func (m *Command) XXX_Merge(src proto.Message)

func (*Command) XXX_Size added in v0.16.0 

func (m *Command) XXX_Size() int

func (*Command) XXX_Unmarshal added in v0.16.0 

func (m *Command) XXX_Unmarshal(b []byte) error

type Disconnect 

type Disconnect struct {
	User      string   `protobuf:"bytes,1,opt,name=user,proto3" json:"user"`
	Whitelist []string `protobuf:"bytes,2,rep,name=whitelist,proto3" json:"whitelist"`
	Code      uint32   `protobuf:"varint,3,opt,name=code,proto3" json:"code"`
	Reason    string   `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason"`
	Reconnect bool     `protobuf:"varint,5,opt,name=reconnect,proto3" json:"reconnect"`
}

func NewPopulatedDisconnect 

func NewPopulatedDisconnect(r randyControl, easy bool) *Disconnect

func (*Disconnect) Descriptor 

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

func (*Disconnect) Equal 

func (this *Disconnect) Equal(that interface{}) bool

func (*Disconnect) GetCode added in v0.14.0 

func (m *Disconnect) GetCode() uint32

func (*Disconnect) GetReason added in v0.14.0 

func (m *Disconnect) GetReason() string

func (*Disconnect) GetReconnect added in v0.14.0 

func (m *Disconnect) GetReconnect() bool

func (*Disconnect) GetUser 

func (m *Disconnect) GetUser() string

func (*Disconnect) GetWhitelist added in v0.14.0 

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

func (*Disconnect) Marshal 

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

func (*Disconnect) MarshalTo 

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

func (*Disconnect) MarshalToSizedBuffer added in v0.16.0 

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

func (*Disconnect) ProtoMessage 

func (*Disconnect) ProtoMessage()

func (*Disconnect) Reset 

func (m *Disconnect) Reset()

func (*Disconnect) Size 

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

func (*Disconnect) String 

func (m *Disconnect) String() string

func (*Disconnect) Unmarshal 

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

func (*Disconnect) XXX_DiscardUnknown added in v0.16.0 

func (m *Disconnect) XXX_DiscardUnknown()

func (*Disconnect) XXX_Marshal added in v0.16.0 

func (m *Disconnect) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Disconnect) XXX_Merge added in v0.16.0 

func (m *Disconnect) XXX_Merge(src proto.Message)

func (*Disconnect) XXX_Size added in v0.16.0 

func (m *Disconnect) XXX_Size() int

func (*Disconnect) XXX_Unmarshal added in v0.16.0 

func (m *Disconnect) XXX_Unmarshal(b []byte) error

type MethodType 

type MethodType int32
const (
	MethodTypeNode           MethodType = 0
	MethodTypeUnsubscribe    MethodType = 1
	MethodTypeDisconnect     MethodType = 2
	MethodTypeShutdown       MethodType = 3
	MethodTypeSurveyRequest  MethodType = 4
	MethodTypeSurveyResponse MethodType = 5
	MethodTypeSubscribe      MethodType = 6
	MethodTypeNotification   MethodType = 7
)

func (MethodType) EnumDescriptor 

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

func (MethodType) String 

func (x MethodType) String() string

type Metrics 

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

func NewPopulatedMetrics 

func NewPopulatedMetrics(r randyControl, easy bool) *Metrics

func (*Metrics) Descriptor 

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

func (*Metrics) Equal 

func (this *Metrics) Equal(that interface{}) bool

func (*Metrics) GetInterval 

func (m *Metrics) GetInterval() float64

func (*Metrics) GetItems 

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

func (*Metrics) Marshal 

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

func (*Metrics) MarshalTo 

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

func (*Metrics) MarshalToSizedBuffer added in v0.16.0 

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

func (*Metrics) ProtoMessage 

func (*Metrics) ProtoMessage()

func (*Metrics) Reset 

func (m *Metrics) Reset()

func (*Metrics) Size 

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

func (*Metrics) String 

func (m *Metrics) String() string

func (*Metrics) Unmarshal 

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

func (*Metrics) XXX_DiscardUnknown added in v0.16.0 

func (m *Metrics) XXX_DiscardUnknown()

func (*Metrics) XXX_Marshal added in v0.16.0 

func (m *Metrics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Metrics) XXX_Merge added in v0.16.0 

func (m *Metrics) XXX_Merge(src proto.Message)

func (*Metrics) XXX_Size added in v0.16.0 

func (m *Metrics) XXX_Size() int

func (*Metrics) XXX_Unmarshal added in v0.16.0 

func (m *Metrics) XXX_Unmarshal(b []byte) error

type Node 

type Node 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"`
	Metrics     *Metrics `protobuf:"bytes,8,opt,name=metrics,proto3" json:"metrics"`
}

func NewPopulatedNode 

func NewPopulatedNode(r randyControl, easy bool) *Node

func (*Node) Descriptor 

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

func (*Node) Equal 

func (this *Node) Equal(that interface{}) bool

func (*Node) GetMetrics 

func (m *Node) GetMetrics() *Metrics

func (*Node) GetName 

func (m *Node) GetName() string

func (*Node) GetNumChannels 

func (m *Node) GetNumChannels() uint32

func (*Node) GetNumClients 

func (m *Node) GetNumClients() uint32

func (*Node) GetNumUsers 

func (m *Node) GetNumUsers() uint32

func (*Node) GetUID 

func (m *Node) GetUID() string

func (*Node) GetUptime 

func (m *Node) GetUptime() uint32

func (*Node) GetVersion 

func (m *Node) GetVersion() string

func (*Node) Marshal 

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

func (*Node) MarshalTo 

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

func (*Node) MarshalToSizedBuffer added in v0.16.0 

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

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) Size 

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

func (*Node) String 

func (m *Node) String() string

func (*Node) Unmarshal 

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

func (*Node) XXX_DiscardUnknown added in v0.16.0 

func (m *Node) XXX_DiscardUnknown()

func (*Node) XXX_Marshal added in v0.16.0 

func (m *Node) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Node) XXX_Merge added in v0.16.0 

func (m *Node) XXX_Merge(src proto.Message)

func (*Node) XXX_Size added in v0.16.0 

func (m *Node) XXX_Size() int

func (*Node) XXX_Unmarshal added in v0.16.0 

func (m *Node) XXX_Unmarshal(b []byte) error

type Notification added in v0.17.0 

type Notification struct {
	Op   string `protobuf:"bytes,1,opt,name=op,proto3" json:"op"`
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data"`
}

func NewPopulatedNotification added in v0.17.0 

func NewPopulatedNotification(r randyControl, easy bool) *Notification

func (*Notification) Descriptor added in v0.17.0 

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

func (*Notification) Equal added in v0.17.0 

func (this *Notification) Equal(that interface{}) bool

func (*Notification) GetData added in v0.17.0 

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

func (*Notification) GetOp added in v0.17.0 

func (m *Notification) GetOp() string

func (*Notification) Marshal added in v0.17.0 

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

func (*Notification) MarshalTo added in v0.17.0 

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

func (*Notification) MarshalToSizedBuffer added in v0.17.0 

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

func (*Notification) ProtoMessage added in v0.17.0 

func (*Notification) ProtoMessage()

func (*Notification) Reset added in v0.17.0 

func (m *Notification) Reset()

func (*Notification) Size added in v0.17.0 

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

func (*Notification) String added in v0.17.0 

func (m *Notification) String() string

func (*Notification) Unmarshal added in v0.17.0 

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

func (*Notification) XXX_DiscardUnknown added in v0.17.0 

func (m *Notification) XXX_DiscardUnknown()

func (*Notification) XXX_Marshal added in v0.17.0 

func (m *Notification) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Notification) XXX_Merge added in v0.17.0 

func (m *Notification) XXX_Merge(src proto.Message)

func (*Notification) XXX_Size added in v0.17.0 

func (m *Notification) XXX_Size() int

func (*Notification) XXX_Unmarshal added in v0.17.0 

func (m *Notification) XXX_Unmarshal(b []byte) error

type Raw 

type Raw []byte

Raw type used by Centrifuge protocol as a type for fields in structs which value we want to stay untouched. For example custom application specific JSON payload data in published message. This is very similar to json.RawMessage type but have some extra methods to fit gogo/protobuf custom type interface.

func NewPopulatedRaw 

func NewPopulatedRaw(r intn) *Raw

NewPopulatedRaw required for gogoprotobuf custom type.

func (Raw) Compare 

func (r Raw) Compare(other Raw) int

Compare exists to fit gogo/protobuf custom type interface.

func (Raw) Equal 

func (r Raw) Equal(other Raw) bool

Equal exists to fit gogo/protobuf custom type interface.

func (Raw) Marshal 

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

Marshal encodes Raw to slice of bytes. Exists to fit gogo/protobuf custom type interface.

func (Raw) MarshalJSON 

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

MarshalJSON returns *r as the JSON encoding of r.

func (Raw) MarshalTo 

func (r Raw) MarshalTo(data []byte) (n int, err error)

MarshalTo exists to fit gogo/protobuf custom type interface.

func (*Raw) Size 

func (r *Raw) Size() int

Size exists to fit gogo/protobuf custom type interface.

func (*Raw) Unmarshal 

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

Unmarshal exists to fit gogo/protobuf custom type interface.

func (*Raw) UnmarshalJSON 

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

UnmarshalJSON sets *r to a copy of data.

type Subscribe added in v0.16.0 

type Subscribe struct {
	User        string `protobuf:"bytes,1,opt,name=user,proto3" json:"user"`
	Channel     string `protobuf:"bytes,2,opt,name=channel,proto3" json:"channel"`
	Presence    bool   `protobuf:"varint,3,opt,name=presence,proto3" json:"presence"`
	JoinLeave   bool   `protobuf:"varint,4,opt,name=join_leave,json=joinLeave,proto3" json:"join_leave"`
	ExpireAt    int64  `protobuf:"varint,5,opt,name=expire_at,json=expireAt,proto3" json:"expire_at"`
	Position    bool   `protobuf:"varint,6,opt,name=position,proto3" json:"position"`
	Recover     bool   `protobuf:"varint,7,opt,name=recover,proto3" json:"recover"`
	ChannelInfo Raw    `protobuf:"bytes,8,opt,name=channel_info,json=channelInfo,proto3,customtype=Raw" json:"channel_info"`
	Client      string `protobuf:"bytes,9,opt,name=client,proto3" json:"client"`
	Data        Raw    `protobuf:"bytes,10,opt,name=data,proto3,customtype=Raw" json:"data"`
}

func NewPopulatedSubscribe added in v0.16.0 

func NewPopulatedSubscribe(r randyControl, easy bool) *Subscribe

func (*Subscribe) Descriptor added in v0.16.0 

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

func (*Subscribe) Equal added in v0.16.0 

func (this *Subscribe) Equal(that interface{}) bool

func (*Subscribe) GetChannel added in v0.16.0 

func (m *Subscribe) GetChannel() string

func (*Subscribe) GetClient added in v0.16.0 

func (m *Subscribe) GetClient() string

func (*Subscribe) GetExpireAt added in v0.16.0 

func (m *Subscribe) GetExpireAt() int64

func (*Subscribe) GetJoinLeave added in v0.16.0 

func (m *Subscribe) GetJoinLeave() bool

func (*Subscribe) GetPosition added in v0.16.0 

func (m *Subscribe) GetPosition() bool

func (*Subscribe) GetPresence added in v0.16.0 

func (m *Subscribe) GetPresence() bool

func (*Subscribe) GetRecover added in v0.16.0 

func (m *Subscribe) GetRecover() bool

func (*Subscribe) GetUser added in v0.16.0 

func (m *Subscribe) GetUser() string

func (*Subscribe) Marshal added in v0.16.0 

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

func (*Subscribe) MarshalTo added in v0.16.0 

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

func (*Subscribe) MarshalToSizedBuffer added in v0.16.0 

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

func (*Subscribe) ProtoMessage added in v0.16.0 

func (*Subscribe) ProtoMessage()

func (*Subscribe) Reset added in v0.16.0 

func (m *Subscribe) Reset()

func (*Subscribe) Size added in v0.16.0 

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

func (*Subscribe) String added in v0.16.0 

func (m *Subscribe) String() string

func (*Subscribe) Unmarshal added in v0.16.0 

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

func (*Subscribe) XXX_DiscardUnknown added in v0.16.0 

func (m *Subscribe) XXX_DiscardUnknown()

func (*Subscribe) XXX_Marshal added in v0.16.0 

func (m *Subscribe) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Subscribe) XXX_Merge added in v0.16.0 

func (m *Subscribe) XXX_Merge(src proto.Message)

func (*Subscribe) XXX_Size added in v0.16.0 

func (m *Subscribe) XXX_Size() int

func (*Subscribe) XXX_Unmarshal added in v0.16.0 

func (m *Subscribe) XXX_Unmarshal(b []byte) error

type SurveyRequest added in v0.15.0 

type SurveyRequest struct {
	ID   uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id"`
	Op   string `protobuf:"bytes,2,opt,name=op,proto3" json:"op"`
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data"`
}

func NewPopulatedSurveyRequest added in v0.15.0 

func NewPopulatedSurveyRequest(r randyControl, easy bool) *SurveyRequest

func (*SurveyRequest) Descriptor added in v0.15.0 

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

func (*SurveyRequest) Equal added in v0.15.0 

func (this *SurveyRequest) Equal(that interface{}) bool

func (*SurveyRequest) GetData added in v0.15.0 

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

func (*SurveyRequest) GetID added in v0.15.0 

func (m *SurveyRequest) GetID() uint64

func (*SurveyRequest) GetOp added in v0.15.0 

func (m *SurveyRequest) GetOp() string

func (*SurveyRequest) Marshal added in v0.15.0 

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

func (*SurveyRequest) MarshalTo added in v0.15.0 

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

func (*SurveyRequest) MarshalToSizedBuffer added in v0.16.0 

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

func (*SurveyRequest) ProtoMessage added in v0.15.0 

func (*SurveyRequest) ProtoMessage()

func (*SurveyRequest) Reset added in v0.15.0 

func (m *SurveyRequest) Reset()

func (*SurveyRequest) Size added in v0.15.0 

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

func (*SurveyRequest) String added in v0.15.0 

func (m *SurveyRequest) String() string

func (*SurveyRequest) Unmarshal added in v0.15.0 

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

func (*SurveyRequest) XXX_DiscardUnknown added in v0.16.0 

func (m *SurveyRequest) XXX_DiscardUnknown()

func (*SurveyRequest) XXX_Marshal added in v0.16.0 

func (m *SurveyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SurveyRequest) XXX_Merge added in v0.16.0 

func (m *SurveyRequest) XXX_Merge(src proto.Message)

func (*SurveyRequest) XXX_Size added in v0.16.0 

func (m *SurveyRequest) XXX_Size() int

func (*SurveyRequest) XXX_Unmarshal added in v0.16.0 

func (m *SurveyRequest) XXX_Unmarshal(b []byte) error

type SurveyResponse added in v0.15.0 

type SurveyResponse struct {
	ID   uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id"`
	Code uint32 `protobuf:"varint,3,opt,name=code,proto3" json:"code"`
	Data []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data"`
}

func NewPopulatedSurveyResponse added in v0.15.0 

func NewPopulatedSurveyResponse(r randyControl, easy bool) *SurveyResponse

func (*SurveyResponse) Descriptor added in v0.15.0 

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

func (*SurveyResponse) Equal added in v0.15.0 

func (this *SurveyResponse) Equal(that interface{}) bool

func (*SurveyResponse) GetCode added in v0.15.0 

func (m *SurveyResponse) GetCode() uint32

func (*SurveyResponse) GetData added in v0.15.0 

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

func (*SurveyResponse) GetID added in v0.15.0 

func (m *SurveyResponse) GetID() uint64

func (*SurveyResponse) Marshal added in v0.15.0 

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

func (*SurveyResponse) MarshalTo added in v0.15.0 

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

func (*SurveyResponse) MarshalToSizedBuffer added in v0.16.0 

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

func (*SurveyResponse) ProtoMessage added in v0.15.0 

func (*SurveyResponse) ProtoMessage()

func (*SurveyResponse) Reset added in v0.15.0 

func (m *SurveyResponse) Reset()

func (*SurveyResponse) Size added in v0.15.0 

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

func (*SurveyResponse) String added in v0.15.0 

func (m *SurveyResponse) String() string

func (*SurveyResponse) Unmarshal added in v0.15.0 

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

func (*SurveyResponse) XXX_DiscardUnknown added in v0.16.0 

func (m *SurveyResponse) XXX_DiscardUnknown()

func (*SurveyResponse) XXX_Marshal added in v0.16.0 

func (m *SurveyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SurveyResponse) XXX_Merge added in v0.16.0 

func (m *SurveyResponse) XXX_Merge(src proto.Message)

func (*SurveyResponse) XXX_Size added in v0.16.0 

func (m *SurveyResponse) XXX_Size() int

func (*SurveyResponse) XXX_Unmarshal added in v0.16.0 

func (m *SurveyResponse) XXX_Unmarshal(b []byte) error

type Unsubscribe 

type Unsubscribe struct {
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel"`
	User    string `protobuf:"bytes,2,opt,name=user,proto3" json:"user"`
	Client  string `protobuf:"bytes,3,opt,name=client,proto3" json:"client"`
}

func NewPopulatedUnsubscribe 

func NewPopulatedUnsubscribe(r randyControl, easy bool) *Unsubscribe

func (*Unsubscribe) Descriptor 

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

func (*Unsubscribe) Equal 

func (this *Unsubscribe) Equal(that interface{}) bool

func (*Unsubscribe) GetChannel 

func (m *Unsubscribe) GetChannel() string

func (*Unsubscribe) GetClient added in v0.16.0 

func (m *Unsubscribe) GetClient() string

func (*Unsubscribe) GetUser 

func (m *Unsubscribe) GetUser() string

func (*Unsubscribe) Marshal 

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

func (*Unsubscribe) MarshalTo 

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

func (*Unsubscribe) MarshalToSizedBuffer added in v0.16.0 

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

func (*Unsubscribe) ProtoMessage 

func (*Unsubscribe) ProtoMessage()

func (*Unsubscribe) Reset 

func (m *Unsubscribe) Reset()

func (*Unsubscribe) Size 

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

func (*Unsubscribe) String 

func (m *Unsubscribe) String() string

func (*Unsubscribe) Unmarshal 

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

func (*Unsubscribe) XXX_DiscardUnknown added in v0.16.0 

func (m *Unsubscribe) XXX_DiscardUnknown()

func (*Unsubscribe) XXX_Marshal added in v0.16.0 

func (m *Unsubscribe) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Unsubscribe) XXX_Merge added in v0.16.0 

func (m *Unsubscribe) XXX_Merge(src proto.Message)

func (*Unsubscribe) XXX_Size added in v0.16.0 

func (m *Unsubscribe) XXX_Size() int

func (*Unsubscribe) XXX_Unmarshal added in v0.16.0 

func (m *Unsubscribe) XXX_Unmarshal(b []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.