controlproto

package
v0.2.0 Latest Latest
Warning

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

 Go to latest Published: Sep 20, 2019 License: MIT Imports: 7 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
Metrics
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"`
	Method MethodType                                           `protobuf:"varint,2,opt,name=method,proto3,enum=controlproto.MethodType" json:"method"`
	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"`
}

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 Metrics 

type Metrics struct {
	Interval float64            `protobuf:"fixed64,1,opt,name=interval,proto3" json:"interval"`
	Items    map[string]float64 `` /* 136-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) 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

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" 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) 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"`
	User    string `protobuf:"bytes,2,opt,name=user,proto3" json:"user"`
}

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.