MCPcopy Create free account

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

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

⨍ Functions 1,054◇ Types & classes 265
↓ 2 callersMethodstop
(self)
tests/da_test_framework/da_signer.py:52
↓ 2 callersFunctiontoBigEndian
(b []byte)
disperser/signer/client.go:124
↓ 2 callersMethodwait_for_rpc_connection
(self)
tests/da_test_framework/da_signer.py:49
↓ 2 callersMethodwriteItems
writeItems writes items in batches of 25 items (which is a limit DynamoDB imposes) update and delete operations are supported. For update operation, r
common/aws/dynamodb/client.go:212
↓ 1 callersMethodBalanceAt
(ctx context.Context, account common.Address, blockNumber *big.Int)
common/ethclient.go:17
↓ 1 callersMethodBatchUpload
(daContract *contract.DAContract, dataRoots []eth_common.Hash)
disperser/batcher/transactor/transactor.go:42
↓ 1 callersMethodBlockByHash
(ctx context.Context, hash common.Hash)
common/ethclient.go:18
↓ 1 callersMethodBlockByNumber
(ctx context.Context, number *big.Int)
common/ethclient.go:19
↓ 1 callersMethodCallContract
(ctx context.Context, msg ethereum.CallMsg, blockNumber *big.Int)
common/ethclient.go:21
↓ 1 callersMethodCodeAt
(ctx context.Context, account common.Address, blockNumber *big.Int)
common/ethclient.go:22
↓ 1 callersMethodConfirmBatch
(ctx context.Context, batchInfo *BatchInfo)
disperser/batcher/confirmer.go:168
↓ 1 callersFunctionConvertToGethLog
(log *types.Log)
disperser/contract/contract.go:206
↓ 1 callersMethodCreateBatch
CreateBatch makes a batch from all blobs in the encoded blob store. If successful, it returns a batch, and updates the reference block number for next
disperser/batcher/encoding_streamer.go:280
↓ 1 callersMethodCreateBucket
(ctx context.Context, name, region string)
common/aws/s3/client.go:166
↓ 1 callersFunctionCreateBucketTable
(ctx *cli.Context)
cli/main.go:173
↓ 1 callersFunctionCreateMetadataTable
(ctx *cli.Context)
cli/main.go:169
↓ 1 callersMethodDebug
(msg string, ctx ...interface{})
common/mock/logging.go:41
↓ 1 callersMethodDebugf
We add the below methods to be compliant with the eigensdk Logger interface
common/logging.go:77
↓ 1 callersFunctionDecodeBatchExpirationKey
Returns the expiration timestamp encoded in the key.
disperser/store.go:279
↓ 1 callersFunctionDefaultCLIConfig
()
common/ratelimit/limiter_cli.go:67
↓ 1 callersMethodDeleteBatchingStatus
(ts uint64)
disperser/batcher/encoded_blob_store.go:169
↓ 1 callersMethodDeleteBucket
(ctx context.Context, name string)
common/aws/s3/client.go:206
↓ 1 callersMethodDeleteEncodingRequest
(blobKey disperser.BlobKey)
disperser/batcher/encoded_blob_store.go:80
↓ 1 callersMethodDeleteEncodingResult
(blobKey disperser.BlobKey)
disperser/batcher/encoded_blob_store.go:126
↓ 1 callersMethodDeleteExpiredEntries
(currentTimeUnixSec int64, timeLimitSec uint64)
disperser/store.go:45
↓ 1 callersMethodDeleteItem
(ctx context.Context, tableName string, key Key)
common/aws/dynamodb/client.go:193
↓ 1 callersMethodDeleteItems
DeleteItems deletes items in batches of 25 items (which is a limit DynamoDB imposes) It returns the items that failed to be deleted.
common/aws/dynamodb/client.go:204
↓ 1 callersMethodDeleteObject
(ctx context.Context, bucket string, key string)
common/aws/s3/client.go:135
↓ 1 callersFunctionDeployResources
(pool *dockertest.Pool, localStackPort, metadataTableName, bucketTableName string)
inabox/deploy/localstack.go:90
↓ 1 callersMethodDescriptor
()
api/grpc/disperser/disperser.pb.go:72
↓ 1 callersMethodDescriptor
Deprecated: Use BlobInfo.ProtoReflect.Descriptor instead.
api/grpc/disperser/disperser.pb.go:460
↓ 1 callersMethodDisperseBatch
(ctx context.Context, batchHeaderHash [32]byte, batchHeader *core.BatchHeader, blobCommitments []*core.BlobCom
disperser/disperser.go:236
↓ 1 callersMethodEncode
()
core/serialization.go:37
↓ 1 callersMethodEncode
()
core/serialization.go:184
↓ 1 callersFunctionEncodeBatchExpirationKey
(expirationTime int64)
disperser/store.go:265
↓ 1 callersFunctionEncodeBatchExpirationKeyPrefix
Returns the encoded prefix for batch expiration key.
disperser/store.go:274
↓ 1 callersFunctionEncodeBlobHeaderKeyPrefix
Returns an encoded prefix of blob header key.
disperser/store.go:295
↓ 1 callersFunctionEncodeToBytes
EncodeToBytes encodes the given value to bytes
common/common.go:33
↓ 1 callersMethodEnsureTransactionEvaled
(ctx context.Context, tx *types.Transaction, tag string)
common/ethclient.go:43
↓ 1 callersMethodEnsureTransactionEvaled
(ctx context.Context, tx *types.Transaction, tag string)
common/geth/client.go:211
↓ 1 callersMethodError
(msg string, ctx ...interface{})
common/mock/logging.go:53
↓ 1 callersMethodEstimateGas
(ctx context.Context, call ethereum.CallMsg)
common/geth/instrumented_client.go:136
↓ 1 callersMethodFinalizeBlobs
FinalizeBlobs checks the latest finalized block and marks blobs in `confirmed` state as `finalized` if their confirmation block number is less than or
disperser/batcher/finalizer.go:142
↓ 1 callersFunctionGetAddress
Converts a private key to an address.
inabox/deploy/utils.go:195
↓ 1 callersMethodGetAllBlobMetadataByBatch
GetAllBlobMetadataByBatch returns the metadata of all the blobs in the batch.
disperser/disperser.go:228
↓ 1 callersMethodGetBatchHeaderHash
GetBatchHeaderHash returns the hash of the reduced BatchHeader that is used to sign the Batch ref: https://github.com/0glabs/0g-da-client/blob/master/
core/serialization.go:78
↓ 1 callersMethodGetBlob
(ctx context.Context, blobKey []byte)
disperser/store.go:229
↓ 1 callersMethodGetBlobContent
GetBlobContent retrieves a blob's content
disperser/disperser.go:209
↓ 1 callersFunctionGetBlobHash
(dataRoot []byte, epoch, quorumId uint64)
disperser/batcher/slice_signer.go:838
↓ 1 callersMethodGetBlobMetadata
(ctx context.Context, blobKey disperser.BlobKey)
disperser/common/memorydb/memorydb.go:283
↓ 1 callersMethodGetBlobMetadataInBatch
(ctx context.Context, batchHeaderHash [32]byte, blobIndex uint32)
disperser/common/blobstore/blob_metadata_store.go:135
↓ 1 callersMethodGetBlobsByMetadata
GetBlobsByMetadata retrieves a list of blobs given a list of metadata
disperser/disperser.go:222
↓ 1 callersMethodGetCols
()
core/data.go:109
↓ 1 callersMethodGetCommitRootSubmissionBatch
()
disperser/batcher/slice_signer.go:708
↓ 1 callersFunctionGetCommitmentHash
(commitment Commitment)
core/serialization.go:108
↓ 1 callersMethodGetEncodedData
()
disperser/api/grpc/encoder/encoder.pb.go:145
↓ 1 callersMethodGetEncodedResultSize
GetEncodedResultSize returns the total size of all the chunks in the encoded results in bytes
disperser/batcher/encoded_blob_store.go:182
↓ 1 callersMethodGetEncodedSlice
()
disperser/api/grpc/signer/signer.pb.go:95
↓ 1 callersMethodGetEncodingRequestingSize
()
disperser/batcher/encoded_blob_store.go:189
↓ 1 callersMethodGetErasureCommitment
()
disperser/api/grpc/signer/signer.pb.go:81
↓ 1 callersFunctionGetLatestTestDirectory
(rootPath string)
inabox/deploy/utils.go:286
↓ 1 callersMethodGetMetadata
(ctx context.Context, key []byte)
disperser/store.go:212
↓ 1 callersMethodGetNewEncodingResults
GetNewEncodingResults returns all the fresh encoded results
disperser/batcher/encoded_blob_store.go:143
↓ 1 callersMethodGetNoSendTransactOpts
()
common/geth/client.go:91
↓ 1 callersMethodGetRequestId
()
api/grpc/disperser/disperser.pb.go:195
↓ 1 callersMethodGetRowInBytes
(idx int)
core/data.go:113
↓ 1 callersMethodGetRows
()
core/data.go:105
↓ 1 callersMethodGetSignatures
()
disperser/api/grpc/signer/signer.pb.go:189
↓ 1 callersMethodGetStorageRoot
()
disperser/api/grpc/signer/signer.pb.go:88
↓ 1 callersMethodHasEncodingRequested
(blobKey disperser.BlobKey)
disperser/batcher/encoded_blob_store.go:64
↓ 1 callersMethodHeaderByHash
(ctx context.Context, hash common.Hash)
common/ethclient.go:25
↓ 1 callersMethodHeaderByNumber
(ctx context.Context, number *big.Int)
common/geth/instrumented_client.go:187
↓ 1 callersMethodIncrementBatchCount
(size int64)
disperser/batcher/metrics.go:168
↓ 1 callersMethodIncrementBlobRetryCount
(ctx context.Context, existingMetadata *disperser.BlobMetadata)
disperser/common/memorydb/memorydb.go:219
↓ 1 callersMethodIncrementBlobRetryCount
(ctx context.Context, existingMetadata *disperser.BlobMetadata)
disperser/common/blobstore/shared_storage.go:191
↓ 1 callersMethodIncrementFailedBlobRequestNum
IncrementFailedBlobRequestNum increments the number of failed blob requests
disperser/metrics.go:93
↓ 1 callersMethodIncrementNumRetries
(ctx context.Context, existingMetadata *disperser.BlobMetadata)
disperser/common/blobstore/blob_metadata_store.go:162
↓ 1 callersMethodIncrementSuccessfulBlobRequestNum
IncrementSuccessfulBlobRequestNum increments the number of successful blob requests
disperser/metrics.go:76
↓ 1 callersMethodInfo
(msg string, ctx ...interface{})
common/mock/logging.go:45
↓ 1 callersMethodInitialize
Initialize is a paid mutator transaction binding the contract method 0x8129fc1c. Solidity: function initialize() returns()
disperser/contract/da_entrance/da_entrance.go:371
↓ 1 callersMethodMarkBlobConfirmed
MarkBlobConfirmed updates blob metadata to Confirmed status with confirmation info Returns the updated metadata and error
disperser/disperser.go:212
↓ 1 callersMethodMarkBlobFailed
(ctx context.Context, blobKey disperser.BlobKey)
disperser/common/memorydb/memorydb.go:208
↓ 1 callersMethodMarkBlobFailed
(ctx context.Context, metadataKey disperser.BlobKey)
disperser/common/blobstore/shared_storage.go:187
↓ 1 callersMethodMarkBlobFinalized
MarkBlobFinalized marks a blob as finalized
disperser/disperser.go:214
↓ 1 callersFunctionMustNewWeb3
(url, key string)
disperser/contract/contract.go:224
↓ 1 callersFunctionNewBlobStore
NewBlobStore creates an empty BlobStore
disperser/common/memorydb/memorydb.go:34
↓ 1 callersFunctionNewConfig
(ctx *cli.Context)
disperser/cmd/combined_server/config.go:39
↓ 1 callersFunctionNewConfig
(ctx *cli.Context)
disperser/cmd/apiserver/config.go:32
↓ 1 callersFunctionNewConfig
(ctx *cli.Context)
disperser/cmd/batcher/config.go:25
↓ 1 callersFunctionNewDAEntrance
NewDAEntrance creates a new instance of DAEntrance, bound to a specific deployed contract.
disperser/contract/da_entrance/da_entrance.go:124
↓ 1 callersFunctionNewDASigners
NewDASigners creates a new instance of DASigners, bound to a specific deployed contract.
disperser/contract/da_signers/da_signers.go:121
↓ 1 callersFunctionNewEncodedSizeNotifier
(notify chan struct{}, threshold uint64)
disperser/batcher/encoding_streamer.go:74
↓ 1 callersFunctionNewEncodedSliceSigner
( ethConfig geth.EthClientConfig, config SignerConfig, workerPool common.WorkerPool, signatureSizeNotifier
disperser/batcher/slice_signer.go:140
↓ 1 callersFunctionNewEncodingStreamer
( config StreamerConfig, blobStore disperser.BlobStore, encoderClient disperser.EncoderClient, encodedSize
disperser/batcher/encoding_streamer.go:82
↓ 1 callersFunctionNewLevelDBStore
(path string)
disperser/leveldb/leveldb.go:18
↓ 1 callersFunctionNewRetrieverClient
(cc grpc.ClientConnInterface)
disperser/api/grpc/retriever/retriever_grpc.pb.go:34
↓ 1 callersFunctionNewSignatureSizeNotifier
(notify chan struct{}, threshold uint64)
disperser/batcher/slice_signer.go:41
↓ 1 callersFunctionNewSignerClient
(timeout time.Duration)
disperser/signer/client.go:30
↓ 1 callersFunctionNewWeb3
(url, key string)
disperser/contract/contract.go:233
↓ 1 callersMethodNonceAt
(ctx context.Context, account common.Address, blockNumber *big.Int)
common/ethclient.go:27
← previousnext →201–300 of 1,054, ranked by callers