Functions — github.com/cantrepro/tsink

hub / github.com/cantrepro/tsink / functions

Functions5,563 in github.com/cantrepro/tsink

⨍ Functions 5,563◇ Types & classes 1,107

↓ 11 callersFunctionrecord_query_usage

( usage_accounting: Option<&UsageAccounting>, tenant_id: &str, operation: &str, source: &str,

crates/tsink-server/src/handlers.rs:574

↓ 11 callersFunctionrestore_from_snapshot

(snapshot_path: String, data_path: String)

crates/tsink-uniffi/src/builder.rs:188

↓ 11 callersFunctionsample_segment_input

()

src/engine/segment/tests.rs:436

↓ 11 callersFunctionscope_rows_for_tenant

(rows: Vec<Row>, tenant_id: &str)

crates/tsink-server/src/tenant.rs:1384

↓ 11 callersMethodseries_query_context

(&self)

src/engine/query_exec/read_context.rs:260

↓ 11 callersMethodset_full_inventory_scan_hook

(&self, hook: F)

src/engine/maintenance/catalog_refresh/context.rs:354

↓ 11 callersMethodset_metadata_live_series_snapshot_hook

(&self, hook: F)

src/engine/test_hooks/query_exec.rs:19

↓ 11 callersFunctionunauthorized_auth_response

(code: &str)

crates/tsink-server/src/server/auth.rs:164

↓ 10 callersMethodclear_full_inventory_scan_hook

(&self)

src/engine/maintenance/catalog_refresh/context.rs:362

↓ 10 callersFunctioncluster_context_with_single_node_control

(temp_dir: &TempDir)

crates/tsink-server/src/handlers.rs:7233

↓ 10 callersMethoddecode_points

(&self)

src/engine/wal.rs:143

↓ 10 callersMethodget

(&self, metric: &str)

src/promql/eval/mod.rs:51

↓ 10 callersMethodis_eof

(&self)

src/promql/lexer.rs:273

↓ 10 callersMethodlabel_name_id

(&self, label_name: &str)

src/engine/series/dictionary.rs:218

↓ 10 callersMethodlifecycle_publication_context

( &self, )

src/engine/core_impl/contexts.rs:385

↓ 10 callersMethodlist_metrics_with_wal

(&self)

src/engine/engine.rs:386

↓ 10 callersFunctionload_segments

(base: impl AsRef<Path>)

src/engine/segment/loader.rs:65

↓ 10 callersMethodnode_is_owner_for_shard_at_ring_version

( &self, shard: u32, node_id: &str, ring_version: u64, )

crates/tsink-server/src/cluster/control.rs:535

↓ 10 callersFunctionnormalize_remote_write_request

( write_req: WriteRequest, tenant_id: &str, precision: TimestampPrecision, )

crates/tsink-server/src/prom_write.rs:124

↓ 10 callersFunctionparse_finite_f64

(raw: &str, context: &str)

crates/tsink-server/src/legacy_ingest.rs:915

↓ 10 callersMethodpeek_byte

(&self)

src/promql/lexer.rs:277

↓ 10 callersFunctionread_admission_error_response

(err: ReadAdmissionError)

crates/tsink-server/src/handlers.rs:6187

↓ 10 callersFunctionrecord_request_rejected

(kind: LegacyAdapterKind, rejected_samples: usize)

crates/tsink-server/src/legacy_ingest.rs:448

↓ 10 callersMethodrecord_series_value_family

( &self, series_id: SeriesId, family: SeriesValueFamily, )

src/engine/series/value_family.rs:190

↓ 10 callersMethodsealed_shard

( self, series_id: SeriesId, )

src/engine/shard_routing.rs:44

↓ 10 callersMethodseries_id_postings_for_label_name

(&self, label_name: &str)

src/engine/query_exec/candidate_planner.rs:214

↓ 10 callersFunctionseries_identity

( metric: &str, point_labels: &[Label], extra_labels: &[Label], extra_label: Option<Label>,

crates/tsink-server/src/otlp.rs:759

↓ 10 callersMethodsnapshot

(&self)

crates/tsink-server/src/cluster/ring.rs:149

↓ 10 callersFunctionspawn_select_server

( points: Vec<DataPoint>, )

crates/tsink-server/src/cluster/query.rs:1886

↓ 10 callersFunctionunix_time_ms

()

crates/tsink-server/src/security.rs:1518

↓ 10 callersFunctionunix_timestamp_millis

()

crates/tsink-server/src/cluster/audit.rs:428

↓ 10 callersFunctionunix_timestamp_millis

()

crates/tsink-server/src/cluster/repair.rs:2722

↓ 10 callersMethodvalidate

(&self)

crates/tsink-server/src/server.rs:170

↓ 10 callersFunctionvalidate_idempotency_key

(value: &str)

crates/tsink-server/src/cluster/dedupe.rs:348

↓ 10 callersFunctionvalidate_labels

(labels: &[Label])

src/validation.rs:19

↓ 10 callersMethodwith_retention

(&self, duration: Duration)

crates/tsink-uniffi/src/builder.rs:49

↓ 9 callersFunctionadmin_rebalance_error_response

( status: u16, code: &str, message: impl Into<String>, )

crates/tsink-server/src/handlers.rs:4286

↓ 9 callersMethodadmit

( &self, surface: TenantAdmissionSurface, requested_units: usize, )

crates/tsink-server/src/tenant.rs:123

↓ 9 callersFunctionaggregate_series

( points: &[DataPoint], aggregation: Aggregation, )

src/query_aggregation.rs:475

↓ 9 callersMethodappend_series_definition_payload

( &mut self, payload: &[u8], )

src/engine/wal/logical.rs:76

↓ 9 callersMethodapply_updates

( &self, tenant_id: &str, updates: &[NormalizedMetricMetadataUpdate], )

crates/tsink-server/src/metadata_store.rs:66

↓ 9 callersMethodas_f64

(&self)

src/value.rs:41

↓ 9 callersFunctionassert_runtime_accounting_matches_disk

(wal: &FramedWal, dir: &Path)

src/engine/wal/tests.rs:79

↓ 9 callersMethodchunk_context

(&self)

src/engine/core_impl/contexts.rs:80

↓ 9 callersMethodclose

(&self)

crates/tsink-uniffi/src/db.rs:244

↓ 9 callersFunctioncpu_rollup_policy

(id: &str, interval: i64)

src/engine/tests/rollups.rs:8

↓ 9 callersMethodeffective_ring_snapshot_at_ring_version

(&self, ring_version: u64)

crates/tsink-server/src/cluster/control.rs:527

↓ 9 callersFunctionencode_series_definition

(definition: &SeriesDefinitionFrame)

src/engine/wal/codec.rs:59

↓ 9 callersFunctioneval_over_time

( engine: &Engine, call: &CallExpr, params: &QueryParams<'_>, kind: OverTimeKind, )

src/promql/eval/functions.rs:540

↓ 9 callersFunctionfind_series_with_primary_owner

(executor: &ReadFanoutExecutor, owner: &str)

crates/tsink-server/src/cluster/query.rs:1834

↓ 9 callersFunctionglobal_public_write_admission

()

crates/tsink-server/src/admission.rs:539

↓ 9 callersFunctionhandle_test_request

( storage: &Arc<dyn Storage>, engine: &Engine, request: HttpRequest, options: TestRequestOptio

crates/tsink-server/src/handlers.rs:991

↓ 9 callersFunctionload_plan

(path: &Path)

crates/tsink-server/src/bin/tsink-migrate.rs:689

↓ 9 callersFunctionmarshal_metric_name

Marshals a metric name and labels into a unique binary identifier.

src/label.rs:72

↓ 9 callersFunctionmerge_positive_limit

( incoming: Option<usize>, existing: Option<usize>, field_name: &str, )

crates/tsink-server/src/tenant.rs:1334

↓ 9 callersMethodmissing_label_postings_for_id

(&self, name_id: DictionaryId)

src/engine/series/postings.rs:174

↓ 9 callersFunctionnew_raw_numeric_storage

(lane_path: std::path::PathBuf, next_segment_id: u64)

src/engine/tests/persistence_background.rs:4

↓ 9 callersFunctionnormalize_non_empty_membership_field

( value: &str, field_name: &str, command_name: &str, )

crates/tsink-server/src/cluster/control.rs:991

↓ 9 callersFunctionnormalize_trimmed_optional_path

( flag: &str, value: Option<PathBuf>, )

crates/tsink-server/src/server.rs:345

↓ 9 callersMethodpaths

(&self)

src/engine/bootstrap/planning.rs:45

↓ 9 callersFunctionpressure_ratio

(value: u64, total: u64, slots: usize)

crates/tsink-server/src/cluster/hotspot.rs:535

↓ 9 callersMethodrebalance_snapshot

(&self)

crates/tsink-server/src/cluster/repair.rs:874

↓ 9 callersMethodrecord_query_tier_plan

(&self, plan: TieredQueryPlan)

src/engine/query_exec.rs:61

↓ 9 callersMethodrefresh_memory_usage

(&self)

src/engine/maintenance/memory_accounting.rs:191

↓ 9 callersMethodrollup_state_store_context

(&self)

src/engine/rollups.rs:334

↓ 9 callersMethodrotate

(&self, usage: &str)

crates/tsink-server/src/security.rs:236

↓ 9 callersMethodroute_and_write

( &self, storage: &Arc<dyn Storage>, rpc_client: &RpcClient, rows: Vec<Row>,

crates/tsink-server/src/cluster/replication.rs:769

↓ 9 callersFunctionsample_key

(sample: &Sample, matching: Option<&VectorMatching>)

src/promql/eval/binary.rs:354

↓ 9 callersMethodselect_points_for_series_with_ring_version

( &self, storage: &Arc<dyn Storage>, rpc_client: &RpcClient, series: &[MetricS

crates/tsink-server/src/cluster/query.rs:960

↓ 9 callersMethodset_persist_post_publish_hook

(&self, hook: F)

src/engine/lifecycle/flush.rs:175

↓ 9 callersMethodsnapshot

(&self)

crates/tsink-server/src/rules.rs:343

↓ 9 callersFunctionusize_to_u64

(value: usize)

crates/tsink-uniffi/src/conversions.rs:5

↓ 9 callersMethodvalidate

(&self)

crates/tsink-server/src/cluster/config.rs:263

↓ 9 callersFunctionvalidate_non_empty_field

(field: &str, value: String)

crates/tsink-server/src/managed_control_plane.rs:1440

↓ 9 callersFunctionwait_for_condition

(timeout: Duration, poll_interval: Duration, condition: F)

src/engine/tests/reliability.rs:57

↓ 9 callersMethodwith_tiered_retention_policy

( &self, hot_retention: Duration, warm_retention: Duration, )

crates/tsink-uniffi/src/builder.rs:57

↓ 9 callersMethodwith_wal_sync_mode

(mut self, mode: WalSyncMode)

src/async.rs:600

↓ 9 callersFunctionwrite_admission_error_response

(err: WriteAdmissionError)

crates/tsink-server/src/handlers.rs:6157

↓ 9 callersFunctionwrite_numeric_segment_to_path

( lane_path: &Path, registry: &SeriesRegistry, series_id: crate::engine::series::SeriesId, lev

src/engine/tests/reliability.rs:104

↓ 8 callersMethodacquire

(&self)

src/concurrency.rs:29

↓ 8 callersFunctionactor

()

crates/tsink-server/src/managed_control_plane.rs:1499

↓ 8 callersFunctionappend_i64

(out: &mut Vec<u8>, value: i64)

src/engine/binio.rs:27

↓ 8 callersMethodappend_samples_payload

(&mut self, payload: &[u8])

src/engine/wal/logical.rs:88

↓ 8 callersMethodapply_writes

( &self, exemplars: &[ExemplarWrite], )

crates/tsink-server/src/exemplar_store.rs:193

↓ 8 callersFunctionassert_memory_usage_reconciled

(registry: &SeriesRegistry)

src/engine/series/tests/mod.rs:9

↓ 8 callersFunctionbase64url_decode

(value: &str)

crates/tsink-server/src/rbac.rs:1843

↓ 8 callersMethodbegin_logical_write

( &self, estimated_bytes: u64, )

src/engine/wal/logical.rs:346

↓ 8 callersMethodbegin_persisted_catalog_publication

( &self, )

src/engine/maintenance/mod.rs:181

↓ 8 callersFunctionbitmap

(series_ids: &[SeriesId])

src/engine/query_exec/candidate_planner.rs:245

↓ 8 callersFunctioncanonical_series_identity

Computes a collision-safe canonical binary identity for a metric series.

src/label.rs:51

↓ 8 callersMethodclear_query_persisted_chunk_decode_hook

(&self)

src/engine/test_hooks/query_exec.rs:228

↓ 8 callersFunctioncollect_wal_segment_files

(dir: &Path)

src/engine/wal/segments.rs:445

↓ 8 callersFunctioneval_time_component

( engine: &Engine, call: &CallExpr, params: &QueryParams<'_>, component: impl Fn(chrono::DateT

src/promql/eval/functions.rs:1030

↓ 8 callersFunctionexpect_range_vector

( value: PromqlValue, func: &str, )

src/promql/eval/functions.rs:1646

↓ 8 callersFunctionexpect_string

(value: PromqlValue, func: &str)

src/promql/eval/functions.rs:1628

↓ 8 callersFunctionextract_bearer_token

(request: &crate::http::HttpRequest)

crates/tsink-server/src/server/auth.rs:140

↓ 8 callersFunctionfixture_dir

()

crates/tsink-server/src/bin/tsink-migrate.rs:3418

↓ 8 callersFunctionfnv1a_update

(hash: &mut u64, bytes: &[u8])

crates/tsink-server/src/handlers/internal_api/mod.rs:835

↓ 8 callersMethodget_value

(&self, id: DictionaryId)

src/engine/series/dictionary.rs:33

↓ 8 callersFunctionhandle_request_with_metadata_store

( storage: &Arc<dyn Storage>, metadata_store: &Arc<MetricMetadataStore>, engine: &Engi

crates/tsink-server/src/handlers.rs:6908

← previous next →301–400 of 5,563, ranked by callers