pb

Documentation

Index

• Variables
• type Message
  • func (*Message) Descriptor() ([]byte, []int)
  • func (m *Message) GetData() []byte
  • func (m *Message) GetMsgType() Message_MsgType
  • func (m *Message) GetTopics() []string
  • func (m *Message) Marshal() (dAtA []byte, err error)
  • func (m *Message) MarshalTo(dAtA []byte) (int, error)
  • func (m *Message) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*Message) ProtoMessage()
  • func (m *Message) Reset()
  • func (m *Message) Size() (n int)
  • func (m *Message) String() string
  • func (m *Message) Unmarshal(dAtA []byte) error
  • func (m *Message) XXX_DiscardUnknown()
  • func (m *Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *Message) XXX_Merge(src proto.Message)
  • func (m *Message) XXX_Size() int
  • func (m *Message) XXX_Unmarshal(b []byte) error
• type Message_MsgType
  • func (Message_MsgType) EnumDescriptor() ([]byte, []int)
  • func (x Message_MsgType) String() string

Variables

var (
	ErrInvalidLengthWires        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowWires          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupWires = fmt.Errorf("proto: unexpected end of group")
)

var Message_MsgType_name = map[int32]string{
	0: "UNKNOWN",
	1: "JOIN",
	2: "LEAVE",
	3: "JOIN_REPLY",
	4: "DATA",
}

var Message_MsgType_value = map[string]int32{
	"UNKNOWN":    0,
	"JOIN":       1,
	"LEAVE":      2,
	"JOIN_REPLY": 3,
	"DATA":       4,
}

Types

type Message

type Message struct {
	MsgType Message_MsgType `protobuf:"varint,1,opt,name=msgType,proto3,enum=pb.Message_MsgType" json:"msgType,omitempty"`
	Topics  []string        `protobuf:"bytes,2,rep,name=topics,proto3" json:"topics,omitempty"`
	Data    []byte          `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
}

func (*Message) Descriptor

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

func (*Message) GetData

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

func (*Message) GetMsgType

func (m *Message) GetMsgType() Message_MsgType

func (*Message) GetTopics

func (m *Message) GetTopics() []string

func (*Message) Marshal

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

func (*Message) MarshalTo

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

func (*Message) MarshalToSizedBuffer

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

func (*Message) ProtoMessage

func (*Message) ProtoMessage()

func (*Message) Reset

func (m *Message) Reset()

func (*Message) Size

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

func (*Message) String

func (m *Message) String() string

func (*Message) Unmarshal

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

func (*Message) XXX_DiscardUnknown

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal

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

func (*Message) XXX_Merge

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

func (*Message) XXX_Size

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal

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

type Message_MsgType

type Message_MsgType int32

const (
	Message_UNKNOWN    Message_MsgType = 0
	Message_JOIN       Message_MsgType = 1
	Message_LEAVE      Message_MsgType = 2
	Message_JOIN_REPLY Message_MsgType = 3
	Message_DATA       Message_MsgType = 4
)

func (Message_MsgType) EnumDescriptor

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

func (Message_MsgType) String

func (x Message_MsgType) String() string