controlproto

package
v0.0.0-...-b165c23 Latest Latest
Warning

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

 Go to latest Published: Nov 16, 2018 License: MIT Imports: 6 Imported by: 0

Documentation

Overview

Package controlproto is a generated protocol buffer package.

It is generated from these files: 

control.proto

It has these top-level messages: 

Command
Node
Unsubscribe
Disconnect

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")
)
View Source 
var MethodType_name = map[int32]string{
	0: "NODE",
	1: "UNSUBSCRIBE",
	2: "DISCONNECT",
}
View Source 
var MethodType_value = map[string]int32{
	"NODE":        0,
	"UNSUBSCRIBE": 1,
	"DISCONNECT":  2,
}

Functions

This section is empty.

Types

type Command 

type Command struct {
	UID    string                                               `protobuf:"bytes,1,opt,name=UID,proto3" json:"UID,omitempty"`
	Method MethodType                                           `protobuf:"varint,2,opt,name=Method,proto3,enum=controlproto.MethodType" json:"Method,omitempty"`
	Params github_com_centrifugal_centrifuge_internal_proto.Raw `protobuf:"bytes,3,opt,name=Params,proto3,customtype=github.com/centrifugal/centrifuge/internal/proto.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) 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

type Decoder 

type Decoder interface {
	DecodeCommand([]byte) (*Command, error)
	DecodeNode([]byte) (*Node, error)
	DecodeUnsubscribe([]byte) (*Unsubscribe, error)
	DecodeDisconnect([]byte) (*Disconnect, error)
}

Decoder ...

type Disconnect 

type Disconnect struct {
	User string `protobuf:"bytes,1,opt,name=User,proto3" json:"User,omitempty"`
}

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) GetUser 

func (m *Disconnect) GetUser() 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) 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

type Encoder 

type Encoder interface {
	EncodeCommand(*Command) ([]byte, error)
	EncodeNode(*Node) ([]byte, error)
	EncodeUnsubscribe(*Unsubscribe) ([]byte, error)
	EncodeDisconnect(*Disconnect) ([]byte, error)
}

Encoder ...

type MethodType 

type MethodType int32
const (
	MethodTypeNode        MethodType = 0
	MethodTypeUnsubscribe MethodType = 1
	MethodTypeDisconnect  MethodType = 2
)

func (MethodType) EnumDescriptor 

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

func (MethodType) String 

func (x MethodType) String() string

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=NumClients,proto3" json:"NumClients,omitempty"`
	NumUsers    uint32 `protobuf:"varint,5,opt,name=NumUsers,proto3" json:"NumUsers,omitempty"`
	NumChannels uint32 `protobuf:"varint,6,opt,name=NumChannels,proto3" json:"NumChannels,omitempty"`
	Uptime      uint32 `protobuf:"varint,7,opt,name=Uptime,proto3" json:"Uptime,omitempty"`
}

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) 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) 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

type ProtobufDecoder 

type ProtobufDecoder struct {
}

ProtobufDecoder ...

func NewProtobufDecoder 

func NewProtobufDecoder() *ProtobufDecoder

NewProtobufDecoder ...

func (*ProtobufDecoder) DecodeCommand 

func (e *ProtobufDecoder) DecodeCommand(data []byte) (*Command, error)

DecodeCommand ...

func (*ProtobufDecoder) DecodeDisconnect 

func (e *ProtobufDecoder) DecodeDisconnect(data []byte) (*Disconnect, error)

DecodeDisconnect ...

func (*ProtobufDecoder) DecodeNode 

func (e *ProtobufDecoder) DecodeNode(data []byte) (*Node, error)

DecodeNode ...

func (*ProtobufDecoder) DecodeUnsubscribe 

func (e *ProtobufDecoder) DecodeUnsubscribe(data []byte) (*Unsubscribe, error)

DecodeUnsubscribe ...

type ProtobufEncoder 

type ProtobufEncoder struct {
}

ProtobufEncoder ...

func NewProtobufEncoder 

func NewProtobufEncoder() *ProtobufEncoder

NewProtobufEncoder ...

func (*ProtobufEncoder) EncodeCommand 

func (e *ProtobufEncoder) EncodeCommand(cmd *Command) ([]byte, error)

EncodeCommand ...

func (*ProtobufEncoder) EncodeDisconnect 

func (e *ProtobufEncoder) EncodeDisconnect(cmd *Disconnect) ([]byte, error)

EncodeDisconnect ...

func (*ProtobufEncoder) EncodeNode 

func (e *ProtobufEncoder) EncodeNode(cmd *Node) ([]byte, error)

EncodeNode ...

func (*ProtobufEncoder) EncodeUnsubscribe 

func (e *ProtobufEncoder) EncodeUnsubscribe(cmd *Unsubscribe) ([]byte, error)

EncodeUnsubscribe ...

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"`
}

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) 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) 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

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.