operator

package

v0.20.0 Latest Latest Go to latest Published: Oct 28, 2025 License: MIT Imports: 43 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/yetanotherco/aligned_layer

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func BaseUrlOnly(input string) (string, error)
func IsVerifierDisabled(disabledVerifiersBitmap *big.Int, verifierId common.ProvingSystemId) bool
func RegisterOperator(ctx context.Context, configuration *config.OperatorConfig, ...) error
type AggregatorRpcClient
- func NewAggregatorRpcClient(aggregatorIpPortAddr string, logger logging.Logger) (*AggregatorRpcClient, error)
- func (c *AggregatorRpcClient) SendSignedTaskResponseToAggregator(signedTaskResponse *types.SignedTaskResponse)
type Operator
- func NewOperatorFromConfig(configuration config.OperatorConfig) (*Operator, error)
type OperatorLastProcessedBatch
type VerificationData

Constants ¶

View Source

const (
	// This time out will even kill the retries, so it should be enough
	// for them to be completed in most cases
	BatchDownloadTimeout    = 3 * time.Minute
	BatchDownloadMaxRetries = 4
	BatchDownloadRetryDelay = 5 * time.Second
	UnverifiedBatchOffset   = 100
)

View Source

const (
	MaxRetries    = 10
	RetryInterval = 10 * time.Second
)

View Source

const (
	MaxBatchURLs = 5
)

Variables ¶

This section is empty.

Functions ¶

func BaseUrlOnly ¶ added in v0.10.0

func BaseUrlOnly(input string) (string, error)

func IsVerifierDisabled ¶ added in v0.10.0

func IsVerifierDisabled(disabledVerifiersBitmap *big.Int, verifierId common.ProvingSystemId) bool

func RegisterOperator ¶ added in v0.1.5

func RegisterOperator(
	ctx context.Context,
	configuration *config.OperatorConfig,
	ecdsaConfig *config.EcdsaConfig,
	operatorToAvsRegistrationSigSalt [32]byte,
) error

RegisterOperator operator registers the operator with the given public key for the given quorum IDs. RegisterOperator registers a new operator with the given public key and socket with the provided quorum ids. If the operator is already registered with a given quorum id, the transaction will fail (noop) and an error will be returned.

Types ¶

type AggregatorRpcClient ¶

type AggregatorRpcClient struct {
	// contains filtered or unexported fields
}

AggregatorRpcClient is the client to communicate with the aggregator via RPC

func NewAggregatorRpcClient ¶

func NewAggregatorRpcClient(aggregatorIpPortAddr string, logger logging.Logger) (*AggregatorRpcClient, error)

func (*AggregatorRpcClient) SendSignedTaskResponseToAggregator ¶

func (c *AggregatorRpcClient) SendSignedTaskResponseToAggregator(signedTaskResponse *types.SignedTaskResponse)

SendSignedTaskResponseToAggregator is the method called by operators via RPC to send their signed task response.

type Operator ¶

type Operator struct {
	Config     config.OperatorConfig
	Address    ethcommon.Address
	Socket     string
	Timeout    time.Duration
	KeyPair    *bls.KeyPair
	OperatorId eigentypes.OperatorId

	NewTaskCreatedChanV3 chan *servicemanager.ContractAlignedLayerServiceManagerNewBatchV3
	Logger               logging.Logger
	// contains filtered or unexported fields
}

func NewOperatorFromConfig ¶

func NewOperatorFromConfig(configuration config.OperatorConfig) (*Operator, error)

func (*Operator) LoadLastProcessedBatch ¶ added in v0.9.0

func (o *Operator) LoadLastProcessedBatch() error

func (*Operator) ProcessMissedBatchesWhileOffline ¶ added in v0.9.0

func (o *Operator) ProcessMissedBatchesWhileOffline()

Here we query all the batches that have not yet been verified starting from the latest verified batch by the operator. We also read from the previous `UnverifiedBatchOffset` blocks, because as batches are processed in parallel, there could be unverified batches slightly before the latest verified batch

func (*Operator) ProcessNewBatchLogV3 ¶ added in v0.7.0

func (o *Operator) ProcessNewBatchLogV3(newBatchLog *servicemanager.ContractAlignedLayerServiceManagerNewBatchV3) error

func (*Operator) SendTelemetryData ¶ added in v0.10.0

func (o *Operator) SendTelemetryData(ctx *cli.Context) error

func (*Operator) SignTaskResponse ¶

func (o *Operator) SignTaskResponse(batchIdentifierHash [32]byte) *bls.Signature

func (*Operator) Start ¶

func (o *Operator) Start(ctx context.Context) error

func (*Operator) SubscribeToNewTasksV3 ¶ added in v0.7.0

func (o *Operator) SubscribeToNewTasksV3(errorPairChan chan chainio.ErrorPair) *chainio.ErrorPair

func (*Operator) UpdateLastProcessBatch ¶ added in v0.9.0

func (o *Operator) UpdateLastProcessBatch(blockNumber uint32) error

type OperatorLastProcessedBatch ¶ added in v0.9.0

type OperatorLastProcessedBatch struct {
	BlockNumber uint32 `json:"block_number"`
	// contains filtered or unexported fields
}

type VerificationData ¶ added in v0.1.2

type VerificationData struct {
	ProvingSystemId common.ProvingSystemId `json:"proving_system"`
	Proof           []byte                 `json:"proof"`
	PubInput        []byte                 `json:"pub_input"`
	VerificationKey []byte                 `json:"verification_key"`
	VmProgramCode   []byte                 `json:"vm_program_code"`
}

Source Files ¶

View all Source files

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