Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

ldb

package

Go to main page

Versions in this module

v0

v0.3.5

Feb 6, 2016

v0.3.4

Oct 29, 2015

v0.3.3

Oct 6, 2015

v0.3.2

Sep 30, 2015

v0.3.1

Sep 20, 2015

Changes in this version

+ const TBL_AB

+ const TBL_AB_NUM

+ const TBL_CB_MR

+ const TBL_CHAIN_HEAD

+ const TBL_DB_MR

+ const TBL_SC

+ const TBL_SC_NUM

type LevelDb

+ func (db *LevelDb) FetchABlockByHash(aBlockHash *common.Hash) (aBlock *common.AdminBlock, err error)

+ func (db *LevelDb) FetchAllABlocks() (aBlocks []common.AdminBlock, err error)

+ func (db *LevelDb) FetchAllChains() (chains []*common.EChain, err error)

+ func (db *LevelDb) FetchAllDirBlockInfo() (dirBlockInfoMap map[string]*common.DirBlockInfo, err error)

+ func (db *LevelDb) FetchAllECBlocks() (ecBlocks []common.ECBlock, err error)

+ func (db *LevelDb) FetchAllUnconfirmedDirBlockInfo() (dirBlockInfoMap map[string]*common.DirBlockInfo, err error)

+ func (db *LevelDb) FetchBlockHeightBySha(sha *wire.ShaHash) (int64, error)

+ func (db *LevelDb) FetchBlockHeightCache() (sha *wire.ShaHash, height int64, err error)

+ func (db *LevelDb) FetchDBHashByHeight(dBlockHeight uint32) (*common.Hash, error)

+ func (db *LevelDb) FetchDBHashByMR(dBMR *common.Hash) (*common.Hash, error)

+ func (db *LevelDb) FetchDBlockByHeight(dBlockHeight uint32) (dBlock *common.DirectoryBlock, err error)

+ func (db *LevelDb) FetchDBlockByMR(dBMR *common.Hash) (*common.DirectoryBlock, error)

+ func (db *LevelDb) FetchDirBlockInfoByHash(dbHash *common.Hash) (dirBlockInfo *common.DirBlockInfo, err error)

+ func (db *LevelDb) FetchECBlockByHash(ecBlockHash *common.Hash) (ecBlock *common.ECBlock, err error)

+ func (db *LevelDb) FetchHeadMRByChainID(chainID *common.Hash) (blkMR *common.Hash, err error)

+ func (db *LevelDb) FetchHeightRange(startHeight, endHeight int64) (rshalist []wire.ShaHash, err error)

+ func (db *LevelDb) FetchNextBlockHeightCache() (height int64)

+ func (db *LevelDb) InsertDirBlockInfo(dirBlockInfo *common.DirBlockInfo) (err error)

+ func (db *LevelDb) InsertEntry(entry *common.Entry) error

+ func (db *LevelDb) ProcessABlockBatch(block *common.AdminBlock) error

+ func (db *LevelDb) ProcessECBlockBatch(block *common.ECBlock) error

+ func (db *LevelDb) UpdateBlockHeightCache(dirBlkHeigh uint32, dirBlkHash *common.Hash) error

+ func (db *LevelDb) UpdateNextBlockHeightCache(dirBlkHeigh uint32) error

v0.2.1

Mar 4, 2015

Changes in this version

+ const STATUS_IN_QUEUE

+ const STATUS_PROCESSED

+ const TBL_CB

+ const TBL_CB_INFO

+ const TBL_CB_NUM

+ const TBL_CHAIN_HASH

+ const TBL_CHAIN_NAME

+ const TBL_DB

+ const TBL_DB_INFO

+ const TBL_DB_NUM

+ const TBL_EB

+ const TBL_EB_CHAIN_NUM

+ const TBL_EB_INFO

+ const TBL_EB_MR

+ const TBL_EB_QUEUE

+ const TBL_ENTRY

+ const TBL_ENTRY_INFO

+ const TBL_ENTRY_QUEUE

+ const TBL_FB

+ const TBL_FB_INFO

+ const TBL_FB_NUM

+ var CurrentDBVersion int32 = 1

+ func OpenLevelDB(dbpath string, create bool) (pbdb database.Db, err error)

+ type LevelDb struct

+ func (db *LevelDb) Close() error

+ func (db *LevelDb) FetchAllCBlocks() (cBlocks []notaryapi.CBlock, err error)

+ func (db *LevelDb) FetchAllChainIDsByName(chainName [][]byte) (chainIDs *[]notaryapi.Hash, err error)

+ func (db *LevelDb) FetchAllChainsByName(chainName [][]byte) (chains *[]notaryapi.EChain, err error)

+ func (db *LevelDb) FetchAllDBlocks() (dBlocks []notaryapi.DBlock, err error)

+ func (db *LevelDb) FetchAllEBInfosByChain(chainID *notaryapi.Hash) (eBInfos *[]notaryapi.EBInfo, err error)

+ func (db *LevelDb) FetchAllEBlocksByChain(chainID *notaryapi.Hash) (eBlocks *[]notaryapi.EBlock, err error)

+ func (db *LevelDb) FetchAllFBlocks() (fBlocks []factoid.FBlock, err error)

+ func (db *LevelDb) FetchCBlockByHash(cBlockHash *notaryapi.Hash) (cBlock *notaryapi.CBlock, err error)

+ func (db *LevelDb) FetchChainByHash(chainID *notaryapi.Hash) (chain *notaryapi.EChain, err error)

+ func (db *LevelDb) FetchChainByName(chainName [][]byte) (chain *notaryapi.EChain, err error)

+ func (db *LevelDb) FetchChainIDByName(chainName [][]byte) (chainID *notaryapi.Hash, err error)

+ func (db *LevelDb) FetchDBEntriesFromQueue(startTime *[]byte) (dbentries []*notaryapi.DBEntry, err error)

+ func (db *LevelDb) FetchDBInfoByHash(dbHash *notaryapi.Hash) (dbInfo *notaryapi.DBInfo, err error)

+ func (db *LevelDb) FetchDBlockByHash(dBlockHash *notaryapi.Hash) (dBlock *notaryapi.DBlock, err error)

+ func (db *LevelDb) FetchEBEntriesFromQueue(chainID *[]byte, startTime *[]byte) (ebentries []*notaryapi.EBEntry, err error)

+ func (db *LevelDb) FetchEBHashByMR(eBMR *notaryapi.Hash) (eBlockHash *notaryapi.Hash, err error)

+ func (db *LevelDb) FetchEBInfoByHash(ebHash *notaryapi.Hash) (ebInfo *notaryapi.EBInfo, err error)

+ func (db *LevelDb) FetchEBlockByHash(eBlockHash *notaryapi.Hash) (eBlock *notaryapi.EBlock, err error)

+ func (db *LevelDb) FetchEBlockByMR(eBMR *notaryapi.Hash) (eBlock *notaryapi.EBlock, err error)

+ func (db *LevelDb) FetchEntryByHash(entrySha *notaryapi.Hash) (entry *notaryapi.Entry, err error)

+ func (db *LevelDb) FetchEntryInfoBranchByHash(entryHash *notaryapi.Hash) (entryInfoBranch *notaryapi.EntryInfoBranch, err error)

+ func (db *LevelDb) FetchEntryInfoByHash(entryHash *notaryapi.Hash) (entryInfo *notaryapi.EntryInfo, err error)

+ func (db *LevelDb) FetchFBlockByHash(fBlockHash *notaryapi.Hash) (fBlock *factoid.FBlock, err error)

+ func (db *LevelDb) InitializeExternalIDMap() (extIDMap map[string]bool, err error)

+ func (db *LevelDb) InsertChain(chain *notaryapi.EChain) (err error)

+ func (db *LevelDb) InsertDBInfo(dbInfo notaryapi.DBInfo) (err error)

+ func (db *LevelDb) InsertEntryAndQueue(entrySha *notaryapi.Hash, binaryEntry *[]byte, entry *notaryapi.Entry, ...) (err error)

+ func (db *LevelDb) ProcessCBlockBatch(block *notaryapi.CBlock) error

+ func (db *LevelDb) ProcessDBlockBatch(dblock *notaryapi.DBlock) error

+ func (db *LevelDb) ProcessEBlockBatch(eblock *notaryapi.EBlock) error

+ func (db *LevelDb) ProcessFBlockBatch(block *factoid.FBlock) error

+ func (db *LevelDb) RollbackClose() error

+ func (db *LevelDb) Sync() error