pruner

package

v0.0.0-...-7ece11e Latest Latest Go to latest Published: Aug 29, 2023 License: MIT Imports: 16 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/incognitochain/incognito-chain

Documentation ¶

Index ¶

Constants
Variables
type Config
type PrunerLogger
- func (prunerLogger *PrunerLogger) Init(logger common.Logger)
type PrunerManager
- func NewPrunerManager(db map[int]incdb.Database) *PrunerManager
type ShardPruner
- func NewShardPruner(sid int, db incdb.Database, blockStorage *blockchain.BlockStorage) *ShardPruner
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 Config ¶

type Config struct {
	ShouldPruneByHash bool `json:"ShouldPruneByHash"`
}

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()

type ShardPrunerReport ¶

type ShardPrunerReport struct {
	ChainID              int
	LastTriggerTime      time.Time
	BloomSize            uint64
	Status               string
	Error                string
	LastProcessingHeight uint64
	LastProcessingMode   string
	TotalNodePrune       uint64
	TotalStoragePrune    uint64
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL