1 viewer
rust 1,961,941 · typescript 233,850 · javascript 141,145 · python 22,871 · 6,801 files · digest 6d882eacc8db · built in 12.5 s · crystals off
crates/cre8-app-provider/src/hyperdb_sink.rs
Items
const KIND_MARKET_ASSET const KIND_MARKET_PROVIDER const KIND_MARKET_BAR_FACT const KIND_MARKET_OBSERVATION const KIND_MARKET_CORRELATION const KIND_MARKET_BASKET static ACTIVE static ON enum Backend impl Backend struct BarBucket impl BarBucket type BucketKey struct HyperdbSink impl HyperdbSink static SINK
Functions
By call-graph weight (PageRank; 1.0 is the average function). 39 functions in all.
| function | kind | lines | cyclomatic | callers | callees | weight | crystal |
|---|---|---|---|---|---|---|---|
| Backend::add_vertexsrc/hyperdb_sink.rs:110 | method | 8 | 2 | 14 | 0 | 5.7 | |
| Backend::graphsrc/hyperdb_sink.rs:102 | method | 7 | 2 | 9 | 0 | 4 | |
| HyperdbSink::with_configsrc/hyperdb_sink.rs:217 | method | 16 | 1 | 11 | 2 | 3.2 | |
| HyperdbSink::from_envsrc/hyperdb_sink.rs:203 | method | 13 | 1 | 1 | 2 | 2.5 | |
| sinksrc/hyperdb_sink.rs:467 | fn | 3 | 1 | 14 | 1 | 2.4 | |
| Backend::upsert_edgesrc/hyperdb_sink.rs:119 | method | 8 | 2 | 4 | 0 | 1.9 | |
| ticksrc/hyperdb_sink.rs:523 | fn | 11 | 1 | 8 | 0 | 1.9 | |
| Backend::open_from_envsrc/hyperdb_sink.rs:80 | method | 21 | 3 | 1 | 1 | 1.9 | |
| HyperdbSink::index_existing_factssrc/hyperdb_sink.rs:237 | method | 13 | 1 | 1 | 0 | 1.9 | |
| env_always_onsrc/hyperdb_sink.rs:66 | fn | 4 | 1 | 1 | 1 | 1.7 | |
| Backend::delete_vertexsrc/hyperdb_sink.rs:137 | method | 8 | 2 | 4 | 0 | 1.4 | |
| is_activesrc/hyperdb_sink.rs:62 | fn | 3 | 2 | 5 | 1 | 1.4 | |
| Backend::delete_edgesrc/hyperdb_sink.rs:128 | method | 8 | 2 | 3 | 0 | 1.3 | |
| HyperdbSink::ensure_vertexsrc/hyperdb_sink.rs:296 | method | 5 | 2 | 3 | 1 | 1.3 | |
| HyperdbSink::append_factsrc/hyperdb_sink.rs:302 | method | 38 | 1 | 2 | 3 | 1.1 | |
| activatesrc/hyperdb_sink.rs:58 | fn | 3 | 1 | 1 | 0 | 0.9 | |
| HyperdbSink::sync_correlation_edgessrc/hyperdb_sink.rs:365 | method | 36 | 5 | 2 | 3 | 0.8 | |
| HyperdbSink::sync_basket_edgessrc/hyperdb_sink.rs:407 | method | 39 | 5 | 2 | 3 | 0.8 | |
| HyperdbSink::maybe_evictsrc/hyperdb_sink.rs:345 | method | 13 | 3 | 1 | 2 | 0.8 | |
| sync_correlation_edgessrc/hyperdb_sink.rs:486 | fn | 8 | 3 | 1 | 3 | 0.6 | |
| sync_basket_edgessrc/hyperdb_sink.rs:498 | fn | 8 | 3 | 1 | 3 | 0.6 | |
| BarBucket::newsrc/hyperdb_sink.rs:169 | method | 3 | 1 | 1 | 0 | 0.6 | |
| BarBucket::absorbsrc/hyperdb_sink.rs:173 | method | 7 | 1 | 1 | 0 | 0.6 | |
| HyperdbSink::flush_stalesrc/hyperdb_sink.rs:278 | method | 17 | 5 | 1 | 1 | 0.6 | |
| observe_tick_if_activesrc/hyperdb_sink.rs:473 | fn | 8 | 3 | 1 | 2 | 0.6 | |
| Backend::is_durablesrc/hyperdb_sink.rs:146 | method | 7 | 2 | 0 | 0 | 0.5 | |
| HyperdbSink::observesrc/hyperdb_sink.rs:251 | method | 22 | 7 | 0 | 4 | 0.5 | |
| HyperdbSink::statussrc/hyperdb_sink.rs:447 | method | 16 | 1 | 0 | 0 | 0.5 | |
| hyperdb_sink_statussrc/hyperdb_sink.rs:509 | fn | 9 | 3 | 0 | 2 | 0.5 | |
| bucket_rollover_appends_bar_facts_with_linked_verticessrc/hyperdb_sink.rs:536 | fn | 24 | 1 | 0 | 3 | 0.5 | |
| stale_buckets_flush_without_new_ticks_on_that_pairsrc/hyperdb_sink.rs:562 | fn | 8 | 1 | 0 | 3 | 0.5 | |
| junk_ticks_are_ignoredsrc/hyperdb_sink.rs:572 | fn | 7 | 1 | 0 | 2 | 0.5 | |
| fact_cap_evicts_oldest_firstsrc/hyperdb_sink.rs:581 | fn | 15 | 2 | 0 | 3 | 0.5 | |
| correlation_edges_upsert_in_place_and_drop_vanished_pairssrc/hyperdb_sink.rs:598 | fn | 21 | 1 | 0 | 3 | 0.5 | |
| basket_hyperedges_span_members_and_drop_vanished_basketssrc/hyperdb_sink.rs:621 | fn | 29 | 1 | 0 | 3 | 0.5 | |
| status_reports_counterssrc/hyperdb_sink.rs:652 | fn | 10 | 1 | 0 | 2 | 0.5 | |
| eviction_reads_one_index_entry_per_evicted_factsrc/hyperdb_sink.rs:664 | fn | 16 | 2 | 0 | 3 | 0.5 | |
| stale_sweep_visits_only_the_stale_prefixsrc/hyperdb_sink.rs:682 | fn | 21 | 2 | 0 | 2 | 0.5 | |
| rolled_buckets_leave_no_stale_due_entriessrc/hyperdb_sink.rs:705 | fn | 9 | 2 | 0 | 2 | 0.5 |
Source not readable from this process.