blocks

Documentation

Index

• func ValidateRewards(rewards []types.AnyReward) error
• type CertConfig
• type Certifier
  • func NewCertifier(db *sql.Database, o eligibility.Rolacle, v *signing.EdVerifier, ...) *Certifier
  • func (c *Certifier) CertCount() map[types.EpochID]int
  • func (c *Certifier) CertifyIfEligible(ctx context.Context, lid types.LayerID, bid types.BlockID) error
  • func (c *Certifier) HandleCertifyMessage(ctx context.Context, peer p2p.Peer, data []byte) error
  • func (c *Certifier) HandleSyncedCertificate(ctx context.Context, lid types.LayerID, cert *types.Certificate) error
  • func (c *Certifier) NumCached() int
  • func (c *Certifier) Register(sig *signing.EdSigner)
  • func (c *Certifier) RegisterForCert(ctx context.Context, lid types.LayerID, bid types.BlockID) error
  • func (c *Certifier) Start(ctx context.Context)
  • func (c *Certifier) Stop()
• type CertifierOpt
  • func WithCertConfig(cfg CertConfig) CertifierOpt
  • func WithCertifierLogger(logger log.Log) CertifierOpt
• type Config
• type Generator
  • func NewGenerator(db *sql.Database, atxs *atxsdata.Data, proposals *store.Store, exec executor, ...) *Generator
  • func (g *Generator) Start(ctx context.Context)
  • func (g *Generator) Stop()
• type GeneratorOpt
  • func WithConfig(cfg Config) GeneratorOpt
  • func WithGeneratorLogger(logger log.Log) GeneratorOpt
  • func WithHareOutputChan(ch <-chan hare3.ConsensusOutput) GeneratorOpt
• type Handler
  • func NewHandler(f system.Fetcher, db *sql.Database, tortoise tortoiseProvider, m meshProvider, ...) *Handler
  • func (h *Handler) HandleSyncedBlock(ctx context.Context, expHash types.Hash32, peer p2p.Peer, data []byte) error
• type Opt
  • func WithLogger(logger log.Log) Opt

Functions

func ValidateRewards

func ValidateRewards(rewards []types.AnyReward) error

ValidateRewards syntactically validates rewards.

Types

type CertConfig

type CertConfig struct {
	CommitteeSize    int `mapstructure:"committee-size"`
	CertifyThreshold int
	LayerBuffer      uint32
	NumLayersToKeep  uint32
}

CertConfig is the config for Certifier.

type Certifier

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

Certifier collects enough CertifyMessage for a given hare output and generate certificate.

func NewCertifier

func NewCertifier(
	db *sql.Database,
	o eligibility.Rolacle,

	v *signing.EdVerifier,
	p pubsub.Publisher,
	lc layerClock,
	b system.BeaconGetter,
	tortoise system.Tortoise,
	opts ...CertifierOpt,
) *Certifier

NewCertifier creates new block certifier.

func (*Certifier) CertCount

func (c *Certifier) CertCount() map[types.EpochID]int

func (*Certifier) CertifyIfEligible

func (c *Certifier) CertifyIfEligible(ctx context.Context, lid types.LayerID, bid types.BlockID) error

CertifyIfEligible signs the hare output, along with its role proof as a certifier, and gossip the CertifyMessage if the node is eligible to be a certifier.

func (*Certifier) HandleCertifyMessage

func (c *Certifier) HandleCertifyMessage(ctx context.Context, peer p2p.Peer, data []byte) error

func (*Certifier) HandleSyncedCertificate

func (c *Certifier) HandleSyncedCertificate(ctx context.Context, lid types.LayerID, cert *types.Certificate) error

HandleSyncedCertificate handles Certificate from sync.

func (*Certifier) NumCached

func (c *Certifier) NumCached() int

NumCached returns the number of layers being cached in memory.

func (*Certifier) Register

func (c *Certifier) Register(sig *signing.EdSigner)

func (*Certifier) RegisterForCert

func (c *Certifier) RegisterForCert(ctx context.Context, lid types.LayerID, bid types.BlockID) error

RegisterForCert register to generate a certificate for the specified layer/block.

func (*Certifier) Start

func (c *Certifier) Start(ctx context.Context)

Start starts the background goroutine for periodic pruning.

func (*Certifier) Stop

func (c *Certifier) Stop()

Stop stops the outstanding goroutines.

type CertifierOpt

type CertifierOpt func(*Certifier)

CertifierOpt for configuring Certifier.

func WithCertConfig

func WithCertConfig(cfg CertConfig) CertifierOpt

WithCertConfig defines cfg for Certifier.

func WithCertifierLogger

func WithCertifierLogger(logger log.Log) CertifierOpt

WithCertifierLogger defines logger for Certifier.

type Config

type Config struct {
	GenBlockInterval   time.Duration
	BlockGasLimit      uint64
	OptFilterThreshold int
}

Config is the config for Generator.

type Generator

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

Generator generates a block from proposals.

func NewGenerator

func NewGenerator(
	db *sql.Database,
	atxs *atxsdata.Data,
	proposals *store.Store,
	exec executor,
	m meshProvider,
	f system.ProposalFetcher,
	c certifier,
	p layerPatrol,
	opts ...GeneratorOpt,
) *Generator

NewGenerator creates new block generator.

func (*Generator) Start

func (g *Generator) Start(ctx context.Context)

Start starts listening to hare output.

func (*Generator) Stop

func (g *Generator) Stop()

Stop stops listening to hare output.

type GeneratorOpt

type GeneratorOpt func(*Generator)

GeneratorOpt for configuring Generator.

func WithConfig

func WithConfig(cfg Config) GeneratorOpt

WithConfig defines cfg for Generator.

func WithGeneratorLogger

func WithGeneratorLogger(logger log.Log) GeneratorOpt

WithGeneratorLogger defines logger for Generator.

func WithHareOutputChan

func WithHareOutputChan(ch <-chan hare3.ConsensusOutput) GeneratorOpt

WithHareOutputChan sets the chan to listen to hare output.

type Handler

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

Handler processes Block fetched from peers during sync.

func NewHandler

func NewHandler(f system.Fetcher, db *sql.Database, tortoise tortoiseProvider, m meshProvider, opts ...Opt) *Handler

NewHandler creates new Handler.

func (*Handler) HandleSyncedBlock

func (h *Handler) HandleSyncedBlock(ctx context.Context, expHash types.Hash32, peer p2p.Peer, data []byte) error

HandleSyncedBlock handles Block data from sync.

type Opt

type Opt func(*Handler)

Opt for configuring BlockHandler.

func WithLogger

func WithLogger(logger log.Log) Opt

WithLogger defines logger for Handler.