iohelper

Documentation

Index

• func ReadInt32(r io.Reader) (int32, error)
• func ReadN(r io.Reader, n int32) ([]byte, error)
• func ReadUint64(r io.Reader) (uint64, error)
• func ReadVarBytes(r ByteMultiReader) ([]byte, error)
• func WriteVarBytes(w io.Writer, b []byte) error
• type ByteMultiReader
• type PbBuffer
  • func NewPbBuffer() *PbBuffer
  • func (b *PbBuffer) Bytes() []byte
  • func (b *PbBuffer) PrependSize() error
  • func (b *PbBuffer) Write(d []byte) (int, error)
  • func (b *PbBuffer) WriteByte(d byte) error
  • func (b *PbBuffer) WriteDelimitedBuffers(bufs ...*PbBuffer) error
  • func (b *PbBuffer) WriteFloat32(d float32) error
  • func (b *PbBuffer) WriteFloat64(d float64) error
  • func (b *PbBuffer) WriteInt32(d int32) error
  • func (b *PbBuffer) WriteInt64(d int64) error
  • func (b *PbBuffer) WritePBMessage(d pb.Message) error
  • func (b *PbBuffer) WriteString(d string) error

Functions

func ReadInt32

func ReadInt32(r io.Reader) (int32, error)

func ReadN

func ReadN(r io.Reader, n int32) ([]byte, error)

func ReadUint64

func ReadUint64(r io.Reader) (uint64, error)

func ReadVarBytes

func ReadVarBytes(r ByteMultiReader) ([]byte, error)

func WriteVarBytes

func WriteVarBytes(w io.Writer, b []byte) error

Types

type ByteMultiReader

type ByteMultiReader interface {
	io.ByteReader
	io.Reader
}

type PbBuffer

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

func NewPbBuffer

func NewPbBuffer() *PbBuffer

func (*PbBuffer) Bytes

func (b *PbBuffer) Bytes() []byte

func (*PbBuffer) PrependSize

func (b *PbBuffer) PrependSize() error

func (*PbBuffer) Write

func (b *PbBuffer) Write(d []byte) (int, error)

func (*PbBuffer) WriteByte

func (b *PbBuffer) WriteByte(d byte) error

func (*PbBuffer) WriteDelimitedBuffers

func (b *PbBuffer) WriteDelimitedBuffers(bufs ...*PbBuffer) error

func (*PbBuffer) WriteFloat32

func (b *PbBuffer) WriteFloat32(d float32) error

func (*PbBuffer) WriteFloat64

func (b *PbBuffer) WriteFloat64(d float64) error

func (*PbBuffer) WriteInt32

func (b *PbBuffer) WriteInt32(d int32) error

func (*PbBuffer) WriteInt64

func (b *PbBuffer) WriteInt64(d int64) error

func (*PbBuffer) WritePBMessage

func (b *PbBuffer) WritePBMessage(d pb.Message) error

func (*PbBuffer) WriteString

func (b *PbBuffer) WriteString(d string) error