Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/0gfoundation/0g-da-client
/ functions
Functions
1,054 in github.com/0gfoundation/0g-da-client
⨍
Functions
1,054
◇
Types & classes
265
↓ 1 callers
Function
ParseBlobKey
(key string)
disperser/disperser.go:59
↓ 1 callers
Method
ParseDataUpload
ParseDataUpload is a log parse operation binding the contract event 0xf0bf37f8713754493879920443065424c575888634675f146c115709bbb59acb. Solidity: eve
disperser/contract/da_entrance/da_entrance.go:572
↓ 1 callers
Method
PendingCallContract
(ctx context.Context, msg ethereum.CallMsg)
common/ethclient.go:28
↓ 1 callers
Method
PendingCodeAt
(ctx context.Context, account common.Address)
common/ethclient.go:29
↓ 1 callers
Method
PendingNonceAt
(ctx context.Context, account common.Address)
common/ethclient.go:30
↓ 1 callers
Method
PersistConfirmedBlobs
(ctx context.Context, metadatas []*disperser.BlobMetadata)
disperser/batcher/finalizer.go:210
↓ 1 callers
Method
ProcessEncodedBlobs
(ctx context.Context, result EncodingResultOrStatus)
disperser/batcher/encoding_streamer.go:246
↓ 1 callers
Method
PublicIPAddress
(ctx context.Context)
common/pubip/pubip.go:49
↓ 1 callers
Method
PutEncodingRequest
(blobKey disperser.BlobKey)
disperser/batcher/encoded_blob_store.go:56
↓ 1 callers
Method
PutEncodingResult
(result *EncodingResult)
disperser/batcher/encoded_blob_store.go:92
↓ 1 callers
Method
PutItems
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 callers
Method
QueueNewBlobMetadata
(ctx context.Context, blobMetadata *disperser.BlobMetadata)
disperser/common/blobstore/blob_metadata_store.go:46
↓ 1 callers
Method
Receive
Receive is a paid mutator transaction binding the contract receive function. Solidity: receive() payable returns()
disperser/contract/da_entrance/da_entrance.go:434
↓ 1 callers
Function
RegisterHealthServer
RegisterHealthServer registers the HealthServer with the provided gRPC server.
common/healthcheck/server.go:25
↓ 1 callers
Method
RegisterNextEpoch
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 callers
Method
RegisterSigner
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 callers
Method
RemoveBlobMetadata
(ctx context.Context, blobMetadata *disperser.BlobMetadata)
disperser/common/blobstore/blob_metadata_store.go:55
↓ 1 callers
Method
RequestEncoding
(ctx context.Context, encoderChan chan EncodingResultOrStatus)
disperser/batcher/encoding_streamer.go:150
↓ 1 callers
Method
RequestEncodingForBlob
(ctx context.Context, metadata *disperser.BlobMetadata, blob *core.Blob, encoderChan chan EncodingResultOrStat
disperser/batcher/encoding_streamer.go:208
↓ 1 callers
Method
RetrieveBlob
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 callers
Function
RunBatcher
(config Config, queue disperser.BlobStore, logger common.Logger, kvStore *disperser.Store)
disperser/cmd/combined_server/main.go:92
↓ 1 callers
Function
RunDisperserServer
(config Config, blobStore disperser.BlobStore, logger common.Logger, kvStore *disperser.Store)
disperser/cmd/combined_server/main.go:56
↓ 1 callers
Method
SetBatchRoot
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 callers
Method
SetHandler
SetHandler updates the logger to write records to the specified handler.
common/logging.go:10
↓ 1 callers
Method
StopWait
()
common/workerpool.go:9
↓ 1 callers
Method
StorageAt
(ctx context.Context, account common.Address, key common.Hash, blockNumber *big.Int)
common/ethclient.go:32
↓ 1 callers
Method
StoreBlob
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 callers
Method
StoreMetadataBatch
(ctx context.Context, blobKeys [][]byte, metadatas [][]byte, blobs [][]byte)
disperser/store.go:166
↓ 1 callers
Method
SubmitAggregateSignatures
(ctx context.Context, rootSubmission []*core.CommitRootSubmission)
disperser/disperser.go:237
↓ 1 callers
Method
SubmitLogEntry
(daContract *contract.DAContract, dataRoots []eth_common.Hash)
disperser/batcher/transactor/transactor.go:29
↓ 1 callers
Method
SubmitOriginalData
(dataRoots []eth_common.Hash, waitForReceipt bool)
disperser/contract/contract.go:118
↓ 1 callers
Method
SubmitOriginalData
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 callers
Method
SubmitVerifiedCommitRoots
SubmitVerifiedCommitRoots is a paid mutator transaction binding the contract method 0xeafed6ce. Solidity: function submitVerifiedCommitRoots((bytes32
disperser/contract/da_entrance/da_entrance.go:413
↓ 1 callers
Method
SubmitVerifiedCommitRoots
(daContract *contract.DAContract, submissions []da_entrance.IDAEntranceCommitRootSubmission)
disperser/batcher/transactor/transactor.go:55
↓ 1 callers
Method
SubscribeFilterLogs
(ctx context.Context, q ethereum.FilterQuery, ch chan<- types.Log)
common/ethclient.go:33
↓ 1 callers
Method
SubscribeNewHead
(ctx context.Context, ch chan<- *types.Header)
common/ethclient.go:34
↓ 1 callers
Method
SuggestGasPrice
(ctx context.Context)
common/ethclient.go:35
↓ 1 callers
Method
SuggestGasTipCap
(ctx context.Context)
common/geth/instrumented_client.go:362
↓ 1 callers
Method
TransactionByHash
(ctx context.Context, hash common.Hash)
common/ethclient.go:37
↓ 1 callers
Method
TransactionCount
(ctx context.Context, blockHash common.Hash)
common/ethclient.go:38
↓ 1 callers
Method
TransactionInBlock
(ctx context.Context, blockHash common.Hash, index uint)
common/ethclient.go:39
↓ 1 callers
Method
Transfer
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 callers
Method
Transfer
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 callers
Method
UpdateBlobMetadata
(ctx context.Context, metadataKey disperser.BlobKey, updated *disperser.BlobMetadata)
disperser/common/blobstore/blob_metadata_store.go:179
↓ 1 callers
Method
UpdateEncodedBlobs
(count int, size uint64)
disperser/batcher/metrics.go:201
↓ 1 callers
Method
UpdateGas
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 callers
Method
UpdateNetworks
(n Networks, startBlock int)
inabox/deploy/subgraph.go:68
↓ 1 callers
Method
UpdateSignedBlobs
(count int, size uint64)
disperser/batcher/metrics.go:196
↓ 1 callers
Method
UpdateSocket
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 callers
Method
UpdateSubgraph
(s *Subgraph, startBlock int)
inabox/deploy/subgraph.go:67
↓ 1 callers
Method
Verify
Verify a message against a G2 public key
core/attestation.go:149
↓ 1 callers
Function
WaitForReceipt
(client *web3go.Client, txHash eth_common.Hash, successRequired bool, opts ...RetryOption)
disperser/contract/contract.go:162
↓ 1 callers
Method
WaitingQueueSize
()
common/workerpool.go:13
↓ 1 callers
Method
Warn
(msg string, ctx ...interface{})
common/mock/logging.go:49
↓ 1 callers
Method
WriteBatch
(keys, values [][]byte)
disperser/db.go:13
↓ 1 callers
Method
__safe_close_stdout_stderr__
(self)
tests/da_test_framework/test_node.py:178
↓ 1 callers
Method
__start_logging
(self)
tests/da_test_framework/da_test_framework.py:66
↓ 1 callers
Method
_raise_assertion_error
Raise an AssertionError with msg modified to identify this node.
tests/da_test_framework/test_node.py:81
↓ 1 callers
Method
add_arguments
(self, parser: argparse.ArgumentParser)
tests/da_test_framework/da_test_framework.py:100
↓ 1 callers
Method
aggregateSignature
(ctx context.Context, signInfo *SignInfo, update chan SignRequestResultOrStatus)
disperser/batcher/slice_signer.go:551
↓ 1 callers
Method
assignEncodedBlobs
(signInfo *SignInfo)
disperser/batcher/slice_signer.go:509
↓ 1 callers
Method
build_binary
(self)
tests/da_test_framework/da_test_framework.py:179
↓ 1 callers
Method
build_blockchain
(self, blockchain_binary_path, blockchain_path)
tests/da_test_framework/da_test_framework.py:205
↓ 1 callers
Function
build_conflux
(conflux_path)
tests/da_test_all.py:145
↓ 1 callers
Method
build_da_encoder
(self, binary_path, src_code_path)
tests/da_test_framework/da_test_framework.py:244
↓ 1 callers
Method
build_da_server
(self, binary_path, src_code_path)
tests/da_test_framework/da_test_framework.py:280
↓ 1 callers
Method
build_da_signer
(self, binary_path, src_code_path)
tests/da_test_framework/da_test_framework.py:262
↓ 1 callers
Function
defaultSigner
(clientWithSigner *web3go.Client)
disperser/contract/contract.go:46
↓ 1 callers
Method
deleteNBlobs
(currentTimeUnixSec int64, numBatches int)
disperser/store.go:69
↓ 1 callers
Method
disperse_blob
(self, data)
tests/da_test_framework/da_server.py:89
↓ 1 callers
Method
doRequest
(ctx context.Context, url string)
common/pubip/pubip.go:60
↓ 1 callers
Method
doSigning
(ctx context.Context, signInfo *SignInfo)
disperser/batcher/slice_signer.go:455
↓ 1 callers
Method
expireLoop
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 callers
Function
file_disperser_disperser_proto_init
()
api/grpc/disperser/disperser.pb.go:654
↓ 1 callers
Function
file_encoder_encoder_proto_init
()
disperser/api/grpc/encoder/encoder.pb.go:220
↓ 1 callers
Function
file_retriever_retriever_proto_init
()
disperser/api/grpc/retriever/retriever.pb.go:191
↓ 1 callers
Function
file_retriever_retriever_proto_init
()
api/grpc/retriever/retriever.pb.go:207
↓ 1 callers
Function
file_signer_signer_proto_init
()
disperser/api/grpc/signer/signer.pb.go:261
↓ 1 callers
Method
getBlobContentParallel
(ctx context.Context, blobKey disperser.BlobKey, blobRequestHeader core.BlobRequestHeader, resultChan chan<- b
disperser/common/blobstore/shared_storage.go:152
↓ 1 callers
Function
getBlobFromRequest
(req *pb.DisperseBlobRequest)
disperser/apiserver/server.go:337
↓ 1 callers
Function
getBlobHash
(blob *core.Blob)
disperser/common/memorydb/memorydb.go:298
↓ 1 callers
Function
getBlobHash
(blob *core.Blob)
disperser/common/blobstore/shared_storage.go:267
↓ 1 callers
Function
getBucketLevel
(bucketLevel, bucketSize, interval, deduction time.Duration)
common/ratelimit/limiter.go:90
↓ 1 callers
Function
getClient
(clientConfig commonaws.ClientConfig)
common/aws/dynamodb/utils_test.go:41
↓ 1 callers
Function
getClient
(clientConfig commonaws.ClientConfig)
common/aws/dynamodb/utils/test_utils.go:41
↓ 1 callers
Function
getClientAndVersion
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 callers
Function
getGasFeeCap
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 callers
Method
getMetadataFromKv
(ctx context.Context, key []byte)
disperser/apiserver/server.go:130
↓ 1 callers
Function
getMetadataHash
(requestedAt uint64)
disperser/common/memorydb/memorydb.go:305
↓ 1 callers
Function
getMetadataHash
(requestedAt uint64, securityParams []*core.SecurityParam)
disperser/common/blobstore/shared_storage.go:251
↓ 1 callers
Method
getPendingBatch
()
disperser/batcher/slice_signer.go:245
↓ 1 callers
Method
getPendingBatch
()
disperser/batcher/confirmer.go:121
↓ 1 callers
Method
getPendingBatchToSign
()
disperser/batcher/slice_signer.go:442
↓ 1 callers
Method
getSigners
(epoch *big.Int, quorumId *big.Int)
disperser/batcher/slice_signer.go:359
↓ 1 callers
Method
getTransactionBlockNumber
(ctx context.Context, hash gcommon.Hash)
disperser/batcher/finalizer.go:259
↓ 1 callers
Function
initialize_config
(config_path, config_parameters)
tests/utility/utils.py:17
↓ 1 callers
Method
keyExists
(ctx context.Context, bucket string, key string)
common/aws/s3/client.go:96
↓ 1 callers
Function
localstack
(ctx *cli.Context)
inabox/deploy/cmd/main.go:110
↓ 1 callers
Method
main
(self)
tests/da_test_framework/da_test_framework.py:368
↓ 1 callers
Function
newEncodedBlobStore
(logger common.Logger)
disperser/batcher/encoded_blob_store.go:45
← previous
next →
301–400 of 1,054, ranked by callers