Documentation ¶
Index ¶
- Constants
- Variables
- type Config
- type PrunerLogger
- type PrunerManager
- func (p *PrunerManager) InsertNewView(shardBestState *blockchain.ShardBestState)
- func (s *PrunerManager) OfflinePrune()
- func (s *PrunerManager) Report() map[int]ShardPrunerReport
- func (p *PrunerManager) SetShardBlockStorage(sid int, blockStorage *blockchain.BlockStorage)
- func (p *PrunerManager) SetShardInsertLock(sid int, mutex *sync.Mutex)
- func (s *PrunerManager) Start() error
- type ShardPruner
- func (s *ShardPruner) CheckDataIntegrity()
- func (s *ShardPruner) InitBloomState() error
- func (s *ShardPruner) LockInsertShardBlock()
- func (s *ShardPruner) Prune(byHash bool) error
- func (s *ShardPruner) PruneByHeight() error
- func (s *ShardPruner) Report() ShardPrunerReport
- func (s *ShardPruner) SetBloomSize(size uint64)
- func (s *ShardPruner) Stop()
- func (s *ShardPruner) UnlockInsertShardBlock()
- type ShardPrunerReport
Constants ¶
View Source
const ( IDLE = 0 INIT = 1 PRUNING = 2 CHECKING = 3 )
Variables ¶
View Source
var Logger = PrunerLogger{}
Global instant to use
Functions ¶
This section is empty.
Types ¶
type PrunerLogger ¶
type PrunerLogger struct {
// contains filtered or unexported fields
}
func (*PrunerLogger) Init ¶
func (prunerLogger *PrunerLogger) Init(logger common.Logger)
type PrunerManager ¶
type PrunerManager struct { ShardPruner map[int]*ShardPruner JobRquest map[int]*Config }
func NewPrunerManager ¶
func NewPrunerManager(db map[int]incdb.Database) *PrunerManager
func (*PrunerManager) InsertNewView ¶
func (p *PrunerManager) InsertNewView(shardBestState *blockchain.ShardBestState)
func (*PrunerManager) OfflinePrune ¶
func (s *PrunerManager) OfflinePrune()
run parallel based on available CPU
func (*PrunerManager) Report ¶
func (s *PrunerManager) Report() map[int]ShardPrunerReport
func (*PrunerManager) SetShardBlockStorage ¶
func (p *PrunerManager) SetShardBlockStorage(sid int, blockStorage *blockchain.BlockStorage)
func (*PrunerManager) SetShardInsertLock ¶
func (p *PrunerManager) SetShardInsertLock(sid int, mutex *sync.Mutex)
func (*PrunerManager) Start ¶
func (s *PrunerManager) Start() error
type ShardPruner ¶
type ShardPruner struct {
// contains filtered or unexported fields
}
func NewShardPruner ¶
func NewShardPruner(sid int, db incdb.Database, blockStorage *blockchain.BlockStorage) *ShardPruner
func (*ShardPruner) CheckDataIntegrity ¶
func (s *ShardPruner) CheckDataIntegrity()
func (*ShardPruner) InitBloomState ¶
func (s *ShardPruner) InitBloomState() error
func (*ShardPruner) LockInsertShardBlock ¶
func (s *ShardPruner) LockInsertShardBlock()
func (*ShardPruner) Prune ¶
func (s *ShardPruner) Prune(byHash bool) error
func (*ShardPruner) PruneByHeight ¶
func (s *ShardPruner) PruneByHeight() error
func (*ShardPruner) Report ¶
func (s *ShardPruner) Report() ShardPrunerReport
func (*ShardPruner) SetBloomSize ¶
func (s *ShardPruner) SetBloomSize(size uint64)
func (*ShardPruner) Stop ¶
func (s *ShardPruner) Stop()
func (*ShardPruner) UnlockInsertShardBlock ¶
func (s *ShardPruner) UnlockInsertShardBlock()
Click to show internal directories.
Click to hide internal directories.