aq

Documentation

Index

• Variables
• type DB
  • func New(filename string, size int) (*DB, error)
  • func (db *DB) Close() error
  • func (db *DB) Flush() error
  • func (db *DB) Iterate() Iterator
  • func (db *DB) Read(hdr Header) ([]byte, error)
  • func (db *DB) Write(data []byte) (Header, error)
• type Header
• type Iterator
  • func (it *Iterator) Bytes() []byte
  • func (it *Iterator) Next() bool

Variables

var (
	InvalidHeader   = Header{Off: -1, Len: -1}
	ErrFull         = errors.New("database is full")
	ErrInvalidValue = errors.New("empty value is not allowed")
)

Types

type DB

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

func New

func New(filename string, size int) (*DB, error)

func (*DB) Close

func (db *DB) Close() error

func (*DB) Flush

func (db *DB) Flush() error

func (*DB) Iterate

func (db *DB) Iterate() Iterator

func (*DB) Read

func (db *DB) Read(hdr Header) ([]byte, error)

func (*DB) Write

func (db *DB) Write(data []byte) (Header, error)

type Header

type Header struct {
	Off int32
	Len int32
}

type Iterator

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

func (*Iterator) Bytes

func (it *Iterator) Bytes() []byte

func (*Iterator) Next

func (it *Iterator) Next() bool