MCPcopy Create free account

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

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

↓ 103 callersMethodError
Log a message at the error level with context key/value pairs # Usage Examples log.Error("msg") log.Error("msg", "key1", val1) log.Error("msg", "
common/logging.go:55
↓ 81 callersMethodErrorf
(template string, args ...interface{})
common/logging.go:80
↓ 69 callersFunctionPrefixEnvVar
PrefixEnvVar returns the environment variable name with the given prefix and suffix
common/common.go:12
↓ 67 callersMethodString
()
disperser/disperser.go:55
↓ 64 callersFunctionPrefixFlag
PrefixFlag returns the flag name with the given prefix and suffix
common/common.go:17
↓ 58 callersMethodInfo
Log a message at the info level with context key/value pairs # Usage Examples log.Info("msg") log.Info("msg", "key1", val1) log.Info("msg", "key1
common/logging.go:37
↓ 48 callersMethodGet
(key []byte)
disperser/db.go:10
↓ 41 callersMethodNew
New returns a new Logger that has this logger's context plus the given context
common/logging.go:7
↓ 37 callersMethodGetBlobKey
()
disperser/disperser.go:155
↓ 26 callersMethodString
()
disperser/api/grpc/signer/signer.pb.go:44
↓ 25 callersFunctioninstrumentFunction
Generic function used to instrument all the eth calls that we make below
common/geth/instrumented_client.go:565
↓ 20 callersMethodDebug
Log a message at the debug level with context key/value pairs # Usage Examples log.Debug("msg") log.Debug("msg", "key1", val1) log.Debug("msg", "
common/logging.go:28
↓ 19 callersMethodTrace
Log a message at the trace level with context key/value pairs # Usage log.Trace("msg") log.Trace("msg", "key1", val1) log.Trace("msg", "key1", va
common/logging.go:19
↓ 17 callersMethodAdd
(key [32]byte, epoch uint64)
disperser/disperser.go:76
↓ 17 callersMethodCall
(result interface{}, method string, args ...interface{})
common/rpc_ethclient.go:12
↓ 14 callersMethodGetItem
GetItem returns the value associated with a given key.
common/param_store.go:8
↓ 11 callersMethodStop
()
common/workerpool.go:8
↓ 9 callersMethodHash
()
disperser/disperser.go:112
↓ 9 callersMethodRemoveBatchingStatus
(ts uint64)
disperser/batcher/slice_signer.go:766
↓ 9 callersMethodWarn
Log a message at the warn level with context key/value pairs # Usage Examples log.Warn("msg") log.Warn("msg", "key1", val1) log.Warn("msg", "key1
common/logging.go:46
↓ 9 callersFunctionchangeDirectory
Changes current working directory.
inabox/deploy/utils.go:87
↓ 9 callersFunctionfile_disperser_disperser_proto_rawDescGZIP
()
api/grpc/disperser/disperser.pb.go:615
↓ 8 callersMethodCreateTable
(ctx context.Context, cfg commonaws.ClientConfig, name string, input *dynamodb.CreateTableInput)
common/aws/dynamodb/client.go:84
↓ 8 callersMethodDo
(req *http.Request)
common/pubip/pubip.go:26
↓ 8 callersMethodUpdateItem
UpdateItem updates the value for the given key.
common/param_store.go:10
↓ 8 callersFunctionnewFpElement
(x *big.Int)
core/attestation.go:44
↓ 7 callersMethodAdd
Add another G1 point to this one
core/attestation.go:60
↓ 7 callersMethodFatalf
eigensdk uses fatal instead of crit so we add it, but should have same semantic as Critf
common/logging.go:84
↓ 7 callersMethodGetBlobMetadata
GetBlobMetadata returns a blob metadata given a metadata key
disperser/disperser.go:230
↓ 7 callersFunctionGetClientAddress
GetClientAddress returns the client address from the context. If the header is not empty, it will take the ip address located at the `numProxies“ posi
common/ratelimit.go:53
↓ 7 callersFunctionNewClient
(cfg commonaws.ClientConfig, logger common.Logger)
common/aws/dynamodb/client.go:48
↓ 7 callersFunctionis_windows_platform
()
tests/utility/utils.py:13
↓ 7 callersMethodprintLog
(level ethlog.Lvl, msg string, ctx ...interface{})
common/mock/logging.go:24
↓ 7 callersFunctionreadFile
(name string)
inabox/deploy/utils.go:23
↓ 6 callersFunctionGetLogger
GetLogger returns a logger with the specified configuration.
common/logging/logging.go:24
↓ 6 callersMethodObserveLatency
(stage string, latencyMs float64)
disperser/batcher/metrics.go:177
↓ 6 callersMethodRetrieveBlob
This fans out request to ZGDA Nodes to retrieve the chunks and returns the reconstructed original blob in response.
api/grpc/retriever/retriever_grpc.pb.go:27
↓ 6 callersMethodType
()
api/grpc/disperser/disperser.pb.go:76
↓ 6 callersMethodapplyDefaults
(c any, prefix, stub string, ind int)
inabox/deploy/config.go:102
↓ 6 callersFunctiongetRequestID
(key disperser.BlobKey)
disperser/batcher/encoded_blob_store.go:193
↓ 6 callersMethodhandleFailure
(ctx context.Context, blobMetadatas []*disperser.BlobMetadata, reason FailReason)
disperser/batcher/batcher.go:279
↓ 5 callersMethodClose
Close terminates the iteration process, releasing any pending underlying resources.
disperser/contract/da_signers/da_signers.go:564
↓ 5 callersMethodDeserialize
(data []byte)
disperser/disperser.go:150
↓ 5 callersMethodFilterLogs
(ctx context.Context, q ethereum.FilterQuery)
common/ethclient.go:24
↓ 5 callersFunctionNewConfig
(ctx *cli.Context)
cli/config.go:15
↓ 5 callersMethodRemoveBlob
RemoveBlob remove a blob and its metadata from s3 and dynamodb
disperser/disperser.go:207
↓ 5 callersMethodRemoveEncodedBlob
(metadata *disperser.BlobMetadata)
disperser/batcher/encoding_streamer.go:356
↓ 5 callersMethodhandleFailure
(ctx context.Context, blobMetadatas []*disperser.BlobMetadata, reason FailReason, ts uint64)
disperser/batcher/slice_signer.go:410
↓ 4 callersMethodBatchSign
(ctx context.Context, in *BatchSignRequest, opts ...grpc.CallOption)
disperser/api/grpc/signer/signer_grpc.pb.go:25
↓ 4 callersFunctionCLIFlags
(envPrefix string, flagPrefix string)
common/logging/cli.go:21
↓ 4 callersFunctionClientFlags
(envPrefix string, flagPrefix string)
common/aws/cli.go:22
↓ 4 callersFunctionDecode
(data []byte, obj any)
core/serialization.go:220
↓ 4 callersMethodDownloadObject
(ctx context.Context, bucket string, key string)
common/aws/s3/client.go:73
↓ 4 callersFunctionEncode
(obj any)
core/serialization.go:210
↓ 4 callersMethodEncode
Encode takes in a blob and returns the commitments and encoded matrix
core/encoding.go:27
↓ 4 callersMethodEncodeBlob
(ctx context.Context, in *EncodeBlobRequest, opts ...grpc.CallOption)
disperser/api/grpc/encoder/encoder_grpc.pb.go:25
↓ 4 callersFunctionEncodeBlobHeaderKey
EncodeBlobHeaderKey returns an encoded key as blob header identification.
disperser/store.go:288
↓ 4 callersMethodHandleBlobFailure
HandleBlobFailure handles a blob failure by either incrementing the retry count or marking the blob as failed
disperser/disperser.go:232
↓ 4 callersMethodHandleFailedRequest
HandleFailedRequest updates the number of failed requests and the size of the blob
disperser/metrics.go:101
↓ 4 callersFunctionNewClient
(cfg commonaws.ClientConfig, logger common.Logger)
common/aws/s3/client.go:37
↓ 4 callersFunctionReadCLIConfig
(ctx *cli.Context, flagPrefix string)
common/logging/cli.go:52
↓ 4 callersFunctionReadClientConfig
(ctx *cli.Context, flagPrefix string)
common/aws/cli.go:55
↓ 4 callersMethodStart
(ctx context.Context)
disperser/encoder/metrics.go:88
↓ 4 callersMethodStart
(ctx context.Context)
disperser/batcher/finalizer.go:24
↓ 4 callersMethodTransact
Transact invokes the (paid) contract method with params as input values.
disperser/contract/da_signers/da_signers.go:180
↓ 4 callersMethodTransact
Transact invokes the (paid) contract method with params as input values.
disperser/contract/da_entrance/da_entrance.go:183
↓ 4 callersMethodTransactionReceipt
(ctx context.Context, txHash common.Hash)
common/ethclient.go:40
↓ 4 callersFunctionUnmarshalBlobMetadata
(item commondynamodb.Item)
disperser/common/blobstore/blob_metadata_store.go:339
↓ 4 callersMethodUpdateCompletedBlob
UpdateCompletedBlob increments the number and updates size of processed blobs.
disperser/batcher/metrics.go:149
↓ 4 callersMethodWaitForReceipt
(txHash eth_common.Hash, successRequired bool, opts ...RetryOption)
disperser/contract/contract.go:158
↓ 4 callersFunctionbindDAEntrance
bindDAEntrance binds a generic wrapper to an already deployed contract.
disperser/contract/da_entrance/da_entrance.go:160
↓ 4 callersFunctionbindDASigners
bindDASigners binds a generic wrapper to an already deployed contract.
disperser/contract/da_signers/da_signers.go:157
↓ 4 callersFunctionexecCmd
(name string, args []string, envVars []string)
inabox/deploy/utils.go:298
↓ 4 callersFunctionexecYarnCmd
Execute yarn command
inabox/deploy/utils.go:101
↓ 4 callersFunctiongetRunner
(command string)
inabox/deploy/cmd/main.go:81
↓ 4 callersFunctionsizeOf
(metadata *disperser.BlobMetadata)
disperser/common/memorydb/memorydb.go:43
↓ 4 callersFunctionteardown
()
common/store/dynamo_store_test.go:80
↓ 4 callersFunctionteardown
()
common/aws/dynamodb/client_test.go:73
↓ 3 callersMethodAllowRequest
(ctx context.Context, requesterID RequesterID, blobSize uint, rate RateParam)
common/ratelimit.go:19
↓ 3 callersMethodContains
(key [32]byte)
disperser/disperser.go:89
↓ 3 callersMethodCrit
(msg string, ctx ...interface{})
common/mock/logging.go:57
↓ 3 callersMethodDisperseBlob
This API accepts blob to disperse from clients. This executes the dispersal async, i.e. it returns once the request is accepted. The client could use
api/grpc/disperser/disperser_grpc.pb.go:29
↓ 3 callersMethodFatal
Fatal is an alias for Crit Log a message at the crit level with context key/value pairs, and then exit. # Usage Examples log.Fatal("msg") log.Fata
common/logging.go:74
↓ 3 callersFunctionGenerateTableSchema
(readCapacityUnits int64, writeCapacityUnits int64, tableName string)
common/store/dynamo_store.go:66
↓ 3 callersMethodGetBlobMetadataByStatus
GetBlobMetadataByStatus returns a list of blob metadata for blobs with the given status
disperser/disperser.go:224
↓ 3 callersMethodGetBlobStatus
This API is meant to be polled for the blob status.
api/grpc/disperser/disperser_grpc.pb.go:31
↓ 3 callersMethodGetData
()
disperser/api/grpc/retriever/retriever.pb.go:131
↓ 3 callersFunctionGetG2Generator
()
core/bn254/attestation.go:77
↓ 3 callersMethodGetQuorum
GetQuorum is a free data retrieval call binding the contract method 0x6ab6f654. Solidity: function getQuorum(uint256 _epoch, uint256 _quorumId) view
disperser/contract/da_signers/da_signers.go:287
↓ 3 callersMethodGetSigner
GetSigner is a free data retrieval call binding the contract method 0xd1f5e5f8. Solidity: function getSigner(address[] _account) view returns((addres
disperser/contract/da_signers/da_signers.go:318
↓ 3 callersMethodHandleSuccessfulRequest
HandleSuccessfulRequest updates the number of successful blob requests and the size of the blob
disperser/metrics.go:84
↓ 3 callersMethodHash
()
core/attestation.go:95
↓ 3 callersMethodHex
()
core/attestation.go:21
↓ 3 callersFunctionNewBlobMetadataStore
(dynamoDBClient *commondynamodb.Client, logger common.Logger, tableName string, ttl time.Duration)
disperser/common/blobstore/blob_metadata_store.go:36
↓ 3 callersFunctionNewClient
(config EthClientConfig, logger common.Logger)
common/geth/client.go:40
↓ 3 callersFunctionNewDynamoParamStore
(client *commondynamodb.Client, tableName string)
common/store/dynamo_store.go:20
↓ 3 callersMethodNewIterator
(prefix []byte)
disperser/db.go:14
↓ 3 callersFunctionNewLevelDBStore
(path string, timeToExpire uint, logger common.Logger)
disperser/store.go:29
↓ 3 callersFunctionNewRateLimiter
(rateParams common.GlobalRateParams, bucketStore BucketStore, allowlist []string, logger common.Logger)
common/ratelimit/limiter.go:22
↓ 3 callersFunctionNewSharedStorage
(bucketName string, s3Client *s3.Client, MetadataHashAsBlobKey bool, blobMetadataStore *BlobMetadataStore, log
disperser/common/blobstore/shared_storage.go:70
next →1–100 of 1,054, ranked by callers