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:

RPCMsg
RPCRes

Index

• Variables
• type RPCMsg
  • func (*RPCMsg) Descriptor() ([]byte, []int)
  • func (m *RPCMsg) GetMsg() 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 RPCRes
  • func (*RPCRes) Descriptor() ([]byte, []int)
  • func (m *RPCRes) GetMsg() string
  • func (m *RPCRes) Marshal() (dAtA []byte, err error)
  • func (m *RPCRes) MarshalTo(dAtA []byte) (int, error)
  • func (*RPCRes) ProtoMessage()
  • func (m *RPCRes) Reset()
  • func (m *RPCRes) Size() (n int)
  • func (m *RPCRes) String() string
  • func (m *RPCRes) Unmarshal(dAtA []byte) error

Variables

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

Types

type RPCMsg

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

RPCMsg message to be sent using rpc

func (*RPCMsg) Descriptor

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

func (*RPCMsg) GetMsg

func (m *RPCMsg) GetMsg() 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 RPCRes

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

RPCRes is the rpc response

func (*RPCRes) Descriptor

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

func (*RPCRes) GetMsg

func (m *RPCRes) GetMsg() string

func (*RPCRes) Marshal

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

func (*RPCRes) MarshalTo

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

func (*RPCRes) ProtoMessage

func (*RPCRes) ProtoMessage()

func (*RPCRes) Reset

func (m *RPCRes) Reset()

func (*RPCRes) Size

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

func (*RPCRes) String

func (m *RPCRes) String() string

func (*RPCRes) Unmarshal

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