rust 1,863,595 · typescript 235,976 · javascript 133,240 · python 20,426 · 6,417 files · digest b3b8c6dd2bb2 · built in 2.5 s · crystals off
crates/cre8-app-conduit/src/multistream.rs
Items
const MULTISTREAM_PROTOCOL const PUSH_SCHEMES const KEY_HINT_CHARS const MAX_ENDPOINT_CHARS const MAX_SESSION_OUTPUTS const MAX_PUSH_TARGETS const MAX_CATALOG_SESSIONS struct EndpointUrl impl EndpointUrl impl Serialize for EndpointUrl impl Debug for EndpointUrl struct ConduitMultistreamCatalog struct ConduitMultistreamSource struct ConduitMultistreamSession struct ConduitMultistreamUpsert struct ConduitMultistreamUpsertResult struct ConduitMultistreamDeleteResult struct ConduitMultistreamSessionStatus struct ConduitMultistreamList enum ConduitMultistreamOutputMode enum ConduitMultistreamOutputStatus enum ConduitMultistreamMediaRole struct ConduitMultistreamOutput impl Default for ConduitMultistreamCatalog impl ConduitMultistreamOutputStatus enum UpsertRefusal impl UpsertRefusal impl Display for UpsertRefusal static PEER_PUSH_RUNNING
Functions
By call-graph weight (PageRank; 1.0 is the average function). 51 functions in all.
| function | kind | lines | cyclomatic | callers | callees | weight | crystal |
|---|---|---|---|---|---|---|---|
| ConduitMultistreamCatalog::defaultsrc/multistream.rs:240 | trait impl | 3 | 1 | 9 | 0 | 12.4 | |
| normalize_idsrc/multistream.rs:941 | fn | 3 | 1 | 4 | 1 | 3.2 | |
| derive_default_outputssrc/multistream.rs:463 | fn | 9 | 1 | 4 | 2 | 2.6 | |
| require_idsrc/multistream.rs:937 | fn | 3 | 1 | 3 | 1 | 2.3 | |
| EndpointUrl::exposesrc/multistream.rs:65 | method | 3 | 1 | 5 | 0 | 2 | |
| split_push_schemesrc/multistream.rs:87 | fn | 3 | 1 | 1 | 0 | 1.9 | |
| source_from_idssrc/multistream.rs:449 | fn | 13 | 1 | 2 | 1 | 1.8 | |
| default_outputs_for_sourcesrc/multistream.rs:572 | fn | 180 | 1 | 2 | 17 | 1.8 | |
| redact_endpoint_urlsrc/multistream.rs:93 | fn | 14 | 3 | 1 | 1 | 1.6 | |
| EndpointUrl::newsrc/multistream.rs:59 | method | 3 | 1 | 4 | 0 | 1.6 | |
| ConduitMultistreamOutputStatus::implementedsrc/multistream.rs:246 | method | 3 | 1 | 3 | 0 | 1.4 | |
| EndpointUrl::redactedsrc/multistream.rs:70 | method | 3 | 1 | 2 | 1 | 1.3 | |
| missing_statussrc/multistream.rs:919 | fn | 17 | 1 | 2 | 0 | 1.2 | |
| upsertsrc/multistream.rs:473 | fn | 38 | 5 | 8 | 5 | 1.2 | |
| upsert_requestsrc/multistream.rs:949 | fn | 13 | 1 | 7 | 0 | 1.1 | |
| statussrc/multistream.rs:512 | fn | 30 | 1 | 4 | 2 | 1.1 | |
| outputsrc/multistream.rs:963 | fn | 3 | 1 | 3 | 0 | 1 | |
| statesrc/multistream.rs:251 | fn | 3 | 1 | 4 | 1 | 1 | |
| UpsertRefusal::messagesrc/multistream.rs:267 | method | 5 | 1 | 1 | 0 | 0.9 | |
| is_live_push_targetsrc/multistream.rs:846 | fn | 5 | 3 | 2 | 0 | 0.9 | |
| push_outputsrc/multistream.rs:973 | fn | 13 | 1 | 4 | 1 | 0.8 | |
| deletesrc/multistream.rs:553 | fn | 18 | 1 | 3 | 3 | 0.8 | |
| normalize_outputsrc/multistream.rs:863 | fn | 24 | 4 | 1 | 6 | 0.8 | |
| listsrc/multistream.rs:543 | fn | 9 | 1 | 3 | 0 | 0.8 | |
| endpointsrc/multistream.rs:969 | fn | 3 | 1 | 3 | 2 | 0.8 | |
| delete_runtimesrc/multistream.rs:437 | fn | 11 | 1 | 2 | 4 | 0.7 | |
| status_runtimesrc/multistream.rs:341 | fn | 7 | 1 | 1 | 4 | 0.7 | |
| merge_outputssrc/multistream.rs:821 | fn | 20 | 5 | 1 | 2 | 0.7 | |
| push_telemetry_rowssrc/multistream.rs:351 | fn | 7 | 1 | 2 | 1 | 0.7 | |
| validated_push_endpoint_urlsrc/multistream.rs:894 | fn | 24 | 7 | 2 | 0 | 0.7 | |
| retains_rtmp_outputsrc/multistream.rs:366 | fn | 7 | 6 | 2 | 1 | 0.6 | |
| set_peer_push_runningsrc/multistream.rs:760 | fn | 3 | 1 | 2 | 0 | 0.6 | |
| peer_push_targetsrc/multistream.rs:768 | fn | 16 | 2 | 1 | 1 | 0.6 | |
| pull_viewsrc/multistream.rs:785 | fn | 21 | 1 | 1 | 2 | 0.6 | |
| push_targetsrc/multistream.rs:807 | fn | 13 | 1 | 1 | 0 | 0.6 | |
| UpsertRefusal::is_deniedsrc/multistream.rs:273 | method | 3 | 1 | 1 | 0 | 0.6 | |
| upsert_runtimesrc/multistream.rs:284 | fn | 56 | 5 | 1 | 12 | 0.6 | |
| reconcile_session_pusherssrc/multistream.rs:374 | fn | 56 | 9 | 1 | 7 | 0.5 | |
| requests_a_push_destinationsrc/multistream.rs:855 | fn | 7 | 3 | 1 | 1 | 0.5 | |
| EndpointUrl::serializesrc/multistream.rs:76 | trait impl | 3 | 1 | 0 | 1 | 0.5 | |
| EndpointUrl::fmtsrc/multistream.rs:82 | trait impl | 3 | 1 | 0 | 1 | 0.5 | |
| UpsertRefusal::fmtsrc/multistream.rs:279 | trait impl | 3 | 1 | 0 | 1 | 0.5 | |
| list_runtimesrc/multistream.rs:431 | fn | 5 | 1 | 0 | 3 | 0.5 | |
| default_outputs_model_pull_views_and_future_push_targetssrc/multistream.rs:988 | fn | 27 | 2 | 0 | 3 | 0.5 | |
| upsert_status_list_delete_are_pure_catalog_operationssrc/multistream.rs:1017 | fn | 32 | 1 | 0 | 5 | 0.5 | |
| removed_or_retyped_outputs_do_not_retain_their_socketsrc/multistream.rs:1051 | fn | 14 | 1 | 0 | 5 | 0.5 | |
| custom_outputs_override_defaults_by_output_idsrc/multistream.rs:1067 | fn | 26 | 1 | 0 | 6 | 0.5 | |
| no_result_shape_serializes_a_stream_keysrc/multistream.rs:1099 | fn | 31 | 2 | 0 | 7 | 0.5 | |
| a_push_endpoint_is_validated_where_the_socket_openssrc/multistream.rs:1135 | fn | 24 | 2 | 0 | 5 | 0.5 | |
| outputs_and_push_targets_are_both_cappedsrc/multistream.rs:1163 | fn | 33 | 4 | 0 | 4 | 0.5 | |
| the_catalog_refuses_a_new_session_past_its_capsrc/multistream.rs:1201 | fn | 22 | 2 | 0 | 3 | 0.5 |
Source not readable from this process.