rio

Aug 23, 2018

Changes in this version

+ const MetaRecord

+ var Endian = binary.LittleEndian

+ func RegisterCompressor(kind CompressorKind, x Xpressor)

+ type Block struct

+ func (blk *Block) Name() string

+ func (blk *Block) Read(data interface{}) error

+ func (blk *Block) RioVersion() Version

+ func (blk *Block) Write(data interface{}) error

+ type BlockDesc struct

+ Name string

+ Type string

+ type Compressor interface

+ Flush func() error

+ Reset func(w io.Writer) error

+ type CompressorKind uint16

+ const CompressDefault

+ const CompressFlate

+ const CompressGzip

+ const CompressLZA

+ const CompressLZO

+ const CompressNone

+ const CompressSnappy

+ const CompressUser

+ const CompressZlib

+ func (ck CompressorKind) NewCompressor(w io.Writer, opts Options) (Compressor, error)

+ func (ck CompressorKind) NewDecompressor(r io.Reader) (Decompressor, error)

+ func (ck CompressorKind) String() string

+ type Decompressor interface

+ Reset func(r io.Reader) error

+ type File struct

+ func Open(r io.ReadSeeker) (*File, error)

+ func (f *File) Close() error

+ func (f *File) Get(name string, ptr interface{}) error

+ func (f *File) Has(name string) bool

+ func (f *File) Keys() []RecordDesc

+ type Marshaler interface

+ RioMarshal func(w io.Writer) error

+ type Metadata struct

+ Offsets map[string][]Span

+ Records []RecordDesc

+ type Options uint32

+ func NewOptions(compr CompressorKind, lvl int, codec int) Options

+ func (o Options) CompressorCodec() int

+ func (o Options) CompressorKind() CompressorKind

+ func (o Options) CompressorLevel() int

+ type Reader struct

+ func NewReader(r io.Reader) (*Reader, error)

+ func (r *Reader) Close() error

+ func (r *Reader) Record(name string) *Record

+ func (r *Reader) Records() []*Record

+ type Record struct

+ func (rec *Record) Block(name string) *Block

+ func (rec *Record) Compress() bool

+ func (rec *Record) Connect(name string, ptr interface{}) error

+ func (rec *Record) Name() string

+ func (rec *Record) Options() Options

+ func (rec *Record) Read() error

+ func (rec *Record) SetUnpack(unpack bool)

+ func (rec *Record) Unpack() bool

+ func (rec *Record) Write() error

+ type RecordDesc struct

+ Blocks []BlockDesc

+ Name string

+ type Scanner struct

+ func NewScanner(r *Reader) *Scanner

+ func (s *Scanner) Err() error

+ func (s *Scanner) Record() *Record

+ func (s *Scanner) Scan() bool

+ func (s *Scanner) Select(selectors []Selector)

+ type Selector struct

+ Name string

+ Unpack bool

+ type Span struct

+ Len int64

+ Pos int64

+ type Streamer interface

+ RioVersion func() Version

+ type Unmarshaler interface

+ RioUnmarshal func(r io.Reader) error

+ type Version uint32

+ type Writer struct

+ func NewWriter(w io.Writer) (*Writer, error)

+ func (w *Writer) Close() error

+ func (w *Writer) Record(name string) *Record

+ func (w *Writer) SetCompressor(compr CompressorKind, lvl int) error

+ func (w *Writer) WriteValue(name string, value interface{}) error

+ type Xpressor interface

+ Deflate func(w io.Writer, opts Options) (Compressor, error)

+ Inflate func(r io.Reader) (Decompressor, error)