mdbx

Documentation

Overview

Copyright © 2022 uscan team

This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; either version 2 of the License, or (at your option) any later version.

This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.

You should have received a copy of the GNU General Public License along with this program. If not, see <http://www.gnu.org/licenses/>.

Copyright © 2022 uscan team

This program is free software; you can redistribute it and/or modify it under the terms of the GNU General Public License as published by the Free Software Foundation; either version 2 of the License, or (at your option) any later version.

This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for more details.

You should have received a copy of the GNU General Public License along with this program. If not, see <http://www.gnu.org/licenses/>.

Index

• type MdbxDB
  • func NewMdbx(path string, schemas []string, schemasSort []string) *MdbxDB
  • func (d *MdbxDB) BeginTx(ctx context.Context) (context.Context, error)
  • func (d *MdbxDB) Close() error
  • func (d *MdbxDB) Commit(ctx context.Context)
  • func (d *MdbxDB) Del(ctx context.Context, key []byte, opts *kv.WriteOption) (err error)
  • func (d *MdbxDB) Get(ctx context.Context, key []byte, opts *kv.ReadOption) (rs []byte, err error)
  • func (d *MdbxDB) Has(ctx context.Context, key []byte, opts *kv.ReadOption) (rs bool, err error)
  • func (d *MdbxDB) Put(ctx context.Context, key []byte, val []byte, opts *kv.WriteOption) error
  • func (d *MdbxDB) RollBack(ctx context.Context)
  • func (d *MdbxDB) SCount(ctx context.Context, key []byte, opts *kv.ReadOption) (count uint64, err error)
  • func (d *MdbxDB) SDel(ctx context.Context, key, val []byte, opts *kv.WriteOption) (err error)
  • func (d *MdbxDB) SGet(ctx context.Context, key []byte, offset, limit uint64, opts *kv.ReadOption) (rs [][]byte, err error)
  • func (d *MdbxDB) SPut(ctx context.Context, key []byte, val []byte, opts *kv.WriteOption) error

Types

type MdbxDB

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

func NewMdbx

func NewMdbx(path string, schemas []string, schemasSort []string) *MdbxDB

func (*MdbxDB) BeginTx

func (d *MdbxDB) BeginTx(ctx context.Context) (context.Context, error)

func (*MdbxDB) Close

func (d *MdbxDB) Close() error

func (*MdbxDB) Commit

func (d *MdbxDB) Commit(ctx context.Context)

func (*MdbxDB) Del

func (d *MdbxDB) Del(ctx context.Context, key []byte, opts *kv.WriteOption) (err error)

func (*MdbxDB) Get

func (d *MdbxDB) Get(ctx context.Context, key []byte, opts *kv.ReadOption) (rs []byte, err error)

func (*MdbxDB) Has

func (d *MdbxDB) Has(ctx context.Context, key []byte, opts *kv.ReadOption) (rs bool, err error)

func (*MdbxDB) Put

func (d *MdbxDB) Put(ctx context.Context, key []byte, val []byte, opts *kv.WriteOption) error

func (*MdbxDB) RollBack

func (d *MdbxDB) RollBack(ctx context.Context)

func (*MdbxDB) SCount

func (d *MdbxDB) SCount(ctx context.Context, key []byte, opts *kv.ReadOption) (count uint64, err error)

func (*MdbxDB) SDel

func (d *MdbxDB) SDel(ctx context.Context, key, val []byte, opts *kv.WriteOption) (err error)

func (*MdbxDB) SGet

func (d *MdbxDB) SGet(ctx context.Context, key []byte, offset, limit uint64, opts *kv.ReadOption) (rs [][]byte, err error)

func (*MdbxDB) SPut

func (d *MdbxDB) SPut(ctx context.Context, key []byte, val []byte, opts *kv.WriteOption) error