Skip to content
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-agent/src/driver.rs

cre8-app-agent · module driver · src · 3,162 lines (2,471 code, 425 comment) · sha 69b1a3814228e955

Items

trait SubstrateTransport struct AgentSessionOrigin impl AgentSessionOrigin impl AuthenticatedSessionAccountOrigin for AgentSessionOrigin struct LocalSubstrateTransport impl LocalSubstrateTransport impl SubstrateTransport for LocalSubstrateTransport type LedgerBalances type ProviderSelection struct IntelligenceBroker impl IntelligenceBroker struct AgentDriver struct AgentBudget impl Default for AgentBudget impl AgentBudget enum TickOutcome enum AgentChoice const CODE_CHANGE_TAG const TOOL_LOOP_MAX_ITERATIONS impl AgentDriver struct JsonObjectScanner impl JsonObjectScanner struct StaticProvider impl StaticProvider impl LlmProvider for StaticProvider struct TestTransport impl Default for TestTransport impl TestTransport impl SubstrateTransport for TestTransport struct SimpleMockProvider impl LlmProvider for SimpleMockProvider struct ClaimThenDoneProvider impl LlmProvider for ClaimThenDoneProvider struct DelegateThenDoneProvider impl LlmProvider for DelegateThenDoneProvider struct HumanSessionOrigin impl AuthenticatedSessionAccountOrigin for HumanSessionOrigin struct ClaimTwiceThenDoneProvider impl LlmProvider for ClaimTwiceThenDoneProvider struct ReplyThenDoneProvider impl LlmProvider for ReplyThenDoneProvider

Functions

By call-graph weight (PageRank; 1.0 is the average function). 155 functions in all.

functionkindlinescyclomaticcallerscalleesweightcrystal
extract_json_objectsrc/driver.rs:1525fn61616.5
balanced_json_object_lensrc/driver.rs:1532fn41106
TestTransport::defaultsrc/driver.rs:1716trait impl1411905
parse_choicesrc/driver.rs:1518fn511215
AgentDriver::dispatch_signedsrc/driver.rs:1423method101713.9
AgentDriver::newsrc/driver.rs:681method2011102.3
AgentSessionOrigin::newsrc/driver.rs:82method51302.2
AgentDriver::run_one_ticksrc/driver.rs:863method356961.6
AgentBudget::defaultsrc/driver.rs:407trait impl141901.5
budget_outcome_forsrc/driver.rs:650fn113201.4
effective_attestation_signalsrc/driver.rs:1437fn193301.3
StaticProvider::choicesrc/driver.rs:1655method311201.2
AgentDriver::fetch_inboxsrc/driver.rs:1026method61111.2
test_driversrc/driver.rs:1879fn1011041.1
AgentDriver::with_brokersrc/driver.rs:702method411001.1
model_requests_premiumsrc/driver.rs:306fn31111.1
seed_b64src/driver.rs:1865fn31701.1
fallback_tier_costsrc/driver.rs:355fn193201
IntelligenceBroker::newsrc/driver.rs:196method31901
AgentDriver::dispatch_choicesrc/driver.rs:1130method378381
summarize_responsesrc/driver.rs:1582fn237201
LocalSubstrateTransport::newsrc/driver.rs:105method31500.9
TestTransport::burn_quotasrc/driver.rs:1831trait impl62100.9
AgentDriver::dispatch_time_logsrc/driver.rs:1348method211220.9
AgentDriver::dispatch_time_entry_self_attestationsrc/driver.rs:1370method212210.9
time_entry_idsrc/driver.rs:1465fn81100.9
IntelligenceBroker::provider_for_tiersrc/driver.rs:205method62100.9
inbox_is_empty_for_personasrc/driver.rs:635fn97430.9
IntelligenceBroker::flat_selectionsrc/driver.rs:242method91220.9
AgentDriver::tick_inputssrc/driver.rs:731method334310.8
AgentDriver::tick_provider_selectionsrc/driver.rs:765method364330.8
AgentDriver::run_one_tick_tooledsrc/driver.rs:930method9596110.8
IntelligenceBroker::select_providersrc/driver.rs:219method203240.8
LocalSubstrateTransport::call_contextsrc/driver.rs:120method51230.8
AgentDriver::take_tick_slotsrc/driver.rs:712method184210.8
AgentDriver::settle_call_spendsrc/driver.rs:823method392210.8
AgentDriver::with_preferred_modelsrc/driver.rs:707method41500.8
inbox_item_countsrc/driver.rs:320fn31100.8
persona_requests_premiumsrc/driver.rs:324fn74100.8
AgentDriver::choose_actionsrc/driver.rs:1033method963330.8
persona_invites_creationsrc/driver.rs:675fn41200.8
AgentDriver::dispatch_tick_choicesrc/driver.rs:802method82220.7
router_provider_selectionsrc/driver.rs:339fn153210.7
inbox_summary_countsrc/driver.rs:662fn31100.7
inbox_items_countsrc/driver.rs:666fn81100.7
IntelligenceBroker::with_routersrc/driver.rs:200method41300.7
complete_with_retrysrc/driver.rs:1486fn284100.7
JsonObjectScanner::consume_string_bytesrc/driver.rs:1554method84100.7
JsonObjectScanner::consume_structural_bytesrc/driver.rs:1563method174100.7
StaticProvider::idsrc/driver.rs:1673trait impl31100.7
StaticProvider::default_modelsrc/driver.rs:1677trait impl31100.7
TestTransport::dispatch_countsrc/driver.rs:1773method31200.7
IntelligenceBroker::market_selectionsrc/driver.rs:259method344130.7
tier_from_preferred_modelsrc/driver.rs:295fn72110.7
tier_from_inbox_contextsrc/driver.rs:310fn94120.7
AgentDriver::emit_code_change_diffsrc/driver.rs:1392method302200.7
routed_brokersrc/driver.rs:1871fn71270.6
code_change_tagssrc/driver.rs:1457fn71100.6
TestTransport::with_burn_failuresrc/driver.rs:1761method31210.6
AgentDriver::dispatch_no_opsrc/driver.rs:1168method31100.6
AgentDriver::dispatch_claim_tasksrc/driver.rs:1172method91110.6
AgentDriver::dispatch_replysrc/driver.rs:1193method213110.6
AgentDriver::dispatch_attestationsrc/driver.rs:1215method323120.6
AgentDriver::dispatch_votesrc/driver.rs:1248method191110.6
AgentDriver::dispatch_prediction_resolution_votesrc/driver.rs:1268method151110.6
AgentDriver::dispatch_propose_code_changesrc/driver.rs:1284method351140.6
AgentDriver::dispatch_submit_subjectsrc/driver.rs:1320method271120.6
TestTransport::with_balancessrc/driver.rs:1769method31210.6
TestTransport::with_dispatch_failuresrc/driver.rs:1733method31210.6
tooled_inbox_promptsrc/driver.rs:1609fn191100.6
truncate_summarysrc/driver.rs:1630fn82100.6
TestTransport::with_balance_failuresrc/driver.rs:1753method31110.6
TestTransport::with_position_failuresrc/driver.rs:1757method31110.6
StaticProvider::failingsrc/driver.rs:1667method31200.6
TestTransport::with_settle_balancesrc/driver.rs:1741method71110.5
AgentDriver::run_until_budgetsrc/driver.rs:901method153110.5
TestTransport::with_unanswered_threadsrc/driver.rs:1749method31110.5
StaticProvider::choice_with_usagesrc/driver.rs:1659method71100.5
TestTransport::with_append_failuresrc/driver.rs:1765method31110.5
SubstrateTransport::settle_llm_spendsrc/driver.rs:55trait default73000.5
SubstrateTransport::check_spend_capssrc/driver.rs:68trait default31000.5
AgentSessionOrigin::as_strsrc/driver.rs:88method31000.5
AgentSessionOrigin::authenticated_session_account_idsrc/driver.rs:94trait impl31000.5
LocalSubstrateTransport::dispatchsrc/driver.rs:128trait impl41020.5
LocalSubstrateTransport::get_ledger_balancessrc/driver.rs:133trait impl41000.5
LocalSubstrateTransport::append_manifold_eventsrc/driver.rs:138trait impl31000.5
LocalSubstrateTransport::burn_quotasrc/driver.rs:142trait impl122000.5
LocalSubstrateTransport::get_positionssrc/driver.rs:155trait impl31010.5
LocalSubstrateTransport::settle_llm_spendsrc/driver.rs:159trait impl71010.5
LocalSubstrateTransport::check_spend_capssrc/driver.rs:167trait impl41010.5
AgentBudget::exhaustedsrc/driver.rs:424method93000.5
default_submit_unitssrc/driver.rs:607fn31000.5
default_attest_verdictsrc/driver.rs:611fn51000.5
default_propose_unitssrc/driver.rs:617fn31000.5
both_oksrc/driver.rs:1474fn42000.5
JsonObjectScanner::consumesrc/driver.rs:1545method82020.5
StaticProvider::completesrc/driver.rs:1681trait impl132020.5
TestTransport::dispatchsrc/driver.rs:1779trait impl375000.5
TestTransport::get_ledger_balancessrc/driver.rs:1817trait impl62000.5
TestTransport::append_manifold_eventsrc/driver.rs:1824trait impl62000.5
TestTransport::get_positionssrc/driver.rs:1838trait impl62000.5
TestTransport::settle_llm_spendsrc/driver.rs:1845trait impl184010.5
extract_json_finds_first_balanced_objectsrc/driver.rs:1891fn51010.5
extract_json_handles_nested_objectssrc/driver.rs:1898fn51010.5
extract_json_handles_braces_in_stringssrc/driver.rs:1905fn51010.5
extract_json_handles_escaped_quotes_and_missing_objectsrc/driver.rs:1912fn51010.5
parse_choice_round_trips_no_opsrc/driver.rs:1919fn72010.5
parse_choice_extracts_attest_with_tagssrc/driver.rs:1928fn172010.5
parse_choice_extracts_attest_with_scoressrc/driver.rs:1947fn252010.5
parse_choice_attest_legacy_shape_still_workssrc/driver.rs:1974fn202010.5
parse_choice_handles_markdown_fencessrc/driver.rs:1996fn82010.5
parse_choice_extracts_vote_prediction_resolutionsrc/driver.rs:2006fn182010.5
budget_exhaustion_signals_correctlysrc/driver.rs:2026fn101000.5
helper_signal_and_summary_branches_are_explicitsrc/driver.rs:2038fn291030.5
tick_inputs_reports_each_transport_stagesrc/driver.rs:2069fn284070.5
run_one_tick_covers_stop_success_llm_and_quota_pathssrc/driver.rs:2099fn8860150.5
dispatch_choice_covers_all_action_armssrc/driver.rs:2189fn532050.5
parse_choice_extracts_submit_subjectsrc/driver.rs:2244fn192010.5
parse_choice_extracts_propose_code_changesrc/driver.rs:2265fn202010.5
parse_choice_submit_subject_uses_default_unitssrc/driver.rs:2287fn132010.5
test_intelligence_broker_selectionsrc/driver.rs:2302fn1001070.5
SimpleMockProvider::idsrc/driver.rs:2305trait impl31000.5
SimpleMockProvider::default_modelsrc/driver.rs:2308trait impl31000.5
SimpleMockProvider::completesrc/driver.rs:2311trait impl101000.5
local_transport_and_driver_helpers_cover_edgessrc/driver.rs:2404fn7210150.5
tick_provider_selection_reports_insufficient_quota_and_run_until_budget_stopssrc/driver.rs:2478fn182090.5
a_completed_broker_tick_settles_the_quoted_spend_through_the_one_appliersrc/driver.rs:2498fn221070.5
default_settle_no_ops_non_quota_denoms_and_unquoted_ticks_settle_nothingsrc/driver.rs:2522fn241050.5
local_transport_settle_debits_agent_and_credits_owner_and_types_the_broke_signalsrc/driver.rs:2548fn441020.5
ClaimThenDoneProvider::idsrc/driver.rs:2600trait impl31000.5
ClaimThenDoneProvider::default_modelsrc/driver.rs:2603trait impl31000.5
ClaimThenDoneProvider::completesrc/driver.rs:2606trait impl262000.5
run_one_tick_tooled_dispatches_signed_claim_via_loopsrc/driver.rs:2640fn343060.5
tick_debits_quota_without_market_positionssrc/driver.rs:2676fn201060.5
tick_with_zero_balance_reports_budget_exhaustedsrc/driver.rs:2698fn142060.5
unpriced_model_still_proceedssrc/driver.rs:2714fn382070.5
DelegateThenDoneProvider::idsrc/driver.rs:2759trait impl31000.5
DelegateThenDoneProvider::default_modelsrc/driver.rs:2762trait impl31000.5
DelegateThenDoneProvider::completesrc/driver.rs:2765trait impl302000.5
run_one_tick_tooled_can_delegate_computesrc/driver.rs:2802fn303060.5
HumanSessionOrigin::authenticated_session_account_idsrc/driver.rs:2838trait impl31000.5
agent_session_origin_is_the_canonical_agent_identitysrc/driver.rs:2844fn91010.5
dispatch_context_carries_the_agent_session_originsrc/driver.rs:2855fn181050.5
parse_choice_extracts_replysrc/driver.rs:2875fn92010.5
reply_choice_dispatches_a_signed_thread_messagesrc/driver.rs:2886fn473050.5
ClaimTwiceThenDoneProvider::idsrc/driver.rs:2940trait impl31000.5
ClaimTwiceThenDoneProvider::default_modelsrc/driver.rs:2943trait impl31000.5
ClaimTwiceThenDoneProvider::completesrc/driver.rs:2946trait impl262000.5
tooled_tick_debits_one_round_price_per_provider_roundsrc/driver.rs:2975fn332080.5
tick_outcome_serializes_the_keys_the_swarm_receipt_publishessrc/driver.rs:3010fn271000.5
tooled_tick_over_budget_reports_budget_exhausted_not_failuresrc/driver.rs:3039fn282080.5
ReplyThenDoneProvider::idsrc/driver.rs:3074trait impl31000.5
ReplyThenDoneProvider::default_modelsrc/driver.rs:3077trait impl31000.5
ReplyThenDoneProvider::completesrc/driver.rs:3080trait impl262000.5
unanswered_thread_makes_the_tooled_inbox_actionablesrc/driver.rs:3109fn533090.5

Source not readable from this process.