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-choreography/src/connection.rs
Items
const SPECS const TICK_SERVICE_ID const TICK_SERVICE_SCOPE struct ChoreographyInput const GENERATED_ID_ATTEMPTS static SEQUENCE struct StepActionRequest struct ReviewSubject struct StepActionContext struct ChoreographyRunState const REVIEWS_DEFAULT_LIMIT const REVIEWS_MAX_LIMIT const REVIEWS_MAX_INSTANCES struct ReviewQueue const TICK_DEFAULT_LIMIT const TICK_MAX_LIMIT const WAIT_CLAIM_LEASE_MS struct WaitPending impl Display for WaitPending impl Error for WaitPending enum TickOutcome const LLM_TOKEN_ASSET struct StepTokens impl StepTokens struct StepOutcome struct BudgetEnvelope type KindOutcome const MAX_STEP_OUTPUT_BYTES const MAP_MAX_DEPTH struct MapChild impl MapChild type FakeDispatch const SEED_SERVICE const SWEEP_BLUEPRINT const PROSPECT_BLUEPRINT const SWEEP_V2_BLUEPRINT const PROSPECT_V2_BLUEPRINT const SWEEP_V3_BLUEPRINT const PROSPECT_V3_BLUEPRINT static OPERATOR_ENV_LOCK const OPERATOR const VISITOR struct OperatorEnv impl Drop for OperatorEnv const HOUR_MS const T0 struct Service impl AuthenticatedServiceOrigin for Service const LEAD_FOLLOW_UP_BLUEPRINT
Functions
By call-graph weight (PageRank; 1.0 is the average function). 150 functions in all.
| function | kind | lines | cyclomatic | callers | callees | weight | crystal |
|---|---|---|---|---|---|---|---|
| connectsrc/connection.rs:124 | fn | 21 | 10 | 22 | 9 | 7.7 | |
| require_operatorsrc/connection.rs:209 | fn | 19 | 4 | 8 | 4 | 3.9 | |
| store_contextsrc/connection.rs:2149 | fn | 12 | 1 | 21 | 2 | 2.8 | |
| choreography_run_stepssrc/connection.rs:744 | fn | 3 | 1 | 8 | 0 | 2.4 | |
| definesrc/connection.rs:2273 | fn | 3 | 1 | 12 | 1 | 2.3 | |
| choreography_step_dependency_idssrc/connection.rs:834 | fn | 6 | 1 | 2 | 0 | 1.9 | |
| verified_callersrc/connection.rs:230 | fn | 3 | 1 | 2 | 1 | 1.9 | |
| parse_drive_stepsrc/connection.rs:1951 | fn | 16 | 1 | 4 | 0 | 1.8 | |
| define_actionsrc/connection.rs:294 | fn | 27 | 1 | 2 | 5 | 1.7 | |
| trigger_actionsrc/connection.rs:325 | fn | 6 | 1 | 2 | 2 | 1.7 | |
| state_actionsrc/connection.rs:650 | fn | 5 | 1 | 2 | 2 | 1.7 | |
| run_actionsrc/connection.rs:723 | fn | 5 | 1 | 2 | 2 | 1.7 | |
| tick_actionsrc/connection.rs:1149 | fn | 43 | 5 | 2 | 5 | 1.7 | |
| bounded_limitsrc/connection.rs:980 | fn | 8 | 3 | 2 | 0 | 1.7 | |
| status_actionsrc/connection.rs:247 | fn | 31 | 1 | 2 | 0 | 1.6 | |
| step_actionsrc/connection.rs:420 | fn | 36 | 5 | 2 | 10 | 1.6 | |
| drive_actionsrc/connection.rs:683 | fn | 33 | 1 | 2 | 6 | 1.6 | |
| reviews_actionsrc/connection.rs:1042 | fn | 14 | 1 | 2 | 3 | 1.6 | |
| callssrc/connection.rs:1989 | fn | 3 | 1 | 5 | 0 | 1.6 | |
| local_business_appssrc/connection.rs:2447 | fn | 31 | 9 | 3 | 0 | 1.5 | |
| set_operator_envsrc/connection.rs:2894 | fn | 11 | 2 | 3 | 0 | 1.4 | |
| run_instancesrc/connection.rs:730 | fn | 7 | 1 | 3 | 5 | 1.4 | |
| budget_envelope_from_blueprintsrc/connection.rs:1302 | fn | 34 | 3 | 5 | 0 | 1.4 | |
| start_runsrc/connection.rs:335 | fn | 39 | 4 | 2 | 7 | 1.4 | |
| instance_statesrc/connection.rs:657 | fn | 19 | 1 | 2 | 4 | 1.4 | |
| choreography_step_idsrc/connection.rs:830 | fn | 3 | 1 | 5 | 0 | 1.3 | |
| StepTokens::totalsrc/connection.rs:1262 | method | 3 | 1 | 3 | 0 | 1.3 | |
| triggersrc/connection.rs:2277 | fn | 4 | 1 | 17 | 1 | 1.3 | |
| runsrc/connection.rs:2282 | fn | 3 | 1 | 17 | 1 | 1.3 | |
| step_is_drivablesrc/connection.rs:1663 | fn | 26 | 9 | 3 | 3 | 1.2 | |
| installsrc/connection.rs:1984 | fn | 4 | 1 | 15 | 0 | 1.2 | |
| run_scopesrc/connection.rs:484 | fn | 5 | 1 | 5 | 1 | 1.2 | |
| extract_subflow_outputsrc/connection.rs:1884 | fn | 7 | 2 | 2 | 0 | 1.2 | |
| calls_tosrc/connection.rs:2286 | fn | 3 | 1 | 14 | 1 | 1.1 | |
| run_choreography_wavesrc/connection.rs:773 | fn | 22 | 3 | 1 | 6 | 1.1 | |
| execute_stepsrc/connection.rs:1399 | fn | 53 | 10 | 3 | 14 | 1.1 | |
| choreography_step_readysrc/connection.rs:810 | fn | 8 | 4 | 1 | 4 | 1.1 | |
| execute_choreography_run_stepsrc/connection.rs:862 | fn | 26 | 4 | 1 | 3 | 1.1 | |
| reviews_limitsrc/connection.rs:974 | fn | 3 | 1 | 2 | 1 | 1 | |
| waiting_reviewssrc/connection.rs:1001 | fn | 40 | 7 | 2 | 4 | 1 | |
| prospect_appssrc/connection.rs:1995 | fn | 18 | 7 | 11 | 0 | 1 | |
| extract_debate_outputsrc/connection.rs:1871 | fn | 11 | 2 | 2 | 0 | 1 | |
| now_mssrc/connection.rs:1069 | fn | 7 | 2 | 4 | 1 | 1 | |
| generated_idsrc/connection.rs:404 | fn | 6 | 1 | 2 | 2 | 1 | |
| waiting_stepssrc/connection.rs:931 | fn | 32 | 9 | 3 | 8 | 0.9 | |
| choreography_run_blueprintsrc/connection.rs:738 | fn | 5 | 1 | 2 | 2 | 0.9 | |
| active_step_instancesrc/connection.rs:525 | fn | 10 | 2 | 2 | 1 | 0.9 | |
| ensure_step_dependenciessrc/connection.rs:566 | fn | 8 | 3 | 2 | 1 | 0.9 | |
| step_definitionsrc/connection.rs:559 | fn | 6 | 1 | 2 | 0 | 0.9 | |
| new_instancesrc/connection.rs:375 | fn | 8 | 1 | 2 | 0 | 0.9 | |
| runtime_serves_connectionsrc/connection.rs:286 | fn | 4 | 2 | 1 | 2 | 0.8 | |
| all_steps_completedsrc/connection.rs:628 | fn | 6 | 1 | 1 | 0 | 0.8 | |
| choreography_step_dependencies_donesrc/connection.rs:826 | fn | 3 | 1 | 2 | 1 | 0.8 | |
| completed_choreography_stepssrc/connection.rs:802 | fn | 3 | 1 | 3 | 1 | 0.8 | |
| record_stepsrc/connection.rs:464 | fn | 9 | 2 | 2 | 4 | 0.8 | |
| load_step_action_contextsrc/connection.rs:543 | fn | 6 | 1 | 2 | 3 | 0.8 | |
| validate_step_actionsrc/connection.rs:550 | fn | 8 | 2 | 2 | 3 | 0.8 | |
| record_choreography_step_successsrc/connection.rs:889 | fn | 14 | 1 | 1 | 1 | 0.8 | |
| connection_registrysrc/connection.rs:282 | fn | 3 | 2 | 1 | 2 | 0.8 | |
| require_tick_authoritysrc/connection.rs:240 | fn | 6 | 3 | 1 | 4 | 0.8 | |
| tick_waitsrc/connection.rs:1203 | fn | 44 | 8 | 1 | 12 | 0.8 | |
| step_execution_idsrc/connection.rs:590 | fn | 6 | 1 | 1 | 1 | 0.8 | |
| complete_instance_when_finishedsrc/connection.rs:597 | fn | 15 | 2 | 1 | 2 | 0.8 | |
| run_choreography_wavessrc/connection.rs:758 | fn | 14 | 3 | 1 | 1 | 0.7 | |
| choreography_run_responsesrc/connection.rs:904 | fn | 22 | 1 | 1 | 4 | 0.7 | |
| review_subjectsrc/connection.rs:495 | fn | 6 | 1 | 2 | 2 | 0.7 | |
| step_instance_blueprintsrc/connection.rs:536 | fn | 6 | 1 | 1 | 1 | 0.7 | |
| review_skipped_by_whensrc/connection.rs:821 | fn | 4 | 2 | 1 | 2 | 0.7 | |
| set_nowsrc/connection.rs:3089 | fn | 3 | 1 | 5 | 0 | 0.7 | |
| define_examplesrc/connection.rs:2437 | fn | 5 | 1 | 4 | 1 | 0.7 | |
| insert_step_executionsrc/connection.rs:575 | fn | 14 | 1 | 1 | 2 | 0.7 | |
| complete_step_actionsrc/connection.rs:613 | fn | 14 | 1 | 1 | 2 | 0.7 | |
| step_action_responsesrc/connection.rs:635 | fn | 14 | 1 | 1 | 0 | 0.7 | |
| insert_generated_instancesrc/connection.rs:390 | fn | 9 | 3 | 1 | 3 | 0.7 | |
| ensure_budget_vertexsrc/connection.rs:1340 | fn | 17 | 1 | 1 | 1 | 0.7 | |
| ticksrc/connection.rs:3093 | fn | 3 | 1 | 4 | 1 | 0.7 | |
| choreography_instance_is_activesrc/connection.rs:796 | fn | 5 | 1 | 1 | 1 | 0.7 | |
| ready_choreography_stepssrc/connection.rs:806 | fn | 3 | 1 | 1 | 1 | 0.7 | |
| execute_choreography_wavesrc/connection.rs:841 | fn | 19 | 4 | 1 | 1 | 0.7 | |
| define_hour_waitsrc/connection.rs:3098 | fn | 13 | 1 | 4 | 1 | 0.6 | |
| step_action_requestsrc/connection.rs:508 | fn | 16 | 1 | 1 | 1 | 0.6 | |
| budget_reservesrc/connection.rs:1896 | fn | 32 | 4 | 2 | 1 | 0.6 | |
| budget_realizesrc/connection.rs:1931 | fn | 9 | 2 | 2 | 1 | 0.6 | |
| release_if_committedsrc/connection.rs:1942 | fn | 5 | 2 | 2 | 1 | 0.6 | |
| MapChild::startsrc/connection.rs:1620 | method | 37 | 3 | 1 | 3 | 0.6 | |
| operator_envsrc/connection.rs:2887 | fn | 6 | 1 | 3 | 1 | 0.6 | |
| auth_required_storesrc/connection.rs:2907 | fn | 5 | 1 | 3 | 1 | 0.6 | |
| access_errorsrc/connection.rs:2941 | fn | 3 | 1 | 3 | 0 | 0.6 | |
| define_review_sweepsrc/connection.rs:2915 | fn | 25 | 1 | 2 | 1 | 0.6 | |
| wait_deadline_mssrc/connection.rs:1098 | fn | 12 | 3 | 1 | 3 | 0.6 | |
| dispatch_step_connectionsrc/connection.rs:1497 | fn | 7 | 2 | 1 | 1 | 0.6 | |
| run_step_actionsrc/connection.rs:458 | fn | 5 | 1 | 1 | 3 | 0.6 | |
| run_wait_stepsrc/connection.rs:1116 | fn | 25 | 4 | 1 | 6 | 0.6 | |
| text_outcomesrc/connection.rs:1456 | fn | 4 | 1 | 1 | 1 | 0.6 | |
| ensure_step_executablesrc/connection.rs:1461 | fn | 8 | 2 | 1 | 3 | 0.6 | |
| skip_reasonsrc/connection.rs:1471 | fn | 19 | 8 | 1 | 6 | 0.6 | |
| run_connection_stepsrc/connection.rs:1512 | fn | 31 | 8 | 1 | 6 | 0.6 | |
| run_map_stepsrc/connection.rs:1553 | fn | 56 | 4 | 1 | 4 | 0.6 | |
| run_llm_stepsrc/connection.rs:1694 | fn | 53 | 3 | 1 | 7 | 0.6 | |
| run_debate_stepsrc/connection.rs:1753 | fn | 77 | 3 | 1 | 7 | 0.6 | |
| run_subflow_stepsrc/connection.rs:1836 | fn | 32 | 1 | 1 | 2 | 0.6 | |
| site_loop_appssrc/connection.rs:2538 | fn | 37 | 7 | 1 | 1 | 0.5 | |
| site_loop_v3_appssrc/connection.rs:2641 | fn | 43 | 5 | 1 | 1 | 0.5 | |
| lead_follow_up_appssrc/connection.rs:3266 | fn | 13 | 4 | 1 | 0 | 0.5 | |
| handle_choreography_definesrc/connection.rs:151 | fn | 4 | 1 | 1 | 1 | 0.5 | |
| handle_choreography_triggersrc/connection.rs:156 | fn | 4 | 1 | 1 | 1 | 0.5 | |
| handle_choreography_statesrc/connection.rs:166 | fn | 4 | 1 | 1 | 1 | 0.5 | |
| handle_choreography_runsrc/connection.rs:176 | fn | 4 | 1 | 1 | 1 | 0.5 | |
| handle_choreography_ticksrc/connection.rs:186 | fn | 4 | 1 | 1 | 1 | 0.5 | |
| handle_choreography_statussrc/connection.rs:146 | fn | 4 | 1 | 0 | 1 | 0.5 | |
| handle_choreography_stepsrc/connection.rs:161 | fn | 4 | 1 | 0 | 1 | 0.5 | |
| handle_choreography_drivesrc/connection.rs:171 | fn | 4 | 1 | 0 | 1 | 0.5 | |
| handle_choreography_reviewssrc/connection.rs:181 | fn | 4 | 1 | 0 | 1 | 0.5 | |
| WaitPending::fmtsrc/connection.rs:1087 | trait impl | 3 | 1 | 0 | 0 | 0.5 | |
| StepTokens::to_jsonsrc/connection.rs:1266 | method | 3 | 1 | 0 | 0 | 0.5 | |
| budget_summarysrc/connection.rs:1361 | fn | 22 | 2 | 0 | 1 | 0.5 | |
| parse_drive_step_extracts_actor_and_promptsrc/connection.rs:2015 | fn | 6 | 1 | 0 | 1 | 0.5 | |
| parse_drive_step_rejects_missing_fieldssrc/connection.rs:2023 | fn | 5 | 1 | 0 | 1 | 0.5 | |
| budget_envelope_parses_from_blueprint_metadatasrc/connection.rs:2030 | fn | 38 | 1 | 0 | 2 | 0.5 | |
| step_kind_defaults_to_llm_and_detects_otherssrc/connection.rs:2070 | fn | 6 | 1 | 0 | 1 | 0.5 | |
| step_is_drivable_per_kindsrc/connection.rs:2078 | fn | 22 | 1 | 0 | 1 | 0.5 | |
| extract_debate_output_prefers_last_writer_messagesrc/connection.rs:2102 | fn | 18 | 1 | 0 | 1 | 0.5 | |
| extract_subflow_output_joins_final_wavesrc/connection.rs:2122 | fn | 9 | 1 | 0 | 1 | 0.5 | |
| prompts_thread_recorded_outputssrc/connection.rs:2133 | fn | 13 | 1 | 0 | 1 | 0.5 | |
| connect_status_and_unknown_actionsrc/connection.rs:2166 | fn | 7 | 1 | 0 | 2 | 0.5 | |
| gated_flow_define_trigger_step_state_completessrc/connection.rs:2175 | fn | 53 | 1 | 0 | 3 | 0.5 | |
| run_halts_and_drive_errors_when_provider_absentsrc/connection.rs:2230 | fn | 22 | 1 | 0 | 2 | 0.5 | |
| drive_debate_step_errors_when_collab_absentsrc/connection.rs:2254 | fn | 16 | 1 | 0 | 2 | 0.5 | |
| connection_steps_thread_the_record_and_bind_receiptssrc/connection.rs:2291 | fn | 34 | 1 | 0 | 9 | 0.5 | |
| refused_connection_halts_and_resume_does_not_repeat_recorded_stepssrc/connection.rs:2327 | fn | 23 | 1 | 0 | 7 | 0.5 | |
| map_branches_per_item_and_sends_only_the_approved_subjectsrc/connection.rs:2352 | fn | 79 | 2 | 0 | 8 | 0.5 | |
| example_sweep_builds_one_private_draft_and_outreach_draft_per_businesssrc/connection.rs:2480 | fn | 47 | 2 | 0 | 10 | 0.5 | |
| example_v2_sweep_audits_each_site_and_imports_a_private_redesignsrc/connection.rs:2577 | fn | 53 | 2 | 0 | 9 | 0.5 | |
| example_v3_sweep_derives_facts_generates_a_pack_and_drafts_outreach_for_reviewsrc/connection.rs:2686 | fn | 57 | 2 | 0 | 9 | 0.5 | |
| recorded_failure_lets_dependents_fall_backsrc/connection.rs:2745 | fn | 19 | 1 | 0 | 7 | 0.5 | |
| skipped_review_skips_its_outbound_stepsrc/connection.rs:2766 | fn | 19 | 1 | 0 | 7 | 0.5 | |
| define_and_trigger_refuse_unsafe_or_malformed_inputsrc/connection.rs:2787 | fn | 13 | 1 | 0 | 3 | 0.5 | |
| trigger_refuses_an_existing_run_and_leaves_its_recordsrc/connection.rs:2802 | fn | 34 | 1 | 0 | 5 | 0.5 | |
| generated_ids_start_distinct_runs_and_blueprints_within_one_secondsrc/connection.rs:2838 | fn | 27 | 2 | 0 | 3 | 0.5 | |
| OperatorEnv::dropsrc/connection.rs:2882 | trait impl | 3 | 1 | 0 | 1 | 0.5 | |
| reads_and_approvals_need_an_operator_where_auth_is_requiredsrc/connection.rs:2946 | fn | 69 | 3 | 0 | 15 | 0.5 | |
| define_and_trigger_need_an_operator_where_auth_is_requiredsrc/connection.rs:3017 | fn | 43 | 3 | 0 | 12 | 0.5 | |
| devnet_reads_stay_open_and_an_approval_names_the_verified_sessionsrc/connection.rs:3062 | fn | 20 | 1 | 0 | 8 | 0.5 | |
| a_run_holds_at_a_wait_and_one_tick_resumes_it_once_duesrc/connection.rs:3113 | fn | 44 | 1 | 0 | 10 | 0.5 | |
| a_claimed_wait_is_left_to_its_holder_until_the_claim_lapsessrc/connection.rs:3159 | fn | 24 | 1 | 0 | 10 | 0.5 | |
| a_run_that_reaches_a_due_wait_records_it_itselfsrc/connection.rs:3185 | fn | 33 | 1 | 0 | 11 | 0.5 | |
| Service::authenticated_service_idsrc/connection.rs:3222 | trait impl | 3 | 1 | 0 | 0 | 0.5 | |
| Service::authenticated_service_scopesrc/connection.rs:3225 | trait impl | 3 | 1 | 0 | 0 | 0.5 | |
| tick_needs_an_operator_or_the_scheduler_service_where_auth_is_requiredsrc/connection.rs:3231 | fn | 28 | 1 | 0 | 15 | 0.5 | |
| example_lead_follow_up_sends_two_reviewed_messages_two_days_apartsrc/connection.rs:3281 | fn | 68 | 1 | 0 | 10 | 0.5 |
Source not readable from this process.