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

↓ 8 callersFunctionhistogram_count_value

(histogram: &NativeHistogram)

src/promql/types.rs:82

↓ 8 callersMethodinsert

(&mut self, metric: String, data: MetricPrefetchRows)

src/promql/eval/mod.rs:47

↓ 8 callersFunctionintersect_candidates

( candidates: &mut RoaringTreemap, filter: Option<&RoaringTreemap>, )

src/engine/query_exec/candidate_planner/bitmap_ops.rs:3

↓ 8 callersMethodis_active

(self)

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

↓ 8 callersFunctionlocal_owned_metadata_scope

( cluster_context: &ClusterRequestContext, ring_version: u64, )

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

↓ 8 callersFunctionmake_persistent_storage

(data_path: &Path)

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

↓ 8 callersMethodmatches_value

(&self, actual: &str)

src/query_matcher.rs:21

↓ 8 callersFunctionnormalize_optional_string

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

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

↓ 8 callersFunctionparse_admin_u64

(value: &str, field: &str)

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

↓ 8 callersFunctionparse_env_usize

(var: &str, default: usize, enforce_positive: bool)

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

↓ 8 callersFunctionpercentile

(mut values: Vec<f64>, p: f64)

benches/workload.rs:1237

↓ 8 callersMethodpostings_for_label

( &self, label_name: &str, label_value: &str, )

src/engine/query_exec/candidate_planner.rs:222

↓ 8 callersFunctionprepare_request_plan

( registry: Option<&TenantRegistry>, managed_control_plane: Option<&ManagedControlPlane>, request:

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

↓ 8 callersMethodreconcile_live_metadata_indexes

(&self)

src/engine/visibility/cache/materialized_series.rs:128

↓ 8 callersMethodrecord

(&self, input: UsageRecordInput<'_>)

crates/tsink-server/src/usage.rs:316

↓ 8 callersFunctionrecord_otlp_request_rejected

()

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

↓ 8 callersFunctionrecord_request_throttled

(kind: LegacyAdapterKind, rejected_samples: usize)

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

↓ 8 callersFunctionremove_path_if_exists

(path: &Path)

src/engine/fs_utils.rs:170

↓ 8 callersMethodreplay_committed_writes_after_with_mode

( &self, replay_highwater: WalHighWatermark, replay_mode: WalReplayMode, )

src/engine/wal/replay.rs:459

↓ 8 callersMethodreplay_from_wal

( &self, replay_highwater: WalHighWatermark, replay_mode: crate::wal::WalReplayMode,

src/engine/lifecycle/replay.rs:116

↓ 8 callersFunctionsample_membership_and_state

()

crates/tsink-server/src/cluster/consensus.rs:1865

↓ 8 callersFunctionsaturating_elapsed_nanos

(duration: std::time::Duration)

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

↓ 8 callersMethodselect

( &self, metric: String, labels: Vec<ULabel>, start: i64, end: i64,

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

↓ 8 callersMethodseries_id_postings_for_metric

(&self, metric: &str)

src/engine/query_exec/candidate_planner.rs:210

↓ 8 callersMethodset_query_persisted_chunk_decode_hook

(&self, hook: F)

src/engine/test_hooks/query_exec.rs:218

↓ 8 callersMethodstate_snapshot

(&self)

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

↓ 8 callersMethodstorage

(&self)

src/promql/eval/mod.rs:208

↓ 8 callersMethodtokenize

(mut self)

src/promql/lexer.rs:123

↓ 8 callersFunctionunix_timestamp_millis

()

crates/tsink-server/src/edge_sync.rs:1090

↓ 8 callersFunctionunix_timestamp_millis

()

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

↓ 8 callersMethodvalidate

(self)

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

↓ 8 callersFunctionvalidate_identifier

(value: &str, label: &str)

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

↓ 8 callersFunctionvalidate_resource_id

(field: &str, value: &str)

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

↓ 8 callersMethodwith_detail

(mut self, detail: impl Into<String>)

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

↓ 8 callersMethodwith_retention_enforced

(mut self, enforced: bool)

src/async.rs:526

↓ 8 callersFunctionwrite_runtime_refresh_segment

( data_path: &Path, metric: &str, series_id: u64, segment_id: u64, points: &[(i64, f64)],

src/engine/tests/persistence_recovery.rs:319

↓ 7 callersMethodaccumulate

(&mut self, other: Self)

src/engine/query_read.rs:73

↓ 7 callersFunctionactor

(id: &str)

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

↓ 7 callersMethodadd_persisted_segments_from_loaded

( &self, loaded_segments: Vec<IndexedSegment>, )

src/engine/lifecycle/persisted_state.rs:53

↓ 7 callersFunctionaggregation_name

(aggregation: Aggregation)

src/query_aggregation.rs:12

↓ 7 callersMethodapply_groups

(&self, groups: Vec<RuleGroupSpec>)

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

↓ 7 callersMethodarm_repair_failure_backoff

(&self, key: &RepairResumeCursorKey)

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

↓ 7 callersFunctionas_range_vector

(value: PromqlValue)

tests/promql_integration_test.rs:605

↓ 7 callersMethodas_str

(self)

src/storage.rs:276

↓ 7 callersMethodas_str

(&self)

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

↓ 7 callersFunctionbase_storage_test_options

( timestamp_precision: TimestampPrecision, current_time_override: Option<i64>, )

src/engine/tests/fixtures/builders.rs:16

↓ 7 callersFunctionbuild_executor_with_topology

( read_consistency: ClusterReadConsistency, local_endpoint: String, node_b_endpoint: S

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

↓ 7 callersFunctioncanonical_series_identity_key

Computes a collision-safe canonical string key for a metric series.

src/label.rs:56

↓ 7 callersMethodcommitted_series_definitions_snapshot

( &self, )

src/engine/wal/series_index.rs:83

↓ 7 callersFunctiondedupe_metrics_snapshot

()

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

↓ 7 callersFunctiondedupe_writable_series

(series: &mut WritableSeries)

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

↓ 7 callersFunctionencode_uvarint

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

src/engine/encoder.rs:454

↓ 7 callersFunctioneval_rate_like

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

src/promql/eval/functions.rs:151

↓ 7 callersMethodforce_registry_checkpoint

(&mut self)

src/engine/bootstrap/discovery.rs:87

↓ 7 callersMethodhandoff_snapshot

(&self)

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

↓ 7 callersFunctionhistogram_zero_count_value

(histogram: &NativeHistogram)

src/promql/types.rs:110

↓ 7 callersMethodis_rotatable

(&self)

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

↓ 7 callersFunctionlabels_for_shard_with_job

( metric: &str, shard_count: u32, target_shard: u32, prefix: &str, job: Option<&str>, )

src/engine/tests/series_selection.rs:36

↓ 7 callersFunctionmanaged_control_plane_actor

(request: &HttpRequest)

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

↓ 7 callersFunctionmanaged_tenant_rejected

(status: u16, code: &'static str, message: String)

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

↓ 7 callersMethodmemory_observability_snapshot

( &self, )

src/engine/maintenance/memory_accounting.rs:195

↓ 7 callersMethodmemory_usage_bytes

(&self)

src/engine/segment/postings.rs:28

↓ 7 callersMethodmissing_label_partition_for_matcher

( &self, matcher: &CompiledSeriesMatcher, )

src/engine/query_exec/candidate_planner/matcher_eval.rs:16

↓ 7 callersMethodmutate

( &self, actor: ManagedControlPlaneActor, operation: &str, target_kind: &str,

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

↓ 7 callersFunctionnext_u64

(state: &mut u64)

src/engine/tests/failure_modes.rs:3

↓ 7 callersFunctionnormalize_tombstone_map

(map: &mut TombstoneMap)

src/engine/tombstone.rs:101

↓ 7 callersMethodnormalized

(&self)

src/storage.rs:171

↓ 7 callersFunctionoutcome

(status: &str, http_status: u16)

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

↓ 7 callersFunctionparse_env_bool

(name: &str, default: bool)

benches/workload.rs:1257

↓ 7 callersFunctionparse_env_usize

(var: &str, default: usize, enforce_positive: bool)

crates/tsink-server/src/cluster/mod.rs:254

↓ 7 callersFunctionparse_manifest

(bytes: &[u8])

src/engine/segment/format.rs:614

↓ 7 callersMethodpersist_segment_with_outcome

(&self)

src/engine/lifecycle/flush.rs:499

↓ 7 callersFunctionprepare_capture_source_data

(plan: &MigrationPlan)

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

↓ 7 callersMethodpropose_command

( &self, rpc_client: &RpcClient, command: InternalControlCommand, )

crates/tsink-server/src/cluster/consensus.rs:565

↓ 7 callersFunctionread_selections_for_tenant

( selection: &SeriesSelection, tenant_id: &str, )

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

↓ 7 callersFunctionread_u32_at

(bytes: &[u8], offset: usize)

src/engine/binio.rs:63

↓ 7 callersFunctionrecord_ingest_usage

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

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

↓ 7 callersFunctionrecord_payload_rejected

(kind: PrometheusPayloadKind, count: usize)

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

↓ 7 callersFunctionrefresh_observability_locked

( state: &mut OutboxState, config: &OutboxConfig, now_unix_ms: u64, )

crates/tsink-server/src/cluster/outbox.rs:1062

↓ 7 callersFunctionrename_and_sync_parents

(source: &Path, destination: &Path)

src/engine/fs_utils.rs:402

↓ 7 callersMethodset_metadata_all_series_postings_hook

(&self, hook: F)

src/engine/test_hooks/query_exec.rs:36

↓ 7 callersMethodsnapshot

Writes an atomic on-disk snapshot to `path`.

src/async.rs:398

↓ 7 callersFunctionstage_dir_path

(target: &Path, purpose: &str)

src/engine/fs_utils.rs:194

↓ 7 callersFunctionstartup_builder

(data_path: &Path)

src/engine/bootstrap/tests.rs:17

↓ 7 callersFunctiontenant_id_for_promql_request

(request: &HttpRequest)

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

↓ 7 callersFunctiontenant_id_for_request

(request: &HttpRequest)

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

↓ 7 callersFunctiontenant_id_for_text_request

(request: &HttpRequest)

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

↓ 7 callersFunctionunix_timestamp_millis

()

crates/tsink-server/src/cluster/outbox.rs:1186

↓ 7 callersFunctionunsupported_histogram_aggregation

(name: &str)

src/promql/eval/aggregation.rs:386

↓ 7 callersFunctionupdate_gauges

(state: &DedupeState)

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

↓ 7 callersMethodused_value

(self)

src/engine/maintenance/memory_accounting/context.rs:140

↓ 7 callersFunctionvalidate_tenant_id

(tenant_id: &str)

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

↓ 7 callersFunctionverify_segment_fingerprint

( path: impl AsRef<Path>, )

src/engine/segment/loader.rs:253

↓ 7 callersMethodwith_memory_limit

(mut self, bytes: usize)

src/async.rs:570

↓ 7 callersMethodwith_metadata_shard_count

(mut self, shard_count: u32)

src/storage.rs:1260

↓ 7 callersMethodwith_object_store_path

(&self, path: String)

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

↓ 7 callersMethodwith_runtime_mode

(mut self, mode: StorageRuntimeMode)

src/storage.rs:1123

↓ 7 callersFunctionwrite_test_file

(path: &Path, contents: &str)

crates/tsink-server/src/cluster/rpc.rs:1583

↓ 6 callersMethodadd_entry

(&mut self, entry: ChunkIndexEntry)

src/engine/index.rs:26

↓ 6 callersFunctionadmin_audit_error_response

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

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

← previous next →401–500 of 5,563, ranked by callers