Help us shape the future of Go! Take the 2026 Go Developer Survey

aggsender

package
v0.11.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 21, 2026 License: Apache-2.0, MIT Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

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,
	l2ClaimSyncer claimsynctypes.ClaimSyncer,
	l1Client aggkittypes.BaseEthereumClienter,
	l2Client aggkittypes.BaseEthereumClienter,
	rollupDataQuerier types.RollupDataQuerier,
	committeeQuerier types.MultisigQuerier,
	initialLER common.Hash,
) (*AggSender, error)

New returns a new AggSender instance

func (*AggSender) ForceTriggerCertificate added in v0.10.0

func (a *AggSender) ForceTriggerCertificate()

func (*AggSender) GetRPCServices

func (a *AggSender) GetRPCServices() []jRPC.Service

GetRPCServices returns the list of services that the RPC provider exposes

func (*AggSender) Info

func (a *AggSender) Info() types.AggsenderInfo

func (*AggSender) Start

func (a *AggSender) Start(ctx context.Context)

Start starts the AggSender

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,
	l2ClaimSyncer claimsynctypes.ClaimSyncer,
	flow types.AggsenderVerifierFlow,
	l1InfoTreeDataQuerier validator.L1InfoTreeRootByLeafQuerier,
	aggLayerClient agglayer.AggLayerClientCertificateIDQuerier,
	certQuerier types.CertificateQuerier,
	aggchainFEPQuerier types.AggchainFEPRollupQuerier,
	initialLER ethcommon.Hash,
	signer signertypes.Signer,
	initialBlockClaimSyncerSetter types.InitialBlockClaimSyncerSetter) (*AggsenderValidator, error)

func (*AggsenderValidator) Start added in v0.7.0

func (a *AggsenderValidator) Start(ctx context.Context)

Start starts the AggsenderValidator service.

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 RateLimiter added in v0.0.2

type RateLimiter interface {
	Call(msg string, allowToSleep bool) *time.Duration
	String() string
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL