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-runtime-dispatch-host/src/lib.rs

cre8-runtime-dispatch-host · module crate root · src · 1,490 lines (1,205 code, 101 comment) · sha f3c30b81c3db34a1

Items

type VertexId type ConnectionHandler type ConnectionHandlerEntry type ConnectionHandlerIndex static DISPATCH_APPS static HANDLER_INDEX struct EmissionContext enum FanoutMode struct FixtureApp static FIXTURE_SPEC static FIXTURE_HANDLERS impl RuntimeApp for FixtureApp static SPEC static EXTRAS static SPEC static EXTRAS static EDGE_RECEIPT static EDGE_FANOUT static SPEC static EXTRAS static EDGE_NEEDS_INTENT static EDGE_MISSING_TO static SPEC static EXTRAS static SPEC static EMPTY_EXTRAS static FROM_FANOUT static MISSING_TO static MISSING_FROM static TO_FANOUT static MISSING_FROM static BOTH_FANOUT

Functions

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

functionkindlinescyclomaticcallerscalleesweightcrystal
anchor_sanitizesrc/lib.rs:172fn63605.3
resolve_vertex_refsrc/lib.rs:335fn911234.2
ctxsrc/lib.rs:890fn811403.7
runtime_appssrc/lib.rs:29fn31303.7
dispatch_connection_execsrc/lib.rs:72fn314452.9
handler_forsrc/lib.rs:45fn1741012.8
recording_contextsrc/lib.rs:899fn1011122.6
non_empty_vertex_idsrc/lib.rs:415fn42202.5
json_path_lookupsrc/lib.rs:457fn103202.4
json_path_stringsrc/lib.rs:489fn31422.4
emit_with_fanoutsrc/lib.rs:649fn294742.2
resolve_each_itemssrc/lib.rs:425fn112722.1
dispatch_connectionsrc/lib.rs:63fn81812.1
resolve_fixed_vertex_refsrc/lib.rs:346fn144131.7
resolve_payload_vertex_refsrc/lib.rs:362fn104121.7
resolve_literal_vertex_refsrc/lib.rs:374fn82111.7
register_dispatch_appssrc/lib.rs:20fn83701.6
vertex_id_from_valuesrc/lib.rs:477fn83211.6
min_vertexsrc/lib.rs:850fn232201.5
try_write_connection_anchorsrc/lib.rs:204fn11101.5
json_scalar_stringsrc/lib.rs:494fn115101.5
write_one_declared_edge_resolvedsrc/lib.rs:787fn613321.4
resolve_each_input_itemssrc/lib.rs:438fn71121.4
resolve_single_itemsrc/lib.rs:447fn71111.4
resolve_json_vertexsrc/lib.rs:403fn41121.2
resolve_output_raw_vertexsrc/lib.rs:409fn41121.2
emit_successful_dispatch_edgessrc/lib.rs:122fn174211.2
receiptsrc/lib.rs:910fn31511.2
emit_declared_edges_for_connectionsrc/lib.rs:535fn265451.1
commit_successful_dispatch_receiptssrc/lib.rs:104fn172221.1
json_path_arraysrc/lib.rs:472fn31111.1
resolve_actor_vertexsrc/lib.rs:384fn32111
resolve_receipt_vertexsrc/lib.rs:389fn31111
resolve_connection_vertexsrc/lib.rs:394fn72111
fanout_modesrc/lib.rs:688fn84111
emit_from_fanoutsrc/lib.rs:698fn272131
emit_to_fanoutsrc/lib.rs:727fn272131
write_one_declared_edgesrc/lib.rs:756fn233121
write_connection_anchor_innersrc/lib.rs:235fn642320.9
fixture_handlersrc/lib.rs:914fn31100.9
anchor_resolve_actorsrc/lib.rs:183fn196300.9
connection_forsrc/lib.rs:33fn41320.8
anchor_enabledsrc/lib.rs:162fn93210.7
emit_declared_edgesrc/lib.rs:563fn303150.7
json_ctxsrc/lib.rs:1039fn41110.6
matching_receipts_for_specsrc/lib.rs:595fn92100.6
spec_skips_for_missing_intentsrc/lib.rs:606fn32100.6
spec_is_receipt_anchoredsrc/lib.rs:611fn42100.6
emit_receipt_anchored_edgessrc/lib.rs:617fn242110.6
all_connection_handlerssrc/lib.rs:40fn41110.6
try_write_connection_anchorsrc/lib.rs:207fn265060.5
try_write_declared_edgessrc/lib.rs:507fn81000.5
try_write_declared_edgessrc/lib.rs:517fn162030.5
FixtureApp::connectionssrc/lib.rs:926trait impl31010.5
FixtureApp::connection_handlerssrc/lib.rs:930trait impl31000.5
FixtureApp::connectsrc/lib.rs:934trait impl31000.5
json_path_string_extracts_dotted_pathssrc/lib.rs:940fn71010.5
resolve_vertex_ref_handles_actor_and_receiptsrc/lib.rs:949fn61020.5
resolve_vertex_ref_handles_connectionsrc/lib.rs:957fn81020.5
resolve_vertex_ref_handles_input_and_output_pathssrc/lib.rs:967fn151020.5
output_raw_passes_vertex_id_through_without_prefixsrc/lib.rs:984fn81020.5
output_raw_skips_missing_or_empty_fieldssrc/lib.rs:994fn91020.5
resolve_vertex_ref_skips_empty_actor_receipt_and_connectionsrc/lib.rs:1005fn91020.5
resolve_vertex_ref_sanitizes_payload_valuessrc/lib.rs:1016fn221030.5
json_path_string_skips_empty_segments_and_non_scalarssrc/lib.rs:1045fn71010.5
resolve_vertex_ref_returns_none_for_fanout_variantsrc/lib.rs:1054fn111020.5
each_input_item_expands_single_stringsrc/lib.rs:1067fn111020.5
each_input_item_expands_multiple_stringssrc/lib.rs:1080fn111020.5
each_input_item_handles_empty_or_missing_arraysrc/lib.rs:1093fn201020.5
each_input_item_skips_non_string_elementssrc/lib.rs:1115fn111020.5
resolve_each_items_delegates_non_fanout_refssrc/lib.rs:1128fn81020.5
commit_successful_dispatch_receipts_commits_or_discards_pendingsrc/lib.rs:1138fn171040.5
emit_successful_dispatch_edges_skips_empty_or_failed_dispatchessrc/lib.rs:1157fn101020.5
registered_dispatch_app_feeds_handlers_reflection_and_dispatchsrc/lib.rs:1169fn281070.5
anchor_resolve_actor_falls_back_through_contextsrc/lib.rs:1199fn181030.5
write_connection_anchor_records_receipt_verticessrc/lib.rs:1219fn301030.5
write_connection_anchor_without_receipts_uses_synthetic_idsrc/lib.rs:1251fn241020.5
declared_edges_write_receipt_and_fanout_edgessrc/lib.rs:1277fn401030.5
declared_edges_skip_nonmatching_intent_and_unresolvable_verticessrc/lib.rs:1319fn351030.5
declared_edges_skip_route_handlers_and_empty_specssrc/lib.rs:1356fn241020.5
emit_with_fanout_handles_from_side_and_missing_constant_sidesrc/lib.rs:1382fn251020.5
emit_with_fanout_skips_missing_from_sidesrc/lib.rs:1409fn151020.5
emit_with_fanout_uses_receipt_hash_for_fanout_leg_idssrc/lib.rs:1426fn181020.5
emit_with_fanout_skips_missing_nonfanout_fromsrc/lib.rs:1446fn141020.5
emit_with_fanout_rejects_cartesian_fanoutsrc/lib.rs:1462fn151020.5
min_vertex_infers_kind_or_unknownsrc/lib.rs:1479fn51010.5
try_write_declared_edges_swallows_errors_and_skips_unclassifiedsrc/lib.rs:1486fn41010.5

Source not readable from this process.