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

stakedb

package module

Go to main page

Versions in this module

v1

v1.0.2

Apr 18, 2019

v1.0.1

Mar 26, 2019

v1.0.0

Mar 26, 2019

Changes in this version

+ const DefaultStakeDbName

+ const DefaultTicketPoolDbFolder

+ const DefaultTicketPoolDbName

+ func DisableLog()

+ func MigrateFromStorm(stormDBFile string, db *badger.DB) (bool, error)

+ func UseLogger(logger slog.Logger)

+ type ChainMonitor struct

+ func (p *ChainMonitor) BlockConnectedHandler()

+ func (p *ChainMonitor) ConnectBlock(hash *chainhash.Hash) (err error)

+ func (p *ChainMonitor) ReorgHandler()

+ func (p *ChainMonitor) SetNewBlockChan(blockChan chan *chainhash.Hash)

+ type PoolDiff struct

+ In []chainhash.Hash

+ Out []chainhash.Hash

+ func LoadAllPoolDiffs(db *badger.DB) ([]PoolDiff, error)

+ type PoolDiffDBItem struct

+ Height int64

+ type PoolInfoCache struct

+ func NewPoolInfoCache(size int) (*PoolInfoCache, error)

+ func (c *PoolInfoCache) Get(hash chainhash.Hash) (*apitypes.TicketPoolInfo, bool)

+ func (c *PoolInfoCache) Set(hash chainhash.Hash, p *apitypes.TicketPoolInfo)

+ func (c *PoolInfoCache) SetCapacity(size int) error

+ type StakeDatabase struct

+ BestNode *stake.Node

+ NodeClient *rpcclient.Client

+ PoolDB *TicketPool

+ StakeDB database.DB

+ func LoadAndRecover(client *rpcclient.Client, params *chaincfg.Params, dataDir string, ...) (*StakeDatabase, error)

+ func NewStakeDatabase(client *rpcclient.Client, params *chaincfg.Params, dataDir string) (*StakeDatabase, int64, error)

+ func (db *StakeDatabase) BlockCached(ind int64) (*dcrutil.Block, bool)

+ func (db *StakeDatabase) Close() error

+ func (db *StakeDatabase) ConnectBlock(block *dcrutil.Block) error

+ func (db *StakeDatabase) ConnectBlockHash(hash *chainhash.Hash) (*dcrutil.Block, error)

+ func (db *StakeDatabase) DBPrevBlock() (*dcrutil.Block, error)

+ func (db *StakeDatabase) DBPrevBlockHeader() (*wire.BlockHeader, error)

+ func (db *StakeDatabase) DBState() (uint32, *chainhash.Hash, error)

+ func (db *StakeDatabase) DBTipBlock() (*dcrutil.Block, error)

+ func (db *StakeDatabase) DBTipBlockHeader() (*wire.BlockHeader, error)

+ func (db *StakeDatabase) DisconnectBlock(neglectCache bool) error

+ func (db *StakeDatabase) DisconnectBlocks(count int64) error

+ func (db *StakeDatabase) ForgetBlock(ind int64)

+ func (db *StakeDatabase) Height() uint32

+ func (db *StakeDatabase) LockStakeNode()

+ func (db *StakeDatabase) NewChainMonitor(ctx context.Context, wg *sync.WaitGroup, reorgChan chan *txhelpers.ReorgData) *ChainMonitor

+ func (db *StakeDatabase) Open(dbName string) error

+ func (db *StakeDatabase) PoolAtHash(hash chainhash.Hash) ([]chainhash.Hash, error)

+ func (db *StakeDatabase) PoolAtHeight(height int64) ([]chainhash.Hash, error)

+ func (db *StakeDatabase) PoolInfo(hash chainhash.Hash) (*apitypes.TicketPoolInfo, bool)

+ func (db *StakeDatabase) PoolInfoBest() *apitypes.TicketPoolInfo

+ func (db *StakeDatabase) PoolSize() int

+ func (db *StakeDatabase) PopulateLiveTicketCache() error

+ func (db *StakeDatabase) Rewind(to int64, neglectCache bool) error

+ func (db *StakeDatabase) SetPoolCacheCapacity(cap int) error

+ func (db *StakeDatabase) SetPoolInfo(blockHash chainhash.Hash, tpi *apitypes.TicketPoolInfo)

+ func (db *StakeDatabase) UnlockStakeNode()

+ func (db *StakeDatabase) WaitForHeight(height int64) chan *chainhash.Hash

+ type TicketPool struct

+ func NewTicketPool(dataDir, dbSubDir string) (tp *TicketPool, err error)

+ func (tp *TicketPool) AdvanceToTip() (int64, error)

+ func (tp *TicketPool) Append(diff *PoolDiff, height int64) error

+ func (tp *TicketPool) AppendAndAdvancePool(diff *PoolDiff, height int64) error

+ func (tp *TicketPool) Close() error

+ func (tp *TicketPool) CurrentPool() ([]chainhash.Hash, int64)

+ func (tp *TicketPool) CurrentPoolSize() int

+ func (tp *TicketPool) Cursor() int64

+ func (tp *TicketPool) Pool(height int64) ([]chainhash.Hash, error)

+ func (tp *TicketPool) Tip() int64

+ func (tp *TicketPool) Trim() (int64, PoolDiff)

Other modules containing this package

github.com/decred/dcrdata

github.com/decred/dcrdata/stakedb/v3

github.com/decred/dcrdata/v3

github.com/decred/dcrdata/v4

github.com/decred/dcrdata/v6

github.com/decred/dcrdata/v7