operator

Documentation

Overview

Package operator AVS operator logic.

Index

• Constants
• type AggregatorRPCClient
  • func NewAggregatorRPCClient(aggregatorIPPortAddr string, logger logging.Logger, metrics metrics.Metrics) (*AggregatorRPCClient, error)
  • func (c *AggregatorRPCClient) SendSignedTaskResponseToAggregator(signedTaskResponse *aggregator.SignedTaskResponse)
• type AggregatorRPCClienter
• type Operator
  • func NewOperatorFromConfig(c types.NodeConfig) (*Operator, error)
  • func (o *Operator) DepositIntoStrategy(strategyAddr common.Address, amount *big.Int) error
  • func (o *Operator) RegisterOperatorWithAvs(operatorEcdsaKeyPair *ecdsa.PrivateKey) error
  • func (o *Operator) RegisterOperatorWithEigenlayer() error
  • func (o *Operator) Start(ctx context.Context) error

Constants

const (
	AvsName = "preconfirmations"
	SemVer  = "0.0.1"
)

Types

type AggregatorRPCClient

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

func NewAggregatorRPCClient

func NewAggregatorRPCClient(aggregatorIPPortAddr string, logger logging.Logger, metrics metrics.Metrics) (*AggregatorRPCClient, error)

func (*AggregatorRPCClient) SendSignedTaskResponseToAggregator

func (c *AggregatorRPCClient) SendSignedTaskResponseToAggregator(signedTaskResponse *aggregator.SignedTaskResponse)

SendSignedTaskResponseToAggregator sends a signed task response to the aggregator. it is meant to be ran inside a go thread, so doesn't return anything. this is because sending the signed task response to the aggregator is time sensitive, so there is no point in retrying if it fails for a few times. Currently hardcoded to retry sending the signed task response 5 times, waiting 2 seconds in between each attempt.

type AggregatorRPCClienter

type AggregatorRPCClienter interface {
	SendSignedTaskResponseToAggregator(signedTaskResponse *aggregator.SignedTaskResponse)
}

type Operator

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

func NewOperatorFromConfig

func NewOperatorFromConfig(c types.NodeConfig) (*Operator, error)

NewOperatorFromConfig the config in core (which is shared with aggregator and challenger)

func (*Operator) DepositIntoStrategy

func (o *Operator) DepositIntoStrategy(strategyAddr common.Address, amount *big.Int) error

func (*Operator) RegisterOperatorWithAvs

func (o *Operator) RegisterOperatorWithAvs(
	operatorEcdsaKeyPair *ecdsa.PrivateKey,
) error

RegisterOperatorWithAvs Registration specific functions

func (*Operator) RegisterOperatorWithEigenlayer

func (o *Operator) RegisterOperatorWithEigenlayer() error

func (*Operator) Start

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