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

↓ 16 callersFunctionreserve_unused_endpoint

()

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

↓ 16 callersFunctionsample_membership_and_ring

()

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

↓ 16 callersFunctionunix_timestamp_millis

()

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

↓ 16 callersMethodvalue

(&self)

src/engine/encoder.rs:153

↓ 15 callersFunctionadmin_membership_error_response

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

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

↓ 15 callersFunctionbitmap_cardinality

(bitmap: &RoaringTreemap)

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

↓ 15 callersFunctioncluster_context_with_control_state_for_config

( temp_dir: &TempDir, config: ClusterConfig, mutate: F, )

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

↓ 15 callersFunctionduration_to_units

Converts duration in milliseconds to timestamp units according to units-per-second.

src/promql/eval/time.rs:2

↓ 15 callersMethodget_id

(&self, value: &str)

src/engine/series/dictionary.rs:29

↓ 15 callersFunctionhandle_request_with_metadata_and_exemplar_store

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

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

↓ 15 callersFunctioninternal_headers

( token: Option<&str>, version: Option<&str>, extra: &[(&str, &str)], )

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

↓ 15 callersMethodlast_log_index_locked

(&self, state: &ConsensusState)

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

↓ 15 callersFunctionnormalize_optional_field

(value: Option<String>)

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

↓ 15 callersMethodquery_tier_plan

(self, start: i64, end: i64)

src/engine/query_exec/read_context.rs:79

↓ 15 callersFunctionreopen_persistent_numeric_storage

( root: &Path, timestamp_precision: TimestampPrecision, chunk_point_cap: usize, )

src/engine/tests/fixtures/persisted.rs:28

↓ 15 callersMethodtrigger_rollup_run

(&self)

src/engine/engine.rs:482

↓ 15 callersFunctionvalidate_metric

(metric: &str)

src/validation.rs:5

↓ 15 callersFunctionwrite_file_atomically_and_sync_parent

(path: &Path, bytes: &[u8])

src/engine/fs_utils.rs:453

↓ 14 callersMethodacquire_request_slot

(&self)

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

↓ 14 callersMethodas_slice

(&self)

src/engine/chunk.rs:200

↓ 14 callersMethodauthorize

( &self, token: Option<&str>, permission: &RbacPermission, )

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

↓ 14 callersMethodbuild

(&self)

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

↓ 14 callersMethodcatalog_refresh_context

(&self)

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

↓ 14 callersFunctioncluster_ring_version

(cluster_context: Option<&ClusterRequestContext>)

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

↓ 14 callersMethodinsert_rows

(&self, rows: &[Row])

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

↓ 14 callersMethodis_empty

(&self)

src/engine/tiering/policy.rs:119

↓ 14 callersMethodmemory_usage_bytes

(&self)

src/engine/series/dictionary.rs:41

↓ 14 callersMethodnode_record

(&self, node_id: &str)

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

↓ 14 callersMethodowners_for_shard

(&self, shard: u32)

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

↓ 14 callersFunctionparse_internal_json_body

(request: &HttpRequest)

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

↓ 14 callersMethodpersist_to_path

(&self, path: &Path)

src/engine/series/persistence.rs:98

↓ 14 callersMethodpost_json

( &self, endpoint: &str, path: &str, request: &Req, )

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

↓ 14 callersFunctionprepare_tenant_request

( tenant_registry: Option<&tenant::TenantRegistry>, managed_control_plane: Option<&ManagedControlPlane

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

↓ 14 callersFunctionruntime_stopped_error

()

src/async.rs:764

↓ 14 callersMethodselect_into

( self, metric: &str, labels: &[Label], start: i64, end: i64,

src/engine/query_exec/read_context.rs:133

↓ 14 callersMethodset_current_time_override

(&self, timestamp: i64)

src/engine/core_impl/utilities.rs:205

↓ 14 callersMethodsnapshot

(&self)

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

↓ 14 callersFunctionsync_dir

(path: &Path)

src/engine/fs_utils.rs:424

↓ 14 callersMethodvalidate

(&self)

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

↓ 14 callersMethodvalidate

(self)

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

↓ 14 callersMethodwith_wal_enabled

(&self, enabled: bool)

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

↓ 13 callersFunctionbuild_test_storage

()

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

↓ 13 callersMethoddecode_series_key

(self, series_id: SeriesId)

src/engine/rollups/runtime.rs:590

↓ 13 callersMethodentries

(&self)

src/engine/series/dictionary.rs:45

↓ 13 callersFunctionhandle_request_with_admin_and_cluster_and_tenant_and_metadata

( storage: &Arc<dyn Storage>, metadata_store: &Arc<MetricMetadataStore>, exemplar_store: &Arc<Exem

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

↓ 13 callersFunctionnormalize_capabilities

(capabilities: I)

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

↓ 13 callersMethodnotify_persisted_refresh_thread

(&self)

src/engine/runtime/supervision.rs:135

↓ 13 callersFunctionparse_env_u64

(var: &str, default: u64, positive_only: bool)

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

↓ 13 callersFunctionparse_env_u64

(name: &str, default: u64, allow_zero: bool)

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

↓ 13 callersMethodpersist_log_locked

(&self, state: &ConsensusState)

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

↓ 13 callersMethodrecord_throttled

( &self, surface: TenantAdmissionSurface, requested_units: usize, reason: impl

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

↓ 13 callersFunctionrecv_reply

(receiver: async_channel::Receiver<Result<T>>)

src/async.rs:760

↓ 13 callersFunctionreply_channel

()

src/async.rs:756

↓ 13 callersMethodrun_due_at

(&self, now_timestamp: i64)

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

↓ 13 callersMethodsync_persisted_segments_from_disk_if_dirty

(&self)

src/engine/maintenance/catalog_refresh.rs:179

↓ 13 callersMethodts

(&self)

src/engine/encoder.rs:149

↓ 13 callersFunctionverify_file_manifest_entry

( entry: &ManifestFileEntry, expected_kind: u8, bytes: &[u8], )

src/engine/segment/format.rs:728

↓ 13 callersMethodwith_repair_probe

(mut self, repair_probe: Arc<RepairProbeFn>)

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

↓ 12 callersMethodadd_estimated_memory_bytes

(&self, bytes: usize)

src/engine/series.rs:278

↓ 12 callersMethodadmit_request

( &self, requested_queries: usize, )

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

↓ 12 callersMethodapply_join_node

( &mut self, node_id: &str, endpoint: &str, )

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

↓ 12 callersFunctionbase_ts_seconds

()

benches/storage_benchmarks.rs:143

↓ 12 callersMethodclear_metadata_all_series_seed_hook

(&self)

src/engine/test_hooks/query_exec.rs:130

↓ 12 callersFunctiondecoded_bucket_values

( spans: &[crate::HistogramBucketSpan], deltas: &[i64], counts: &[f64], )

src/promql/types.rs:414

↓ 12 callersFunctionduration_to_timestamp_units

( duration: Duration, precision: TimestampPrecision, )

src/engine/core_impl/utilities.rs:72

↓ 12 callersMethodensure_open

(&self)

src/async.rs:444

↓ 12 callersFunctionexpect_instant_vector

(value: PromqlValue, func: &str)

src/promql/eval/functions.rs:1637

↓ 12 callersFunctionglobal_public_read_admission

()

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

↓ 12 callersFunctionlabels_for_shard

(metric: &str, shard_count: u32, target_shard: u32, prefix: &str)

src/engine/tests/series_selection.rs:11

↓ 12 callersFunctionlabels_to_key

(labels: &[Label])

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

↓ 12 callersMethodlist_metrics

(&self)

src/engine/engine.rs:382

↓ 12 callersFunctionmaterial_resolver_for_path

(path: &Path)

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

↓ 12 callersMethodname

(self)

src/engine/series/value_family.rs:87

↓ 12 callersMethodpush_audit_entry

(&self, input: RbacAuditEntryInput)

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

↓ 12 callersMethodreplay_frames

(&self)

src/engine/wal/replay.rs:417

↓ 12 callersMethodrequest_background_persisted_refresh_if_needed

(&self)

src/engine/query_exec.rs:105

↓ 12 callersFunctionrpc_client

()

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

↓ 12 callersMethodset_metadata_all_series_seed_hook

(&self, hook: F)

src/engine/test_hooks/query_exec.rs:29

↓ 12 callersMethodset_repair_resume_cursor

(&self, key: &RepairResumeCursorKey, row_offset: Option<u64>)

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

↓ 12 callersFunctionstable_series_identity_hash

Computes a stable 64-bit hash for a metric series identity.

src/label.rs:110

↓ 12 callersMethodstart_background_persisted_refresh_thread

(self: &Arc<Self>)

src/engine/runtime.rs:423

↓ 12 callersFunctionwrite_http_response

( stream: &mut W, response: &HttpResponse, )

crates/tsink-server/src/http.rs:286

↓ 12 callersFunctionwrite_numeric_segment_to_path

( lane_path: &std::path::Path, registry: &SeriesRegistry, series_id: crate::engine::series::Series

src/engine/tests/persistence_background.rs:20

↓ 11 callersFunctionadmin_repair_error_response

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

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

↓ 11 callersMethodas_str

(self)

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

↓ 11 callersFunctionbuild_router_with_endpoints

( local_endpoint: String, seed_nodes: Vec<(&str, String)>, replication_factor: u16,

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

↓ 11 callersFunctionbuild_rows

(count: usize)

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

↓ 11 callersMethodclear_metadata_live_series_snapshot_hook

(&self)

src/engine/test_hooks/query_exec.rs:126

↓ 11 callersMethodconfig

(&self)

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

↓ 11 callersFunctiondecode_svarint

(bytes: &[u8], pos: &mut usize)

src/engine/encoder.rs:495

↓ 11 callersFunctionexpect_scalar

(value: PromqlValue, func: &str)

src/promql/eval/functions.rs:1610

↓ 11 callersFunctioninvoke_commit_hook

(slot: &RwLock<Option<Arc<IngestCommitHook>>>)

src/engine/test_hooks/mod.rs:48

↓ 11 callersMethodis_local_control_leader

(&self)

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

↓ 11 callersMethodlane_path

(&self, lane: SegmentLaneFamily, tier: PersistedSegmentTier)

src/engine/config.rs:14

↓ 11 callersMethodlist_metrics

( &self, endpoint: &str, )

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

↓ 11 callersFunctionnew_ingest_test_storage_with_options

( chunk_point_cap: usize, mut options: ChunkStorageOptions, )

src/engine/tests/ingest_core.rs:28

↓ 11 callersMethodpeek

(&self)

src/promql/parser.rs:538

↓ 11 callersFunctionpersistent_rollup_storage

( root: &Path, )

src/engine/tests/fixtures/persisted.rs:96

↓ 11 callersMethodrecord_persisted_tier_fetch_stats

(&self, stats: PersistedTierFetchStats)

src/engine/query_exec.rs:82

↓ 11 callersFunctionrecord_query_pressure

(tenant_id: &str, requests: usize, units: usize)

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

← previous next →201–300 of 5,563, ranked by callers