protorpc

package

v0.23.0 Latest Latest Go to latest Published: Jan 29, 2019 License: Apache-2.0 Imports: 10 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/go-micro/go-micro

Links

Open Source Insights

Documentation ¶

Overview ¶

Package proto is a generated protocol buffer package.

It is generated from these files:

envelope.proto

It has these top-level messages:

Request
Response

Protorpc provides a net/rpc proto-rpc codec. See envelope.proto for the format.

Index ¶

func NewCodec(rwc io.ReadWriteCloser) codec.Codec
func ReadNetString(r io.Reader) (data []byte, err error)
func WriteNetString(w io.Writer, data []byte) (written int, err error)
type Request
type Response

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewCodec ¶

func NewCodec(rwc io.ReadWriteCloser) codec.Codec

func ReadNetString ¶

func ReadNetString(r io.Reader) (data []byte, err error)

ReadNetString reads data from a big-endian netstring.

func WriteNetString ¶

func WriteNetString(w io.Writer, data []byte) (written int, err error)

WriteNetString writes data to a big-endian netstring on a Writer. Size is always a 32-bit unsigned int.

Types ¶

type Request ¶

type Request struct {
	ServiceMethod    *string `protobuf:"bytes,1,opt,name=service_method" json:"service_method,omitempty"`
	Seq              *uint64 `protobuf:"fixed64,2,opt,name=seq" json:"seq,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Request) GetSeq ¶

func (m *Request) GetSeq() uint64

func (*Request) GetServiceMethod ¶

func (m *Request) GetServiceMethod() string

func (*Request) ProtoMessage ¶

func (*Request) ProtoMessage()

func (*Request) Reset ¶

func (m *Request) Reset()

func (*Request) String ¶

func (m *Request) String() string

type Response ¶

type Response struct {
	ServiceMethod    *string `protobuf:"bytes,1,opt,name=service_method" json:"service_method,omitempty"`
	Seq              *uint64 `protobuf:"fixed64,2,opt,name=seq" json:"seq,omitempty"`
	Error            *string `protobuf:"bytes,3,opt,name=error" json:"error,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Response) GetError ¶

func (m *Response) GetError() string

func (*Response) GetSeq ¶

func (m *Response) GetSeq() uint64

func (*Response) GetServiceMethod ¶

func (m *Response) GetServiceMethod() string

func (*Response) ProtoMessage ¶

func (*Response) ProtoMessage()

func (*Response) Reset ¶

func (m *Response) Reset()

func (*Response) String ¶

func (m *Response) String() string

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
client
mock module
rpc module
cmd module
codec module
bytes module
grpc module
json module
jsonrpc module
proto module
protorpc module
errors module
metadata module
registry module
consul module
gossip module
mdns module
memory module
selector module
dns module
registry module
static module
server module
debug module
debug/proto module
mock module
rpc module
transport module
http module
memory module

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL