1 viewer
rust 1,860,549 · typescript 235,540 · javascript 132,956 · python 20,426 · 6,408 files · digest f04d4637f52b · built in 1.5 s · crystals off
crates/cre8-app-manifold/src/obligation_dispatch.rs
Items
const KIND_OBLIGATION_DISPATCH const DEFAULT_MAX_ATTEMPTS const ENV_MAX_ATTEMPTS const DEFAULT_RETRY_BACKOFF_MS const MAX_DRAIN_LIMIT const STATUS_BREACHED static OBLIGATION_DRAIN_LOCK struct ObligationDispatchOutcome struct ObligationDrainReport impl ObligationDrainReport struct AttemptFacts impl AttemptFacts static TEST_ENV_LOCK struct DownChokepoint impl ManifoldCommitService for DownChokepoint
Functions
By call-graph weight (PageRank; 1.0 is the average function). 57 functions in all.
| function | kind | lines | cyclomatic | callers | callees | weight | crystal |
|---|---|---|---|---|---|---|---|
| drain_due_obligations_withsrc/obligation_dispatch.rs:183 | fn | 163 | 14 | 15 | 19 | 3.2 | |
| serialsrc/obligation_dispatch.rs:656 | fn | 3 | 1 | 21 | 0 | 1.8 | |
| savesrc/obligation_dispatch.rs:744 | fn | 3 | 1 | 19 | 2 | 1.5 | |
| chokepoint_contextsrc/obligation_dispatch.rs:679 | fn | 29 | 2 | 3 | 11 | 1.5 | |
| dispatch_record_vidsrc/obligation_dispatch.rs:508 | fn | 3 | 1 | 3 | 0 | 1.4 | |
| load_dispatch_recordsrc/obligation_dispatch.rs:512 | fn | 5 | 1 | 11 | 3 | 1.2 | |
| drain_due_obligationssrc/obligation_dispatch.rs:176 | fn | 5 | 1 | 2 | 2 | 1.1 | |
| drain_failing_atsrc/obligation_dispatch.rs:720 | fn | 6 | 1 | 6 | 1 | 1.1 | |
| counted_failuressrc/obligation_dispatch.rs:371 | fn | 8 | 1 | 2 | 0 | 1.1 | |
| reported_refusalsrc/obligation_dispatch.rs:413 | fn | 21 | 5 | 2 | 0 | 1.1 | |
| context_with_real_chokepointsrc/obligation_dispatch.rs:671 | fn | 3 | 1 | 11 | 1 | 1 | |
| balance_ofsrc/obligation_dispatch.rs:709 | fn | 3 | 1 | 11 | 0 | 1 | |
| burn_pathsrc/obligation_dispatch.rs:715 | fn | 3 | 1 | 11 | 2 | 1 | |
| breach_already_settledsrc/obligation_dispatch.rs:503 | fn | 4 | 2 | 5 | 1 | 1 | |
| pendingsrc/obligation_dispatch.rs:748 | fn | 3 | 1 | 9 | 2 | 1 | |
| contextsrc/obligation_dispatch.rs:660 | fn | 7 | 1 | 7 | 3 | 0.9 | |
| drain_clocksrc/obligation_dispatch.rs:729 | fn | 3 | 1 | 4 | 0 | 0.9 | |
| upsert_dispatch_recordsrc/obligation_dispatch.rs:519 | fn | 43 | 2 | 2 | 2 | 0.8 | |
| drain_failingsrc/obligation_dispatch.rs:740 | fn | 3 | 1 | 5 | 2 | 0.7 | |
| max_attemptssrc/obligation_dispatch.rs:88 | fn | 7 | 1 | 2 | 1 | 0.7 | |
| outcome_forsrc/obligation_dispatch.rs:1036 | fn | 7 | 1 | 3 | 0 | 0.7 | |
| with_policysrc/obligation_dispatch.rs:1287 | fn | 5 | 1 | 3 | 1 | 0.6 | |
| ObligationDrainReport::emptysrc/obligation_dispatch.rs:151 | method | 16 | 1 | 1 | 0 | 0.6 | |
| AttemptFacts::newsrc/obligation_dispatch.rs:359 | method | 8 | 1 | 1 | 1 | 0.6 | |
| select_due_dispatchablesrc/obligation_dispatch.rs:380 | fn | 11 | 2 | 1 | 2 | 0.6 | |
| payload_with_manifold_contextsrc/obligation_dispatch.rs:392 | fn | 14 | 2 | 1 | 0 | 0.6 | |
| persist_successsrc/obligation_dispatch.rs:435 | fn | 25 | 1 | 1 | 3 | 0.6 | |
| persist_failuresrc/obligation_dispatch.rs:466 | fn | 33 | 3 | 1 | 4 | 0.6 | |
| delete_pending_obligationsrc/obligation_dispatch.rs:563 | fn | 6 | 1 | 1 | 2 | 0.6 | |
| record_dispatch_receiptsrc/obligation_dispatch.rs:574 | fn | 36 | 5 | 1 | 4 | 0.6 | |
| note_receipt_errorsrc/obligation_dispatch.rs:614 | fn | 27 | 1 | 1 | 3 | 0.6 | |
| refusal_bodysrc/obligation_dispatch.rs:1032 | fn | 3 | 1 | 2 | 0 | 0.6 | |
| ObligationDrainReport::to_jsonsrc/obligation_dispatch.rs:168 | method | 4 | 1 | 0 | 0 | 0.5 | |
| dispatches_due_work_and_deletes_it_after_successsrc/obligation_dispatch.rs:753 | fn | 24 | 1 | 0 | 7 | 0.5 | |
| retries_failures_with_backoff_then_succeedssrc/obligation_dispatch.rs:779 | fn | 23 | 1 | 0 | 6 | 0.5 | |
| passive_obligations_are_not_consumedsrc/obligation_dispatch.rs:804 | fn | 13 | 1 | 0 | 6 | 0.5 | |
| breach_fires_at_the_attempt_threshold_and_not_one_attempt_beforesrc/obligation_dispatch.rs:821 | fn | 43 | 3 | 0 | 8 | 0.5 | |
| breach_slash_mints_onto_the_burn_twin_never_the_positive_pathsrc/obligation_dispatch.rs:866 | fn | 28 | 1 | 0 | 11 | 0.5 | |
| breach_is_idempotent_across_redrainssrc/obligation_dispatch.rs:896 | fn | 35 | 1 | 0 | 11 | 0.5 | |
| a_torn_breach_record_reopens_the_breach_instead_of_freezing_itsrc/obligation_dispatch.rs:933 | fn | 15 | 1 | 0 | 2 | 0.5 | |
| unattributed_obligations_breach_on_the_record_but_move_no_repsrc/obligation_dispatch.rs:950 | fn | 22 | 1 | 0 | 7 | 0.5 | |
| succeeded_and_retrying_obligations_are_never_slashedsrc/obligation_dispatch.rs:974 | fn | 27 | 2 | 0 | 8 | 0.5 | |
| env_override_retunes_the_breach_thresholdsrc/obligation_dispatch.rs:1003 | fn | 25 | 1 | 0 | 8 | 0.5 | |
| an_ok_false_body_is_a_failed_attempt_that_is_retriedsrc/obligation_dispatch.rs:1045 | fn | 32 | 1 | 0 | 8 | 0.5 | |
| an_ok_false_body_takes_the_same_retry_and_breach_path_as_errsrc/obligation_dispatch.rs:1079 | fn | 60 | 5 | 0 | 13 | 0.5 | |
| ok_true_and_bodies_without_ok_still_keep_the_promisesrc/obligation_dispatch.rs:1141 | fn | 25 | 5 | 0 | 9 | 0.5 | |
| refusal_text_keeps_whatever_error_and_reason_the_connection_givessrc/obligation_dispatch.rs:1168 | fn | 23 | 1 | 0 | 1 | 0.5 | |
| a_refused_slash_mint_is_failed_not_committed_and_the_same_receipt_retriessrc/obligation_dispatch.rs:1195 | fn | 25 | 1 | 0 | 10 | 0.5 | |
| a_drain_records_a_refused_slash_as_unsettledsrc/obligation_dispatch.rs:1222 | fn | 14 | 1 | 0 | 7 | 0.5 | |
| DownChokepoint::commitsrc/obligation_dispatch.rs:1242 | trait impl | 6 | 1 | 0 | 0 | 0.5 | |
| an_audit_receipt_the_chokepoint_drops_is_recorded_not_swallowedsrc/obligation_dispatch.rs:1251 | fn | 19 | 1 | 0 | 7 | 0.5 | |
| a_settled_audit_receipt_leaves_no_receipt_errorsrc/obligation_dispatch.rs:1272 | fn | 12 | 1 | 0 | 6 | 0.5 | |
| failures_inside_grace_reschedule_and_never_count_toward_breachsrc/obligation_dispatch.rs:1294 | fn | 46 | 2 | 0 | 10 | 0.5 | |
| a_grace_retry_lands_at_the_end_of_grace_when_backoff_would_overshoot_itsrc/obligation_dispatch.rs:1342 | fn | 17 | 1 | 0 | 6 | 0.5 | |
| max_attempts_in_the_payload_replaces_the_deployment_budgetsrc/obligation_dispatch.rs:1361 | fn | 37 | 3 | 0 | 10 | 0.5 | |
| without_a_policy_both_counters_move_together_and_backoff_is_the_defaultsrc/obligation_dispatch.rs:1400 | fn | 16 | 1 | 0 | 6 | 0.5 | |
| a_record_written_before_the_counter_existed_counts_every_attemptsrc/obligation_dispatch.rs:1418 | fn | 5 | 1 | 0 | 1 | 0.5 |
Source not readable from this process.