utils

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: 24 Imported by: 0

Documentation

Index

Constants

View Source 
const ATT_AUTOMATA = "automata"
View Source 
const ATT_AUTOMATA_TEST = "automata_test"
View Source 
const ATT_HOLESKY = "holesky"
View Source 
const ATT_OPTIMISM = "optimism"
View Source 
const MULTI_PROVER_AVS_NAME = "MultiProverAVS"

Variables

View Source 
var HoleskyTestnetPreset = &PresetConfig{
	RegistryCoordinatorAddress:    common.HexToAddress("0x62c715575cE3Ad7C5a43aA325b881c70564f2215"),
	OperatorStateRetrieverAddress: common.HexToAddress("0xbfd43ac0a19c843e44491c3207ea13914818E214"),
	LineaProverURL:                "https://avs-prover-staging.ata.network",
	ScrollProverURL:               "https://avs-prover-staging.ata.network",
	DefaultAttestationLayer:       ATT_HOLESKY,
	AttestationLayer: map[string]*PresetAttestationConfig{
		ATT_HOLESKY: {
			Address: common.HexToAddress("0x2E8628F6000Ef85dea615af6Da4Fd6dF4fD149e6"),
		},
		ATT_AUTOMATA_TEST: {
			URL:     "https://rpc.ata.network",
			Address: common.HexToAddress("0x2c674af4C9B6DE266E4515Be0E2A9C1c30452026"),
		},
	},
}
View Source 
var MainnetPreset = &PresetConfig{
	RegistryCoordinatorAddress:    common.HexToAddress("0x414696E4F7f06273973E89bfD3499e8666D63Bd4"),
	OperatorStateRetrieverAddress: common.HexToAddress("0x91246253d3Bff9Ae19065A90dC3AB6e09EefD2B6"),
	LineaProverURL:                "https://avs-prover-mainnet1.ata.network:18232",
	ScrollProverURL:               "https://avs-prover-mainnet1.ata.network:18232",
	DefaultAttestationLayer:       ATT_OPTIMISM,
	AttestationLayer: map[string]*PresetAttestationConfig{
		ATT_OPTIMISM: {
			URL:     "",
			Address: common.HexToAddress("0x99886d5C39c0DF3B0EAB67FcBb4CA230EF373510"),
		},
		ATT_AUTOMATA: {
			URL:     "https://rpc.ata.network",
			Address: common.HexToAddress("0x2c674af4C9B6DE266E4515Be0E2A9C1c30452026"),
		},
	},
}
View Source 
var PresetConfigs = []*PresetConfig{HoleskyTestnetPreset, MainnetPreset}
View Source 
var (
	ZeroAddress common.Address
)

Functions

func BytesToQuorumNums 

func BytesToQuorumNums(data []byte) types.QuorumNums

func EcdsaAddress 

func EcdsaAddress(key *ecdsa.PrivateKey) common.Address

func ExpandPubkey 

func ExpandPubkey(pubkey *bls.G1Point) ([32]byte, [32]byte)

func FixFilepath 

func FixFilepath(path string) string

func GetAvsName added in v0.2.0 

func GetAvsName(chainID *big.Int) string

func GetTxCost added in v0.2.0 

func GetTxCost(receipt *types.Receipt) float64

func PromptEcdsaKey 

func PromptEcdsaKey(path string) (*ecdsa.PrivateKey, error)

func ProverAddrHash added in v0.2.0 

func ProverAddrHash(url string) common.Hash

func ReadBlsKey 

func ReadBlsKey(path string, password string) (*bls.KeyPair, error)

func ReadPassword 

func ReadPassword(prompt string) (string, error)

func Retry added in v0.2.3 

func Retry[T any](retryTime int, sleep time.Duration, fn func() (T, error), ctx ...interface{}) (out T, err error)

func SplitPubkey 

func SplitPubkey(pubkey []byte) ([32]byte, [32]byte)

func WaitTx 

func WaitTx(ctx context.Context, client *ethclient.Client, tx *types.Transaction, deferFunc func()) (*types.Receipt, error)

func WeiToF64 added in v0.2.0 

func WeiToF64(val *big.Int, decimals int64) float64

Types

type KeyLogTracer added in v0.3.0 

type KeyLogTracer struct{}

func (KeyLogTracer) Get added in v0.3.0 

func (c KeyLogTracer) Get(ctx context.Context) *LogTracer

func (KeyLogTracer) Save added in v0.3.0 

func (c KeyLogTracer) Save(ctx context.Context, client *LogTracer) context.Context

type KeyLogTracerSourceClient added in v0.2.0 

type KeyLogTracerSourceClient struct{}

func (KeyLogTracerSourceClient) Get added in v0.2.0 

func (c KeyLogTracerSourceClient) Get(ctx context.Context) *ethclient.Client

func (KeyLogTracerSourceClient) Save added in v0.2.0 

func (c KeyLogTracerSourceClient) Save(ctx context.Context, client *ethclient.Client) context.Context

type LogHandler added in v0.2.0 

type LogHandler interface {
	GetBlock() (uint64, error)
	SaveBlock(uint64) error
	OnNewLog(ctx context.Context, log *types.Log) error
}

type LogTracer added in v0.2.0 

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

func NewLogTracer added in v0.2.0 

func NewLogTracer(source *ethclient.Client, cfg *LogTracerConfig) *LogTracer

func (*LogTracer) LookBack added in v0.3.0 

func (l *LogTracer) LookBack(ctx context.Context, end int64) (*types.Log, error)

func (*LogTracer) Run added in v0.2.0 

func (l *LogTracer) Run(ctx context.Context) error

type LogTracerConfig added in v0.2.0 

type LogTracerConfig struct {
	Id               string
	Wait             uint64
	Max              uint64
	Topics           [][]common.Hash
	Addresses        []common.Address
	Handler          LogHandler
	ScanIntervalSecs int64
	SkipOnError      bool
}

type Logger 

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

func NewLogger 

func NewLogger(raw *logex.Logger) *Logger

func (*Logger) Debug 

func (l *Logger) Debug(msg string, tags ...any)

func (*Logger) Debugf 

func (l *Logger) Debugf(template string, args ...interface{})

func (*Logger) Error 

func (l *Logger) Error(msg string, tags ...any)

func (*Logger) Errorf 

func (l *Logger) Errorf(template string, args ...interface{})

func (*Logger) Fatal 

func (l *Logger) Fatal(msg string, tags ...any)

func (*Logger) Fatalf 

func (l *Logger) Fatalf(template string, args ...interface{})

func (*Logger) Info 

func (l *Logger) Info(msg string, tags ...any)

func (*Logger) Infof 

func (l *Logger) Infof(template string, args ...interface{})

func (*Logger) Warn 

func (l *Logger) Warn(msg string, tags ...any)

func (*Logger) Warnf 

func (l *Logger) Warnf(template string, args ...interface{})

func (*Logger) With 

func (l *Logger) With(args ...any) logging.Logger

type OperatorAvsStateMap added in v0.2.3 

type OperatorAvsStateMap = map[types.OperatorId]types.OperatorAvsState

type PresetAttestationConfig added in v0.5.0 

type PresetAttestationConfig struct {
	Address common.Address
	URL     string
}

type PresetConfig added in v0.3.0 

type PresetConfig struct {
	RegistryCoordinatorAddress    common.Address
	OperatorStateRetrieverAddress common.Address
	// TEELivenessVerifierAddress    common.Address
	DefaultAttestationLayer string
	AttestationLayer        map[string]*PresetAttestationConfig
	LineaProverURL          string
	ScrollProverURL         string
}

func PresetConfigByRegistryCoordinatorAddress added in v0.3.0 

func PresetConfigByRegistryCoordinatorAddress(registryCoordinatorAddress common.Address) *PresetConfig

func (*PresetConfig) GetAttestationLayer added in v0.5.0 

func (p *PresetConfig) GetAttestationLayer(profile string) *PresetAttestationConfig

type QuorumAvsStateMap added in v0.2.3 

type QuorumAvsStateMap = map[types.QuorumNum]types.QuorumAvsState

type RegistryCache added in v0.2.3 

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

func NewRegistryCache added in v0.2.3 

func NewRegistryCache(avsStateCaller *avsregistry.AvsRegistryServiceChainCaller) *RegistryCache

func (*RegistryCache) GetCheckSignaturesIndices added in v0.2.3 

func (c *RegistryCache) GetCheckSignaturesIndices(opts *bind.CallOpts, referenceBlockNumber types.BlockNum, quorumNumbers types.QuorumNums, nonSignerOperatorIds []types.OperatorId) (opstateretriever.OperatorStateRetrieverCheckSignaturesIndices, error)

func (*RegistryCache) GetOperatorsAvsStateAtBlock added in v0.2.3 

func (c *RegistryCache) GetOperatorsAvsStateAtBlock(ctx context.Context, quorumNumbers types.QuorumNums, blockNumber types.BlockNum) (OperatorAvsStateMap, error)

func (*RegistryCache) GetQuorumsAvsStateAtBlock added in v0.2.3 

func (c *RegistryCache) GetQuorumsAvsStateAtBlock(ctx context.Context, quorumNumbers types.QuorumNums, blockNumber types.BlockNum) (QuorumAvsStateMap, error)

type SingleFlightLruCache added in v0.2.3 

type SingleFlightLruCache[K comparable, V any] struct {
	// contains filtered or unexported fields
}

func NewSingleFlightLruCache added in v0.2.3 

func NewSingleFlightLruCache[K comparable, V any](cap int) *SingleFlightLruCache[K, V]

func (*SingleFlightLruCache[K, V]) Get added in v0.2.3 

func (s *SingleFlightLruCache[K, V]) Get(key K, getter func(key K) (V, error)) (V, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.