Functions — github.com/Layr-Labs/eigensdk-go

hub / github.com/Layr-Labs/eigensdk-go / functions

Functions7,967 in github.com/Layr-Labs/eigensdk-go

⨍ Functions 7,967◇ Types & classes 1,471

Start starts the node api server in a goroutine

This function starts the service thread, initializing the aggregateResponses, initializeTask and processSignature channels, passing them to the run me

services/bls_aggregation/blsagg.go:290

↓ 1 callersMethodStorageAt

( ctx context.Context, account common.Address, key common.Hash, blockNumber *big.Int, )

chainio/clients/eth/instrumented_client.go:287

↓ 1 callersMethodSubscribeFilterLogs

( ctx context.Context, query ethereum.FilterQuery, ch chan<- types.Log, )

chainio/clients/eth/instrumented_client.go:301

↓ 1 callersMethodSubscribeNewHead

( ctx context.Context, ch chan<- *types.Header, )

chainio/clients/eth/instrumented_client.go:318

↓ 1 callersMethodSuggestGasPrice

(ctx context.Context)

chainio/clients/eth/instrumented_client.go:334

↓ 1 callersMethodSuggestGasTipCap

(ctx context.Context)

chainio/clients/eth/instrumented_client.go:343

↓ 1 callersMethodSyncProgress

(ctx context.Context)

chainio/clients/eth/instrumented_client.go:356

↓ 1 callersMethodToContractPubkeys

()

types/operator.go:105

↓ 1 callersMethodTransact

Transact invokes the (paid) contract method with params as input values.

M2-contracts/bindings/OperatorStateRetriever/binding.go:239

↓ 1 callersMethodTransact

Transact invokes the (paid) contract method with params as input values.

M2-contracts/bindings/IBLSSignatureChecker/binding.go:233

↓ 1 callersMethodTransact

Transact invokes the (paid) contract method with params as input values.

contracts/bindings/OperatorStateRetriever/binding.go:239

↓ 1 callersMethodTransactionByHash

We write the instrumentation of this function directly because instrumentFunction[] generic fct only takes a single return value

chainio/clients/eth/instrumented_client.go:371

↓ 1 callersMethodTransactionCount

(ctx context.Context, blockHash common.Hash)

chainio/clients/eth/instrumented_client.go:393

↓ 1 callersMethodTransactionInBlock

( ctx context.Context, blockHash common.Hash, index uint, )

chainio/clients/eth/instrumented_client.go:406

↓ 1 callersMethodTransactionReceipt

(ctx context.Context, txHash common.Hash)

chainio/clients/wallet/privatekey_wallet.go:16

↓ 1 callersMethodUpdateServiceStatus

(serviceId string, serviceStatus ServiceStatus)

nodeapi/nodeapi.go:82

↓ 1 callersMethodValidate

()

types/operator_metadata.go:33

↓ 1 callersFunctionValidateRawGithubUrl

(url string)

utils/utils.go:222

↓ 1 callersMethodVerify

Verify a message against a public key

crypto/bls/attestation.go:139

↓ 1 callersMethodWatchNewPubkeyRegistration

(opts *bind.WatchOpts, sink chan<- *ContractBLSApkRegistryNewPubkeyRegistration, operator []common.Address)

contracts/bindings/BLSApkRegistry/binding.go:165

↓ 1 callersMethodWatchOperatorSocketUpdate

(opts *bind.WatchOpts, sink chan<- *ContractRegistryCoordinatorOperatorSocketUpdate, operatorId [][32]byte)

contracts/bindings/RegistryCoordinator/binding.go:333

↓ 1 callersFunctionWriteKeyFromHex

(path, privateKeyHex, password string)

crypto/ecdsa/utils.go:21

↓ 1 callersMethodaddGasBuffer

(gasLimit uint64)

chainio/txmgr/geometric/geometric.go:627

↓ 1 callersFunctioncheckIfStakeThresholdsMet

checkIfStakeThresholdsMet checks at least quorumThresholdPercentage of stake has signed for each quorum.

services/bls_aggregation/blsagg.go:774

↓ 1 callersFunctioncloneStakePerQuorumMap

(stakes map[types.QuorumNum]types.StakeAmount)

services/bls_aggregation/blsagg.go:820

↓ 1 callersFunctionconvertIndexedOperatorInfoGqlToOperatorInfo

(operator *IndexedOperatorInfoGql)

services/operatorsinfo/operatorsinfo_subgraph.go:109

↓ 1 callersFunctioncreateDir

(c *cli.Context, prefix string)

cmd/egnkey/generate/generate.go:125

↓ 1 callersFunctioncreatePasswordAndPrivateKeyFiles

(folder string)

cmd/egnkey/generate/generate.go:150

↓ 1 callersFunctioncreateTx

(client eth.HttpBackend, address common.Address)

chainio/txmgr/geometric/geometric_example_test.go:27

↓ 1 callersFunctioncreateTxMgr

(rpcUrl string, ecdsaPrivateKey *ecdsa.PrivateKey)

chainio/txmgr/geometric/geometric_example_test.go:39

↓ 1 callersMethodensureAnyFireblocksTransactionBroadcasted

ensureAnyFireblocksTransactionBroadcasted waits until at least one of the bumped transactions are broadcasted to the network. this is only needed for

chainio/txmgr/geometric/geometric.go:270

↓ 1 callersMethodensureAnyTransactionConfirmed

ensureAnyTransactionConfirmed waits until at least one of the transactions is confirmed (mined + confirmationBlocks blocks). It returns the receipt of

chainio/txmgr/geometric/geometric.go:295

↓ 1 callersMethodestimateGasAndNonce

estimateGasAndNonce we are explicitly implementing this because * We want to support legacy transactions (i.e. not dynamic fee) * We want to support g

chainio/txmgr/simple.go:204

↓ 1 callersMethodestimateGasFeeCap

estimateGasFeeCap returns the gas fee cap for a transaction, calculated as: gasFeeCap = 2 * baseFee + gasTipCap Rationale: https://www.blocknative.com

chainio/txmgr/geometric/geometric.go:619

↓ 1 callersFunctionfillUnsetParamsWithDefaultValues

(params *GeometricTxnManagerParams)

chainio/txmgr/geometric/geometric.go:99

↓ 1 callersFunctiongenerateBlsKeys

(numKeys int, path string, passwordFile, privateKeyFile *os.File)

cmd/egnkey/generate/generate.go:163

↓ 1 callersFunctiongenerateECDSAKeys

(numKeys int, path string, passwordFile, privateKeyFile *os.File)

cmd/egnkey/generate/generate.go:199

↓ 1 callersFunctiongetAvsContractAddrs

( client *ethclient.Client, registryCoordinatorAddr common.Address, serviceManagerAddr common.Address, )

cmd/egnaddrs/main.go:166

↓ 1 callersFunctiongetClientAndVersion

Not sure why this method is not exposed in the ethclient itself... but it is needed to comply with the rpc metrics defined in avs-node spec https://do

chainio/clients/eth/instrumented_client.go:439

↓ 1 callersFunctiongetEigenlayerContractAddrs

( client *ethclient.Client, registryCoordinatorAddr common.Address, )

cmd/egnaddrs/main.go:204

↓ 1 callersFunctiongetEthereumSignature

(expectedPublicKeyBytes []byte, txHash []byte, r []byte, s []byte)

signerv2/kms_signer.go:83

↓ 1 callersMethodgetIndexedOperatorInfoByOperatorId

( ctx context.Context, operator common.Address, )

services/operatorsinfo/operatorsinfo_subgraph.go:90

↓ 1 callersFunctiongetPubkeyRegistrationParams

Returns the pubkey registration params for the operator given by `operatorAddress`.

chainio/clients/elcontracts/writer.go:947

↓ 1 callersFunctiongetRegCoordAndServiceMngrAddr

( c *cli.Context, client *ethclient.Client, )

cmd/egnaddrs/main.go:109

↓ 1 callersFunctiongetRegistrationWithChurnAbi

()

chainio/clients/elcontracts/writer.go:1066

↓ 1 callersMethodgetWhitelistedAccount

( ctx context.Context, address common.Address, )

chainio/clients/wallet/fireblocks_wallet.go:111

↓ 1 callersMethodgetWhitelistedContract

( ctx context.Context, address common.Address, )

chainio/clients/wallet/fireblocks_wallet.go:142

↓ 1 callersMethodhealthHandler

https://docs.eigenlayer.xyz/eigenlayer/avs-guides/spec/api/#get-eigennodehealth

nodeapi/nodeapi.go:137

↓ 1 callersMethodinitMetrics

()

metrics/eigenmetrics.go:64

↓ 1 callersMethodinitOperatorId

initialize the operatorId if it hasn't already been initialized

metrics/collectors/economic/economic.go:129

↓ 1 callersMethodmonitorTransaction

monitorTransaction waits until the transaction is confirmed (or failed) and resends it with a higher gas price if it is not mined without a timeout. I

chainio/txmgr/geometric/geometric.go:370

↓ 1 callersFunctionnewFakeAVSRegistryReader

()

metrics/collectors/economic/economic_test.go:53

↓ 1 callersFunctionnewFakeAVSRegistrySubscriber

( eventSubscription *fakeEventSubscription, pubkeyRegistrationEventC chan *blsapkreg.ContractBLSApkRegistryN

services/operatorsinfo/operatorsinfo_inmemory_test.go:32

↓ 1 callersFunctionnewFakeELReader

()

metrics/collectors/economic/economic_test.go:25

↓ 1 callersFunctionnewFakeEventSubscription

( errC chan error)

services/operatorsinfo/operatorsinfo_inmemory_test.go:56

↓ 1 callersFunctionnewIntegrationTestHarness

(t *testing.T)

chainio/txmgr/geometric/geometric_test.go:368

↓ 1 callersFunctionnewTxnRequest

(tx *types.Transaction)

chainio/txmgr/geometric/geometric.go:159

↓ 1 callersMethodnodeHandler

https://docs.eigenlayer.xyz/eigenlayer/avs-guides/spec/api/#get-eigennode

nodeapi/nodeapi.go:124

↓ 1 callersMethodprocessTransaction

processTransaction sends the transaction and runs a monitoring loop to bump the gasPrice until the tx get included. processTransaction can be called c

chainio/txmgr/geometric/geometric.go:185

↓ 1 callersMethodqueryPastRegisteredOperatorEventsAndFillDb

( ctx context.Context, opts Opts, )

services/operatorsinfo/operatorsinfo_inmemory.go:283

↓ 1 callersMethodqueryReceipt

(ctx context.Context, txID wallet.TxID)

chainio/txmgr/simple.go:185

↓ 1 callersFunctionrun

(logger logging.Logger, httpServer *http.Server)

nodeapi/nodeapi.go:201

↓ 1 callersMethodrun

Here is executed the main loop, where the requests are received from the initialize task and process signature channels, executing the corresponding l

services/bls_aggregation/blsagg.go:312

↓ 1 callersMethodrunService

( ctx context.Context, queryC <-chan query, wg *sync.WaitGroup, opts Opts, )

services/operatorsinfo/operatorsinfo_inmemory.go:129

↓ 1 callersMethodserviceHealthHandler

https://docs.eigenlayer.xyz/eigenlayer/avs-guides/spec/api/#get-eigennodeservicesservice_idhealth

nodeapi/nodeapi.go:167

↓ 1 callersMethodservicesHandler

https://docs.eigenlayer.xyz/eigenlayer/avs-guides/spec/api/#get-eigennodeservices

nodeapi/nodeapi.go:156

↓ 1 callersMethodsetCongestedBlocks

(n uint64)

chainio/txmgr/geometric/geometric_test.go:300

↓ 1 callersFunctionsetup

()

chainio/clients/eth/instrumented_client_test.go:43

↓ 1 callersFunctionsetup

()

aws/kms/get_public_key_test.go:36

↓ 1 callersFunctionsetup

()

signerv2/kms_signer_test.go:51

↓ 1 callersFunctionsignChurnRegistration

Returns the pubkey registration params for the operator given by `operatorAddress`.

chainio/clients/elcontracts/writer.go:978

↓ 1 callersMethodsignJwt

signJwt signs a JWT token for the Fireblocks API mostly copied from the Fireblocks example: https://github.com/fireblocks/developers-hub/blob/main/aut

chainio/clients/fireblocks/client.go:113

↓ 1 callersMethodsingleTaskAggregatorGoroutineFunc

( metadata TaskMetadata, signedTaskRespsC <-chan types.SignedTaskResponseDigest, aggregatedResponsesC chan<

services/bls_aggregation/blsagg.go:419

↓ 1 callersMethodspeedUpTxn

speedUpTxn increases the gas price of the existing transaction by specified percentage. It makes sure the new gas price is not lower than the current

chainio/txmgr/geometric/geometric.go:505

↓ 1 callersMethodstartMining

()

chainio/txmgr/geometric/geometric_test.go:271

↓ 1 callersMethodverifySignature

verifySignature verifies that a signature is valid against the operator pubkey stored in the operatorsAvsStateDict for that particular task

services/bls_aggregation/blsagg.go:713

↓ 1 callersFunctionwriteBytesToFile

(path string, data []byte)

crypto/ecdsa/utils.go:55

MethodALLOCATIONCONFIGURATIONDELAY

ALLOCATIONCONFIGURATIONDELAY is a free data retrieval call binding the contract method 0x7bc1ef61. Solidity: function ALLOCATION_CONFIGURATION_DELAY(

contracts/bindings/AllocationManager/binding.go:447

MethodALLOCATIONCONFIGURATIONDELAY

ALLOCATIONCONFIGURATIONDELAY is a free data retrieval call binding the contract method 0x7bc1ef61. Solidity: function ALLOCATION_CONFIGURATION_DELAY(

contracts/bindings/AllocationManager/binding.go:464

MethodALLOCATIONCONFIGURATIONDELAY

ALLOCATIONCONFIGURATIONDELAY is a free data retrieval call binding the contract method 0x7bc1ef61. Solidity: function ALLOCATION_CONFIGURATION_DELAY(

contracts/bindings/AllocationManager/binding.go:471

MethodAcceptAdmin

Accept a pending admin for the account given by `request.AccountAddress`. The sender of the transaction must be the pending admin.

chainio/clients/elcontracts/writer.go:845

MethodAcceptAdmin

AcceptAdmin is a paid mutator transaction binding the contract method 0x628806ef. Solidity: function acceptAdmin(address account) returns()

contracts/bindings/PermissionController/binding.go:541

MethodAcceptAdmin

AcceptAdmin is a paid mutator transaction binding the contract method 0x628806ef. Solidity: function acceptAdmin(address account) returns()

contracts/bindings/PermissionController/binding.go:548

MethodAcceptAdmin

AcceptAdmin is a paid mutator transaction binding the contract method 0x628806ef. Solidity: function acceptAdmin(address account) returns()

contracts/bindings/PermissionController/binding.go:555

MethodActivationDelay

ActivationDelay is a free data retrieval call binding the contract method 0x3a8c0786. Solidity: function activationDelay() view returns(uint32)

M2-contracts/bindings/IRewardsCoordinator/binding.go:561

MethodActivationDelay

ActivationDelay is a free data retrieval call binding the contract method 0x3a8c0786. Solidity: function activationDelay() view returns(uint32)

M2-contracts/bindings/IRewardsCoordinator/binding.go:578

MethodActivationDelay

ActivationDelay is a free data retrieval call binding the contract method 0x3a8c0786. Solidity: function activationDelay() view returns(uint32)

M2-contracts/bindings/IRewardsCoordinator/binding.go:585

MethodActivationDelay

ActivationDelay is a free data retrieval call binding the contract method 0x3a8c0786. Solidity: function activationDelay() view returns(uint32)

contracts/bindings/RewardsCoordinator/binding.go:680

MethodActivationDelay

ActivationDelay is a free data retrieval call binding the contract method 0x3a8c0786. Solidity: function activationDelay() view returns(uint32)

contracts/bindings/RewardsCoordinator/binding.go:697

MethodActivationDelay

ActivationDelay is a free data retrieval call binding the contract method 0x3a8c0786. Solidity: function activationDelay() view returns(uint32)

contracts/bindings/RewardsCoordinator/binding.go:704

MethodActiveValidatorCount

ActiveValidatorCount is a free data retrieval call binding the contract method 0x2340e8d3. Solidity: function activeValidatorCount() view returns(uin

chainio/clients/eigenpod/bindings/IEigenPod.go:228

MethodActiveValidatorCount

ActiveValidatorCount is a free data retrieval call binding the contract method 0x2340e8d3. Solidity: function activeValidatorCount() view returns(uin

chainio/clients/eigenpod/bindings/IEigenPod.go:245

MethodActiveValidatorCount

ActiveValidatorCount is a free data retrieval call binding the contract method 0x2340e8d3. Solidity: function activeValidatorCount() view returns(uin

chainio/clients/eigenpod/bindings/IEigenPod.go:252

MethodActiveValidatorCount

(opts *bind.CallOpts)

M2-contracts/bindings/EigenPod/binding.go:115

MethodActiveValidatorCount

ActiveValidatorCount is a free data retrieval call binding the contract method 0x2340e8d3. Solidity: function activeValidatorCount() view returns(uin

M2-contracts/bindings/EigenPod/binding.go:402

MethodActiveValidatorCount

ActiveValidatorCount is a free data retrieval call binding the contract method 0x2340e8d3. Solidity: function activeValidatorCount() view returns(uin

M2-contracts/bindings/EigenPod/binding.go:419

MethodActiveValidatorCount

ActiveValidatorCount is a free data retrieval call binding the contract method 0x2340e8d3. Solidity: function activeValidatorCount() view returns(uin

M2-contracts/bindings/EigenPod/binding.go:426

MethodActiveValidatorCount

ActiveValidatorCount is a free data retrieval call binding the contract method 0x2340e8d3. Solidity: function activeValidatorCount() view returns(uin

contracts/bindings/EigenPod/binding.go:405

MethodActiveValidatorCount

ActiveValidatorCount is a free data retrieval call binding the contract method 0x2340e8d3. Solidity: function activeValidatorCount() view returns(uin

contracts/bindings/EigenPod/binding.go:422

← previous next →1,201–1,300 of 7,967, ranked by callers