rust 1,859,968 · typescript 235,218 · javascript 132,952 · python 20,426 · 6,406 files · digest c536f05fc420 · built in 1.4 s · crystals off
crates/cre8-app-compute/src/connection/execution_singleflight.rs
Items
const EXECUTION_WORK_FLIGHT_FOLLOWER_WAIT_TIMEOUT enum ExecutionWorkFlightCompletion struct ExecutionSingleflightMetrics enum FlightState struct ExecutionWorkFlight static EXECUTION_WORK_FLIGHTS static ACTIVE_FLIGHTS static LEADERS_TOTAL static FOLLOWERS_TOTAL static COMPLETED_TOTAL static FAILED_TOTAL static RECOVERED_PANICS_TOTAL static TIMED_OUT_TOTAL enum ExecutionWorkFlightJoin struct ExecutionWorkFlightLeader impl ExecutionWorkFlightLeader impl Drop for ExecutionWorkFlightLeader struct ExecutionWorkFlightFollower impl ExecutionWorkFlightFollower enum ExecutionWorkFlightWait static TEST_KEY_SEQUENCE const CALLERS
Functions
By call-graph weight (PageRank; 1.0 is the average function). 14 functions in all.
| function | kind | lines | cyclomatic | callers | callees | weight | crystal |
|---|---|---|---|---|---|---|---|
| lock_recoversrc/connection/execution_singleflight.rs:61 | fn | 3 | 1 | 4 | 0 | 2.8 | |
| ExecutionWorkFlightLeader::finishsrc/connection/execution_singleflight.rs:108 | method | 47 | 8 | 3 | 2 | 2.3 | |
| work_flightssrc/connection/execution_singleflight.rs:57 | fn | 3 | 1 | 2 | 0 | 1.7 | |
| execution_singleflight_metricssrc/connection/execution_singleflight.rs:224 | fn | 11 | 1 | 5 | 0 | 1 | |
| join_execution_worksrc/connection/execution_singleflight.rs:70 | fn | 17 | 2 | 6 | 3 | 0.9 | |
| ExecutionWorkFlightLeader::finish_completedsrc/connection/execution_singleflight.rs:100 | method | 3 | 1 | 6 | 1 | 0.9 | |
| ExecutionWorkFlightFollower::wait_timeoutsrc/connection/execution_singleflight.rs:191 | method | 25 | 7 | 4 | 1 | 0.8 | |
| ExecutionWorkFlightLeader::finish_failedsrc/connection/execution_singleflight.rs:104 | method | 3 | 1 | 3 | 1 | 0.7 | |
| test_keysrc/connection/execution_singleflight.rs:252 | fn | 3 | 1 | 3 | 0 | 0.7 | |
| ExecutionWorkFlightLeader::dropsrc/connection/execution_singleflight.rs:158 | trait impl | 10 | 3 | 0 | 1 | 0.5 | |
| ExecutionWorkFlightFollower::waitsrc/connection/execution_singleflight.rs:177 | method | 10 | 3 | 0 | 1 | 0.5 | |
| one_execution_leader_serves_all_concurrent_followerssrc/connection/execution_singleflight.rs:257 | fn | 44 | 4 | 0 | 6 | 0.5 | |
| panicking_leader_unblocks_follower_and_releases_work_keysrc/connection/execution_singleflight.rs:303 | fn | 40 | 4 | 0 | 6 | 0.5 | |
| timed_out_follower_keeps_the_leader_flight_registeredsrc/connection/execution_singleflight.rs:345 | fn | 22 | 3 | 0 | 6 | 0.5 |
Source not readable from this process.