MCPcopy Create free account

hub / github.com/0gfoundation/0g-da-client / functions

Functions1,054 in github.com/0gfoundation/0g-da-client

↓ 1 callersFunctionParseBlobKey
(key string)
disperser/disperser.go:59
↓ 1 callersMethodParseDataUpload
ParseDataUpload is a log parse operation binding the contract event 0xf0bf37f8713754493879920443065424c575888634675f146c115709bbb59acb. Solidity: eve
disperser/contract/da_entrance/da_entrance.go:572
↓ 1 callersMethodPendingCallContract
(ctx context.Context, msg ethereum.CallMsg)
common/ethclient.go:28
↓ 1 callersMethodPendingCodeAt
(ctx context.Context, account common.Address)
common/ethclient.go:29
↓ 1 callersMethodPendingNonceAt
(ctx context.Context, account common.Address)
common/ethclient.go:30
↓ 1 callersMethodPersistConfirmedBlobs
(ctx context.Context, metadatas []*disperser.BlobMetadata)
disperser/batcher/finalizer.go:210
↓ 1 callersMethodProcessEncodedBlobs
(ctx context.Context, result EncodingResultOrStatus)
disperser/batcher/encoding_streamer.go:246
↓ 1 callersMethodPublicIPAddress
(ctx context.Context)
common/pubip/pubip.go:49
↓ 1 callersMethodPutEncodingRequest
(blobKey disperser.BlobKey)
disperser/batcher/encoded_blob_store.go:56
↓ 1 callersMethodPutEncodingResult
(result *EncodingResult)
disperser/batcher/encoded_blob_store.go:92
↓ 1 callersMethodPutItems
PutItems puts items in batches of 25 items (which is a limit DynamoDB imposes) It returns the items that failed to be put.
common/aws/dynamodb/client.go:134
↓ 1 callersMethodQueueNewBlobMetadata
(ctx context.Context, blobMetadata *disperser.BlobMetadata)
disperser/common/blobstore/blob_metadata_store.go:46
↓ 1 callersMethodReceive
Receive is a paid mutator transaction binding the contract receive function. Solidity: receive() payable returns()
disperser/contract/da_entrance/da_entrance.go:434
↓ 1 callersFunctionRegisterHealthServer
RegisterHealthServer registers the HealthServer with the provided gRPC server.
common/healthcheck/server.go:25
↓ 1 callersMethodRegisterNextEpoch
RegisterNextEpoch is a paid mutator transaction binding the contract method 0x56a32372. Solidity: function registerNextEpoch((uint256,uint256) _signa
disperser/contract/da_signers/da_signers.go:449
↓ 1 callersMethodRegisterSigner
RegisterSigner is a paid mutator transaction binding the contract method 0x7ca4dd5e. Solidity: function registerSigner((address,string,(uint256,uint2
disperser/contract/da_signers/da_signers.go:470
↓ 1 callersMethodRemoveBlobMetadata
(ctx context.Context, blobMetadata *disperser.BlobMetadata)
disperser/common/blobstore/blob_metadata_store.go:55
↓ 1 callersMethodRequestEncoding
(ctx context.Context, encoderChan chan EncodingResultOrStatus)
disperser/batcher/encoding_streamer.go:150
↓ 1 callersMethodRequestEncodingForBlob
(ctx context.Context, metadata *disperser.BlobMetadata, blob *core.Blob, encoderChan chan EncodingResultOrStat
disperser/batcher/encoding_streamer.go:208
↓ 1 callersMethodRetrieveBlob
This fans out request to ZGDA Nodes to retrieve the chunks and returns the reconstructed original blob in response.
disperser/api/grpc/retriever/retriever_grpc.pb.go:27
↓ 1 callersFunctionRunBatcher
(config Config, queue disperser.BlobStore, logger common.Logger, kvStore *disperser.Store)
disperser/cmd/combined_server/main.go:92
↓ 1 callersFunctionRunDisperserServer
(config Config, blobStore disperser.BlobStore, logger common.Logger, kvStore *disperser.Store)
disperser/cmd/combined_server/main.go:56
↓ 1 callersMethodSetBatchRoot
SetBatchRoot sets the BatchRoot field of the BatchHeader to the Merkle root of the blob headers in the batch (i.e. the root of the Merkle tree whose l
core/serialization.go:18
↓ 1 callersMethodSetHandler
SetHandler updates the logger to write records to the specified handler.
common/logging.go:10
↓ 1 callersMethodStopWait
()
common/workerpool.go:9
↓ 1 callersMethodStorageAt
(ctx context.Context, account common.Address, key common.Hash, blockNumber *big.Int)
common/ethclient.go:32
↓ 1 callersMethodStoreBlob
StoreBlob adds a blob to the queue and returns a key that can be used to retrieve the blob later
disperser/disperser.go:205
↓ 1 callersMethodStoreMetadataBatch
(ctx context.Context, blobKeys [][]byte, metadatas [][]byte, blobs [][]byte)
disperser/store.go:166
↓ 1 callersMethodSubmitAggregateSignatures
(ctx context.Context, rootSubmission []*core.CommitRootSubmission)
disperser/disperser.go:237
↓ 1 callersMethodSubmitLogEntry
(daContract *contract.DAContract, dataRoots []eth_common.Hash)
disperser/batcher/transactor/transactor.go:29
↓ 1 callersMethodSubmitOriginalData
(dataRoots []eth_common.Hash, waitForReceipt bool)
disperser/contract/contract.go:118
↓ 1 callersMethodSubmitOriginalData
SubmitOriginalData is a paid mutator transaction binding the contract method 0xd4ae59c9. Solidity: function submitOriginalData(bytes32[] _dataRoots)
disperser/contract/da_entrance/da_entrance.go:392
↓ 1 callersMethodSubmitVerifiedCommitRoots
SubmitVerifiedCommitRoots is a paid mutator transaction binding the contract method 0xeafed6ce. Solidity: function submitVerifiedCommitRoots((bytes32
disperser/contract/da_entrance/da_entrance.go:413
↓ 1 callersMethodSubmitVerifiedCommitRoots
(daContract *contract.DAContract, submissions []da_entrance.IDAEntranceCommitRootSubmission)
disperser/batcher/transactor/transactor.go:55
↓ 1 callersMethodSubscribeFilterLogs
(ctx context.Context, q ethereum.FilterQuery, ch chan<- types.Log)
common/ethclient.go:33
↓ 1 callersMethodSubscribeNewHead
(ctx context.Context, ch chan<- *types.Header)
common/ethclient.go:34
↓ 1 callersMethodSuggestGasPrice
(ctx context.Context)
common/ethclient.go:35
↓ 1 callersMethodSuggestGasTipCap
(ctx context.Context)
common/geth/instrumented_client.go:362
↓ 1 callersMethodTransactionByHash
(ctx context.Context, hash common.Hash)
common/ethclient.go:37
↓ 1 callersMethodTransactionCount
(ctx context.Context, blockHash common.Hash)
common/ethclient.go:38
↓ 1 callersMethodTransactionInBlock
(ctx context.Context, blockHash common.Hash, index uint)
common/ethclient.go:39
↓ 1 callersMethodTransfer
Transfer initiates a plain transaction to move funds to the contract, calling its default method if one is available.
disperser/contract/da_signers/da_signers.go:175
↓ 1 callersMethodTransfer
Transfer initiates a plain transaction to move funds to the contract, calling its default method if one is available.
disperser/contract/da_entrance/da_entrance.go:178
↓ 1 callersMethodUpdateBlobMetadata
(ctx context.Context, metadataKey disperser.BlobKey, updated *disperser.BlobMetadata)
disperser/common/blobstore/blob_metadata_store.go:179
↓ 1 callersMethodUpdateEncodedBlobs
(count int, size uint64)
disperser/batcher/metrics.go:201
↓ 1 callersMethodUpdateGas
UpdateGas returns an otherwise identical txn to the one provided but with updated gas prices sampled from the existing network conditions and an accur
common/geth/client.go:108
↓ 1 callersMethodUpdateNetworks
(n Networks, startBlock int)
inabox/deploy/subgraph.go:68
↓ 1 callersMethodUpdateSignedBlobs
(count int, size uint64)
disperser/batcher/metrics.go:196
↓ 1 callersMethodUpdateSocket
UpdateSocket is a paid mutator transaction binding the contract method 0x0cf4b767. Solidity: function updateSocket(string _socket) returns()
disperser/contract/da_signers/da_signers.go:491
↓ 1 callersMethodUpdateSubgraph
(s *Subgraph, startBlock int)
inabox/deploy/subgraph.go:67
↓ 1 callersMethodVerify
Verify a message against a G2 public key
core/attestation.go:149
↓ 1 callersFunctionWaitForReceipt
(client *web3go.Client, txHash eth_common.Hash, successRequired bool, opts ...RetryOption)
disperser/contract/contract.go:162
↓ 1 callersMethodWaitingQueueSize
()
common/workerpool.go:13
↓ 1 callersMethodWarn
(msg string, ctx ...interface{})
common/mock/logging.go:49
↓ 1 callersMethodWriteBatch
(keys, values [][]byte)
disperser/db.go:13
↓ 1 callersMethod__safe_close_stdout_stderr__
(self)
tests/da_test_framework/test_node.py:178
↓ 1 callersMethod__start_logging
(self)
tests/da_test_framework/da_test_framework.py:66
↓ 1 callersMethod_raise_assertion_error
Raise an AssertionError with msg modified to identify this node.
tests/da_test_framework/test_node.py:81
↓ 1 callersMethodadd_arguments
(self, parser: argparse.ArgumentParser)
tests/da_test_framework/da_test_framework.py:100
↓ 1 callersMethodaggregateSignature
(ctx context.Context, signInfo *SignInfo, update chan SignRequestResultOrStatus)
disperser/batcher/slice_signer.go:551
↓ 1 callersMethodassignEncodedBlobs
(signInfo *SignInfo)
disperser/batcher/slice_signer.go:509
↓ 1 callersMethodbuild_binary
(self)
tests/da_test_framework/da_test_framework.py:179
↓ 1 callersMethodbuild_blockchain
(self, blockchain_binary_path, blockchain_path)
tests/da_test_framework/da_test_framework.py:205
↓ 1 callersFunctionbuild_conflux
(conflux_path)
tests/da_test_all.py:145
↓ 1 callersMethodbuild_da_encoder
(self, binary_path, src_code_path)
tests/da_test_framework/da_test_framework.py:244
↓ 1 callersMethodbuild_da_server
(self, binary_path, src_code_path)
tests/da_test_framework/da_test_framework.py:280
↓ 1 callersMethodbuild_da_signer
(self, binary_path, src_code_path)
tests/da_test_framework/da_test_framework.py:262
↓ 1 callersFunctiondefaultSigner
(clientWithSigner *web3go.Client)
disperser/contract/contract.go:46
↓ 1 callersMethoddeleteNBlobs
(currentTimeUnixSec int64, numBatches int)
disperser/store.go:69
↓ 1 callersMethoddisperse_blob
(self, data)
tests/da_test_framework/da_server.py:89
↓ 1 callersMethoddoRequest
(ctx context.Context, url string)
common/pubip/pubip.go:60
↓ 1 callersMethoddoSigning
(ctx context.Context, signInfo *SignInfo)
disperser/batcher/slice_signer.go:455
↓ 1 callersMethodexpireLoop
The expireLoop is a loop that is run once per configured second(s) while the node is running. It scans for expired blobs and removes them from the loc
disperser/batcher/finalizer.go:290
↓ 1 callersFunctionfile_disperser_disperser_proto_init
()
api/grpc/disperser/disperser.pb.go:654
↓ 1 callersFunctionfile_encoder_encoder_proto_init
()
disperser/api/grpc/encoder/encoder.pb.go:220
↓ 1 callersFunctionfile_retriever_retriever_proto_init
()
disperser/api/grpc/retriever/retriever.pb.go:191
↓ 1 callersFunctionfile_retriever_retriever_proto_init
()
api/grpc/retriever/retriever.pb.go:207
↓ 1 callersFunctionfile_signer_signer_proto_init
()
disperser/api/grpc/signer/signer.pb.go:261
↓ 1 callersMethodgetBlobContentParallel
(ctx context.Context, blobKey disperser.BlobKey, blobRequestHeader core.BlobRequestHeader, resultChan chan<- b
disperser/common/blobstore/shared_storage.go:152
↓ 1 callersFunctiongetBlobFromRequest
(req *pb.DisperseBlobRequest)
disperser/apiserver/server.go:337
↓ 1 callersFunctiongetBlobHash
(blob *core.Blob)
disperser/common/memorydb/memorydb.go:298
↓ 1 callersFunctiongetBlobHash
(blob *core.Blob)
disperser/common/blobstore/shared_storage.go:267
↓ 1 callersFunctiongetBucketLevel
(bucketLevel, bucketSize, interval, deduction time.Duration)
common/ratelimit/limiter.go:90
↓ 1 callersFunctiongetClient
(clientConfig commonaws.ClientConfig)
common/aws/dynamodb/utils_test.go:41
↓ 1 callersFunctiongetClient
(clientConfig commonaws.ClientConfig)
common/aws/dynamodb/utils/test_utils.go:41
↓ 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://ei
common/geth/instrumented_client.go:590
↓ 1 callersFunctiongetGasFeeCap
getGasFeeCap returns the gas fee cap for a transaction, calculated as: gasFeeCap = 2 * baseFee + gasTipCap Rationale: https://www.blocknative.com/blog
common/geth/client.go:264
↓ 1 callersMethodgetMetadataFromKv
(ctx context.Context, key []byte)
disperser/apiserver/server.go:130
↓ 1 callersFunctiongetMetadataHash
(requestedAt uint64)
disperser/common/memorydb/memorydb.go:305
↓ 1 callersFunctiongetMetadataHash
(requestedAt uint64, securityParams []*core.SecurityParam)
disperser/common/blobstore/shared_storage.go:251
↓ 1 callersMethodgetPendingBatch
()
disperser/batcher/slice_signer.go:245
↓ 1 callersMethodgetPendingBatch
()
disperser/batcher/confirmer.go:121
↓ 1 callersMethodgetPendingBatchToSign
()
disperser/batcher/slice_signer.go:442
↓ 1 callersMethodgetSigners
(epoch *big.Int, quorumId *big.Int)
disperser/batcher/slice_signer.go:359
↓ 1 callersMethodgetTransactionBlockNumber
(ctx context.Context, hash gcommon.Hash)
disperser/batcher/finalizer.go:259
↓ 1 callersFunctioninitialize_config
(config_path, config_parameters)
tests/utility/utils.py:17
↓ 1 callersMethodkeyExists
(ctx context.Context, bucket string, key string)
common/aws/s3/client.go:96
↓ 1 callersFunctionlocalstack
(ctx *cli.Context)
inabox/deploy/cmd/main.go:110
↓ 1 callersMethodmain
(self)
tests/da_test_framework/da_test_framework.py:368
↓ 1 callersFunctionnewEncodedBlobStore
(logger common.Logger)
disperser/batcher/encoded_blob_store.go:45
← previousnext →301–400 of 1,054, ranked by callers