ustoredb

Documentation

Overview

DB wrapper for USTORE

Index

• func Close(db *UStoreDB)
• func DeleteColumnFamilyHandle(cfh *ColumnFamilyHandle)
• func DeleteIterator(it ustore.Iterator)
• func DeleteWriteBatch(batch *WriteBatch)
• func GetIterator(cfh *ColumnFamilyHandle) (ustore.Iterator, error)
• type ColumnFamilyHandle
  • func (cfh *ColumnFamilyHandle) GetCFName() string
• type UStoreDB
  • func OpenDB() (*UStoreDB, error)
  • func (db *UStoreDB) CreateColumnFamily(cfname string) (*ColumnFamilyHandle, error)
  • func (db *UStoreDB) DeleteCF(cfh *ColumnFamilyHandle, key string) error
  • func (db *UStoreDB) DropColumnFamily(cfh *ColumnFamilyHandle) error
  • func (db *UStoreDB) ExistCF(cfh *ColumnFamilyHandle, key string) error
  • func (db *UStoreDB) GetCF(cfh *ColumnFamilyHandle, key string) (string, error)
  • func (db *UStoreDB) GetSize() uint64
  • func (db *UStoreDB) PutCF(cfh *ColumnFamilyHandle, key string, value string) error
  • func (db *UStoreDB) Write(writebatch *WriteBatch) error
• type WriteBatch
  • func NewWriteBatch() (*WriteBatch, error)
  • func (writebatch *WriteBatch) Clear()
  • func (writebatch *WriteBatch) DeleteCF(cfh *ColumnFamilyHandle, key string)
  • func (writebatch *WriteBatch) PutCF(cfh *ColumnFamilyHandle, key string, value string) error

Functions

func Close

func Close(db *UStoreDB)

func DeleteColumnFamilyHandle

func DeleteColumnFamilyHandle(cfh *ColumnFamilyHandle)

func DeleteIterator

func DeleteIterator(it ustore.Iterator)

func DeleteWriteBatch

func DeleteWriteBatch(batch *WriteBatch)

func GetIterator

func GetIterator(cfh *ColumnFamilyHandle) (ustore.Iterator, error)

Types

type ColumnFamilyHandle

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

column family namespace

func (*ColumnFamilyHandle) GetCFName

func (cfh *ColumnFamilyHandle) GetCFName() string

type UStoreDB

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

func OpenDB

func OpenDB() (*UStoreDB, error)

func (*UStoreDB) CreateColumnFamily

func (db *UStoreDB) CreateColumnFamily(cfname string) (*ColumnFamilyHandle, error)

func (*UStoreDB) DeleteCF

func (db *UStoreDB) DeleteCF(cfh *ColumnFamilyHandle, key string) error

func (*UStoreDB) DropColumnFamily

func (db *UStoreDB) DropColumnFamily(cfh *ColumnFamilyHandle) error

func (*UStoreDB) ExistCF

func (db *UStoreDB) ExistCF(cfh *ColumnFamilyHandle, key string) error

func (*UStoreDB) GetCF

func (db *UStoreDB) GetCF(cfh *ColumnFamilyHandle, key string) (string, error)

func (*UStoreDB) GetSize

func (db *UStoreDB) GetSize() uint64

func (*UStoreDB) PutCF

func (db *UStoreDB) PutCF(cfh *ColumnFamilyHandle, key string, value string) error

func (*UStoreDB) Write

func (db *UStoreDB) Write(writebatch *WriteBatch) error

type WriteBatch

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

wrap write batch, indexed by ColumnFamily name

func NewWriteBatch

func NewWriteBatch() (*WriteBatch, error)

func (*WriteBatch) Clear

func (writebatch *WriteBatch) Clear()

func (*WriteBatch) DeleteCF

func (writebatch *WriteBatch) DeleteCF(cfh *ColumnFamilyHandle, key string)

func (*WriteBatch) PutCF

func (writebatch *WriteBatch) PutCF(cfh *ColumnFamilyHandle, key string, value string) error