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

↓ 29 callersFunctionappend_u64

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

src/engine/binio.rs:23

↓ 29 callersMethodinsert_rows

(&self, rows: &[Row])

crates/tsink-server/src/cluster/distributed_storage.rs:272

↓ 29 callersFunctionmake_storage

()

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

↓ 29 callersFunctionparse_env

(name: &str, default: T)

benches/workload.rs:1247

↓ 29 callersFunctionread_u16

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

src/engine/binio.rs:45

↓ 29 callersFunctionscoped_storage

(inner: Arc<dyn Storage>, tenant_id: impl Into<String>)

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

↓ 28 callersMethodhandle_append_request

( &self, request: InternalControlAppendRequest, )

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

↓ 28 callersMethodlayout

(&self)

src/engine/segment/writer.rs:43

↓ 28 callersFunctionpersistent_numeric_storage

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

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

↓ 27 callersFunctionadmin_handoff_error_response

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

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

↓ 27 callersMethodinsert_rows

(&self, rows: Vec<Row>)

src/async.rs:210

↓ 27 callersMethodwith_downsample

(mut self, interval: i64, aggregation: Aggregation)

src/storage.rs:1560

↓ 26 callersFunctionadmin_control_plane_error_response

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

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

↓ 26 callersFunctionappend_u16

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

src/engine/binio.rs:15

↓ 26 callersFunctionchecksum32

(bytes: &[u8])

src/engine/binio.rs:7

↓ 26 callersMethoddisplay

(&self)

crates/tsink-server/src/cluster/query_merge.rs:252

↓ 26 callersMethodfinish

(self)

src/engine/tiering/inventory.rs:153

↓ 26 callersFunctionmake_metadata_store

(data_path: Option<&Path>)

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

↓ 26 callersMethodowners_for_shard_at_ring_version

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

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

↓ 26 callersMethodpath_without_query

(&self)

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

↓ 26 callersFunctionstale_ring_version_response

( expected_ring_version: u64, received_ring_version: u64, detail: Option<String>, )

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

↓ 26 callersMethodwith_object_store_path

(mut self, path: impl AsRef<Path>)

src/storage.rs:1080

↓ 26 callersMethodwith_tiered_retention_policy

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

src/storage.rs:1111

↓ 25 callersMethodappend_samples

(&self, batches: &[SamplesBatchFrame])

src/engine/wal/logical.rs:337

↓ 25 callersMethodapply_loaded_segment_indexes

( &self, loaded: LoadedSegmentIndexes, reconcile_registry_with_persisted: bool, )

src/engine/lifecycle/persisted_state.rs:93

↓ 25 callersMethodopen

(dir: impl AsRef<Path>, sync_mode: WalSyncMode)

src/engine/wal/segments.rs:58

↓ 25 callersMethodselect

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

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

↓ 25 callersFunctionunix_timestamp_millis

()

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

↓ 25 callersFunctionwrite_numeric_segment

( lane_path: &std::path::Path, registry: &SeriesRegistry, series_id: u64, level: u8, segme

src/engine/tests/retention_policy.rs:2088

↓ 24 callersFunctionexpect_arg_count

(call: &CallExpr, expected: usize)

src/promql/eval/functions.rs:1599

↓ 24 callersFunctionmake_exemplar_store

(data_path: Option<&Path>)

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

↓ 24 callersMethodmetric

(&self)

src/lib.rs:108

↓ 24 callersMethodpersist

(&self, state: &ControlState)

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

↓ 24 callersFunctionread_u8

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

src/engine/binio.rs:31

↓ 24 callersMethodshard_count

(&self)

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

↓ 24 callersFunctionstable_fnv1a64_update

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

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

↓ 24 callersMethodtimestamp_units_per_second

(&self)

src/promql/eval/mod.rs:216

↓ 24 callersMethodwith_builder

(&self, f: F)

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

↓ 24 callersMethodwith_partition_duration

(mut self, duration: Duration)

src/async.rs:556

↓ 23 callersMethodas_slice

(&self)

src/mmap.rs:92

↓ 23 callersFunctioneval_unary_map

( engine: &Engine, call: &CallExpr, params: &QueryParams<'_>, map: impl Fn(f64) -> f64, )

src/promql/eval/functions.rs:1191

↓ 23 callersMethodrun_once

(&self, storage: Arc<dyn Storage>)

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

↓ 23 callersFunctionsnappy_encode

(data: &[u8])

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

↓ 22 callersMethodcmp

(&self, other: &Self)

src/engine/compactor/execution.rs:627

↓ 22 callersMethodinsert

( &mut self, label_name: impl Into<String>, label_value: impl Into<String>, se

src/engine/index.rs:79

↓ 22 callersFunctionlex

(input: &str)

tests/promql_parser_lexer_extended_test.rs:7

↓ 22 callersMethodpolicy

(&self)

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

↓ 22 callersFunctionsetup_storage

()

tests/promql_integration_test.rs:10

↓ 22 callersMethodshard_for_series_id

(&self, series_id: u64)

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

↓ 22 callersMethodwith_aggregation

(mut self, aggregation: Aggregation)

src/storage.rs:1568

↓ 22 callersMethodwith_metadata_shard_count

(&self, shard_count: u32)

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

↓ 21 callersMethodapply_rollup_policies

( &self, policies: Vec<crate::storage::RollupPolicy>, )

src/engine/engine.rs:475

↓ 21 callersMethodas_str

(self)

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

↓ 21 callersFunctioncluster_context_with_control

(temp_dir: &TempDir)

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

↓ 21 callersFunctionelapsed_nanos_u64

(started: Instant)

src/engine/core_impl/utilities.rs:61

↓ 21 callersMethodensure_open

(&self)

src/engine/core_impl/utilities.rs:145

↓ 21 callersMethodis_empty

(&self)

src/engine/lifecycle/flush.rs:31

↓ 21 callersFunctionread_i64

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

src/engine/binio.rs:109

↓ 21 callersFunctionremove_path_if_exists_and_sync_parent

(path: &Path)

src/engine/fs_utils.rs:185

↓ 20 callersMethodactive_shard

( self, series_id: SeriesId, )

src/engine/shard_routing.rs:37

↓ 20 callersMethodadmit_with_usage

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

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

↓ 20 callersMethodapply_shard_handoff_progress

( &mut self, shard: u32, phase: ShardHandoffPhase, copied_rows: Option<u64>,

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

↓ 20 callersMethodflush_pipeline_once

(&self)

src/engine/runtime.rs:463

↓ 20 callersMethodis_empty

(&self)

src/engine/construction/resources.rs:32

↓ 20 callersFunctionopen_runtime_for_node

( temp_dir: &TempDir, node_id: &str, bind: &str, seeds: &[&str], state

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

↓ 20 callersFunctionparse_server_args

(args: I)

crates/tsink-server/src/main.rs:505

↓ 20 callersMethodrecord_rejected

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

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

↓ 20 callersFunctiontempdir

()

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

↓ 19 callersFunctionappend_u8

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

src/engine/binio.rs:11

↓ 19 callersMethodclose

Close the storage. Additional operations return `StorageClosed`.

src/async.rs:413

↓ 19 callersMethodclose

(&self)

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

↓ 19 callersFunctionelapsed_nanos_since

(started: Instant)

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

↓ 19 callersFunctionresponse_body

(response: &[u8])

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

↓ 19 callersMethodselect

( &self, endpoint: &str, request: &InternalSelectRequest, )

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

↓ 19 callersMethodsnapshot

(&self)

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

↓ 19 callersMethodwith_current_time_override_for_tests

(mut self, timestamp: i64)

src/storage.rs:1267

↓ 19 callersMethodwith_labels

( metric: impl Into<String>, labels: Vec<Label>, data_point: DataPoint, )

src/lib.rs:96

↓ 18 callersFunctionadmin_control_recovery_error_response

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

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

↓ 18 callersMethodappend

(&self, input: ClusterAuditEntryInput)

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

↓ 18 callersFunctionbuild_test_storage

(shard_count: u32)

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

↓ 18 callersFunctionclear_commit_hook

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

src/engine/test_hooks/mod.rs:62

↓ 18 callersFunctionread_required_segment_file

(segment_root: &Path, path: &Path)

src/engine/segment/loader.rs:589

↓ 18 callersFunctionsend_request_with_runtime

( storage: Arc<dyn Storage>, config: &ServerConfig, tenant_registry: Option<Arc<tenant

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

↓ 18 callersFunctionset_commit_hook

(slot: &RwLock<Option<Arc<IngestCommitHook>>>, hook: F)

src/engine/test_hooks/mod.rs:55

↓ 18 callersMethodwith_data_path

(&self, path: String)

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

↓ 17 callersMethodapply_begin_shard_handoff

( &mut self, shard: u32, from_node_id: &str, to_node_id: &str, activat

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

↓ 17 callersFunctionbuild_digest_runtime_for_test

( temp_dir: &std::path::Path, peer_endpoint: &str, config: DigestExchangeConfig,

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

↓ 17 callersMethoddata_point

(&self)

src/lib.rs:116

↓ 17 callersMethodis_empty

(&self)

src/engine/series/identity.rs:531

↓ 17 callersMethodquery

(&self, query: &ClusterAuditQuery)

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

↓ 17 callersMethodregister_series_with_id

( &self, series_id: SeriesId, metric: &str, labels: &[Label], )

src/engine/series/identity.rs:432

↓ 17 callersFunctionresolve_admin_path

( requested_path: &Path, admin_path_prefix: Option<&Path>, must_exist: bool, )

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

↓ 17 callersMethodto_http_response

(&self)

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

↓ 17 callersMethodwith_digest_probe

(mut self, digest_probe: Arc<DigestProbeFn>)

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

↓ 16 callersFunctionauthorize_internal_cluster_request

( request: &HttpRequest, internal_api: Option<&InternalApiConfig>, cluster_context: Option<&Cluste

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

↓ 16 callersFunctioncurrent_control_state

( cluster_context: Option<&ClusterRequestContext>, )

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

↓ 16 callersFunctionhandle_request_with_admin

( storage: &Arc<dyn Storage>, engine: &Engine, request: HttpRequest, server_start: Instant,

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

↓ 16 callersFunctionlane_name

(lane: SegmentLaneFamily)

src/engine/tiering/layout.rs:185

↓ 16 callersFunctionpath_exists_no_follow

(path: &Path)

src/engine/fs_utils.rs:90

↓ 16 callersFunctionread_http_request

( stream: &mut R, buffer: &mut Vec<u8>, )

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

← previous next →101–200 of 5,563, ranked by callers