hybridDB

Documentation

Index

• type HybridDB
  • func NewBoltMapHybridDB(bucketList [][]byte, filename string) *HybridDB
  • func NewLevelMapHybridDB(filename string, create bool) (*HybridDB, error)
  • func (db *HybridDB) Clear(bucket []byte) error
  • func (db *HybridDB) Close() error
  • func (db *HybridDB) Delete(bucket, key []byte) error
  • func (db *HybridDB) DoesKeyExist(bucket, key []byte) (bool, error)
  • func (db *HybridDB) Get(bucket, key []byte, destination interfaces.BinaryMarshallable) (interfaces.BinaryMarshallable, error)
  • func (db *HybridDB) GetAll(bucket []byte, sample interfaces.BinaryMarshallableAndCopyable) ([]interfaces.BinaryMarshallableAndCopyable, [][]byte, error)
  • func (db *HybridDB) ListAllBuckets() ([][]byte, error)
  • func (db *HybridDB) ListAllKeys(bucket []byte) ([][]byte, error)
  • func (db *HybridDB) Put(bucket, key []byte, data interfaces.BinaryMarshallable) error
  • func (db *HybridDB) PutInBatch(records []interfaces.Record) error
  • func (db *HybridDB) Trim()

Types

type HybridDB

type HybridDB struct {
	Sem sync.RWMutex
	// contains filtered or unexported fields
}

func NewBoltMapHybridDB

func NewBoltMapHybridDB(bucketList [][]byte, filename string) *HybridDB

func NewLevelMapHybridDB

func NewLevelMapHybridDB(filename string, create bool) (*HybridDB, error)

func (*HybridDB) Clear

func (db *HybridDB) Clear(bucket []byte) error

func (*HybridDB) Close

func (db *HybridDB) Close() error

func (*HybridDB) Delete

func (db *HybridDB) Delete(bucket, key []byte) error

func (*HybridDB) DoesKeyExist

func (db *HybridDB) DoesKeyExist(bucket, key []byte) (bool, error)

func (*HybridDB) Get

func (db *HybridDB) Get(bucket, key []byte, destination interfaces.BinaryMarshallable) (interfaces.BinaryMarshallable, error)

func (*HybridDB) GetAll

func (db *HybridDB) GetAll(bucket []byte, sample interfaces.BinaryMarshallableAndCopyable) ([]interfaces.BinaryMarshallableAndCopyable, [][]byte, error)

func (*HybridDB) ListAllBuckets

func (db *HybridDB) ListAllBuckets() ([][]byte, error)

func (*HybridDB) ListAllKeys

func (db *HybridDB) ListAllKeys(bucket []byte) ([][]byte, error)

func (*HybridDB) Put

func (db *HybridDB) Put(bucket, key []byte, data interfaces.BinaryMarshallable) error

func (*HybridDB) PutInBatch

func (db *HybridDB) PutInBatch(records []interfaces.Record) error

func (*HybridDB) Trim

func (db *HybridDB) Trim()