goridge

May 22, 2020

Changes in this version

+ func MemAvail() uint64 — linux/amd64

Apr 21, 2020

Changes in this version

type Codec

+ func NewCodecWithRelay(relay Relay) *Codec

Mar 23, 2020

Changes in this version

+ const BufferSize

+ const PayloadControl

+ const PayloadEmpty

+ const PayloadError

+ const PayloadRaw

+ const Uint64Size

+ type ClientCodec struct

+ func NewClientCodec(rwc io.ReadWriteCloser) *ClientCodec

+ func (c *ClientCodec) Close() error

+ func (c *ClientCodec) ReadResponseBody(out interface{}) error

+ func (c *ClientCodec) ReadResponseHeader(r *rpc.Response) error

+ func (c *ClientCodec) WriteRequest(r *rpc.Request, body interface{}) error

+ type Codec struct

+ func NewCodec(rwc io.ReadWriteCloser) *Codec

+ func (c *Codec) Close() error

+ func (c *Codec) ReadRequestBody(out interface{}) error

+ func (c *Codec) ReadRequestHeader(r *rpc.Request) error

+ func (c *Codec) WriteResponse(r *rpc.Response, body interface{}) error

+ type PipeRelay struct

+ BufferSize uint64

+ func NewPipeRelay(in io.ReadCloser, out io.WriteCloser) *PipeRelay

+ func (rl *PipeRelay) Close() error

+ func (rl *PipeRelay) Receive() (data []byte, p Prefix, err error)

+ func (rl *PipeRelay) Send(data []byte, flags byte) (err error)

+ type Prefix [17]byte

+ func NewPrefix() Prefix

+ func (p Prefix) Flags() byte

+ func (p Prefix) HasFlag(flag byte) bool

+ func (p Prefix) HasPayload() bool

+ func (p Prefix) Size() uint64

+ func (p Prefix) String() string

+ func (p Prefix) Valid() bool

+ func (p Prefix) WithFlag(flag byte) Prefix

+ func (p Prefix) WithFlags(flags byte) Prefix

+ func (p Prefix) WithSize(size uint64) Prefix

+ type Relay interface

+ Close func() error

+ Receive func() (data []byte, p Prefix, err error)

+ Send func(data []byte, flags byte) (err error)

+ type SocketRelay struct

+ BufferSize uint64

+ func NewSocketRelay(rwc io.ReadWriteCloser) *SocketRelay

+ func (rl *SocketRelay) Close() error

+ func (rl *SocketRelay) Receive() (data []byte, p Prefix, err error)

+ func (rl *SocketRelay) Send(data []byte, flags byte) (err error)