Documentation
¶
Index ¶
- Variables
- func NewCertificateSendTrigger(ctx context.Context, cfg config.Config, log aggkitcommon.Logger, ...) (types.CertificateSendTrigger, error)
- func NewValidatorPoller(log aggkitcommon.Logger, storage db.AggSenderStorage, ...) *validatorPoller
- type AggSender
- type AggsenderValidator
- type ConfigEpochNotifierPerBlock
- type EpochNotifierPerBlock
- type ExtraInfoEventEpoch
- type RateLimiter
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrNilCertificate = errors.New("aggsender-validator nil certificate") ErrMetadataNotCompatible = errors.New("aggsender-validator metadata not compatible with the current version") )
Functions ¶
func NewCertificateSendTrigger ¶ added in v0.8.0
func NewCertificateSendTrigger( ctx context.Context, cfg config.Config, log aggkitcommon.Logger, l1Client aggkittypes.BaseEthereumClienter, l2BridgeSync types.L2BridgeSyncer, agglayerClient agglayer.AgglayerClientInterface) (types.CertificateSendTrigger, error)
NewCertificateSendTrigger creates and returns a new CertificateSendTrigger instance based on the provided configuration mode. It supports two modes: PreconfPPMode which returns a preconfTrigger, and all other modes which return an epochBasedTrigger.
func NewValidatorPoller ¶ added in v0.7.0
func NewValidatorPoller( log aggkitcommon.Logger, storage db.AggSenderStorage, proposerSigner signertypes.Signer, multisigQuerier types.MultisigQuerier, validatorClientCfg *grpc.ClientConfig, ) *validatorPoller
NewValidatorPoller creates a new ValidatorCommittee instance
Types ¶
type AggSender ¶
type AggSender struct {
// contains filtered or unexported fields
}
AggSender is a component that will send certificates to the aggLayer
func New ¶
func New( ctx context.Context, logger *log.Logger, cfg config.Config, aggLayerClient agglayer.AgglayerClientInterface, l1InfoTreeSyncer types.L1InfoTreeSyncer, l2Syncer types.L2BridgeSyncer, l1Client aggkittypes.BaseEthereumClienter, l2Client aggkittypes.BaseEthereumClienter, rollupDataQuerier types.RollupDataQuerier, committeeQuerier types.MultisigQuerier, ) (*AggSender, error)
New returns a new AggSender instance
func (*AggSender) ForceTriggerCertitificate ¶ added in v0.7.2
func (a *AggSender) ForceTriggerCertitificate()
func (*AggSender) GetRPCServices ¶
GetRPCServices returns the list of services that the RPC provider exposes
func (*AggSender) Info ¶
func (a *AggSender) Info() types.AggsenderInfo
type AggsenderValidator ¶ added in v0.7.0
type AggsenderValidator struct {
// contains filtered or unexported fields
}
func NewAggsenderValidator ¶ added in v0.7.0
func NewAggsenderValidator(ctx context.Context, logger aggkitcommon.Logger, cfg validator.Config, flow types.AggsenderVerifierFlow, l1InfoTreeDataQuerier validator.L1InfoTreeRootByLeafQuerier, aggLayerClient agglayer.AggLayerClientCertificateIDQuerier, certQuerier types.CertificateQuerier, aggchainFEPQuerier types.AggchainFEPRollupQuerier, lerQuerier types.LERQuerier, signer signertypes.Signer) (*AggsenderValidator, error)
func (*AggsenderValidator) Start ¶ added in v0.7.0
func (a *AggsenderValidator) Start(ctx context.Context)
func (*AggsenderValidator) ValidateCertificate ¶ added in v0.7.0
func (a *AggsenderValidator) ValidateCertificate(ctx context.Context, params types.VerifyIncomingRequest) error
ValidateCertificate validates the incoming certificate against the previous one.
type ConfigEpochNotifierPerBlock ¶
type ConfigEpochNotifierPerBlock struct {
StartingEpochBlock uint64
NumBlockPerEpoch uint
// EpochNotificationPercentage
// 0 -> begin new Epoch
// 50 -> middle of epoch
// 100 -> end of epoch (same as 0)
EpochNotificationPercentage uint
}
func NewConfigEpochNotifierPerBlock ¶
func NewConfigEpochNotifierPerBlock(ctx context.Context, agglayerClient agglayer.AggLayerClientGetEpochConfiguration, epochNotificationPercentage uint) (*ConfigEpochNotifierPerBlock, error)
func (*ConfigEpochNotifierPerBlock) String ¶
func (c *ConfigEpochNotifierPerBlock) String() string
func (*ConfigEpochNotifierPerBlock) Validate ¶
func (c *ConfigEpochNotifierPerBlock) Validate() error
type EpochNotifierPerBlock ¶
type EpochNotifierPerBlock struct {
Config ConfigEpochNotifierPerBlock
aggkitcommon.PubSub[types.EpochEvent]
// contains filtered or unexported fields
}
func NewEpochNotifierPerBlock ¶
func NewEpochNotifierPerBlock(blockNotifier ethermantypes.BlockNotifier, logger aggkitcommon.Logger, config ConfigEpochNotifierPerBlock, subscriber aggkitcommon.PubSub[types.EpochEvent]) (*EpochNotifierPerBlock, error)
func (*EpochNotifierPerBlock) ForcePublishEpochEvent ¶ added in v0.7.2
func (e *EpochNotifierPerBlock) ForcePublishEpochEvent()
func (*EpochNotifierPerBlock) GetEpochStatus ¶ added in v0.0.2
func (e *EpochNotifierPerBlock) GetEpochStatus() types.EpochStatus
GetCurrentStatus returns the current status of the epoch
func (*EpochNotifierPerBlock) Start ¶
func (e *EpochNotifierPerBlock) Start(ctx context.Context)
Start starts the notifier synchronously
func (*EpochNotifierPerBlock) StartAsync ¶
func (e *EpochNotifierPerBlock) StartAsync(ctx context.Context)
StartAsync starts the notifier in a goroutine
func (*EpochNotifierPerBlock) String ¶
func (e *EpochNotifierPerBlock) String() string
type ExtraInfoEventEpoch ¶
type ExtraInfoEventEpoch struct {
PendingBlocks int
}
func (*ExtraInfoEventEpoch) String ¶
func (e *ExtraInfoEventEpoch) String() string
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.