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

    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