slashfilter

Documentation

Index

• func SlashConsensus(ctx context.Context, cfg *config.FaultReporterConfig, walletAPI v1.IWallet, ...) error
• type ISlashFilter
  • func NewLocalSlashFilter(dstore ds.Batching) ISlashFilter
  • func NewMysqlSlashFilter(cfg config.MySQLConfig) (ISlashFilter, error)
• type LocalSlashFilter
  • func (f *LocalSlashFilter) MinedBlock(ctx context.Context, bh *types.BlockHeader, parentEpoch abi.ChainEpoch) (cid.Cid, bool, error)
• type MinedBlock
• type MysqlSlashFilter
  • func (f *MysqlSlashFilter) MinedBlock(ctx context.Context, bh *types.BlockHeader, parentEpoch abi.ChainEpoch) (cid.Cid, bool, error)

Functions

func SlashConsensus

func SlashConsensus(ctx context.Context,
	cfg *config.FaultReporterConfig,
	walletAPI v1.IWallet,
	chainAPI v1.IChain,
	mpoolAPI v1.IMessagePool,
	syncAPI v1.ISyncer,
) error

Types

type ISlashFilter

type ISlashFilter interface {
	MinedBlock(ctx context.Context, bh *types.BlockHeader, parentEpoch abi.ChainEpoch) (cid.Cid, bool, error)
}

ISlashFilter used to detect whether the miner mined a invalidated block , support local db and mysql storage

func NewLocalSlashFilter

func NewLocalSlashFilter(dstore ds.Batching) ISlashFilter

NewLocalSlashFilter create a slash filter base on badger db

func NewMysqlSlashFilter

func NewMysqlSlashFilter(cfg config.MySQLConfig) (ISlashFilter, error)

NewMysqlSlashFilter create a new slash filter base on mysql database

type LocalSlashFilter

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

LocalSlashFilter use badger db to save mined block for detect slash consensus block

func (*LocalSlashFilter) MinedBlock

func (f *LocalSlashFilter) MinedBlock(ctx context.Context, bh *types.BlockHeader, parentEpoch abi.ChainEpoch) (cid.Cid, bool, error)

MinedBlock check whether the block mined is slash

type MinedBlock

type MinedBlock struct {
	ParentEpoch int64  `gorm:"column:parent_epoch;type:bigint(20);NOT NULL"`
	ParentKey   string `gorm:"column:parent_key;type:varchar(2048);NOT NULL"`

	Epoch int64  `gorm:"column:epoch;type:bigint(20);NOT NULL"`
	Miner string `gorm:"column:miner;type:varchar(256);NOT NULL"`
	Cid   string `gorm:"column:cid;type:varchar(256);NOT NULL"`
}

MinedBlock record mined block

type MysqlSlashFilter

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

func (*MysqlSlashFilter) MinedBlock

func (f *MysqlSlashFilter) MinedBlock(ctx context.Context, bh *types.BlockHeader, parentEpoch abi.ChainEpoch) (cid.Cid, bool, error)

MinedBlock check whether the block mined is slash