Functions — github.com/cowprotocol/services

hub / github.com/cowprotocol/services / functions

Functions8,522 in github.com/cowprotocol/services

⨍ Functions 8,522◇ Types & classes 3,082

( &self, block: BlockInfo, partially_processed_block: &watch::Sender<u64>, ful

↓ 1 callersFunctionindexer_pass_snapshot

One full indexer lifecycle (start → wait for head → snapshot → stop). Two calls in sequence over the same DB are how `checkpoint_resume` proves the re

crates/e2e/tests/e2e/pool_indexer.rs:522

↓ 1 callersFunctioninfo

(app: axum::Router<State>)

crates/driver/src/infra/api/routes/info.rs:3

↓ 1 callersFunctioninit

Setup the observability. The log argument configures the tokio tracing framework.

crates/driver/src/infra/observe/mod.rs:39

↓ 1 callersFunctioninit

Setup the metrics registry.

crates/solvers/src/infra/metrics.rs:27

↓ 1 callersFunctioninit_liquidity

( eth: &Ethereum, block_retriever: Arc<dyn BlockRetrieving>, config: &infra::liquidity::config::Un

crates/driver/src/boundary/liquidity/uniswap/v3.rs:111

↓ 1 callersFunctioninit_liquidity

( eth: &Ethereum, block_stream: &CurrentBlockWatcher, block_retriever: Arc<dyn BlockRetrieving>,

crates/driver/src/boundary/liquidity/balancer/v2/mod.rs:97

↓ 1 callersMethodinitialize

Resets all the counters to 0 so we can always use them in Grafana queries.

crates/orderbook/src/orderbook.rs:111

↓ 1 callersMethodinitialize_from_database

(&self)

crates/cow-amm/src/cache.rs:47

↓ 1 callersFunctioninitialize_observability

(args: &Arguments)

crates/pool-indexer/src/run.rs:141

↓ 1 callersMethodinitialize_pools

(&self)

crates/liquidity-sources/src/balancer_v2/pool_init.rs:18

↓ 1 callersMethodinject

(&self, request: RequestBuilder)

crates/autopilot/src/infra/solvers/mod.rs:178

↓ 1 callersMethodinner

(&self)

crates/liquidity-sources/src/uniswap_v3/event_fetching.rs:55

↓ 1 callersMethodinner_encode

( &self, execution: AmmOrderExecution, encoder: &mut SettlementEncoder, )

crates/solver/src/liquidity/balancer_v2.rs:179

↓ 1 callersMethodinputs

The assets consumed by this interaction. These assets are taken from the settlement contract when the interaction executes.

crates/driver/src/domain/competition/solution/interaction.rs:27

↓ 1 callersFunctioninsert

(ex: &mut PgTransaction<'_>, scores: &[Score])

crates/database/src/reference_scores.rs:17

↓ 1 callersFunctioninsert

( ex: &mut PgConnection, auction_id: AuctionId, solver: Address, solution_uid: i64, start_

crates/database/src/settlement_executions.rs:22

↓ 1 callersFunctioninsert

( ex: &mut PgTransaction<'_>, prices: &[AuctionPrice], )

crates/database/src/auction_prices.rs:21

↓ 1 callersMethodinsert_balance

Only inserts new balances. This should always be used when we needed to fetch a balance because it was requested by a backend component.

crates/account-balances/src/cached.rs:56

↓ 1 callersFunctioninsert_batch

( ex: &mut PgConnection, fee_policies: impl IntoIterator<Item = FeePolicy>, )

crates/database/src/fee_policies.rs:31

↓ 1 callersFunctioninsert_batch

( ex: &mut PgConnection, auction_id: domain::auction::Id, fee_policies: impl IntoIterator<Item = (

crates/autopilot/src/database/fee_policies.rs:6

↓ 1 callersMethodinsert_full_app_data

( &self, contract_app_data: &AppDataHash, full_app_data: &str, )

crates/orderbook/src/database/app_data.rs:28

↓ 1 callersFunctioninsert_interactions

( ex: &mut PgConnection, order: &OrderUid, interactions: &[Interaction], )

crates/database/src/orders.rs:264

↓ 1 callersFunctioninsert_invalidation

( ex: &mut PgConnection, index: &EventIndex, event: &Invalidation, )

crates/database/src/events.rs:93

↓ 1 callersFunctioninsert_order_hooks

( db: &mut PgConnection, orders: &[Order], trampoline: &HooksTrampoline::Instance, )

crates/autopilot/src/database/onchain_order_events/mod.rs:683

↓ 1 callersFunctioninsert_order_parts_in_db

(db: &mut PgConnection, order_parts: &EthflowOrderParts)

crates/database/src/ethflow_orders.rs:337

↓ 1 callersFunctioninsert_quotes

(ex: &mut PgConnection, quotes: &[Quote])

crates/database/src/orders.rs:362

↓ 1 callersFunctioninstrument

( estimator: T, name: impl Into<String>, )

crates/price-estimation/src/factory.rs:557

↓ 1 callersFunctioninteraction

( interaction: &solution::Interaction, settlement: &Address, )

crates/driver/src/domain/quote.rs:319

↓ 1 callersFunctioninteraction_data_from_domain

(interaction_data: &[eth::Interaction])

crates/solvers/src/api/routes/solve/dto/solution.rs:137

↓ 1 callersMethodinto_chunk_changes

(self)

crates/pool-indexer/src/indexer/uniswap_v3.rs:976

↓ 1 callersMethodinto_dex_solution

Creates a full solution for a single order solution given gas and sell token prices. Computes the fee internally from the gas parameters.

crates/solvers/src/domain/solution.rs:206

↓ 1 callersFunctioninto_domain

( receipt: TransactionReceipt, trace: GethTrace, timestamp: u64, )

crates/autopilot/src/infra/blockchain/mod.rs:167

↓ 1 callersFunctioninto_domain

Converts a data transfer object into its domain object representation.

crates/solvers/src/api/routes/solve/dto/auction.rs:13

↓ 1 callersMethodinto_domain

(self)

crates/driver/src/infra/api/routes/quote/dto/order.rs:9

↓ 1 callersMethodinto_inner

(self)

crates/driver/src/infra/config/file/mod.rs:399

↓ 1 callersMethodinto_settle_call

(&self)

crates/simulator/src/encoding.rs:77

↓ 1 callersMethodinto_tick_data

(self, pool_address: Address)

crates/liquidity-sources/src/uniswap_v3/pool_indexer.rs:205

↓ 1 callersMethodinto_underlying

(self)

contracts/generated/contracts-generated/izeroex/src/lib.rs:77

↓ 1 callersMethodinto_underlying

(self)

contracts/generated/contracts-generated/cowswaponchainorders/src/lib.rs:667

↓ 1 callersMethodinto_underlying

(self)

contracts/generated/contracts-generated/liquoricesettlement/src/lib.rs:2211

↓ 1 callersMethodinto_underlying

(self)

contracts/generated/contracts-generated/balancerqueries/src/lib.rs:77

↓ 1 callersMethodinto_underlying

(self)

contracts/generated/contracts-generated/balancerv2vault/src/lib.rs:81

↓ 1 callersMethodinto_underlying

(self)

contracts/generated/contracts-generated/cowswapethflow/src/lib.rs:1187

↓ 1 callersMethodinto_underlying

(self)

contracts/generated/contracts-generated/gnosissafe/src/lib.rs:75

↓ 1 callersFunctioninvalid_address_returns_400

()

crates/e2e/tests/e2e/pool_indexer.rs:561

↓ 1 callersFunctioninvalid_length

()

crates/app-data/src/app_data_hash.rs:154

↓ 1 callersMethodinvalidateOrder

( data: &[u8], )

contracts/generated/contracts-generated/gpv2settlement/src/lib.rs:4314

↓ 1 callersMethodinvalidateOrdersIgnoringNotAllowed

( data: &[u8], )

contracts/generated/contracts-generated/cowswapethflow/src/lib.rs:4278

↓ 1 callersMethodinvalidated

Mark order as invalidated on-chain after creation.

crates/e2e/tests/e2e/refunder.rs:158

↓ 1 callersMethodisSanctioned

( data: &[u8], )

contracts/generated/contracts-generated/chainalysisoracle/src/lib.rs:1284

↓ 1 callersMethodis_alive

(&self)

crates/orderbook/src/orderbook.rs:773

↓ 1 callersFunctionis_buy_order_filled

(amount: &BigDecimal, executed_amount: &BigDecimal)

crates/orderbook/src/database/orders.rs:668

↓ 1 callersMethodis_contract

Check if a smart contract is deployed to the given address.

crates/driver/src/infra/blockchain/mod.rs:185

↓ 1 callersMethodis_contract_error

(&self)

crates/ethrpc/src/alloy/errors.rs:28

↓ 1 callersMethodis_contract_revert

(&self)

crates/ethrpc/src/alloy/errors.rs:60

↓ 1 callersFunctionis_delegated_to

Check whether the account's code is an EIP-7702 delegation to `expected_delegate`.

crates/driver/src/infra/solver/eip7702.rs:365

↓ 1 callersMethodis_disabled

A mempool is disabled if all of the following are true: the settlement may revert (see [`Settlement::may_revert`]) the pool has revert protection enab

crates/driver/src/domain/mempools.rs:103

↓ 1 callersFunctionis_duplicate_record_error

(err: &sqlx::Error)

crates/database/src/orders.rs:230

↓ 1 callersMethodis_leader

Returns true if the leader lock is being held If the feature is disabled, always returns true

crates/autopilot/src/leader_lock_tracker.rs:95

↓ 1 callersMethodis_network_configured

(&self, name: &str)

crates/pool-indexer/src/api/mod.rs:23

↓ 1 callersMethodis_partial

(&self)

crates/driver/src/domain/competition/order/mod.rs:143

↓ 1 callersFunctionis_range_too_large

True if the server-side JSON-RPC payload rejected `eth_getLogs` for being too wide / returning too many logs / exceeding a response-size cap / hitting

crates/pool-indexer/src/indexer/uniswap_v3.rs:653

↓ 1 callersMethodis_revert

Returns whether the error indicates that the original transaction reverted.

crates/driver/src/infra/blockchain/mod.rs:385

↓ 1 callersFunctionis_sell_order_filled

( amount: &BigDecimal, executed_amount: &BigDecimal, executed_fee: &BigDecimal, )

crates/orderbook/src/database/orders.rs:656

↓ 1 callersFunctionis_send

(_: F)

crates/solana-indexer/src/indexer/ingester.rs:299

↓ 1 callersFunctionis_settlement_trace

(trace: &blockchain::CallFrame, settlement_contract: eth::Address)

crates/autopilot/src/domain/settlement/transaction/mod.rs:203

↓ 1 callersMethodis_user_order

(&self)

crates/model/src/order.rs:75

↓ 1 callersMethodis_valid_for_all_pairs

(&self)

crates/balance-overrides/src/approval/mod.rs:164

↓ 1 callersMethodis_valid_solver

( &self, prospective_solver: eth::Address, block: BlockId, )

crates/autopilot/src/domain/settlement/transaction/mod.rs:28

↓ 1 callersFunctionjemalloc_stats_report

()

crates/observe/src/heap_dump_handler.rs:216

↓ 1 callersMethodjit_orders

Check that the solution contains the expected JIT orders.

crates/driver/src/tests/setup/mod.rs:1332

↓ 1 callersFunctionjoin_url

Join a path with a URL, ensuring that there is only one slash between them.

crates/liquidity-sources/src/zeroex.rs:33

↓ 1 callersMethodjust_stepped_up

Returns true if the last try_acquire call resulted in acquiring the leader lock If the feature is disabled, always returns false

crates/autopilot/src/leader_lock_tracker.rs:82

↓ 1 callersMethodkeep_track_of_balances

Tells the cache to continuously update the settlement contract balance of the given tokens if they are already present in the cache. That only really

crates/driver/src/infra/tokens.rs:60

↓ 1 callersMethodkill

Most reliable way to kill the process. If you get the chance to manually clean up the [`Node`] do it because the [`Drop::drop`] implementation can not

crates/e2e/src/nodes/mod.rs:98

↓ 1 callersMethodlabel

Returns a the order kind as a string label that can be used in metrics.

crates/model/src/order.rs:921

↓ 1 callersMethodlast_handled_block

(&self)

crates/event-indexing/src/event_handler.rs:261

↓ 1 callersFunctionlast_used_auction_id

(ex: &mut PgConnection)

crates/database/src/auction.rs:21

↓ 1 callersMethodlast_used_auction_id

(&self)

crates/orderbook/src/database/auctions.rs:23

↓ 1 callersFunctionlatest_auction_id

(ex: &mut PgConnection)

crates/e2e/tests/e2e/database.rs:68

↓ 1 callersMethodlatest_order_event

(&self, order_uid: &OrderUid)

crates/orderbook/src/database/orders.rs:399

↓ 1 callersMethodlayer

(&self, inner: S)

crates/ethrpc/src/alloy/instrumentation.rs:33

↓ 1 callersMethodleader

(&self, key: String)

crates/autopilot/src/infra/persistence/mod.rs:98

↓ 1 callersFunctionliquidity

(config: &config::Config, eth: &Ethereum)

crates/driver/src/run.rs:210

↓ 1 callersMethodliquidity

(&self)

crates/driver/src/infra/api/mod.rs:203

↓ 1 callersMethodliquidity_pairs

Returns a collection of liquidity token pairs that are relevant to this auction.

crates/driver/src/domain/competition/auction.rs:99

↓ 1 callersFunctionliquidity_sources_notifier

( config: &config::Config, eth: &Ethereum, )

crates/driver/src/run.rs:216

↓ 1 callersFunctionload

Load the driver configuration from a TOML file for the specifed Ethereum network. # Panics This method panics if the config is invalid or on I/O err

crates/driver/src/infra/config/file/load.rs:29

↓ 1 callersFunctionload

Load the driver configuration from a TOML file. # Panics This method panics if the config is invalid or on I/O errors.

crates/solvers/src/infra/config/baseline.rs:58

↓ 1 callersFunctionload_account

(account: file::Account, chain_id: Option<u64>)

crates/driver/src/infra/config/file/load.rs:391

↓ 1 callersFunctionload_by_tx_hash

( mut ex: &mut PgConnection, tx_hash: TransactionHash, after_block: Option<i64>, )

crates/database/src/solver_competition_v2.rs:75

↓ 1 callersMethodload_competition_by_tx_hash

( &self, tx_hash: B256, current_block: Option<i64>, )

crates/orderbook/src/database/solver_competition_v2.rs:34

↓ 1 callersFunctionload_latest

( mut ex: &mut PgConnection, after_block: Option<i64>, )

crates/database/src/solver_competition_v2.rs:96

↓ 1 callersMethodload_latest_competition

( &self, current_block: Option<i64>, )

crates/orderbook/src/database/solver_competition_v2.rs:56

↓ 1 callersMethodload_latest_competitions

( &self, latest_competitions_count: u32, )

crates/orderbook/src/database/solver_competition.rs:95

↓ 1 callersFunctionlog

Logs the message in this process' logs and reports it back to the connected socket.

crates/observe/src/tracing/reload_handler.rs:108

↓ 1 callersMethodlog_simulation_command

( &self, tx: TransactionRequest, overrides: StateOverride, block: BlockNo,

crates/simulator/src/tenderly/mod.rs:161

↓ 1 callersFunctionlog_simulation_outcome

Logs disagreements (signature pass + simulation revert, or vice versa) and infra errors as warnings. Agreement is silent.

crates/shared/src/order_validation.rs:114

↓ 1 callersFunctionlog_simulation_request

( simulation_endpoint: &Url, dashboard: &Url, simulation: dto::Request, )

crates/simulator/src/tenderly/mod.rs:254

← previous next →2,101–2,200 of 8,522, ranked by callers