emitter

type Config struct {
	VersionToPublish string

	Validator ValidatorConfig

	EmitIntervals EmitIntervals // event emission intervals

	MaxTxsPerAddress int

	MaxParents idx.Event

	// thresholds on GasLeft
	LimitedTpsThreshold uint64
	NoTxsThreshold      uint64
	EmergencyThreshold  uint64

	TxsCacheInvalidation time.Duration

	PrevEmittedEventFile PrevEmittedEventFile
}

type EmitIntervals struct {
	Min                        time.Duration
	Max                        time.Duration
	Confirming                 time.Duration // emit time when there's no txs to originate, but at least 1 tx to confirm
	ParallelInstanceProtection time.Duration
	DoublesignProtection       time.Duration
}

type Emitter struct {
	logger.Periodic
	// contains filtered or unexported fields
}

type External interface {
	sync.Locker
	Reader

	Check(e *inter.EventPayload, parents inter.Events) error
	Process(*inter.EventPayload) error
	Broadcast(*inter.EventPayload)
	Build(*inter.MutableEventPayload, func()) error
	DagIndex() *vecmt.Index

	IsBusy() bool
	IsSynced() bool
	PeersNum() int
}

type PrevEmittedEventFile struct {
	Path     string
	SyncMode bool
}

type Reader interface {
	GetLatestBlockIndex() idx.Block
	GetEpochValidators() (*pos.Validators, idx.Epoch)
	GetEvent(hash.Event) *inter.Event
	GetEventPayload(hash.Event) *inter.EventPayload
	GetLastEvent(epoch idx.Epoch, from idx.ValidatorID) *hash.Event
	GetHeads(idx.Epoch) hash.Events
	GetGenesisTime() inter.Timestamp
	GetRules() opera.Rules
	GetRecommendedGasPrice() *big.Int
}

type Signer valkeystore.SignerI

type TxPool interface {
	// Has returns an indicator whether txpool has a transaction cached with the
	// given hash.
	Has(hash common.Hash) bool
	// Pending should return pending transactions.
	// The slice should be modifiable by the caller.
	Pending() (map[common.Address]types.Transactions, error)

	// SubscribeNewTxsNotify should return an event subscription of
	// NewTxsNotify and send events to the given channel.
	SubscribeNewTxsNotify(chan<- evmcore.NewTxsNotify) notify.Subscription

	// Count returns the total number of transactions
	Count() int
}

type TxSigner types.Signer

type ValidatorConfig struct {
	ID     idx.ValidatorID
	PubKey validatorpk.PubKey
}

type World struct {
	External
	TxPool   TxPool
	Signer   valkeystore.SignerI
	TxSigner types.Signer
}