miner

Documentation

Overview

Package miner is responsible for creating valid blocks that contain valid activation transactions and transactions

Index

• func ActiveSetFromEpochFirstBlock(db sql.Executor, epoch types.EpochID) ([]types.ATXID, error)
• type Opt
  • func WithHdist(dist uint32) Opt
  • func WithLayerPerEpoch(layers uint32) Opt
  • func WithLayerSize(size uint32) Opt
  • func WithLogger(logger log.Log) Opt
  • func WithMinGoodAtxPercent(percent int) Opt
  • func WithMinimalActiveSetWeight(weight []types.EpochMinimalActiveWeight) Opt
  • func WithNetworkDelay(delay time.Duration) Opt
  • func WithSigners(signers ...*signing.EdSigner) Opt
  • func WithWorkersLimit(limit int) Opt
• type ProposalBuilder
  • func New(clock layerClock, cdb *datastore.CachedDB, publisher pubsub.Publisher, ...) *ProposalBuilder
  • func (pb *ProposalBuilder) Register(signer *signing.EdSigner)
  • func (pb *ProposalBuilder) Run(ctx context.Context) error
  • func (pb *ProposalBuilder) UpdateActiveSet(epoch types.EpochID, activeSet []types.ATXID)

Functions

func ActiveSetFromEpochFirstBlock

func ActiveSetFromEpochFirstBlock(db sql.Executor, epoch types.EpochID) ([]types.ATXID, error)

Types

type Opt

type Opt func(h *ProposalBuilder)

Opt for configuring ProposalBuilder.

func WithHdist

func WithHdist(dist uint32) Opt

func WithLayerPerEpoch

func WithLayerPerEpoch(layers uint32) Opt

WithLayerPerEpoch defines the number of layers per epoch.

func WithLayerSize

func WithLayerSize(size uint32) Opt

WithLayerSize defines the average number of proposal per layer.

func WithLogger

func WithLogger(logger log.Log) Opt

WithLogger defines the logger.

func WithMinGoodAtxPercent

func WithMinGoodAtxPercent(percent int) Opt

func WithMinimalActiveSetWeight

func WithMinimalActiveSetWeight(weight []types.EpochMinimalActiveWeight) Opt

func WithNetworkDelay

func WithNetworkDelay(delay time.Duration) Opt

func WithSigners

func WithSigners(signers ...*signing.EdSigner) Opt

WithSigners guarantees that builder will start execution with provided list of signers. Should be after logging.

func WithWorkersLimit

func WithWorkersLimit(limit int) Opt

WithWorkersLimit configures paralelization factor for builder operation when working with more than one signer.

type ProposalBuilder

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

ProposalBuilder builds Proposals for a miner.

func New

func New(
	clock layerClock,
	cdb *datastore.CachedDB,
	publisher pubsub.Publisher,
	trtl votesEncoder,
	syncer system.SyncStateProvider,
	conState conservativeState,
	opts ...Opt,
) *ProposalBuilder

New creates a struct of block builder type.

func (*ProposalBuilder) Register

func (pb *ProposalBuilder) Register(signer *signing.EdSigner)

func (*ProposalBuilder) Run

func (pb *ProposalBuilder) Run(ctx context.Context) error

Start the loop that listens to layers and build proposals.

func (*ProposalBuilder) UpdateActiveSet

func (pb *ProposalBuilder) UpdateActiveSet(epoch types.EpochID, activeSet []types.ATXID)