Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/celestiaorg/celestia-app
/ functions
Functions
5,969 in github.com/celestiaorg/celestia-app
⨍
Functions
5,969
◇
Types & classes
615
↓ 19 callers
Method
Sequence
Sequence returns the sequence number of the account. This is locally tracked
pkg/user/account.go:50
↓ 19 callers
Method
UnmarshalJSON
UnmarshalJSON decodes a hex string into a commitment.
fibre/blob_id.go:25
↓ 19 callers
Function
encodeVarintEvent
(dAtA []byte, offset int, v uint64)
x/fibre/types/event.pb.go:807
↓ 18 callers
Method
Free
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 callers
Method
FromProto
FromProto converts the [PaymentPromise] from its protobuf representation.
fibre/payment_promise.go:77
↓ 18 callers
Method
GetProcessedPayment
GetProcessedPayment retrieves a processed payment by promiseHash
x/fibre/keeper/keeper.go:192
↓ 18 callers
Function
Mul16
Mul16 multiplies two GF(2^16) elements
pkg/rsema1d/field/gf16.go:21
↓ 18 callers
Function
New
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 callers
Function
NewTree
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 callers
Method
Put
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 callers
Method
RequestWithdrawal
RequestWithdrawal requests withdrawal from the signer's escrow account
x/fibre/types/tx.pb.go:587
↓ 18 callers
Method
SetEscrowAccount
SetEscrowAccount stores an escrow account
x/fibre/keeper/keeper.go:83
↓ 18 callers
Function
VerifyRowWithContext
VerifyRowWithContext verifies a row proof using pre-initialized context Efficient for multiple verifications with same commitment
pkg/rsema1d/proof.go:46
↓ 18 callers
Function
encodeVarintProof
(dAtA []byte, offset int, v uint64)
pkg/proof/proof.pb.go:607
↓ 18 callers
Function
encodeVarintTx
(dAtA []byte, offset int, v uint64)
x/zkism/types/tx.pb.go:892
↓ 18 callers
Function
sovFibre
(x uint64)
x/fibre/types/fibre.pb.go:626
↓ 17 callers
Method
ConfirmTx
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 callers
Function
DefaultTxOpts
()
test/util/blobfactory/test_util.go:15
↓ 17 callers
Method
GetConfig
()
tools/talis/client.go:22
↓ 17 callers
Method
IsZero
IsZero returns true if the DataAvailabilityHeader is nil or it has no row or column roots.
pkg/da/data_availability_header.go:258
↓ 17 callers
Function
NewTxCache
NewTxCache creates a new transaction cache
app/tx_cache.go:16
↓ 17 callers
Method
SetProcessedPayment
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 callers
Method
SignBytes
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 callers
Method
String
()
x/valaddr/types/query.pb.go:225
↓ 17 callers
Method
Validate
Validate checks configuration constraints
pkg/rsema1d/config.go:35
↓ 17 callers
Method
WithChainID
WithChainID sets the chain ID and returns the Config.
test/util/testnode/config.go:125
↓ 17 callers
Function
assemblerRowCount
Primary row count used by most tests (assembler slab).
fibre/internal/row/pool_test.go:23
↓ 17 callers
Function
handleErr
handleErr prints the error and exits the program if the error is not nil
cmd/celestia-appd/cmd/testnet.go:230
↓ 17 callers
Function
makeTestData
(k, rowSize int)
pkg/rsema1d/codec_test.go:53
↓ 17 callers
Function
reject
()
app/process_proposal.go:236
↓ 16 callers
Method
CreateSyntheticToken
(chain *ibctesting.TestChain, ismID, mailboxID util.HexAddress)
test/interop/hyperlane_test.go:406
↓ 16 callers
Method
Encode
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 callers
Method
GetCelestiaApp
(chain *ibctesting.TestChain)
test/interop/ibc_test.go:36
↓ 16 callers
Method
GetSubspace
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 callers
Function
NewErasuredNamespacedMerkleTree
NewErasuredNamespacedMerkleTree creates a new ErasuredNamespacedMerkleTree with an underlying NMT of namespace size `share.NamespaceSize` and with `ig
pkg/wrapper/nmt_wrapper.go:54
↓ 16 callers
Method
ProcessProposal
ProcessProposal overwrites the default app's method to auto accept any proposal.
test/util/malicious/app.go:88
↓ 16 callers
Function
SetGasLimitAndGasPrice
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 callers
Method
Size
Size returns the number of bytes Sum will return.
test/util/malicious/hasher.go:85
↓ 16 callers
Method
TryUpgrade
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 callers
Method
Upload
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 callers
Method
createPaymentPromise
createPaymentPromise creates a properly signed and valid payment promise for testing
x/fibre/keeper/keeper_test.go:703
↓ 16 callers
Function
encodeVarintFibre
(dAtA []byte, offset int, v uint64)
x/fibre/types/fibre.pb.go:541
↓ 16 callers
Method
getApp
getApp gets the appropriate app based on the latest application version.
multiplexer/abci/multiplexer.go:427
↓ 16 callers
Function
sovTx
(x uint64)
app/grpc/tx/tx.pb.go:851
↓ 15 callers
Method
BeginBlocker
BeginBlocker processes automatic state transitions at the beginning of each block
x/fibre/keeper/abci.go:9
↓ 15 callers
Method
ChainID
ChainID returns the chain ID of the state machine.
fibre/state/client.go:29
↓ 15 callers
Method
DeriveForwardingAddress
DeriveForwardingAddress derives the forwarding address for given parameters.
x/forwarding/types/query.pb.go:307
↓ 15 callers
Method
Exists
Exists checks whether the Tx exists in the cache and the blobs match the cached blobs
app/tx_cache.go:29
↓ 15 callers
Method
Info
(_ context.Context, req *abci.RequestInfo)
multiplexer/abci/abci.go:107
↓ 15 callers
Function
NewBlob
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 callers
Method
Params
Params queries the parameters of the module.
x/minfee/types/query.pb.go:248
↓ 15 callers
Method
SetWithdrawal
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 callers
Method
Slabs
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 callers
Method
String
String implements the Stringer interface.
x/blob/types/params.go:59
↓ 15 callers
Method
WithDelayedPrecommitTimeout
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 callers
Function
makeTestPaymentPromise
makeTestPaymentPromise creates a test payment promise for store tests.
fibre/store_test.go:348
↓ 15 callers
Method
unusedAccount
()
app/test/std_sdk_test.go:73
↓ 14 callers
Method
Config
Config returns the blob's configuration.
fibre/blob.go:231
↓ 14 callers
Method
CreateCollateralToken
(chain *ibctesting.TestChain, ismID, mailboxID util.HexAddress, denom string)
test/interop/hyperlane_test.go:376
↓ 14 callers
Function
DefaultServerConfig
DefaultServerConfig returns a [ServerConfig] with default values.
fibre/server_config.go:70
↓ 14 callers
Method
DepositToEscrow
DepositToEscrow deposits funds to the signer's escrow account
x/fibre/types/tx.pb.go:585
↓ 14 callers
Method
GetPubKey
()
fibre/server_test.go:99
↓ 14 callers
Method
Save
(root string)
tools/talis/config.go:326
↓ 14 callers
Method
Store
Store returns the server's store.
fibre/server.go:84
↓ 14 callers
Method
WaitForHeight
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 callers
Function
WithDefaultAccount
(name string)
pkg/user/tx_client.go:153
↓ 14 callers
Function
computeRLC
computeRLC computes random linear combination for a row (internal)
pkg/rsema1d/commitment.go:75
↓ 14 callers
Function
copyFile
copyFile copies a single file from src to dest, preserving permissions and creating parent directories if needed.
tools/talis/init.go:297
↓ 14 callers
Function
encodeVarintTx
(dAtA []byte, offset int, v uint64)
app/grpc/tx/tx.pb.go:738
↓ 14 callers
Function
makePaymentPromise
makePaymentPromise creates a test [fibre.PaymentPromise] with the given private key.
fibre/payment_promise_test.go:15
↓ 14 callers
Function
makeTestConfig
Helper functions
pkg/rsema1d/codec_test.go:44
↓ 14 callers
Function
setup
(t *testing.T)
x/signal/keeper_test.go:576
↓ 14 callers
Function
sovEvents
(x uint64)
x/zkism/types/events.pb.go:452
↓ 13 callers
Method
BroadcastTx
(ctx context.Context, msgs []sdktypes.Msg, opts ...TxOption)
pkg/user/tx_client.go:461
↓ 13 callers
Method
Close
Close cleans up test resources
pkg/user/worker_account_test.go:62
↓ 13 callers
Function
ComputeRootFromProof
ComputeRootFromProof computes the Merkle root given a leaf and its proof
pkg/rsema1d/merkle/proof.go:134
↓ 13 callers
Function
DefaultBlobConfigV0
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 callers
Method
Download
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 callers
Method
EstimateGasPrice
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 callers
Method
GetMinter
GetMinter returns the minter.
x/mint/keeper/keeper.go:44
↓ 13 callers
Method
GetWithdrawalsBySigner
GetWithdrawalsBySigner retrieves all withdrawals for a signer
x/fibre/keeper/keeper.go:141
↓ 13 callers
Method
IsStopped
()
multiplexer/appd/run.go:107
↓ 13 callers
Function
MakeRecipient32
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 callers
Function
RandBlobTxsWithNamespacesAndSigner
( signer *user.Signer, namespaces []share.Namespace, sizes []int, )
test/util/blobfactory/payforblob_factory.go:291
↓ 13 callers
Method
RegisterLegacyAminoCodec
RegisterLegacyAminoCodec registers the blob module's types on the LegacyAmino codec.
x/blob/module.go:54
↓ 13 callers
Method
SetFibreProviderInfo
SetFibreProviderInfo allows a validator to set or update their fibre provider information
x/valaddr/types/tx.pb.go:172
↓ 13 callers
Method
SetSequence
(accountName string, seq uint64)
pkg/user/signer.go:238
↓ 13 callers
Function
Zero
Zero returns the zero element in GF128
pkg/rsema1d/field/gf128.go:9
↓ 13 callers
Function
makeTestLeaves
(n int)
pkg/rsema1d/merkle/merkle_test.go:359
↓ 13 callers
Function
runScriptInTMux
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 callers
Function
sovQuery
(x uint64)
x/fibre/types/query.pb.go:1349
↓ 13 callers
Function
sovService
(x uint64)
x/fibre/types/service.pb.go:879
↓ 13 callers
Function
sovTx
(x uint64)
x/fibre/types/tx.pb.go:1268
↓ 13 callers
Function
validMsgPayForBlobs
(t *testing.T)
x/blob/types/payforblob_test.go:209
↓ 12 callers
Function
BuildPaddedRLCTree
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 callers
Function
DefaultAppConfig
()
app/default_overrides.go:291
↓ 12 callers
Function
DeriveForwardingAddress
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 callers
Method
GetSubspace
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 callers
Function
MustGetFreePort
MustGetFreePort returns a free port and panics in case of an error.
test/util/testnode/utils.go:119
↓ 12 callers
Function
NewClient
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
← previous
next →
101–200 of 5,969, ranked by callers