MCPcopy Create free account

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

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

↓ 19 callersMethodSequence
Sequence returns the sequence number of the account. This is locally tracked
pkg/user/account.go:50
↓ 19 callersMethodUnmarshalJSON
UnmarshalJSON decodes a hex string into a commitment.
fibre/blob_id.go:25
↓ 19 callersFunctionencodeVarintEvent
(dAtA []byte, offset int, v uint64)
x/fibre/types/event.pb.go:807
↓ 18 callersMethodFree
Free returns the pooled slab (parity + partial-row buffers) back to the pool. Subsequent calls are no-ops. Safe to call concurrently.
fibre/internal/row/assembler.go:150
↓ 18 callersMethodFromProto
FromProto converts the [PaymentPromise] from its protobuf representation.
fibre/payment_promise.go:77
↓ 18 callersMethodGetProcessedPayment
GetProcessedPayment retrieves a processed payment by promiseHash
x/fibre/keeper/keeper.go:192
↓ 18 callersFunctionMul16
Mul16 multiplies two GF(2^16) elements
pkg/rsema1d/field/gf16.go:21
↓ 18 callersFunctionNew
New returns a reference to an uninitialized app. Callers must subsequently call app.Info or app.InitChain to initialize the baseapp. Setting delayedPr
app/app.go:226
↓ 18 callersFunctionNewTree
NewTree builds a binary Merkle tree from the given leaves Requires: len(leaves) must be a power of 2
pkg/rsema1d/merkle/merkle.go:24
↓ 18 callersMethodPut
Put stores given [PaymentPromise] and [types.BlobShard]. Shards are stored as a single blob under /shard/<commitment>/<promise-hash>. The payment pro
fibre/store.go:108
↓ 18 callersMethodRequestWithdrawal
RequestWithdrawal requests withdrawal from the signer's escrow account
x/fibre/types/tx.pb.go:587
↓ 18 callersMethodSetEscrowAccount
SetEscrowAccount stores an escrow account
x/fibre/keeper/keeper.go:83
↓ 18 callersFunctionVerifyRowWithContext
VerifyRowWithContext verifies a row proof using pre-initialized context Efficient for multiple verifications with same commitment
pkg/rsema1d/proof.go:46
↓ 18 callersFunctionencodeVarintProof
(dAtA []byte, offset int, v uint64)
pkg/proof/proof.pb.go:607
↓ 18 callersFunctionencodeVarintTx
(dAtA []byte, offset int, v uint64)
x/zkism/types/tx.pb.go:892
↓ 18 callersFunctionsovFibre
(x uint64)
x/fibre/types/fibre.pb.go:626
↓ 17 callersMethodConfirmTx
ConfirmTx periodically pings the provided node for the commitment of a transaction by its hash. It will continually loop until the context is cancelle
pkg/user/tx_client.go:764
↓ 17 callersFunctionDefaultTxOpts
()
test/util/blobfactory/test_util.go:15
↓ 17 callersMethodGetConfig
()
tools/talis/client.go:22
↓ 17 callersMethodIsZero
IsZero returns true if the DataAvailabilityHeader is nil or it has no row or column roots.
pkg/da/data_availability_header.go:258
↓ 17 callersFunctionNewTxCache
NewTxCache creates a new transaction cache
app/tx_cache.go:16
↓ 17 callersMethodSetProcessedPayment
SetProcessedPayment saves a processed payment to both indexes: 1. Primary index: processed_payments_by_hash/{hash} 2. Secondary index: processed_payme
x/fibre/keeper/keeper.go:206
↓ 17 callersMethodSignBytes
SignBytes returns the canonical bytes that should be signed for this [PaymentPromise]. Both keyring (client) and validator paths sign these same bytes
fibre/payment_promise.go:254
↓ 17 callersMethodString
()
x/valaddr/types/query.pb.go:225
↓ 17 callersMethodValidate
Validate checks configuration constraints
pkg/rsema1d/config.go:35
↓ 17 callersMethodWithChainID
WithChainID sets the chain ID and returns the Config.
test/util/testnode/config.go:125
↓ 17 callersFunctionassemblerRowCount
Primary row count used by most tests (assembler slab).
fibre/internal/row/pool_test.go:23
↓ 17 callersFunctionhandleErr
handleErr prints the error and exits the program if the error is not nil
cmd/celestia-appd/cmd/testnet.go:230
↓ 17 callersFunctionmakeTestData
(k, rowSize int)
pkg/rsema1d/codec_test.go:53
↓ 17 callersFunctionreject
()
app/process_proposal.go:236
↓ 16 callersMethodCreateSyntheticToken
(chain *ibctesting.TestChain, ismID, mailboxID util.HexAddress)
test/interop/hyperlane_test.go:406
↓ 16 callersMethodEncode
Encode creates parity and commitment for K+N rows. rows must have length K+N. Original data goes in rows[:K], and parity rows in rows[K:] must be allo
pkg/rsema1d/coder.go:37
↓ 16 callersMethodGetCelestiaApp
(chain *ibctesting.TestChain)
test/interop/ibc_test.go:36
↓ 16 callersMethodGetSubspace
GetSubspace returns a param subspace for a given module name. NOTE: This is solely to be used for testing purposes.
app/app.go:767
↓ 16 callersFunctionNewErasuredNamespacedMerkleTree
NewErasuredNamespacedMerkleTree creates a new ErasuredNamespacedMerkleTree with an underlying NMT of namespace size `share.NamespaceSize` and with `ig
pkg/wrapper/nmt_wrapper.go:54
↓ 16 callersMethodProcessProposal
ProcessProposal overwrites the default app's method to auto accept any proposal.
test/util/malicious/app.go:88
↓ 16 callersFunctionSetGasLimitAndGasPrice
SetGasLimitAndGasPrice sets the gas limit and fee using the provided gas price and gas limit. Note that this could overwrite or be overwritten by othe
pkg/user/tx_options.go:59
↓ 16 callersMethodSize
Size returns the number of bytes Sum will return.
test/util/malicious/hasher.go:85
↓ 16 callersMethodTryUpgrade
TryUpgrade tallies all the votes for all the versions to determine if a quorum has been reached for a version.
x/signal/types/tx.pb.go:261
↓ 16 callersMethodUpload
Upload uploads the given [Blob] to the Fibre network. It creates a [PaymentPromise], uploads the data to validators, and collects signatures confirmin
fibre/client_upload.go:59
↓ 16 callersMethodcreatePaymentPromise
createPaymentPromise creates a properly signed and valid payment promise for testing
x/fibre/keeper/keeper_test.go:703
↓ 16 callersFunctionencodeVarintFibre
(dAtA []byte, offset int, v uint64)
x/fibre/types/fibre.pb.go:541
↓ 16 callersMethodgetApp
getApp gets the appropriate app based on the latest application version.
multiplexer/abci/multiplexer.go:427
↓ 16 callersFunctionsovTx
(x uint64)
app/grpc/tx/tx.pb.go:851
↓ 15 callersMethodBeginBlocker
BeginBlocker processes automatic state transitions at the beginning of each block
x/fibre/keeper/abci.go:9
↓ 15 callersMethodChainID
ChainID returns the chain ID of the state machine.
fibre/state/client.go:29
↓ 15 callersMethodDeriveForwardingAddress
DeriveForwardingAddress derives the forwarding address for given parameters.
x/forwarding/types/query.pb.go:307
↓ 15 callersMethodExists
Exists checks whether the Tx exists in the cache and the blobs match the cached blobs
app/tx_cache.go:29
↓ 15 callersMethodInfo
(_ context.Context, req *abci.RequestInfo)
multiplexer/abci/abci.go:107
↓ 15 callersFunctionNewBlob
NewBlob creates a new [Blob] instance by encoding the data. It takes ownership of data and may reuse it directly as backing storage for original rows.
fibre/blob.go:158
↓ 15 callersMethodParams
Params queries the parameters of the module.
x/minfee/types/query.pb.go:248
↓ 15 callersMethodSetWithdrawal
SetWithdrawal saves a withdrawal to both indexes: 1. Primary index: withdrawals_by_signer/{signer}/{requested_timestamp} 2. Secondary index: withdrawa
x/fibre/keeper/keeper.go:113
↓ 15 callersMethodSlabs
Slabs returns the total count of live slabs (in-use plus free) across all buckets. For tests and observability; locks each bucket briefly.
fibre/internal/row/pool.go:163
↓ 15 callersMethodString
String implements the Stringer interface.
x/blob/types/params.go:59
↓ 15 callersMethodWithDelayedPrecommitTimeout
WithDelayedPrecommitTimeout sets the target block time using DelayedPrecommitTimeout in the app options and returns the Config. This affects the Delay
test/util/testnode/config.go:99
↓ 15 callersFunctionmakeTestPaymentPromise
makeTestPaymentPromise creates a test payment promise for store tests.
fibre/store_test.go:348
↓ 15 callersMethodunusedAccount
()
app/test/std_sdk_test.go:73
↓ 14 callersMethodConfig
Config returns the blob's configuration.
fibre/blob.go:231
↓ 14 callersMethodCreateCollateralToken
(chain *ibctesting.TestChain, ismID, mailboxID util.HexAddress, denom string)
test/interop/hyperlane_test.go:376
↓ 14 callersFunctionDefaultServerConfig
DefaultServerConfig returns a [ServerConfig] with default values.
fibre/server_config.go:70
↓ 14 callersMethodDepositToEscrow
DepositToEscrow deposits funds to the signer's escrow account
x/fibre/types/tx.pb.go:585
↓ 14 callersMethodGetPubKey
()
fibre/server_test.go:99
↓ 14 callersMethodSave
(root string)
tools/talis/config.go:326
↓ 14 callersMethodStore
Store returns the server's store.
fibre/server.go:84
↓ 14 callersMethodWaitForHeight
WaitForHeight performs a blocking check where it waits for the network to reach the specified height. If that height is not reached within a timeout,
test/util/testnode/node_interaction_api.go:161
↓ 14 callersFunctionWithDefaultAccount
(name string)
pkg/user/tx_client.go:153
↓ 14 callersFunctioncomputeRLC
computeRLC computes random linear combination for a row (internal)
pkg/rsema1d/commitment.go:75
↓ 14 callersFunctioncopyFile
copyFile copies a single file from src to dest, preserving permissions and creating parent directories if needed.
tools/talis/init.go:297
↓ 14 callersFunctionencodeVarintTx
(dAtA []byte, offset int, v uint64)
app/grpc/tx/tx.pb.go:738
↓ 14 callersFunctionmakePaymentPromise
makePaymentPromise creates a test [fibre.PaymentPromise] with the given private key.
fibre/payment_promise_test.go:15
↓ 14 callersFunctionmakeTestConfig
Helper functions
pkg/rsema1d/codec_test.go:44
↓ 14 callersFunctionsetup
(t *testing.T)
x/signal/keeper_test.go:576
↓ 14 callersFunctionsovEvents
(x uint64)
x/zkism/types/events.pb.go:452
↓ 13 callersMethodBroadcastTx
(ctx context.Context, msgs []sdktypes.Msg, opts ...TxOption)
pkg/user/tx_client.go:461
↓ 13 callersMethodClose
Close cleans up test resources
pkg/user/worker_account_test.go:62
↓ 13 callersFunctionComputeRootFromProof
ComputeRootFromProof computes the Merkle root given a leaf and its proof
pkg/rsema1d/merkle/proof.go:134
↓ 13 callersFunctionDefaultBlobConfigV0
DefaultBlobConfigV0 returns a [BlobConfig] with default values for version 0. The config is created once at init and shared across all callers.
fibre/blob.go:59
↓ 13 callersMethodDownload
Download retrieves and reconstructs a [Blob] by [BlobID] from the [Server]s. The algorithm selects validators shuffled by stake weight for load balan
fibre/client_download.go:52
↓ 13 callersMethodEstimateGasPrice
estimateGasPrice takes a transaction priority and estimates the gas price based on the gas prices of the transactions in the last five blocks. If no t
app/grpc/gasestimation/gas_estimator.pb.go:337
↓ 13 callersMethodGetMinter
GetMinter returns the minter.
x/mint/keeper/keeper.go:44
↓ 13 callersMethodGetWithdrawalsBySigner
GetWithdrawalsBySigner retrieves all withdrawals for a signer
x/fibre/keeper/keeper.go:141
↓ 13 callersMethodIsStopped
()
multiplexer/appd/run.go:107
↓ 13 callersFunctionMakeRecipient32
MakeRecipient32 pads a 20-byte address to a 32-byte Hyperlane recipient. The address bytes are placed at the end (bytes 12-31).
test/interop/helpers.go:43
↓ 13 callersFunctionRandBlobTxsWithNamespacesAndSigner
( signer *user.Signer, namespaces []share.Namespace, sizes []int, )
test/util/blobfactory/payforblob_factory.go:291
↓ 13 callersMethodRegisterLegacyAminoCodec
RegisterLegacyAminoCodec registers the blob module's types on the LegacyAmino codec.
x/blob/module.go:54
↓ 13 callersMethodSetFibreProviderInfo
SetFibreProviderInfo allows a validator to set or update their fibre provider information
x/valaddr/types/tx.pb.go:172
↓ 13 callersMethodSetSequence
(accountName string, seq uint64)
pkg/user/signer.go:238
↓ 13 callersFunctionZero
Zero returns the zero element in GF128
pkg/rsema1d/field/gf128.go:9
↓ 13 callersFunctionmakeTestLeaves
(n int)
pkg/rsema1d/merkle/merkle_test.go:359
↓ 13 callersFunctionrunScriptInTMux
runScriptInTMux SSHes into each remote host in parallel, and launches the specified remoteScript inside a detached tmux session named sessionName. It
tools/talis/execution.go:19
↓ 13 callersFunctionsovQuery
(x uint64)
x/fibre/types/query.pb.go:1349
↓ 13 callersFunctionsovService
(x uint64)
x/fibre/types/service.pb.go:879
↓ 13 callersFunctionsovTx
(x uint64)
x/fibre/types/tx.pb.go:1268
↓ 13 callersFunctionvalidMsgPayForBlobs
(t *testing.T)
x/blob/types/payforblob_test.go:209
↓ 12 callersFunctionBuildPaddedRLCTree
BuildPaddedRLCTree creates a padded Merkle tree from RLC original values Only stores K values padded to kPadded (not totalPadded like row tree)
pkg/rsema1d/padding.go:28
↓ 12 callersFunctionDefaultAppConfig
()
app/default_overrides.go:291
↓ 12 callersFunctionDeriveForwardingAddress
DeriveForwardingAddress computes a deterministic forwarding address from destination parameters. Each address is bound to a single token for a given (
x/forwarding/types/address.go:40
↓ 12 callersMethodGetSubspace
GetSubspace returns a param subspace for a given module name. NOTE: This is solely to be used for testing purposes.
test/interop/simapp.go:857
↓ 12 callersFunctionMustGetFreePort
MustGetFreePort returns a free port and panics in case of an error.
test/util/testnode/utils.go:119
↓ 12 callersFunctionNewClient
NewClient creates a new [Client] with the provided dependencies. Returns an error if the configured key is not found in the keyring.
fibre/client.go:55
← previousnext →101–200 of 5,969, ranked by callers