Versions in this module Expand all Collapse all v1 v1.0.1 Nov 24, 2021 Changes in this version + const PayloadIndexerSize + const SenderCountBufferSize + const TxTimeBufferSize + const TxTurnNonces + const TxTurnPeriod + const TxTurnPeriodLatency + var ErrNotEnoughGasPower = errors.New("not enough gas power") + type Config struct + EmergencyThreshold uint64 + EmitIntervals EmitIntervals + LimitedTpsThreshold uint64 + MaxParents idx.Event + MaxTxsPerAddress int + NoTxsThreshold uint64 + PrevEmittedEventFile PrevEmittedEventFile + TxsCacheInvalidation time.Duration + Validator ValidatorConfig + VersionToPublish string + func DefaultConfig() Config + func FakeConfig(num int) Config + type EmitIntervals struct + Confirming time.Duration + DoublesignProtection time.Duration + Max time.Duration + Min time.Duration + ParallelInstanceProtection time.Duration + func (cfg EmitIntervals) RandomizeEmitTime(r *rand.Rand) EmitIntervals + type Emitter struct + func NewEmitter(config Config, world World) *Emitter + func (em *Emitter) EmitEvent() *inter.EventPayload + func (em *Emitter) OnEventConfirmed(he inter.EventI) + func (em *Emitter) OnEventConnected(e inter.EventPayloadI) + func (em *Emitter) OnNewEpoch(newValidators *pos.Validators, newEpoch idx.Epoch) + func (em *Emitter) Start() + func (em *Emitter) Stop() + type External interface + Broadcast func(*inter.EventPayload) + Build func(*inter.MutableEventPayload, func()) error + Check func(e *inter.EventPayload, parents inter.Events) error + DagIndex func() *vecmt.Index + IsBusy func() bool + IsSynced func() bool + PeersNum func() int + Process func(*inter.EventPayload) error + type PrevEmittedEventFile struct + Path string + SyncMode bool + type Reader interface + GetEpochValidators func() (*pos.Validators, idx.Epoch) + GetEvent func(hash.Event) *inter.Event + GetEventPayload func(hash.Event) *inter.EventPayload + GetGenesisTime func() inter.Timestamp + GetHeads func(idx.Epoch) hash.Events + GetLastEvent func(epoch idx.Epoch, from idx.ValidatorID) *hash.Event + GetLatestBlockIndex func() idx.Block + GetRecommendedGasPrice func() *big.Int + GetRules func() mugambo.Rules + type Signer valkeystore.SignerI + type TxPool interface + Count func() int + Has func(hash common.Hash) bool + Pending func() (map[common.Address]types.Transactions, error) + SubscribeNewTxsNotify func(chan<- evmcore.NewTxsNotify) notify.Subscription + type TxSigner types.Signer + type ValidatorConfig struct + ID idx.ValidatorID + PubKey validatorpk.PubKey + type World struct + Signer valkeystore.SignerI + TxPool TxPool + TxSigner types.Signer
Go to main page