operator

package
v0.5.0 Latest Latest
Warning

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

Go to latest
Published: Oct 23, 2024 License: Apache-2.0 Imports: 39 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ABI = func() abi.ABI {
	ty := `[{"inputs":[{"internalType":"uint8","name":"_version","type":"uint8"},{"internalType":"bytes","name":"_parentBatchHeader","type":"bytes"},{"internalType":"bytes[]","name":"_chunks","type":"bytes[]"},{"internalType":"bytes","name":"_skippedL1MessageBitmap","type":"bytes"}],"name":"commitBatch","outputs":[],"stateMutability":"nonpayable","type":"function"}]`
	result, err := abi.JSON(bytes.NewReader([]byte(ty)))
	if err != nil {
		panic(err)
	}
	return result
}()

Functions

This section is empty.

Types

type Config

type Config struct {
	ProverURL     string
	AggregatorURL string
	Identifier    int64

	BlsKeyFile     string
	BlsKeyPassword string

	EthRpcUrl string

	AttestationLayerProfile  string
	AttestationLayerEcdsaKey string
	AttestationLayerRpcURL   string

	RegistryCoordinatorAddress    common.Address
	OperatorStateRetrieverAddress common.Address

	TEELivenessVerifierAddress common.Address
	EigenMetricsIpPortAddress  string
	NodeApiIpPortAddress       string
}

func (*Config) InitFromEnv added in v0.2.0

func (c *Config) InitFromEnv()

type ConfigContext

type ConfigContext struct {
	Config              *Config
	BlsKey              *bls.KeyPair
	AttestationEcdsaKey *ecdsa.PrivateKey
	Client              *ethclient.Client
	AttestationClient   *ethclient.Client
	EigenClients        *clients.Clients
	AvsName             string
}

func ParseConfigContext

func ParseConfigContext(cfgPath string, ecdsaKey *ecdsa.PrivateKey) (*ConfigContext, error)

func (*ConfigContext) QueryOperatorAddress

func (c *ConfigContext) QueryOperatorAddress() (common.Address, error)

type Metrics

type Metrics struct {
	EigenMetrics eigenmetrics.Metrics
	// contains filtered or unexported fields
}

func NewMetrics

func NewMetrics(appName string, clients *clients.Clients, logger logging.Logger, operatorAddr common.Address, socketAddr string, quorumNames map[types.QuorumNum]string) *Metrics

func (*Metrics) Gather added in v0.2.0

func (g *Metrics) Gather() ([]*xmetric.MetricFamily, error)

func (*Metrics) Serve added in v0.2.0

func (c *Metrics) Serve(addr string, proverAddr string) chan error

type Operator

type Operator struct {
	TEELivenessVerifier *TEELivenessVerifier.TEELivenessVerifier
	// contains filtered or unexported fields
}

func NewOperator

func NewOperator(path string, semVer string) (*Operator, error)

func (*Operator) RegisterAttestationReport

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

func (*Operator) Start

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

type TaskFetcher

type TaskFetcher struct {
	Endpoint         string
	Topics           [][]common.Hash
	Addresses        []common.Address
	OffsetFile       string
	ScanIntervalSecs int64
}

Jump to

Keyboard shortcuts

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