operator

package

v0.0.0-...-28ca4d1 Latest Latest Go to latest Published: Mar 25, 2024 License: AGPL-3.0 Imports: 33 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/cairoeth/preconfirmations

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)

Constants ¶

View Source

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

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
cmd
operator
core
chainio Package chainio contains the logic to interact with the AVS contracts onchain.	Package chainio contains the logic to interact with the AVS contracts onchain.
config Package config contains the config types.	Package config contains the config types.
receiverapi Package receiverapi contains the logic to receive preconfirmation callbacks.	Package receiverapi contains the logic to receive preconfirmation callbacks.
sse Package sse is the SSE Client for preconf-share	Package sse is the SSE Client for preconf-share
types Package types contains the types used in the AVS JSON-RPC communication.	Package types contains the types used in the AVS JSON-RPC communication.

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