protos

Documentation

Overview

Package protos is a generated protocol buffer package.

It is generated from these files:

cluster.proto

It has these top-level messages:

Response
UserMessage
NewUser
RPCMsg
AllMembers

Index

• Variables
• type AllMembers
  • func (*AllMembers) Descriptor() ([]byte, []int)
  • func (m *AllMembers) GetMembers() []string
  • func (m *AllMembers) Marshal() (dAtA []byte, err error)
  • func (m *AllMembers) MarshalTo(dAtA []byte) (int, error)
  • func (*AllMembers) ProtoMessage()
  • func (m *AllMembers) Reset()
  • func (m *AllMembers) Size() (n int)
  • func (m *AllMembers) String() string
  • func (m *AllMembers) Unmarshal(dAtA []byte) error
• type NewUser
  • func (*NewUser) Descriptor() ([]byte, []int)
  • func (m *NewUser) GetContent() string
  • func (m *NewUser) Marshal() (dAtA []byte, err error)
  • func (m *NewUser) MarshalTo(dAtA []byte) (int, error)
  • func (*NewUser) ProtoMessage()
  • func (m *NewUser) Reset()
  • func (m *NewUser) Size() (n int)
  • func (m *NewUser) String() string
  • func (m *NewUser) Unmarshal(dAtA []byte) error
• type RPCMsg
  • func (*RPCMsg) Descriptor() ([]byte, []int)
  • func (m *RPCMsg) GetMsg() string
  • func (m *RPCMsg) GetRoute() string
  • func (m *RPCMsg) Marshal() (dAtA []byte, err error)
  • func (m *RPCMsg) MarshalTo(dAtA []byte) (int, error)
  • func (*RPCMsg) ProtoMessage()
  • func (m *RPCMsg) Reset()
  • func (m *RPCMsg) Size() (n int)
  • func (m *RPCMsg) String() string
  • func (m *RPCMsg) Unmarshal(dAtA []byte) error
• type Response
  • func (*Response) Descriptor() ([]byte, []int)
  • func (m *Response) GetCode() int32
  • func (m *Response) GetMsg() string
  • func (m *Response) Marshal() (dAtA []byte, err error)
  • func (m *Response) MarshalTo(dAtA []byte) (int, error)
  • func (*Response) ProtoMessage()
  • func (m *Response) Reset()
  • func (m *Response) Size() (n int)
  • func (m *Response) String() string
  • func (m *Response) Unmarshal(dAtA []byte) error
• type UserMessage
  • func (*UserMessage) Descriptor() ([]byte, []int)
  • func (m *UserMessage) GetContent() string
  • func (m *UserMessage) GetName() string
  • func (m *UserMessage) Marshal() (dAtA []byte, err error)
  • func (m *UserMessage) MarshalTo(dAtA []byte) (int, error)
  • func (*UserMessage) ProtoMessage()
  • func (m *UserMessage) Reset()
  • func (m *UserMessage) Size() (n int)
  • func (m *UserMessage) String() string
  • func (m *UserMessage) Unmarshal(dAtA []byte) error

Variables

var (
	ErrInvalidLengthCluster = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCluster   = fmt.Errorf("proto: integer overflow")
)

Types

type AllMembers

type AllMembers struct {
	Members []string `protobuf:"bytes,1,rep,name=Members" json:"Members,omitempty"`
}

AllMembers contains all members uid

func (*AllMembers) Descriptor

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

func (*AllMembers) GetMembers

func (m *AllMembers) GetMembers() []string

func (*AllMembers) Marshal

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

func (*AllMembers) MarshalTo

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

func (*AllMembers) ProtoMessage

func (*AllMembers) ProtoMessage()

func (*AllMembers) Reset

func (m *AllMembers) Reset()

func (*AllMembers) Size

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

func (*AllMembers) String

func (m *AllMembers) String() string

func (*AllMembers) Unmarshal

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

type NewUser

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

NewUser message will be received when new user join room

func (*NewUser) Descriptor

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

func (*NewUser) GetContent

func (m *NewUser) GetContent() string

func (*NewUser) Marshal

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

func (*NewUser) MarshalTo

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

func (*NewUser) ProtoMessage

func (*NewUser) ProtoMessage()

func (*NewUser) Reset

func (m *NewUser) Reset()

func (*NewUser) Size

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

func (*NewUser) String

func (m *NewUser) String() string

func (*NewUser) Unmarshal

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

type RPCMsg

type RPCMsg struct {
	Route string `protobuf:"bytes,1,opt,name=Route,proto3" json:"Route,omitempty"`
	Msg   string `protobuf:"bytes,2,opt,name=Msg,proto3" json:"Msg,omitempty"`
}

func (*RPCMsg) Descriptor

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

func (*RPCMsg) GetMsg

func (m *RPCMsg) GetMsg() string

func (*RPCMsg) GetRoute

func (m *RPCMsg) GetRoute() string

func (*RPCMsg) Marshal

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

func (*RPCMsg) MarshalTo

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

func (*RPCMsg) ProtoMessage

func (*RPCMsg) ProtoMessage()

func (*RPCMsg) Reset

func (m *RPCMsg) Reset()

func (*RPCMsg) Size

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

func (*RPCMsg) String

func (m *RPCMsg) String() string

func (*RPCMsg) Unmarshal

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

type Response

type Response struct {
	Code int32  `protobuf:"varint,1,opt,name=Code,proto3" json:"Code,omitempty"`
	Msg  string `protobuf:"bytes,2,opt,name=Msg,proto3" json:"Msg,omitempty"`
}

Response represents a rpc message

func (*Response) Descriptor

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

func (*Response) GetCode

func (m *Response) GetCode() int32

func (*Response) GetMsg

func (m *Response) GetMsg() string

func (*Response) Marshal

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

func (*Response) MarshalTo

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

func (*Response) ProtoMessage

func (*Response) ProtoMessage()

func (*Response) Reset

func (m *Response) Reset()

func (*Response) Size

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

func (*Response) String

func (m *Response) String() string

func (*Response) Unmarshal

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

type UserMessage

type UserMessage struct {
	Name    string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Content string `protobuf:"bytes,2,opt,name=Content,proto3" json:"Content,omitempty"`
}

UserMessage represents a message that user sent

func (*UserMessage) Descriptor

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

func (*UserMessage) GetContent

func (m *UserMessage) GetContent() string

func (*UserMessage) GetName

func (m *UserMessage) GetName() string

func (*UserMessage) Marshal

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

func (*UserMessage) MarshalTo

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

func (*UserMessage) ProtoMessage

func (*UserMessage) ProtoMessage()

func (*UserMessage) Reset

func (m *UserMessage) Reset()

func (*UserMessage) Size

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

func (*UserMessage) String

func (m *UserMessage) String() string

func (*UserMessage) Unmarshal

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