ipfs_log

Documentation

Index

• Constants
• Variables
• type DB
  • func (db *DB) Close() error
  • func (db *DB) Compact() error
  • func (db *DB) Delete(key []byte) error
  • func (db *DB) Get(key []byte) ([]byte, error)
  • func (d *DB) GetLevelDB() *leveldb.DB
  • func (s *DB) GetStorageEngine() interface{}
  • func (db *DB) NewIterator() driver.IIterator
  • func (db *DB) NewSnapshot() (driver.ISnapshot, error)
  • func (db *DB) NewWriteBatch() driver.IWriteBatch
  • func (db *DB) Put(key, value []byte) error
  • func (db *DB) SyncDelete(key []byte) error
  • func (db *DB) SyncPut(key []byte, value []byte) error
• type Iterator
  • func (it *Iterator) Close() error
  • func (it *Iterator) First()
  • func (it *Iterator) Key() []byte
  • func (it *Iterator) Last()
  • func (it *Iterator) Next()
  • func (it *Iterator) Prev()
  • func (it *Iterator) Seek(key []byte)
  • func (it *Iterator) Valid() bool
  • func (it *Iterator) Value() []byte
• type Snapshot
  • func (s *Snapshot) Close()
  • func (s *Snapshot) Get(key []byte) ([]byte, error)
  • func (s *Snapshot) NewIterator() driver.IIterator
• type Store
  • func (s Store) Open(path string, cfg *config.Config) (driver.IDB, error)
  • func (s Store) Repair(path string, cfg *config.Config) error
  • func (s Store) String() string
• type WriteBatch
  • func (w *WriteBatch) Close()
  • func (w *WriteBatch) Commit() error
  • func (w *WriteBatch) Data() []byte
  • func (w *WriteBatch) Delete(key []byte)
  • func (w *WriteBatch) Put(key, value []byte)
  • func (w *WriteBatch) Rollback() error
  • func (w *WriteBatch) SyncCommit() error

Constants

const (
	StorageName = "ipfs-log"
)

Variables

var Dbname = "ifdb-event-kv"

Types

type DB

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

func (*DB) Close

func (db *DB) Close() error

func (*DB) Compact

func (db *DB) Compact() error

func (*DB) Delete

func (db *DB) Delete(key []byte) error

func (*DB) Get

func (db *DB) Get(key []byte) ([]byte, error)

func (*DB) GetLevelDB

func (d *DB) GetLevelDB() *leveldb.DB

func (*DB) GetStorageEngine

func (s *DB) GetStorageEngine() interface{}

func (*DB) NewIterator

func (db *DB) NewIterator() driver.IIterator

func (*DB) NewSnapshot

func (db *DB) NewSnapshot() (driver.ISnapshot, error)

func (*DB) NewWriteBatch

func (db *DB) NewWriteBatch() driver.IWriteBatch

func (*DB) Put

func (db *DB) Put(key, value []byte) error

func (*DB) SyncDelete

func (db *DB) SyncDelete(key []byte) error

func (*DB) SyncPut

func (db *DB) SyncPut(key []byte, value []byte) error

type Iterator

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

func (*Iterator) Close

func (it *Iterator) Close() error

func (*Iterator) First

func (it *Iterator) First()

func (*Iterator) Key

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

func (*Iterator) Last

func (it *Iterator) Last()

func (*Iterator) Next

func (it *Iterator) Next()

func (*Iterator) Prev

func (it *Iterator) Prev()

func (*Iterator) Seek

func (it *Iterator) Seek(key []byte)

func (*Iterator) Valid

func (it *Iterator) Valid() bool

func (*Iterator) Value

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

type Snapshot

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

func (*Snapshot) Close

func (s *Snapshot) Close()

func (*Snapshot) Get

func (s *Snapshot) Get(key []byte) ([]byte, error)

func (*Snapshot) NewIterator

func (s *Snapshot) NewIterator() driver.IIterator

type Store

type Store struct{}

func (Store) Open

func (s Store) Open(path string, cfg *config.Config) (driver.IDB, error)

func (Store) Repair

func (s Store) Repair(path string, cfg *config.Config) error

func (Store) String

func (s Store) String() string

type WriteBatch

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

func (*WriteBatch) Close

func (w *WriteBatch) Close()

func (*WriteBatch) Commit

func (w *WriteBatch) Commit() error

func (*WriteBatch) Data

func (w *WriteBatch) Data() []byte

func (*WriteBatch) Delete

func (w *WriteBatch) Delete(key []byte)

func (*WriteBatch) Put

func (w *WriteBatch) Put(key, value []byte)

func (*WriteBatch) Rollback

func (w *WriteBatch) Rollback() error

func (*WriteBatch) SyncCommit

func (w *WriteBatch) SyncCommit() error