MCPcopy Create free account

hub / github.com/celestiaorg/celestia-app / functions

Functions5,969 in github.com/celestiaorg/celestia-app

↓ 12 callersFunctionNewRange
(rangeMin, rangeMax int)
test/txsim/blob.go:141
↓ 12 callersFunctionRandMsgPayForBlobsWithSigner
(rand *rand.Rand, signer string, size, blobCount int)
test/util/blobfactory/payforblob_factory.go:35
↓ 12 callersMethodRoot
Root returns the Merkle root
pkg/rsema1d/merkle/merkle.go:106
↓ 12 callersMethodSize
Size returns the current number of entries in the cache
app/tx_cache.go:71
↓ 12 callersMethodTotalRows
TotalRows returns the total number of rows (OriginalRows + ParityRows).
fibre/blob.go:112
↓ 12 callersMethodTxQueueWorkerCount
TxQueueWorkerCount returns the number of workers in the tx queue
pkg/user/tx_client.go:1128
↓ 12 callersMethodValidateBasic
ValidateBasic performs basic validation of the MsgSetFibreProviderInfo message. Host must be in `host:port` form: a non-empty host (IP literal or DNS
x/valaddr/types/msg.go:39
↓ 12 callersMethodValidators
Validators getter
test/util/genesis/genesis.go:67
↓ 12 callersFunctionencodeVarintEvents
(dAtA []byte, offset int, v uint64)
x/zkism/types/events.pb.go:370
↓ 11 callersFunctionAdd128
Add128 adds two GF128 elements (component-wise XOR)
pkg/rsema1d/field/gf128.go:14
↓ 11 callersMethodAssemble
Assemble returns an [Assembly] holding the originalRows+parityRows row view for encoding data at the given rowSize. Use [Assembly.Rows] to access the
fibre/internal/row/assembler.go:58
↓ 11 callersFunctionExtendShares
(s [][]byte)
pkg/da/data_availability_header.go:143
↓ 11 callersMethodFinalizeBlock
FinalizeBlock implements the abci interface. It overrides baseapp's FinalizeBlock method, essentially becoming a decorator in order to add transaction
app/app.go:580
↓ 11 callersMethodGetLatestBlockHeight
GetLatestBlockHeight returns the latest block height of the given node. This function will periodically check for the latest block height until the ti
test/docker-e2e/e2e_test.go:114
↓ 11 callersMethodInfo
(ctx context.Context, info *types.RequestInfo)
tools/cpu_requirements/main.go:617
↓ 11 callersFunctionMedian
Median calculates the median value of the provided gas prices. Expects a sorted slice.
app/grpc/gasestimation/gas_estimator.go:266
↓ 11 callersMethodPush
Push adds the provided data to the underlying NamespaceMerkleTree, and automatically uses the first share.NamespaceSize number of bytes as the namespa
pkg/wrapper/nmt_wrapper.go:92
↓ 11 callersMethodRoot
Root fulfills the rsmt2d.Tree interface by generating and returning the underlying NamespaceMerkleTree Root.
pkg/wrapper/nmt_wrapper.go:117
↓ 11 callersMethodRowSize
RowSize returns the size of each row in bytes. Returns 0 if no original data available to determine row size.
fibre/blob.go:245
↓ 11 callersMethodRows
Rows returns the originalRows+parityRows assembled row view. Returns nil after [Assembly.Free]. The returned slice shares its backing array with the
fibre/internal/row/assembler.go:128
↓ 11 callersMethodString
()
x/mint/types/mint.pb.go:48
↓ 11 callersMethodSubmitPayForBlob
SubmitPayForBlob forms a transaction from the provided blobs, signs it, and submits it to the chain. TxOptions may be provided to set the fee and gas
pkg/user/tx_client.go:348
↓ 11 callersMethodTxStatus
TxStatus returns the status of a transaction. There are four possible states: - Committed - Pending - Evicted - Unknown
app/grpc/tx/tx.pb.go:406
↓ 11 callersFunctionValidateRLCRoot
ValidateRLCRoot verifies that an RLC root is consistent with a commitment by using a row inclusion proof to derive the row root. This is used to valid
pkg/rsema1d/proof.go:176
↓ 11 callersMethodWithImage
WithImage sets the docker image and returns the Config.
test/docker-e2e/dockerchain/config.go:60
↓ 11 callersMethodWithTag
WithTag sets the docker tag and returns the Config.
test/docker-e2e/dockerchain/config.go:66
↓ 11 callersFunctioncomputeRLCOrig
computeRLCOrig computes random linear combinations for original rows
pkg/rsema1d/codec.go:133
↓ 11 callersFunctionencodeVarintQuery
(dAtA []byte, offset int, v uint64)
x/fibre/types/query.pb.go:1197
↓ 11 callersFunctionencodeVarintService
(dAtA []byte, offset int, v uint64)
x/fibre/types/service.pb.go:764
↓ 11 callersFunctionencodeVarintTx
(dAtA []byte, offset int, v uint64)
x/fibre/types/tx.pb.go:1131
↓ 11 callersMethodgetBalance
getBalance gets the balance of a specific denom for an address
test/docker-e2e/e2e_ibc_test.go:389
↓ 11 callersFunctionloadCometBFTConfig
loadCometBFTConfig loads the CometBFT configuration from config.toml
cmd/celestia-appd/cmd/update_config.go:103
↓ 11 callersFunctionmakeValidatorSet
(n int)
fibre/validator/set_test.go:340
↓ 11 callersFunctionrunMigration
runMigration orchestrates the full LevelDB-to-PebbleDB migration.
tools/migrate-db/main.go:172
↓ 11 callersFunctionsovQuery
(x uint64)
x/zkism/types/query.pb.go:879
↓ 11 callersFunctionsovTx
(x uint64)
x/blob/types/tx.pb.go:674
↓ 11 callersFunctionsovTx
(x uint64)
x/forwarding/types/tx.pb.go:488
↓ 10 callersFunctionAdd16
Add16 adds two GF(2^16) elements (XOR)
pkg/rsema1d/field/gf16.go:26
↓ 10 callersMethodClone
Clone replicates n instances of the sequence for scaling up the load on a network. This is called before `Init`
test/txsim/sequence.go:19
↓ 10 callersMethodCopy
()
pkg/user/account.go:54
↓ 10 callersFunctionDefaultClientConfig
DefaultClientConfig returns a [ClientConfig] with the default values. Values are derived from DefaultProtocolParams.
fibre/client_config.go:62
↓ 10 callersMethodDefaultGenesis
DefaultGenesis returns a default genesis from the registered AppModuleBasic's.
test/interop/simapp.go:833
↓ 10 callersMethodEstimateGasPriceAndUsage
EstimateGasPriceAndUsage takes a transaction priority and a transaction bytes and estimates the gas price and the gas used for that transaction. The g
app/grpc/gasestimation/gas_estimator.pb.go:345
↓ 10 callersFunctionExtendVertical
ExtendVertical performs vertical RS extension using Leopard GF16
pkg/rsema1d/encoding/encoding.go:11
↓ 10 callersMethodFibreProviderInfo
FibreProviderInfo queries the fibre provider information for a specific validator
x/valaddr/types/query.pb.go:375
↓ 10 callersMethodGet
(string)
app/app_test.go:200
↓ 10 callersMethodGetFee
()
x/forwarding/types/query.pb.go:239
↓ 10 callersFunctionGetTxWithRetry
GetTxWithRetry polls ServiceClient.GetTx until the tx is indexed or indexerWaitTimeout elapses. The CometBFT TxStatus RPC (used by TxClient.ConfirmTx)
pkg/user/utils/txclient_utils.go:70
↓ 10 callersMethodGetVersion
()
x/signal/types/tx.pb.go:79
↓ 10 callersMethodGetWithdrawal
GetWithdrawal retrieves a withdrawal by signer and timestamp
x/fibre/keeper/keeper.go:98
↓ 10 callersMethodIsRunning
()
multiplexer/appd/run.go:103
↓ 10 callersMethodMarshal
()
x/fibre/types/tx.pb.go:933
↓ 10 callersMethodMarshal
()
x/fibre/types/query.pb.go:826
↓ 10 callersMethodMessages
Messages defines an rpc method for querying authorized Hyperlane message IDs.
x/zkism/types/query.pb.go:401
↓ 10 callersMethodName
Name returns the name of the App
app/app.go:563
↓ 10 callersFunctionNewAssembler
NewAssembler creates an Assembler for originalRows original rows and parityRows parity rows. It constructs an internal [Pool] sized for the assembler'
fibre/internal/row/assembler.go:34
↓ 10 callersMethodPayForFibre
PayForFibre contains the original payment promise with validator signatures
x/fibre/types/tx.pb.go:589
↓ 10 callersMethodQuoteForwardingFee
QuoteForwardingFee returns the estimated Hyperlane IGP fee for forwarding to a destination. Relayers should query this before submitting MsgForward to
x/forwarding/types/query.pb.go:310
↓ 10 callersMethodSelect
Select returns validators to download shards from, shuffled by stake for load balancing. Each [SelectedValidator] includes the expected row count for
fibre/validator/set.go:115
↓ 10 callersMethodSetParams
SetParams sets the params
x/blob/keeper/params.go:27
↓ 10 callersMethodStart
Start initializes the client by starting the underlying [StateClient] (e.g. auto-detecting the chain ID from the node). Must be called before [Client.
fibre/client.go:106
↓ 10 callersMethodSubmitPayForBlobToQueue
SubmitPayForBlobToQueue submits blobs to the parallel transaction queue and blocks until confirmed. TxOptions may be provided to set the fee and gas l
pkg/user/tx_client.go:355
↓ 10 callersMethodValidatePaymentPromiseStateful
ValidatePaymentPromiseStateful performs stateful validation of a payment promise. This method does NOT perform stateless validation. Callers should p
x/fibre/keeper/keeper.go:382
↓ 10 callersMethodVersion
Version returns the blob version encoded in this BlobID. Panics if the BlobID is invalid (empty or wrong length).
fibre/blob_id.go:93
↓ 10 callersFunctioncalculateNewDataHash
(t *testing.T, txs [][]byte)
app/test/process_proposal_test.go:314
↓ 10 callersMethodcreateEscrowAccount
createEscrowAccount creates an escrow account for the given payment promise with sufficient balance
x/fibre/keeper/keeper_test.go:725
↓ 10 callersFunctionmakeShardFrom
makeShardFrom extracts a shard from a blob at the given row indices.
fibre/store_test.go:308
↓ 10 callersFunctionmakeTestKeyring
(t *testing.T)
fibre/client_test.go:84
↓ 10 callersFunctionnewMockClient
(startHeight uint64)
fibre/state/caching_client_test.go:20
↓ 10 callersFunctionsetupTxClientWithMockServers
setupTxClientWithMockServers creates mock gRPC servers with different broadcast handlers (works for single or multiple servers)
pkg/user/mock_tx_server_test.go:155
↓ 10 callersFunctionskipQuery
(dAtA []byte)
x/fibre/types/query.pb.go:2293
↓ 10 callersFunctionskipTx
(dAtA []byte)
x/fibre/types/tx.pb.go:2131
↓ 9 callersMethodBroadcastPayForBlob
BroadcastPayForBlob signs and broadcasts a transaction to pay for blobs. It does not confirm that the transaction has been committed on chain. If no g
pkg/user/tx_client.go:415
↓ 9 callersFunctionEncodeHex
EncodeHex is a convenience function to encode byte slices as 0x prefixed hexadecimal strings.
x/zkism/types/keys.go:109
↓ 9 callersFunctionEstimateGasForPayForFibre
EstimateGasForPayForFibre estimates the gas required for a PayForFibre message. The formula is: GasFibre = B + A × n where: B = 650,000 — fixed cost
x/fibre/keeper/msg_server.go:332
↓ 9 callersMethodForward
Forward forwards the token bound to a derived forwarding address to its committed destination via Hyperlane warp transfer.
x/forwarding/types/tx.pb.go:244
↓ 9 callersMethodGenerateProof
GenerateProof generates a Merkle proof for the leaf at the given index
pkg/rsema1d/merkle/proof.go:75
↓ 9 callersFunctionGenerateRandNamespacedRawData
GenerateRandNamespacedRawData returns random data of length count. Each chunk of random data is of size shareSize and is prefixed with a random blob n
test/util/testfactory/common.go:35
↓ 9 callersMethodGetPaymentPromise
GetPaymentPromise retrieves a [PaymentPromise] by its hash.
fibre/store.go:193
↓ 9 callersMethodGetUpgrade
GetUpgrade enables a client to query for upgrade information if an upgrade is pending. The response will be empty if no upgrade is pending.
x/signal/types/query.pb.go:373
↓ 9 callersMethodLatestHeight
LatestHeight returns the latest height of the network or an error if the query fails.
test/util/testnode/node_interaction_api.go:72
↓ 9 callersMethodMarshalToSizedBuffer
(dAtA []byte)
x/fibre/types/query.pb.go:841
↓ 9 callersMethodMarshalToSizedBuffer
(dAtA []byte)
x/zkism/types/query.pb.go:558
↓ 9 callersFunctionNewBaseInstance
(nodeType NodeType)
tools/talis/config.go:101
↓ 9 callersFunctionNewDefaultValidator
(name string)
test/util/genesis/accounts.go:65
↓ 9 callersFunctionNewTreePool
NewTreePool creates a new TreePool with the specified configuration.
pkg/wrapper/buffered_tree.go:25
↓ 9 callersMethodNewValidator
NewValidator creates a new validator account and adds it to the genesis.
test/util/genesis/genesis.go:208
↓ 9 callersMethodPaymentPromiseTimeout
PaymentPromiseTimeout processes a payment promise after the timeout period
x/fibre/types/tx.pb.go:591
↓ 9 callersMethodRegisterGRPCGatewayRoutes
RegisterGRPCGatewayRoutes registers the gRPC Gateway routes for the module.
x/blob/module.go:79
↓ 9 callersMethodSetGasLimit
SetGasLimit sets a custom gas limit to be used for all transactions
test/txsim/account.go:551
↓ 9 callersMethodSignatures
Signatures returns collected signatures ordered by validator set position if thresholds are met. Validators that did not sign have nil entries. Return
fibre/validator/signature_set.go:73
↓ 9 callersMethodSize
()
pkg/proof/proof.pb.go:706
↓ 9 callersMethodSize
()
x/fibre/types/query.pb.go:1208
↓ 9 callersMethodSize
()
x/zkism/types/query.pb.go:787
↓ 9 callersFunctionToBytes128
ToBytes128 serializes a GF128 to 16 bytes (little-endian)
pkg/rsema1d/field/gf128.go:32
↓ 9 callersMethodTxQueueWorkerAccountName
TxQueueWorkerAccountName returns the account name for the worker at the given index
pkg/user/tx_client.go:1144
↓ 9 callersMethodUpdateFibreParams
UpdateFibreParams defines a rpc handler method for MsgUpdateFibreParams.
x/fibre/types/tx.pb.go:593
↓ 9 callersMethodValidateBasic
ValidateBasic performs stateless validation for PaymentPromise
x/fibre/types/msgs.go:50
↓ 9 callersFunctionValidateGroth16Vkey
ValidateGroth16Vkey checks that a serialized Groth16 verifying key has the expected total size and that the internal length prefixes (G1.K, Commitment
x/zkism/types/keys.go:85
↓ 9 callersMethodWaitForBlocks
WaitForBlocks waits until n blocks have been committed, returning an error upon failure.
test/util/testnode/node_interaction_api.go:180
← previousnext →201–300 of 5,969, ranked by callers