protostream

Documentation

Index

• func DecodeVarint(b []byte) (uint64, int)
• func EncodeVarint(v uint64) []byte
• type ProtoStream
  • func NewProtoStream(rw ReaderWriter) *ProtoStream
  • func (p *ProtoStream) Recv(m proto.Message) error
  • func (p *ProtoStream) Send(m proto.Message) error
• type ReaderWriter

Functions

func DecodeVarint

func DecodeVarint(b []byte) (uint64, int)

func EncodeVarint

func EncodeVarint(v uint64) []byte

Types

type ProtoStream

type ProtoStream struct {
	// contains filtered or unexported fields
}

func NewProtoStream

func NewProtoStream(rw ReaderWriter) *ProtoStream

func (*ProtoStream) Recv

func (p *ProtoStream) Recv(m proto.Message) error

func (*ProtoStream) Send

func (p *ProtoStream) Send(m proto.Message) error

type ReaderWriter

type ReaderWriter interface {
	io.Reader
	io.Writer
}