aggsender

package
v0.9.0-rc2 Latest Latest
Warning

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

Go to latest
Published: Feb 5, 2026 License: Apache-2.0, MIT Imports: 29 Imported by: 0

Documentation

Index

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 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) ForceTriggerCertificate

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 (*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 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