MCPcopy Create free account

hub / github.com/GeorgeBake/pipeline-cli / functions

Functions5,659 in github.com/GeorgeBake/pipeline-cli

⨍ Functions 5,659◇ Types & classes 1,648
↓ 6 callersMethodmap_result
Discards the result and return storage changes.
crates/types/src/services.rs:57
↓ 6 callersMethodmaybe_spend_inputs
Marks inputs as spent, by preserves the information about the spender in the case if we need to unspend inputs later, see [`unspend_inputs`] for more
crates/services/txpool_v2/src/spent_inputs.rs:44
↓ 6 callersMethodnative_executor_version
(&self)
crates/services/upgradable-executor/src/executor.rs:274
↓ 6 callersMethodnew_known_tx
We expect it to be called a lot (every new tx in the pool).
crates/services/txpool_v2/src/pending_pool.rs:235
↓ 6 callersMethodnext_block_algorithm
(&self)
crates/services/gas_price_service/src/v1/service.rs:253
↓ 6 callersMethodnth
(&mut self, n: usize)
crates/chain-config/src/config/state/parquet/decode.rs:68
↓ 6 callersFunctionopen_db
( path: &Path, capacity: Option<usize>, max_fds: i32, )
bin/fuel-core/src/cli/snapshot.rs:211
↓ 6 callersMethodpartial_close
(self)
crates/chain-config/src/config/state/writer.rs:371
↓ 6 callersMethodread_options
(&self)
crates/fuel-core/src/state/rocks_db.rs:449
↓ 6 callersMethodread_response
( &mut self, protocol: &Self::Protocol, socket: &mut T, )
crates/services/p2p/src/codecs/request_response.rs:75
↓ 6 callersMethodrecipient
Get the message recipient
crates/types/src/entities/relayer/message.rs:87
↓ 6 callersFunctionreport_peer
(p2p: &Arc<P>, peer_id: Option<PeerId>, reason: PeerReportReason)
crates/services/sync/src/import.rs:653
↓ 6 callersMethodroot
Returns the state root of the whole contract.
crates/services/executor/src/refs/contract.rs:190
↓ 6 callersFunctionrun
A single iteration of the run loop.
crates/services/relayer/src/service/run.rs:38
↓ 6 callersMethodsender
Get the message sender
crates/types/src/entities/relayer/message.rs:72
↓ 6 callersMethodsetup_contract
setup a contract and add to genesis configuration
tests/test-helpers/src/builder.rs:126
↓ 6 callersMethodshutdown
(self)
crates/fuel-core/src/database.rs:185
↓ 6 callersFunctionsingle_asset_assert
( owner: Address, asset_ids: &[AssetId], base_asset_id: &AssetId,
crates/fuel-core/src/coins_query.rs:608
↓ 6 callersMethodstart_and_await
Start all sub services and await for them to start.
crates/fuel-core/src/service.rs:393
↓ 6 callersMethodsubscribe
(&self)
crates/services/compression/src/service.rs:483
↓ 6 callersMethodsubscribe
(&self)
crates/services/gas_price_service/src/v1/da_source_service/service.rs:39
↓ 6 callersMethodsync_timeout
(&self)
bin/e2e-test-client/src/config.rs:33
↓ 6 callersFunctiontest_case_run
( case: TestCase, coin_type: CoinType, base_asset_id: AssetId, )
crates/fuel-core/src/coins_query.rs:1729
↓ 6 callersFunctiontest_storage
()
crates/services/compression/src/service.rs:499
↓ 6 callersMethodtest_view
(&self)
crates/fuel-core/src/graphql_api/database.rs:214
↓ 6 callersFunctiontransactions_from_subsections
( rng: &mut StdRng, subsections: Vec<UploadSubsection>, amount: u64, )
tests/test-helpers/src/lib.rs:58
↓ 6 callersMethodtry_to_peer_id
(&self)
crates/services/p2p/src/lib.rs:48
↓ 6 callersMethodtx
(&self)
crates/services/txpool_v2/src/service.rs:138
↓ 6 callersMethodupdate_components_and_caches_on_removal
( &mut self, removed_transactions: impl Iterator<Item = &'a StorageData>, )
crates/services/txpool_v2/src/pool.rs:717
↓ 6 callersMethodv1
(&self)
crates/services/gas_price_service/src/common/updater_metadata.rs:26
↓ 6 callersFunctionverifier
(result: R)
crates/services/importer/src/importer/test.rs:188
↓ 6 callersMethodview_at
(&self, _: &Self::Height)
crates/services/upgradable-executor/src/executor.rs:1247
↓ 6 callersMethodwatch
(&self)
crates/services/consensus_module/poa/src/service_test/test_time.rs:61
↓ 6 callersMethodwith_config
(&mut self, config: Config)
crates/services/consensus_module/poa/src/service_test.rs:117
↓ 6 callersMethodwith_latest_da_block_height_from_relayer
( mut self, latest_block_height: DaBlockHeight, )
crates/services/producer/src/block_producer/tests.rs:982
↓ 6 callersMethodwith_post_call
(mut self, post_call: Vec<Instruction>)
benches/src/lib.rs:305
↓ 6 callersMethodworst_case
(&self, height: u32)
crates/fuel-gas-price-algorithm/src/v1.rs:55
↓ 6 callersMethodwrite_response
( &mut self, protocol: &Self::Protocol, socket: &mut T, res: Self::Response,
crates/services/p2p/src/codecs/request_response.rs:112
↓ 5 callersMethodadd_address
Adds a known listen address of a peer participating in the DHT to the routing table.
crates/services/p2p/src/discovery.rs:76
↓ 5 callersFunctionadd_consensus_parameters
( mut database: Storage, consensus_parameters: &ConsensusParameters, )
crates/services/parallel-executor/src/tests/tests_executor.rs:203
↓ 5 callersMethodall_dependencies
(&self)
crates/services/txpool_v2/src/storage/checked_collision.rs:38
↓ 5 callersMethodas_u64
(&self)
crates/fuel-core/src/database/database_description.rs:25
↓ 5 callersMethodassemble
(mut self)
crates/fuel-core/src/schema/tx/assemble_tx.rs:372
↓ 5 callersFunctionassert_absence
(status_read: &mpsc::Sender<ReadRequest>, txs: Vec<Bytes32>)
crates/services/tx_status_manager/src/service.rs:977
↓ 5 callersMethodasset_id
(&self)
crates/fuel-core/src/schema/coins.rs:82
↓ 5 callersMethodawait_transaction_commit
Awaits for the transaction to be committed into a block This will wait forever if needed, so consider wrapping this call with a `tokio::time::timeout
crates/client/src/client.rs:1367
↓ 5 callersMethodblob_id
(&self)
crates/fuel-core/src/schema/tx/types.rs:839
↓ 5 callersFunctionblock_to_import_result
(block: Block)
crates/services/gas_price_service/src/common/l2_block_source/tests.rs:99
↓ 5 callersFunctionbuild_block
(chain_id: &ChainId, height: BlockHeight)
crates/services/gas_price_service/src/common/l2_block_source/tests.rs:176
↓ 5 callersMethodbuild_with_handles
(self)
crates/services/consensus_module/poa/src/pre_confirmation_signature_service/tests.rs:219
↓ 5 callersMethodclone
(&self)
crates/services/gas_price_service/src/common/gas_price_algorithm.rs:13
↓ 5 callersMethodcoins
( &self, utxo_ids: Vec<UtxoId>, )
crates/fuel-core/src/query/coin.rs:34
↓ 5 callersMethodcommit_changes
(&mut self, changes: Changes)
crates/storage/src/transactional.rs:312
↓ 5 callersMethodconsensus_mut
Mutable getter for consensus portion of header
crates/types/src/blockchain/header.rs:251
↓ 5 callersMethodconsensus_parameters
( &self, version: i32, )
crates/client/src/client.rs:683
↓ 5 callersMethodconsensus_parameters_version
(&self)
crates/storage/src/vm_storage.rs:268
↓ 5 callersMethodconsistency_20s
Wait for the node to reach consistency with the given transactions within 20 seconds.
crates/fuel-core/src/p2p_test_helpers.rs:641
↓ 5 callersMethodcontract_id
(&self)
crates/fuel-core/src/schema/assets.rs:59
↓ 5 callersMethodda_compressed_block
( &self, height: BlockHeight, )
crates/client/src/client.rs:1511
↓ 5 callersFunctiondatabase
()
crates/services/block_aggregator_api/src/db/storage_db/tests.rs:17
↓ 5 callersMethoddecode
(&self, bytes: &[u8])
crates/services/p2p/src/codecs/postcard.rs:57
↓ 5 callersMethoddelete
(&mut self, key: &[u8], column: Self::Column)
crates/fuel-core/src/state/rocks_db.rs:1136
↓ 5 callersFunctiondeploy
Deploy the contract
tests/test-helpers/src/mint_contract.rs:43
↓ 5 callersMethodderef
(&self)
crates/fuel-core/src/state/rocks_db.rs:82
↓ 5 callersMethoddigest
(&self)
crates/fuel-core/src/schema/tx/receipt.rs:99
↓ 5 callersFunctiondownload_logs
Download the logs from the DA layer.
crates/services/relayer/src/service/get_logs.rs:20
↓ 5 callersMethodexecute
(&self, id: &str, op: &Instruction)
crates/client/src/client.rs:1206
↓ 5 callersMethodexecute_chargeable_transaction
( &self, mut checked_tx: Checked<Tx>, header: &PartialBlockHeader, coinbase_co
crates/services/executor/src/executor.rs:1442
↓ 5 callersMethodexists
(&self, key: &[u8], column: Self::Column)
crates/storage/src/kv_store.rs:100
↓ 5 callersMethodgas_price_factor
(&self)
crates/fuel-core/src/schema/chain.rs:267
↓ 5 callersMethodgenerate_data
(&mut self, max_amount: usize)
bin/fuel-core/src/cli/snapshot.rs:689
↓ 5 callersFunctiongenerate_p2p_port
()
crates/services/consensus_module/poa/src/service_test.rs:96
↓ 5 callersFunctionget_block_info
( block: &Block<Transaction>, gas_price_factor: u64, block_gas_limit: u64, )
crates/services/gas_price_service/src/common/fuel_core_storage_adapter.rs:174
↓ 5 callersMethodget_direct_dependencies
( &self, index: NodeIndex, )
crates/services/txpool_v2/src/storage/graph.rs:327
↓ 5 callersMethodget_direct_dependents
( &self, index: NodeIndex, )
crates/services/txpool_v2/src/storage/graph.rs:319
↓ 5 callersMethodget_finalized_da_height
Get finalized da height that represents last block from da layer that got finalized. Panics if height is not set as of initialization of the relayer.
crates/services/relayer/src/service.rs:330
↓ 5 callersMethodget_l2_block
(&mut self)
crates/services/gas_price_service/src/common/l2_block_source.rs:53
↓ 5 callersFunctionget_random_peers
(size: usize)
crates/services/p2p/src/peer_manager.rs:401
↓ 5 callersMethodgiven_logs
(&mut self, mut logs: Vec<Log>)
crates/services/relayer/tests/integration.rs:291
↓ 5 callersFunctiongossipsub_broadcast
TODO: Move me before tests that use this function Reusable helper function for Broadcasting Gossipsub requests
crates/services/p2p/src/p2p_service/tests.rs:797
↓ 5 callersFunctiongraphql_metrics
()
crates/metrics/src/graphql_metrics.rs:72
↓ 5 callersFunctionincrement
Increment the counter, returning the new value
tests/test-helpers/src/counter_contract.rs:134
↓ 5 callersFunctioninput_contracts
(tx: &Tx)
crates/fuel-core/src/schema/tx/types.rs:982
↓ 5 callersMethodinsert_events
( &mut self, da_height: &DaBlockHeight, events: &[Event], )
crates/services/relayer/src/mock_db.rs:106
↓ 5 callersMethodinsert_message
(&self, message: Message)
crates/services/txpool_v2/src/tests/mocks.rs:154
↓ 5 callersMethodinto_inner
Returns the storage and changes to it.
crates/storage/src/transactional.rs:116
↓ 5 callersMethodinto_log
(self)
crates/services/relayer/src/test_helpers.rs:61
↓ 5 callersMethodinto_message
Converts the hash into a message having the same bytes.
crates/types/src/blockchain/primitives.rs:62
↓ 5 callersMethodinto_storage
Returns the inner storage.
crates/storage/src/structured_storage.rs:107
↓ 5 callersMethodis_cancelled
(&self)
crates/fuel-core/src/lib.rs:107
↓ 5 callersFunctionis_dialable
(multiaddr: &Multiaddr)
crates/services/p2p/src/utils.rs:3
↓ 5 callersMethodis_dry_run
(&self)
crates/services/upgradable-executor/src/executor.rs:115
↓ 5 callersMethodis_final
(&self)
crates/fuel-core/src/schema/tx/types.rs:442
↓ 5 callersMethodjson
(dir: impl Into<PathBuf>)
crates/chain-config/src/config/state/writer.rs:261
↓ 5 callersFunctionl2_source
( genesis_block_height: BlockHeight, gas_price_settings: T, committed_block_stream: BoxStream<Shar
crates/services/gas_price_service/src/common/l2_block_source/tests.rs:77
↓ 5 callersMethodlast_block_config
(&self)
crates/chain-config/src/config/state/reader.rs:292
↓ 5 callersMethodlisteners
(&self)
crates/fuel-core/src/p2p_test_helpers.rs:249
↓ 5 callersMethodmake_coin
( &mut self, owner: Address, amount: Word, asset_id: AssetId,
crates/fuel-core/src/coins_query.rs:1893
↓ 5 callersFunctionmake_config
( name: String, mut node_config: Config, config_overrides: CustomizeConfig, )
crates/fuel-core/src/p2p_test_helpers.rs:494
↓ 5 callersFunctionmake_node
(node_config: Config, test_txs: Vec<Transaction>)
crates/fuel-core/src/p2p_test_helpers.rs:527
← previousnext →501–600 of 5,659, ranked by callers