internal

Dec 18, 2020

Changes in this version

+ func Copy(src, dst string, exclude []string) error

+ func LoadFromJsonFile(path string, v interface{}) error

+ func SaveJsonToFile(v interface{}, path string, mode os.FileMode) error

Sep 2, 2019

Changes in this version

+ const FileIDSize

+ const Int32Size

+ const Int64Size

+ const KeySize

+ const OffsetSize

+ const SizeSize

+ const ValueSize

+ func DecodeWithoutPrefix(buf []byte, valueOffset uint64, v *Entry)

+ func GetKeyValueSizes(buf []byte) (uint64, uint64)

+ func ReadBytes(r io.Reader) ([]byte, error)

+ func ReadIndex(r io.Reader, t art.Tree) error

+ func WriteBytes(b []byte, w io.Writer) (int, error)

+ func WriteIndex(t art.Tree, w io.Writer) (err error)

+ func WriteItem(item Item, w io.Writer) (int, error)

+ type Decoder struct

+ func NewDecoder(r io.Reader) *Decoder

+ func (d *Decoder) Decode(v *Entry) (int64, error)

+ type Encoder struct

+ func NewEncoder(w io.Writer) *Encoder

+ func (e *Encoder) Encode(msg Entry) (int64, error)

+ type Entry struct

+ Checksum uint32

+ Key []byte

+ Offset int64

+ Value []byte

type Item

+ func ReadItem(r io.Reader) (Item, error)

Aug 4, 2019

Changes in this version

+ func ConfigureMemPool(maxConcurrency *int)

Jul 26, 2019

Changes in this version

+ func DirSize(path string) (int64, error)

+ func Exists(path string) bool

type Keydir

+ func (k *Keydir) Load(fn string) error

Mar 23, 2019

Changes in this version

+ var ErrReadError = errors.New("error: read error")

type Item

+ Size int64

Mar 21, 2019

Changes in this version

+ const DefaultDatafileFilename

+ var Commit = "HEAD"

+ var ErrReadonly = errors.New("error: read only datafile")

+ var Version = "0.0.1"

+ func FullVersion() string

+ func GetDatafiles(path string) ([]string, error)

+ func NewEntry(key string, value []byte) pb.Entry

+ func ParseIds(fns []string) ([]int, error)

+ type Datafile struct

+ func NewDatafile(path string, id int, readonly bool) (*Datafile, error)

+ func (df *Datafile) Close() error

+ func (df *Datafile) FileID() int

+ func (df *Datafile) Name() string

+ func (df *Datafile) Read() (e pb.Entry, err error)

+ func (df *Datafile) ReadAt(index int64) (e pb.Entry, err error)

+ func (df *Datafile) Size() (int64, error)

+ func (df *Datafile) Sync() error

+ func (df *Datafile) Write(e pb.Entry) (int64, error)

+ type Item struct

+ FileID int

+ Offset int64

+ type Keydir struct

+ func NewKeydir() *Keydir

+ func NewKeydirFromBytes(r io.Reader) (*Keydir, error)

+ func (k *Keydir) Add(key string, fileid int, offset int64) Item

+ func (k *Keydir) Bytes() ([]byte, error)

+ func (k *Keydir) Delete(key string)

+ func (k *Keydir) Get(key string) (Item, bool)

+ func (k *Keydir) Keys() chan string

+ func (k *Keydir) Len() int

+ func (k *Keydir) Save(fn string) error