Functions — github.com/bitdriftlabs/pulse

hub / github.com/bitdriftlabs/pulse / functions

Functions2,474 in github.com/bitdriftlabs/pulse

⨍ Functions 2,474◇ Types & classes 540

↓ 4 callersMethodmax

Get the maximum sample value.

pulse-metrics/src/pipeline/processor/aggregation/cm_quantile.rs:392

↓ 4 callersMethodname

(&self)

pulse-metrics/src/pipeline/metric_cache.rs:256

↓ 4 callersMethodname_terms

(&mut self, terms: usize)

pulse-metrics/src/metric_generator.rs:104

↓ 4 callersMethodnext_batch_set

Get the next set of batches. Returns None when the builder has been shutdown and there is no more data.

pulse-metrics/src/batch.rs:360

↓ 4 callersMethodpartial_cmp

(&self, other: &Self)

pulse-metrics/src/pipeline/processor/aggregation/cm_quantile.rs:62

↓ 4 callersMethodproduce_value

( &mut self, previous_aggregation: Option<&Self>, metric_id: &MetricId, config: &AggregationCo

pulse-metrics/src/pipeline/processor/aggregation/counter.rs:151

↓ 4 callersMethodquantile_timers

(&self)

pulse-protobuf/src/protos/pulse/config/processor/v1/aggregation.rs:76

↓ 4 callersMethodrecv_samples

(&self, samples: Vec<ParsedMetric>)

pulse-metrics/src/pipeline/outflow/wire.rs:104

↓ 4 callersMethodregister_handler

( &self, path: &str, handler: AdminHandler, )

pulse-metrics/src/admin/test.rs:44

↓ 4 callersMethodresolve_tcp

(&self, _name: &str)

pulse-proxy/src/config_test.rs:27

↓ 4 callersMethodsend_from_inflow

(&self, name: &str, index: usize, samples: Vec<ParsedMetric>)

pulse-metrics/src/pipeline/mod_test.rs:188

↓ 4 callersMethodstart

(&self)

pulse-metrics/src/pipeline/mod.rs:686

↓ 4 callersFunctionstart_multi_node

()

pulse-proxy/src/test/integration/multi_node.rs:68

↓ 4 callersMethodtag

(&self, tag_name: &str)

pulse-metrics/src/protos/metric.rs:173

↓ 4 callersMethodtarget_server

(mut self)

pulse-metrics/src/pipeline/inflow/prom_scrape/scraper_test.rs:931

↓ 4 callersMethodupdate

(&self, config_yaml: &str)

pulse-metrics/src/pipeline/mod_test.rs:83

↓ 4 callersMethodupdate_config

(&mut self, new_contents: &str)

pulse-metrics/src/test/mod.rs:391

↓ 4 callersFunctionwait_for_gauge

(helper: &Helper, expected: i64, name: &str, timeout_secs: u64, msg: &str)

pulse-proxy/src/test/integration/multi_node.rs:400

↓ 3 callersMethodadd_failure_response_code

(&self, status_code: StatusCode)

pulse-proxy/src/test/integration/mod.rs:425

↓ 3 callersMethodbroadcast

(&self)

pulse-common/src/k8s/pods_info.rs:623

↓ 3 callersFunctioncheck_route

(config: &PipelineConfig, route: &Chars)

pulse-metrics/src/pipeline/config.rs:106

↓ 3 callersFunctioncheck_send_to

(config: &CommonWireClientConfig)

pulse-metrics/src/pipeline/outflow/mod.rs:130

↓ 3 callersMethoddrain

(&mut self)

pulse-metrics/src/reservoir_timer.rs:54

↓ 3 callersMethodemit_up_metric

(mut self)

pulse-metrics/src/pipeline/inflow/prom_scrape/scraper_test.rs:946

↓ 3 callersFunctionescaped_string

Return a parser which: Captures an escaped string, single (or double) quoted, with any character including an escaped \' (or \"), until the final ' (o

pulse-metrics/src/protos/carbon.rs:31

↓ 3 callersMethodexpect_send_and_receive_with_downstream_id

( &mut self, send: ParsedMetric, receive: Vec<ParsedMetric>, expected_downstream_ids: Vec<Down

pulse-metrics/src/pipeline/processor/mutate/mod_test.rs:76

↓ 3 callersMethodexpected_metric

( &self, name: &'static str, value: MetricValue, metric_type: MetricType, )

pulse-metrics/src/pipeline/processor/aggregation/test/mod.rs:271

↓ 3 callersFunctionfile_descriptor

`FileDescriptor` object which allows dynamic access to files

pulse-protobuf/src/protos/pulse/drop_tester/v1/drop_tester.rs:618

↓ 3 callersFunctionfile_descriptor

`FileDescriptor` object which allows dynamic access to files

pulse-protobuf/src/protos/pulse/config/processor/v1/cardinality_limiter.rs:724

↓ 3 callersFunctionfile_descriptor

`FileDescriptor` object which allows dynamic access to files

pulse-protobuf/src/protos/pulse/config/common/v1/file_watcher.rs:662

↓ 3 callersFunctionfile_descriptor

`FileDescriptor` object which allows dynamic access to files

pulse-protobuf/src/protos/opentelemetry/metrics_service.rs:447

↓ 3 callersFunctionfinal_kv_merge

( resource_attributes: Option<&HashMap<Bytes, Bytes>>, scope_attributes: Option<&HashMap<Bytes, Bytes>>,

pulse-metrics/src/pipeline/inflow/otlp/mod.rs:118

↓ 3 callersMethodfind_tag_inner

(&mut self, tag_name: &[u8], undelete: bool)

pulse-metrics/src/protos/metric.rs:707

↓ 3 callersFunctiongenerate_samples

(n: usize)

pulse-metrics/src/pipeline/outflow/http/remote_write_test.rs:71

↓ 3 callersMethodget_or_init

( &self, handle: &SingletonHandle, init_func: impl Future<Output = Result<Arc<T>, E>> + Send, )

pulse-common/src/singleton.rs:36

↓ 3 callersMethodinsert

Incrementally processes inserts by moving data from the buffer to the samples using a cursor.

pulse-metrics/src/pipeline/processor/aggregation/cm_quantile.rs:181

↓ 3 callersFunctionkv_to_iterator

(metadata: Vec<KeyValue>)

pulse-metrics/src/pipeline/inflow/otlp/mod.rs:99

↓ 3 callersFunctionmake_emit_interval

(seconds: u64)

pulse-metrics/src/pipeline/processor/elision/state_test.rs:29

↓ 3 callersFunctionmake_emit_ratio

(ratio: f64)

pulse-metrics/src/pipeline/processor/elision/state_test.rs:22

↓ 3 callersFunctionmake_error_response

(status: StatusCode, message: String)

pulse-metrics/src/pipeline/inflow/http_inflow.rs:207

↓ 3 callersFunctionmake_family_name

Given an internal metric, create the prom metric family name.

pulse-metrics/src/protos/prom.rs:880

↓ 3 callersFunctionmake_fst_filter

( metrics: &[&[u8]], match_decision: MetricFilterDecision, prom: bool, name: String, )

pulse-metrics/src/filters/fst_test.rs:37

↓ 3 callersMethodmake_metric_ex

( &self, name: &str, metric_type: Option<MetricType>, sample_rate: Option<f64>, value: Met

pulse-metrics/src/pipeline/processor/aggregation/test/mod.rs:215

↓ 3 callersFunctionmake_name

(prefix: &str, name: &Bytes, postfix: &str)

pulse-metrics/src/pipeline/processor/aggregation/mod.rs:594

↓ 3 callersFunctionmake_reuse_port_udp_socket

(name: &str)

pulse-common/src/bind_resolver.rs:63

↓ 3 callersMethodmessages_e2e_timer_observe

(&self, received_at: &[Instant])

pulse-metrics/src/pipeline/outflow/mod.rs:77

↓ 3 callersMethodmetadata

(&self)

pulse-metrics/src/pipeline/inflow/prom_scrape/scraper.rs:377

↓ 3 callersMethodnamespace_and_name

(&self)

pulse-common/src/k8s/pods_info.rs:449

↓ 3 callersMethodnode_info

(&self)

pulse-common/src/k8s/pods_info.rs:74

↓ 3 callersFunctionon_send_error

( stats: &WireOutflowStats, bytes: u64, samples: u64, received_at: &[Instant], shutdown: ComponentSh

pulse-metrics/src/pipeline/outflow/wire.rs:284

↓ 3 callersFunctionparse_lines

( lines: Vec<bytes::Bytes>, wire_protocol: &WireProtocol, received_at: Instant, downstream_id: &Downst

pulse-metrics/src/pipeline/inflow/wire/util.rs:130

↓ 3 callersMethodpods

(&self)

pulse-common/src/k8s/pods_info.rs:233

↓ 3 callersMethodrecv_samples

(&self, samples: Vec<ParsedMetric>)

pulse-metrics/src/pipeline/outflow/http/remote_write.rs:498

↓ 3 callersMethodreset

(&mut self)

pulse-metrics/src/pipeline/inflow/wire/util.rs:196

↓ 3 callersMethodretry_attempts

(&self)

pulse-metrics/src/pipeline/outflow/http/retry_offload.rs:94

↓ 3 callersMethodrun

(mut self, mut socket: T, mut shutdown: ComponentShutdown)

pulse-metrics/src/pipeline/inflow/wire/util.rs:297

↓ 3 callersFunctionsetup_test

( client: MockHttpRemoteWriteClient, )

pulse-metrics/src/pipeline/outflow/http/remote_write_test.rs:29

↓ 3 callersFunctionshould_retry

(e: &HttpRemoteWriteError)

pulse-metrics/src/clients/http.rs:330

↓ 3 callersMethodstatsd_output

(&self)

pulse-metrics/src/admin/stats.rs:69

↓ 3 callersMethodsync_point

This is the only API that should generally be called from production code. It introduces a "sync point" that test code can then use to force blocking,

pulse-metrics/src/test/thread_synchronizer.rs:48

↓ 3 callersFunctiontags_to_key_value

(metric: &ParsedMetric, convert_names_to_prom: bool)

pulse-metrics/src/pipeline/outflow/otlp/mod.rs:100

↓ 3 callersMethodtake_udp_addr

Note that this removes the socket so that it can be closed. For UDP with reuse port the kernel can distribute packets to this socket so for tests we w

pulse-proxy/src/test/integration/mod.rs:187

↓ 3 callersMethodto_datetime

(&self)

pulse-metrics/src/protos/metric.rs:436

↓ 3 callersMethodtry_evict_lru

Iterate LRU entries in each shard, attempting to evict them using an eviction function. Iteration stops when the eviction function returns false under

pulse-metrics/src/lru_map.rs:360

↓ 3 callersFunctionunwrap_prom_timestamp

Normalize an incoming Prom timestamp.

pulse-metrics/src/protos/prom.rs:869

↓ 3 callersMethodupdate_and_decide

( &self, metric: &ParsedMetric, metric_filters: &[DynamicMetricFilter], skip_decider: &SkipDec

pulse-metrics/src/pipeline/processor/elision/state.rs:252

↓ 3 callersFunctionupdate_metadata_map

( metadata_map: &mut HashMap<Chars, PromMetricType>, family_name: &Chars, metric: &ParsedMetric, chang

pulse-metrics/src/protos/prom.rs:1097

↓ 3 callersMethodvalue

(&self)

pulse-protobuf/src/protos/opentelemetry/metrics.rs:3535

↓ 3 callersFunctionwrite_carbon_tag

(line: &mut bytes::BytesMut, tag: &TagValue)

pulse-metrics/src/protos/carbon.rs:138

↓ 2 callersMethodadjust_lru

Given a key in the map, move it to most recently used.

pulse-metrics/src/lru_map.rs:92

↓ 2 callersFunctionadvance_metrics

(metrics: &[ParsedMetric], value: f64)

pulse-promloadgen/src/main.rs:24

↓ 2 callersFunctionall

()

pulse-proxy/src/test/integration/complex_config.rs:380

↓ 2 callersMethodbuffer

(&mut self, metrics: Vec<ParsedMetric>)

pulse-metrics/src/pipeline/inflow/wire/pre_buffer.rs:57

↓ 2 callersFunctionbuild_stats_provider

(config: &Config)

pulse-proxy/src/lib.rs:70

↓ 2 callersFunctioncardinality_to_gauge_value

(count: f64)

pulse-metrics/src/pipeline/processor/cardinality_tracker/mod.rs:114

↓ 2 callersMethodchange_mtype

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

pulse-metrics/src/protos/metric.rs:741

↓ 2 callersMethodchange_name

(&mut self, name: Bytes)

pulse-metrics/src/protos/metric.rs:736

↓ 2 callersFunctioncheck_routes

TODO(mattklein123): Check for cycles.

pulse-metrics/src/pipeline/config.rs:123

↓ 2 callersMethodcompress

Incrementally processes compression by using a cursor/

pulse-metrics/src/pipeline/processor/aggregation/cm_quantile.rs:264

↓ 2 callersMethodcount

(&self)

pulse-metrics/src/pipeline/processor/aggregation/timer.rs:76

↓ 2 callersMethodcreate_dir_and_file

(&self, file_contents: &str)

pulse-metrics/src/test/mod.rs:353

↓ 2 callersMethodcursor_increment

Computes the number of items to process in one iteration.

pulse-metrics/src/pipeline/processor/aggregation/cm_quantile.rs:257

↓ 2 callersFunctiondecode_otlp_request

( headers: &HeaderMap, body: Bytes, )

pulse-metrics/src/pipeline/inflow/otlp/mod.rs:423

↓ 2 callersFunctiondefault_max_in_flight

()

pulse-metrics/src/pipeline/config.rs:101

↓ 2 callersFunctiondefault_n_tasks

()

pulse-metrics/src/pipeline/inflow/metric_generator/mod.rs:21

↓ 2 callersMethoddetermine_shard

Fetch a shard.

pulse-metrics/src/lru_map.rs:204

↓ 2 callersFunctiondo_fetch

(config: &HttpServiceDiscovery)

pulse-metrics/src/pipeline/inflow/prom_scrape/http_sd.rs:25

↓ 2 callersMethoddrop_sample

(&self, sample: &ParsedMetric)

pulse-metrics/src/pipeline/processor/drop/mod.rs:151

↓ 2 callersMethodemit_absolute_counters_as_delta_rate

(mut self)

pulse-metrics/src/pipeline/processor/aggregation/test/mod.rs:90

↓ 2 callersMethodeq

(&self, other: &Self)

pulse-metrics/src/lru_map.rs:45

↓ 2 callersFunctionextract_from_config

( field_name: &str, proxy_config: Option<&Config>, processor_name: &str, extract: impl Fn(&Pro

pulse-vrl-tester/src/lib.rs:49

↓ 2 callersFunctionfile_descriptor

`FileDescriptor` object which allows dynamic access to files

pulse-protobuf/src/protos/pulse/config/inflow/v1/prom_remote_write.rs:398

↓ 2 callersFunctionfile_descriptor

`FileDescriptor` object which allows dynamic access to files

pulse-protobuf/src/protos/pulse/config/outflow/v1/otlp.rs:442

↓ 2 callersFunctionfile_descriptor

`FileDescriptor` object which allows dynamic access to files

pulse-protobuf/src/protos/pulse/config/outflow/v1/prom_remote_write.rs:603

↓ 2 callersMethodfilter_aggregated_metrics

( &self, input: Vec<Option<ParsedMetric>>, parsed_metrics: &mut Vec<ParsedMetric>, last_aggreg

pulse-metrics/src/pipeline/processor/aggregation/mod.rs:495

↓ 2 callersMethodfinish

(&mut self)

pulse-metrics/src/pipeline/outflow/wire.rs:195

↓ 2 callersFunctionfinish_otlp_batch

( samples: Vec<ParsedMetric>, compression: OtlpCompression, convert_names_to_prom: bool, )

pulse-metrics/src/pipeline/outflow/otlp/mod.rs:260

↓ 2 callersMethodget_file

(&self, etag: Option<String>)

pulse-metrics/src/file_watcher/remote.rs:297

↓ 2 callersFunctionget_file_watcher

( source: FileSourceConfig, shutdown: ComponentShutdown, )

pulse-metrics/src/file_watcher/mod.rs:58

↓ 2 callersMethodhas_annotation_matcher

(&self)

pulse-protobuf/src/protos/pulse/config/inflow/v1/k8s_prom.rs:627

← previous next →201–300 of 2,474, ranked by callers