Versions in this module Expand all Collapse all v1 v1.1.3 Jan 20, 2025 v1.1.2 Jan 20, 2025 Changes in this version + const ProfitabilityAcceptAll + const ProfitabilityBase + func FirstToUpper(s string) string + type Aggregator struct + EthTxManager ethTxManager + Ethman etherman + ProfitabilityChecker aggregatorTxProfitabilityChecker + State stateInterface + StateDBMutex *sync.Mutex + TimeCleanupLockedProofs types.Duration + TimeSendFinalProof time.Time + TimeSendFinalProofMutex *sync.RWMutex + func New(cfg Config, stateInterface stateInterface, ethTxManager ethTxManager, ...) (Aggregator, error) + func (a *Aggregator) Channel(stream prover.AggregatorService_ChannelServer) error + func (a *Aggregator) Start(ctx context.Context) error + func (a *Aggregator) Stop() + type Config struct + BatchProofL1BlockConfirmations uint64 + ChainID uint64 + CleanupLockedProofsInterval types.Duration + ForkId uint64 + GasOffset uint64 + GeneratingProofCleanupThreshold string + Host string + IntervalAfterWhichBatchConsolidateAnyway types.Duration + Port int + ProofStatePollingInterval types.Duration + RetryTime types.Duration + SenderAddress string + TxProfitabilityCheckerType TxProfitabilityCheckerType + TxProfitabilityMinReward TokenAmountWithDecimals + UpgradeEtrogBatchNumber uint64 + VerifyProofInterval types.Duration + type TokenAmountWithDecimals struct + func (t *TokenAmountWithDecimals) UnmarshalText(data []byte) error + type TxProfitabilityCheckerAcceptAll struct + IntervalAfterWhichBatchSentAnyway time.Duration + State stateInterface + func NewTxProfitabilityCheckerAcceptAll(state stateInterface, interval time.Duration) *TxProfitabilityCheckerAcceptAll + func (pc *TxProfitabilityCheckerAcceptAll) IsProfitable(ctx context.Context, polCollateral *big.Int) (bool, error) + type TxProfitabilityCheckerBase struct + IntervalAfterWhichBatchSentAnyway time.Duration + MinReward *big.Int + State stateInterface + func NewTxProfitabilityCheckerBase(state stateInterface, interval time.Duration, minReward *big.Int) *TxProfitabilityCheckerBase + func (pc *TxProfitabilityCheckerBase) IsProfitable(ctx context.Context, polCollateral *big.Int) (bool, error) + type TxProfitabilityCheckerType string