recordioiov

Documentation

Overview

Package recordioiov provides utility functions for dealing with [][]bytes, used by recordio transformers.

Index

• func Slice(buf []byte, size int) []byte
• func TotalBytes(buf [][]byte) int
• type IOVecReader
  • func NewIOVecReader(buf [][]byte) IOVecReader
  • func (r *IOVecReader) Read(p []byte) (int, error)
  • func (r *IOVecReader) ReadByte() (byte, error)

Functions

func Slice

func Slice(buf []byte, size int) []byte

Slice returns a byte slice of the given size. If cap(buf)>=size, then it returns buf[:size]. Else it allocates a new slice on heap.

func TotalBytes

func TotalBytes(buf [][]byte) int

TotalBytes returns the total size of the iovec.

Types

type IOVecReader

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

IOVecReader is an io.Reader adapter for [][]byte.

func NewIOVecReader

func NewIOVecReader(buf [][]byte) IOVecReader

NewIOVecReader creates a new io.Reader that reads from the given buf.

func (*IOVecReader) Read

func (r *IOVecReader) Read(p []byte) (int, error)

Read implements the io.Reader interface.

func (*IOVecReader) ReadByte

func (r *IOVecReader) ReadByte() (byte, error)

ReadByte reads one byte from the reader. On EOF, returns (0, io.EOF).