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-market/src/connection.rs
Items
const LIVE_POSITION_SCALE const NEAR_CROSS_BPS const PULSE_OPPORTUNITY_LIMIT const DEFAULT_INFER_INTERVAL_MS const DEFAULT_INFER_LOOP_TICKS const MAX_INFER_LOOP_TICKS const MAX_PULSE_STREAM_EVENTS const PULSE_EVENT_BUFFER_CAPACITY const SPECS enum MarketAction const MARKET_ACTION_ALIASES struct MarketConnectionInput struct InferenceCacheEntry struct InferenceCache static MARKET_INFERENCE_CACHE struct PulseEventBuffer static MARKET_PULSE_EVENTS struct LiveMarketFilters struct ExternalPositionSummary struct LiveMarket impl LiveMarket struct ExternalPositionAmounts struct ExternalPositionPricing struct InternalBook struct PriceLevel enum BookSideLevel impl InternalBook struct ExecutableWindowTotals struct ExecutableWindowCursor struct ExecutableFill impl ExecutableWindowCursor impl ExecutableFill
Functions
By call-graph weight (PageRank; 1.0 is the average function). 129 functions in all.
| function | kind | lines | cyclomatic | callers | callees | weight | crystal |
|---|---|---|---|---|---|---|---|
| connectsrc/connection.rs:2447 | fn | 17 | 5 | 13 | 6 | 4.1 | |
| normalized_symbol_filtersrc/connection.rs:1363 | fn | 3 | 1 | 6 | 0 | 3.6 | |
| opportunity_scoresrc/connection.rs:1781 | fn | 6 | 2 | 3 | 0 | 2.8 | |
| live_graph_pulsesrc/connection.rs:1614 | fn | 46 | 2 | 5 | 6 | 2 | |
| pulse_event_buffersrc/connection.rs:153 | fn | 3 | 1 | 3 | 0 | 1.9 | |
| inference_cachesrc/connection.rs:149 | fn | 3 | 1 | 2 | 0 | 1.7 | |
| parse_actionsrc/connection.rs:157 | fn | 14 | 2 | 3 | 0 | 1.6 | |
| pricing_reportsrc/connection.rs:1367 | fn | 31 | 1 | 4 | 5 | 1.6 | |
| single_amountsrc/connection.rs:1326 | fn | 8 | 2 | 2 | 0 | 1.6 | |
| arc_mentions_pairsrc/connection.rs:2019 | fn | 5 | 3 | 2 | 0 | 1.5 | |
| dry_run_intentsrc/connection.rs:2312 | fn | 72 | 1 | 2 | 2 | 1.5 | |
| record_inference_pulse_eventsrc/connection.rs:785 | fn | 30 | 2 | 2 | 5 | 1.4 | |
| is_external_positionsrc/connection.rs:1609 | fn | 4 | 2 | 4 | 0 | 1.4 | |
| provider_from_market_idsrc/connection.rs:1354 | fn | 8 | 1 | 1 | 0 | 1.4 | |
| maybe_compact_inference_responsesrc/connection.rs:542 | fn | 32 | 2 | 4 | 0 | 1.4 | |
| recent_pulse_events_aftersrc/connection.rs:884 | fn | 23 | 1 | 2 | 2 | 1.4 | |
| infer_into_contextsrc/connection.rs:265 | fn | 73 | 3 | 2 | 16 | 1.3 | |
| bpssrc/connection.rs:2305 | fn | 6 | 4 | 3 | 0 | 1.3 | |
| live_market_summarysrc/connection.rs:1016 | fn | 18 | 1 | 3 | 5 | 1.3 | |
| infer_loop_into_contextsrc/connection.rs:575 | fn | 76 | 3 | 1 | 9 | 1.2 | |
| pulse_event_matches_inputsrc/connection.rs:908 | fn | 30 | 3 | 2 | 1 | 1.2 | |
| select_intent_windowsrc/connection.rs:2385 | fn | 21 | 2 | 1 | 1 | 1.1 | |
| no_live_inference_responsesrc/connection.rs:469 | fn | 26 | 1 | 1 | 4 | 1.1 | |
| registrysrc/connection.rs:186 | fn | 3 | 1 | 1 | 1 | 1.1 | |
| market_primary_connect_responsesrc/connection.rs:2465 | fn | 13 | 5 | 1 | 4 | 1.1 | |
| market_view_patch_responsesrc/connection.rs:2487 | fn | 15 | 8 | 1 | 4 | 1.1 | |
| market_secondary_connect_responsesrc/connection.rs:2503 | fn | 16 | 3 | 1 | 2 | 1.1 | |
| LiveMarket::newsrc/connection.rs:1134 | method | 11 | 1 | 1 | 1 | 1 | |
| pricing_itemsrc/connection.rs:1399 | fn | 79 | 1 | 2 | 9 | 1 | |
| internal_positionssrc/connection.rs:1588 | fn | 20 | 1 | 2 | 2 | 1 | |
| external_position_pricingsrc/connection.rs:1268 | fn | 13 | 2 | 1 | 2 | 1 | |
| write_inference_servicessrc/connection.rs:768 | fn | 16 | 5 | 3 | 1 | 1 | |
| market_readonly_execution_responsesrc/connection.rs:2520 | fn | 12 | 4 | 1 | 3 | 1 | |
| market_registry_responsesrc/connection.rs:2533 | fn | 13 | 4 | 1 | 3 | 1 | |
| pulse_event_scope_listsrc/connection.rs:827 | fn | 14 | 2 | 2 | 0 | 0.9 | |
| inference_responsesrc/connection.rs:715 | fn | 33 | 1 | 3 | 0 | 0.9 | |
| ask_external_position_pricingsrc/connection.rs:1282 | fn | 13 | 1 | 1 | 0 | 0.9 | |
| bid_external_position_pricingsrc/connection.rs:1296 | fn | 13 | 1 | 1 | 0 | 0.9 | |
| refresh_price_levelssrc/connection.rs:1582 | fn | 5 | 2 | 1 | 0 | 0.9 | |
| recent_pulse_eventssrc/connection.rs:880 | fn | 3 | 1 | 2 | 1 | 0.9 | |
| handlesrc/connection.rs:190 | fn | 6 | 1 | 3 | 2 | 0.9 | |
| request_market_actionsrc/connection.rs:172 | fn | 13 | 5 | 1 | 2 | 0.9 | |
| run_market_handle_actionsrc/connection.rs:197 | fn | 13 | 2 | 1 | 2 | 0.9 | |
| run_market_inference_actionsrc/connection.rs:211 | fn | 12 | 3 | 1 | 2 | 0.9 | |
| run_market_side_effect_actionsrc/connection.rs:224 | fn | 7 | 3 | 1 | 2 | 0.9 | |
| run_market_infer_actionsrc/connection.rs:232 | fn | 9 | 1 | 1 | 1 | 0.9 | |
| run_market_infer_loop_actionsrc/connection.rs:242 | fn | 10 | 1 | 1 | 1 | 0.9 | |
| run_market_pulse_actionsrc/connection.rs:253 | fn | 5 | 1 | 1 | 1 | 0.9 | |
| run_market_intent_actionsrc/connection.rs:259 | fn | 5 | 1 | 1 | 1 | 0.9 | |
| live_dirty_statesrc/connection.rs:1000 | fn | 15 | 1 | 3 | 1 | 0.8 | |
| remember_inferencesrc/connection.rs:994 | fn | 5 | 2 | 2 | 1 | 0.8 | |
| sort_depthsrc/connection.rs:1181 | fn | 13 | 2 | 1 | 0 | 0.8 | |
| summary_jsonsrc/connection.rs:1335 | fn | 18 | 1 | 1 | 0 | 0.8 | |
| pulse_itemsrc/connection.rs:1719 | fn | 27 | 1 | 1 | 1 | 0.8 | |
| top_opportunitiessrc/connection.rs:1747 | fn | 33 | 2 | 1 | 1 | 0.8 | |
| market_result_servicesrc/connection.rs:2547 | fn | 3 | 1 | 1 | 0 | 0.8 | |
| read_only_infer_loop_responsesrc/connection.rs:2551 | fn | 12 | 1 | 1 | 0 | 0.8 | |
| read_only_infer_responsesrc/connection.rs:2564 | fn | 18 | 1 | 1 | 5 | 0.8 | |
| market_get_responsesrc/connection.rs:2583 | fn | 16 | 1 | 1 | 0 | 0.8 | |
| market_status_responsesrc/connection.rs:2600 | fn | 21 | 1 | 1 | 0 | 0.8 | |
| InternalBook::push_levelsrc/connection.rs:1521 | method | 12 | 2 | 1 | 0 | 0.7 | |
| price_level_from_positionsrc/connection.rs:1545 | fn | 14 | 4 | 1 | 5 | 0.7 | |
| price_levels_from_livesrc/connection.rs:2060 | fn | 24 | 3 | 1 | 0 | 0.7 | |
| executable_windowsrc/connection.rs:2189 | fn | 37 | 1 | 1 | 4 | 0.7 | |
| normalized_market_filtersrc/connection.rs:842 | fn | 3 | 1 | 1 | 0 | 0.7 | |
| push_pulse_eventsrc/connection.rs:846 | fn | 17 | 3 | 1 | 2 | 0.7 | |
| pulse_item_stringssrc/connection.rs:864 | fn | 15 | 1 | 1 | 0 | 0.7 | |
| no_live_inference_response_if_idlesrc/connection.rs:381 | fn | 27 | 3 | 1 | 1 | 0.7 | |
| cached_inference_response_if_freshsrc/connection.rs:435 | fn | 21 | 1 | 1 | 4 | 0.7 | |
| with_gateway_connectionsrc/connection.rs:956 | fn | 22 | 2 | 2 | 1 | 0.7 | |
| pulse_stream_responsesrc/connection.rs:2479 | fn | 7 | 1 | 1 | 0 | 0.7 | |
| live_market_filterssrc/connection.rs:1040 | fn | 6 | 1 | 1 | 1 | 0.7 | |
| sorted_live_external_positionssrc/connection.rs:1047 | fn | 5 | 1 | 1 | 0 | 0.7 | |
| collect_live_marketssrc/connection.rs:1053 | fn | 31 | 5 | 1 | 4 | 0.7 | |
| LiveMarket::into_jsonsrc/connection.rs:1154 | method | 25 | 1 | 1 | 2 | 0.7 | |
| fresh_confidence_labelsrc/connection.rs:2291 | fn | 9 | 5 | 1 | 0 | 0.7 | |
| partial_confidence_labelsrc/connection.rs:2301 | fn | 3 | 3 | 1 | 0 | 0.7 | |
| pulse_stream_eventssrc/connection.rs:2407 | fn | 39 | 3 | 1 | 2 | 0.7 | |
| path_touches_idssrc/connection.rs:1916 | fn | 12 | 1 | 2 | 0 | 0.7 | |
| transaction_touches_idssrc/connection.rs:1929 | fn | 5 | 1 | 2 | 0 | 0.7 | |
| executable_window_totalssrc/connection.rs:2227 | fn | 10 | 2 | 1 | 5 | 0.7 | |
| executable_edge_bpssrc/connection.rs:2238 | fn | 3 | 2 | 1 | 1 | 0.7 | |
| near_crossed_windowsrc/connection.rs:2242 | fn | 3 | 3 | 1 | 0 | 0.7 | |
| cached_inference_skip_reasonsrc/connection.rs:457 | fn | 11 | 4 | 1 | 0 | 0.7 | |
| set_inference_report_fieldssrc/connection.rs:749 | fn | 18 | 2 | 1 | 0 | 0.7 | |
| position_matches_market_filtersrc/connection.rs:1085 | fn | 3 | 1 | 1 | 0 | 0.6 | |
| summary_matches_symbol_filtersrc/connection.rs:1089 | fn | 3 | 1 | 1 | 1 | 0.6 | |
| observe_live_market_positionsrc/connection.rs:1093 | fn | 9 | 1 | 1 | 1 | 0.6 | |
| external_position_summarysrc/connection.rs:1195 | fn | 9 | 2 | 1 | 4 | 0.6 | |
| is_provider_positionsrc/connection.rs:1205 | fn | 3 | 1 | 1 | 0 | 0.6 | |
| external_position_amountssrc/connection.rs:1216 | fn | 9 | 3 | 1 | 1 | 0.6 | |
| external_position_summary_for_amountssrc/connection.rs:1226 | fn | 34 | 1 | 1 | 1 | 0.6 | |
| position_side_and_levelsrc/connection.rs:1310 | fn | 15 | 6 | 1 | 0 | 0.6 | |
| is_ask_position_pairsrc/connection.rs:1560 | fn | 3 | 2 | 1 | 0 | 0.6 | |
| is_bid_position_pairsrc/connection.rs:1564 | fn | 3 | 2 | 1 | 0 | 0.6 | |
| positive_single_amountsrc/connection.rs:1568 | fn | 4 | 1 | 1 | 1 | 0.6 | |
| book_price_levelsrc/connection.rs:1573 | fn | 8 | 1 | 1 | 0 | 0.6 | |
| edge_touches_marketsrc/connection.rs:1901 | fn | 8 | 2 | 1 | 0 | 0.6 | |
| warn_skipped_infer_loop_ticksrc/connection.rs:652 | fn | 20 | 2 | 1 | 0 | 0.6 | |
| capture_infer_loop_pulse_eventsrc/connection.rs:673 | fn | 15 | 3 | 1 | 0 | 0.6 | |
| backfill_local_pulse_eventssrc/connection.rs:689 | fn | 15 | 4 | 1 | 0 | 0.6 | |
| sleep_mssrc/connection.rs:705 | fn | 9 | 2 | 1 | 0 | 0.6 | |
| pulse_event_statussrc/connection.rs:939 | fn | 16 | 1 | 1 | 1 | 0.6 | |
| ExecutableWindowCursor::newsrc/connection.rs:2114 | method | 9 | 1 | 1 | 0 | 0.6 | |
| ExecutableWindowCursor::has_levelssrc/connection.rs:2124 | method | 3 | 2 | 1 | 0 | 0.6 | |
| ExecutableWindowCursor::next_fillsrc/connection.rs:2128 | method | 24 | 3 | 1 | 0 | 0.6 | |
| ExecutableWindowCursor::apply_fillsrc/connection.rs:2153 | method | 15 | 3 | 1 | 0 | 0.6 | |
| ExecutableWindowCursor::into_totalssrc/connection.rs:2169 | method | 3 | 1 | 1 | 0 | 0.6 | |
| internal_book_for_symbolsrc/connection.rs:1503 | fn | 11 | 3 | 1 | 2 | 0.6 | |
| count_matching_edges_touching_marketsrc/connection.rs:1788 | fn | 30 | 2 | 1 | 1 | 0.6 | |
| matching_evidence_for_marketsrc/connection.rs:1819 | fn | 81 | 1 | 1 | 4 | 0.6 | |
| count_lattice_routes_touchingsrc/connection.rs:1935 | fn | 24 | 1 | 1 | 1 | 0.6 | |
| lattice_evidence_for_pairsrc/connection.rs:1960 | fn | 58 | 1 | 1 | 1 | 0.6 | |
| depth_opportunity_windowssrc/connection.rs:2033 | fn | 26 | 5 | 1 | 2 | 0.6 | |
| freshness_labelsrc/connection.rs:2256 | fn | 19 | 6 | 1 | 0 | 0.6 | |
| edge_touches_idssrc/connection.rs:1910 | fn | 5 | 1 | 1 | 0 | 0.6 | |
| inference_skip_responsesrc/connection.rs:339 | fn | 41 | 2 | 1 | 2 | 0.6 | |
| scoped_inference_generationsrc/connection.rs:409 | fn | 25 | 2 | 1 | 0 | 0.6 | |
| lattice_ratessrc/connection.rs:496 | fn | 31 | 1 | 1 | 3 | 0.6 | |
| run_capital_strategy_scansrc/connection.rs:528 | fn | 13 | 1 | 1 | 2 | 0.6 | |
| inference_cache_keysrc/connection.rs:979 | fn | 10 | 1 | 1 | 1 | 0.6 | |
| cached_inferencesrc/connection.rs:990 | fn | 3 | 1 | 1 | 1 | 0.6 | |
| LiveMarket::observesrc/connection.rs:1146 | method | 7 | 3 | 0 | 0 | 0.5 | |
| InternalBook::finalizesrc/connection.rs:1534 | method | 9 | 1 | 0 | 1 | 0.5 | |
| live_graph_summarysrc/connection.rs:1661 | fn | 57 | 1 | 0 | 5 | 0.5 | |
| depth_basesrc/connection.rs:2025 | fn | 7 | 1 | 0 | 0 | 0.5 | |
| ExecutableFill::to_jsonsrc/connection.rs:2175 | method | 12 | 1 | 0 | 0 | 0.5 | |
| executable_window_statussrc/connection.rs:2246 | fn | 9 | 3 | 0 | 0 | 0.5 | |
| confidence_labelsrc/connection.rs:2276 | fn | 14 | 4 | 0 | 2 | 0.5 |
Source not readable from this process.