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

↓ 1,953 callersMethodclone

(&self)

src/engine/chunk.rs:66

↓ 1,929 callersMethodexpect

(&mut self, expect: TokenExpect)

src/promql/parser.rs:554

↓ 772 callersMethodpath

(&self)

src/engine/wal/segments.rs:160

↓ 539 callersMethodas_ref

(&self)

src/engine/chunk.rs:80

↓ 513 callersMethodlen

(&self)

src/mmap.rs:99

↓ 424 callersMethodlen

(&self)

src/engine/series/dictionary.rs:37

↓ 373 callersMethodget

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

src/engine/index.rs:95

↓ 360 callersMethodpush

(&mut self, point: DataPoint)

src/engine/query_read/pagination.rs:68

↓ 341 callersMethodinsert_rows

(self, rows: &[Row])

src/engine/rollups/materialization.rs:160

↓ 326 callersMethodis_empty

(&self)

src/mmap.rs:106

↓ 297 callersMethodpush

(&mut self, task: JoinHandle<()>)

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

↓ 237 callersMethodinsert

(&mut self, series: MetricSeries)

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

↓ 236 callersMethodclose

(&self)

src/engine/engine.rs:598

↓ 232 callersMethodwith_data_path

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

src/async.rs:514

↓ 198 callersMethodload

(series_index_path: Option<&Path>)

src/engine/bootstrap/discovery.rs:55

↓ 183 callersMethodwith_timestamp_precision

(mut self, precision: TimestampPrecision)

src/async.rs:532

↓ 181 callersMethodinsert

(&mut self, candidate: SegmentInventoryEntry)

src/engine/tiering/inventory.rs:138

↓ 168 callersFunctionstart_time

()

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

↓ 162 callersFunctiontext_response

(status: u16, text: &str)

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

↓ 160 callersMethodpath

(&self)

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

↓ 152 callersMethodbuild

( chunk_point_cap: usize, numeric_lane_path: Option<PathBuf>, blob_lane_path: Option<P

src/engine/construction/assembly.rs:18

↓ 144 callersMethodload

(&self)

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

↓ 143 callersMethodbuild

(self)

src/async.rs:623

↓ 140 callersMethodany

(&self)

src/engine/maintenance/post_flush/context.rs:48

↓ 138 callersFunctionmake_engine

(storage: &Arc<dyn Storage>)

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

↓ 132 callersFunctionmake_storage

()

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

↓ 125 callersMethodis_empty

(&self)

src/engine/state/active.rs:230

↓ 120 callersMethodresolve_or_insert

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

src/engine/series/identity.rs:262

↓ 110 callersMethodinsert_rows

(&self, rows: &[Row])

tests/async_storage_test.rs:338

↓ 107 callersMethodinstant_query

(&self, query_str: &str, time: i64)

src/promql/eval/mod.rs:76

↓ 107 callersMethodwith_matcher

(mut self, matcher: SeriesMatcher)

src/storage.rs:121

↓ 100 callersMethodwith_header

(mut self, name: impl Into<String>, value: impl Into<String>)

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

↓ 95 callersFunctionas_instant_vector

(value: PromqlValue)

tests/promql_integration_test.rs:598

↓ 95 callersFunctioninternal_error_response

( status: u16, code: impl Into<String>, message: impl Into<String>, retryable: bool, )

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

↓ 94 callersMethodwith_metric

(mut self, metric: &str, series_ids: &[SeriesId])

src/engine/query_exec/candidate_planner.rs:159

↓ 93 callersMethodcmp

(&self, other: &Self)

src/label.rs:36

↓ 93 callersMethodparam

Get a parameter from query string or form body (for GET/POST PromQL endpoints).

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

↓ 91 callersFunctionjson_response

(status: u16, value: &impl serde::Serialize)

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

↓ 80 callersMethodwith_wal_enabled

(mut self, enabled: bool)

src/async.rs:582

↓ 78 callersMethodobservability_snapshot

(&self)

src/engine/engine.rs:471

↓ 75 callersMethodas_str

(self)

crates/tsink-server/src/cluster/planner.rs:19

↓ 75 callersMethodis_empty

(&self)

src/engine/chunk.rs:257

↓ 74 callersMethodwith_chunk_points

(mut self, points: usize)

src/async.rs:538

↓ 73 callersMethodkind

(&self)

src/value.rs:162

↓ 72 callersMethodresolve_existing

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

src/engine/series/identity.rs:315

↓ 71 callersFunctionbuilder_at_time

(now: i64)

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

↓ 70 callersFunctionhandle_request_with_admin_and_cluster

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

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

↓ 66 callersMethodextend

( &mut self, series: impl IntoIterator<Item = MetricSeries>, )

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

↓ 63 callersMethodselect

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

src/engine/engine.rs:339

↓ 63 callersMethodselect

( &self, _metric: &str, _labels: &[Label], _start: i64, _end: i64,

tests/async_storage_test.rs:353

↓ 62 callersMethodas_bytes

(&self)

src/value.rs:206

↓ 61 callersMethodcurrent_state

(&self)

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

↓ 59 callersMethodnext

(&mut self)

src/engine/query.rs:102

↓ 59 callersMethodselect_series

(&self, selection: &SeriesSelection)

src/engine/engine.rs:397

↓ 59 callersMethodwrite_segment

( &self, registry: &SeriesRegistry, chunks_by_series: &HashMap<SeriesId, Vec<T>>,

src/engine/segment/writer.rs:47

↓ 58 callersFunctionpromql_error_response

(error_type: &str, error: &str)

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

↓ 57 callersMethodeval

(&self, expr: &Expr, params: &QueryParams<'_>)

src/promql/eval/mod.rs:183

↓ 53 callersMethodwith_retention

(mut self, retention: Duration)

src/async.rs:520

↓ 51 callersMethodas_str

(self)

src/wal.rs:25

↓ 49 callersFunctiondefault_future_skew_window

( precision: TimestampPrecision, )

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

↓ 49 callersFunctionparse

(input: &str)

src/promql/mod.rs:12

↓ 49 callersFunctionsaturating_u64_from_usize

(value: usize)

src/engine/core_impl/utilities.rs:57

↓ 48 callersFunctionread_u32

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

src/engine/binio.rs:51

↓ 47 callersMethodbuild

( shard_count: u32, replication_factor: u16, membership: &MembershipView, )

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

↓ 47 callersFunctionbuild_http_request

( method: &str, path: &str, headers: &[(&str, &str)], body: &[u8], )

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

↓ 46 callersMethodappend_series_definition

(&self, definition: &SeriesDefinitionFrame)

src/engine/wal/logical.rs:332

↓ 45 callersMethodflush_all_active

(&self)

src/engine/write_buffer.rs:85

↓ 45 callersFunctionnon_empty_param

(value: Option<String>)

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

↓ 45 callersMethodwith_timestamp_precision

(&self, precision: UTimestampPrecision)

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

↓ 43 callersMethodinto_inner

(self)

src/async.rs:206

↓ 43 callersMethodsum

(iter: I)

src/value.rs:359

↓ 41 callersMethodclose

(&self)

tests/async_storage_test.rs:380

↓ 40 callersMethodas_str

(self)

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

↓ 40 callersMethodencode

(points: &[DataPoint])

src/engine/encoder.rs:189

↓ 40 callersMethodinsert_rows

(&self, rows: &[Row])

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

↓ 39 callersMethodcapacity

(&self)

src/engine/chunk.rs:169

↓ 39 callersMethoddelete_series

(&self, selection: &SeriesSelection)

src/engine/engine.rs:455

↓ 39 callersFunctionemit_mutating_admin_audit_entry

( cluster_context: Option<&ClusterRequestContext>, request: &HttpRequest, operation: &str, res

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

↓ 38 callersFunctionadmin_cluster_snapshot_error_response

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

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

↓ 38 callersMethodadvance

(&mut self)

src/promql/parser.rs:545

↓ 38 callersFunctionload_segments_for_level

(base: impl AsRef<Path>, level: u8)

src/engine/segment/loader.rs:341

↓ 38 callersFunctionsend_request_with_config

( storage: Arc<dyn Storage>, config: &ServerConfig, raw_request: &[u8], )

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

↓ 38 callersMethodwith_time_range

(mut self, start: i64, end: i64)

src/storage.rs:133

↓ 37 callersFunctionappend_u32

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

src/engine/binio.rs:19

↓ 37 callersMethodflush

(&self)

src/engine/core_impl.rs:50

↓ 37 callersMethodselect_with_options

(&self, _metric: &str, _opts: QueryOptions)

tests/async_storage_test.rs:363

↓ 36 callersFunctionprometheus_escape_label_value

(value: &str)

crates/tsink-server/src/handlers/metrics/mod.rs:1706

↓ 36 callersMethodselect_series

(&self, selection: SeriesSelection)

src/async.rs:353

↓ 35 callersFunctioninternal_api

()

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

↓ 34 callersFunctionhandle_request

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

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

↓ 34 callersFunctionstable_fnv1a64_update

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

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

↓ 34 callersFunctionstable_series_identity_hash

(metric: &str, labels: &[Label])

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

↓ 33 callersMethodwith_metric

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

src/storage.rs:115

↓ 32 callersFunctionread_u64

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

src/engine/binio.rs:57

↓ 31 callersFunctiondispatch_internal_request

( storage: &Arc<dyn Storage>, engine: &Engine, internal_api: &InternalApiConfig,

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

↓ 31 callersMethodlabels

(&self)

src/lib.rs:112

↓ 31 callersFunctionload_segment_indexes

(base: impl AsRef<Path>)

src/engine/segment/loader.rs:168

↓ 31 callersFunctionread_bytes

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

src/engine/binio.rs:121

↓ 30 callersMethodappend

(&mut self, ts: i64, value: Value)

src/engine/chunk.rs:337

↓ 30 callersMethodheader

(&self, name: &str)

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

next →1–100 of 5,563, ranked by callers