MCPcopy Create free account

hub / github.com/bitdriftlabs/pulse / functions

Functions2,474 in github.com/bitdriftlabs/pulse

⨍ Functions 2,474◇ Types & classes 540
↓ 2,129 callersFunctionnew
(connect_to: ConnectTo, write_timeout: Option<Duration>)
pulse-metrics/src/clients/client_pool.rs:23
↓ 878 callersMethodpush
( &mut self, items: impl Iterator<Item = (&'static str, Option<TestBatchResult>)>, )
pulse-metrics/src/batch_test.rs:45
↓ 839 callersMethodclone
(&self)
pulse-metrics/src/vrl/pulse_log.rs:132
↓ 329 callersMethodget
Fetch a map value under read lock.
pulse-metrics/src/lru_map.rs:218
↓ 174 callersMethodis_empty
See if the map is empty.
pulse-metrics/src/lru_map.rs:319
↓ 144 callersMethodlen
Get the length of the map.
pulse-metrics/src/lru_map.rs:304
↓ 128 callersMethodmetric
(&self)
pulse-metrics/src/protos/metric.rs:764
↓ 100 callersMethodpush
(&mut self, samples: impl Iterator<Item = ParsedMetric>)
pulse-metrics/src/pipeline/outflow/wire.rs:181
↓ 87 callersMethodget_id
(&self)
pulse-metrics/src/protos/metric.rs:428
↓ 71 callersMethodrecv
(&self, metrics: Vec<ParsedMetric>)
pulse-metrics/src/pipeline/processor/aggregation/test/mod.rs:316
↓ 57 callersMethodinsert
(&self, key: Bytes, metric: &MetricId)
pulse-metrics/src/pipeline/processor/cardinality_tracker/mod.rs:251
↓ 56 callersMethodexpect_dispatch
(&mut self, expected: Vec<ParsedMetric>)
pulse-metrics/src/pipeline/processor/aggregation/test/mod.rs:307
↓ 49 callersMethodshutdown
(mut self)
pulse-proxy/src/test/integration/mod.rs:285
↓ 48 callersMethodbuild
(self)
pulse-metrics/src/pipeline/processor/aggregation/test/mod.rs:110
↓ 44 callersMethodsend
(&self, samples: Vec<ParsedMetric>)
pulse-metrics/src/pipeline/outflow/prom/mod.rs:241
↓ 42 callersMethodsend
Send an item through the batch builder. This may result in old data getting dropped if the total data in the queue and the pending batch is too large.
pulse-metrics/src/batch.rs:204
↓ 40 callersFunctionparse
(input: &bytes::Bytes)
pulse-metrics/src/protos/carbon.rs:133
↓ 36 callersMethodlocal_tcp_addr
(&self, name: &str)
pulse-proxy/src/test/integration/mod.rs:173
↓ 36 callersFunctionmake_node_info
()
pulse-common/src/k8s/test/mod.rs:31
↓ 35 callersMethodtags
(&self)
pulse-metrics/src/protos/metric.rs:169
↓ 34 callersMethodlossy_to_f64
(self)
pulse-common/src/lib.rs:54
↓ 31 callersFunctionmake_pod_info
( namespace: &str, name: &str, labels: &BTreeMap<String, String>, annotations: BTreeMap<String, String
pulse-common/src/k8s/test/mod.rs:43
↓ 30 callersMethodget
(&mut self)
pulse-metrics/src/pipeline/inflow/prom_scrape/scraper.rs:923
↓ 28 callersMethodpath
(&self)
pulse-metrics/src/test/mod.rs:387
↓ 26 callersMethodname
(&self)
pulse-metrics/src/protos/metric.rs:165
↓ 26 callersMethodname
(&self)
pulse-metrics/src/pipeline/inflow/prom_scrape/scraper.rs:79
↓ 25 callersFunctionwrite_all
(stream: &mut TcpStream, lines: &[&str])
pulse-proxy/src/test/integration/mod.rs:94
↓ 24 callersMethodinsert
(&mut self, pod_info: PodInfo, insert_by_ip: bool)
pulse-common/src/k8s/pods_info.rs:180
↓ 24 callersFunctionmake_remote_write_error
(family_name: &[u8], message: &str)
pulse-metrics/src/protos/prom.rs:188
↓ 22 callersMethodsend
(&self, metrics: Vec<ParsedMetric>)
pulse-proxy/src/test/integration/mod.rs:590
↓ 21 callersMethodcollector
(&self)
pulse-metrics/src/admin/stats.rs:82
↓ 21 callersFunctionprocessor_factory_context_for_test
()
pulse-metrics/src/test/mod.rs:298
↓ 21 callersMethodunwrap_duration_or
(&self, default: Duration)
pulse-common/src/proto.rs:68
↓ 20 callersFunctioncomplete
(size: usize)
pulse-metrics/src/batch_test.rs:29
↓ 19 callersFunctioncreate_endpoints
( namespace: &str, ip: &str, inclusion_filters: &[InclusionFilter], use_k8s_https_service_auth_matcher
pulse-metrics/src/pipeline/inflow/prom_scrape/scraper.rs:196
↓ 19 callersMethodentry
(&self, name: &str)
pulse-metrics/src/test/thread_synchronizer.rs:35
↓ 19 callersFunctionmake_abs_counter
( name: &str, tags: &[(&str, &str)], timestamp: u64, value: f64, )
pulse-metrics/src/test/mod.rs:134
↓ 19 callersMethodremove
(&mut self, namespace: &str, pod_name: &str)
pulse-common/src/k8s/pods_info.rs:199
↓ 18 callersFunctionfile_descriptor
`FileDescriptor` object which allows dynamic access to files
pulse-protobuf/src/protos/opentelemetry/metrics.rs:3762
↓ 18 callersFunctionmake_metric_id
(name: &str, mtype: Option<MetricType>, tags: &[(&str, &str)])
pulse-metrics/src/test/mod.rs:69
↓ 17 callersMethodexpect_send_and_receive
(&mut self, send: ParsedMetric, receive: Vec<ParsedMetric>)
pulse-metrics/src/pipeline/processor/mutate/mod_test.rs:66
↓ 17 callersMethodmtype
(&self)
pulse-metrics/src/protos/metric.rs:157
↓ 17 callersMethodsource
(&self)
pulse-metrics/src/protos/metric.rs:841
↓ 17 callersMethodstats_helper
(&self)
pulse-proxy/src/test/integration/mod.rs:290
↓ 16 callersFunctionmake_metric_ex
( name: &str, tags: &[(&str, &str)], timestamp: u64, metric_type: Option<MetricType>, sample_rate: O
pulse-metrics/src/test/mod.rs:207
↓ 16 callersFunctionprom_stale_marker
()
pulse-metrics/src/protos/prom.rs:93
↓ 16 callersMethodto_simple
(&self)
pulse-metrics/src/protos/metric.rs:309
↓ 15 callersMethodget
Get a slot value that may or may not have been initialized.
pulse-metrics/src/pipeline/metric_cache.rs:124
↓ 15 callersFunctionmake_metric
( name: Bytes, tags: Vec<TagValue>, value: MetricValue, sample_rate: Option<f64>, timestamp: u64,
pulse-metrics/src/pipeline/processor/aggregation/mod.rs:602
↓ 15 callersMethodwrite
(&mut self, from: &mut T)
pulse-metrics/src/clients/client.rs:63
↓ 14 callersFunctionprocessor_decide
( processor: &ElisionProcessor, carbon: bytes::Bytes, metric_cache: &Arc<MetricCache>, )
pulse-metrics/src/pipeline/processor/elision/mod_test.rs:56
↓ 14 callersMethodvalue
(&self)
pulse-metrics/src/pipeline/processor/aggregation/gauge.rs:107
↓ 13 callersFunctionfrom_write_request
Convert an incoming write request to a vector of internal metrics. Order of individual metrics is not currently preserved, however order of samples is
pulse-metrics/src/protos/prom.rs:772
↓ 13 callersMethodgauge
(&self)
pulse-protobuf/src/protos/opentelemetry/metrics.rs:509
↓ 13 callersMethodinitialize_cache
(&mut self, metric_cache: &Arc<MetricCache>)
pulse-metrics/src/protos/metric.rs:967
↓ 12 callersMethodappend_to_downstream_id
Appends a suffix to the downstream ID, converting to InflowProvided if necessary.
pulse-metrics/src/protos/metric.rs:858
↓ 12 callersMethodapply_pod
( &mut self, node_info: &NodeInfo, pod: &Pod, service_cache: Option<&mut ServiceCache>
pulse-common/src/k8s/pods_info.rs:237
↓ 12 callersFunctionfile_descriptor
`FileDescriptor` object which allows dynamic access to files
pulse-protobuf/src/protos/pulse/internode/v1/metric.rs:2377
↓ 12 callersFunctionfile_descriptor
`FileDescriptor` object which allows dynamic access to files
pulse-protobuf/src/protos/pulse/config/processor/v1/drop.rs:2419
↓ 12 callersFunctionfile_descriptor
`FileDescriptor` object which allows dynamic access to files
pulse-protobuf/src/protos/pulse/config/inflow/v1/k8s_prom.rs:2575
↓ 12 callersMethodmake_owned
(self: Arc<Self>)
pulse-common/src/k8s/pods_info.rs:96
↓ 12 callersMethodmetric
(&self)
pulse-protobuf/src/protos/pulse/vrl_tester/v1/vrl_tester.rs:197
↓ 12 callersMethodnext
(&mut self)
pulse-metrics/src/pipeline/inflow/prom_scrape/scraper.rs:770
↓ 12 callersMethodwait_for_metrics
(&mut self)
pulse-proxy/src/test/integration/mod.rs:488
↓ 11 callersMethodadd_or_change_tag
(&mut self, tag: TagValue)
pulse-metrics/src/protos/metric.rs:645
↓ 11 callersFunctionfile_descriptor
`FileDescriptor` object which allows dynamic access to files
pulse-protobuf/src/protos/pulse/config/processor/v1/aggregation.rs:2102
↓ 11 callersFunctionfile_descriptor
`FileDescriptor` object which allows dynamic access to files
pulse-protobuf/src/protos/pulse/config/bootstrap/v1/bootstrap.rs:2380
↓ 11 callersMethodquery
Query for a particular quantile.
pulse-metrics/src/pipeline/processor/aggregation/cm_quantile.rs:345
↓ 11 callersMethodshutdown
(&mut self)
pulse-metrics/src/pipeline/inflow/prom_scrape/scraper_test.rs:1030
↓ 10 callersMethodaggregate
(&mut self, sample: f64)
pulse-metrics/src/pipeline/processor/aggregation/gauge.rs:53
↓ 10 callersMethodcarbon_output
(&self, timestamp: u64)
pulse-metrics/src/admin/stats.rs:261
↓ 10 callersFunctionclean
(mut metric: Metric)
pulse-metrics/src/protos/statsd_test.rs:15
↓ 10 callersMethodcmp
(&self, other: &Self)
pulse-metrics/src/pipeline/processor/aggregation/cm_quantile.rs:68
↓ 10 callersFunctiondefault_timestamp
()
pulse-metrics/src/protos/metric.rs:402
↓ 10 callersMethoddownstream_id
(&self, metric_id: &MetricId)
pulse-metrics/src/pipeline/inflow/http_inflow.rs:189
↓ 10 callersMethodget_or_init
Get a slot value or initialize it via a passed initialization function if it does not exist.
pulse-metrics/src/pipeline/metric_cache.rs:140
↓ 10 callersMethodlossy_to_u64
(self)
pulse-common/src/lib.rs:93
↓ 10 callersFunctionmake_metric
(name: &str, metric_cache: &Arc<MetricCache>, received_at: Instant)
pulse-metrics/src/pipeline/metric_cache_test.rs:26
↓ 10 callersFunctionmake_object_meta
( name: &str, labels: BTreeMap<String, String>, annotations: BTreeMap<String, String>, )
pulse-common/src/k8s/test/mod.rs:17
↓ 10 callersFunctionmake_parsed_metric
(downstream_id: DownstreamId)
pulse-metrics/src/protos/metric_test.rs:253
↓ 10 callersFunctionmake_pod_status
(ip: &str, phase: &str)
pulse-common/src/k8s/pods_info_test.rs:28
↓ 10 callersFunctionmock_metric
( name: bytes::Bytes, metric_type: Option<MetricType>, value: f64, timestamp: u64, )
pulse-metrics/src/pipeline/processor/elision/state_test.rs:51
↓ 10 callersFunctionparse_carbon_line
Parse a complete carbon line, returning a structure with all the fields populated, including tags, timestamp and underlying value
pulse-metrics/src/protos/carbon.rs:105
↓ 9 callersMethodborrow_and_update
(&mut self)
pulse-common/src/k8s/pods_info.rs:65
↓ 9 callersFunctionfile_descriptor
`FileDescriptor` object which allows dynamic access to files
pulse-protobuf/src/protos/pulse/config/processor/v1/elision.rs:1731
↓ 9 callersMethodfilter
(&self, samples: Vec<ParsedMetric>)
pulse-metrics/src/pipeline/processor/elision/mod.rs:318
↓ 9 callersMethodinto_parts
(self)
pulse-metrics/src/protos/metric.rs:181
↓ 9 callersFunctionload_and_check_validity
(path: &str)
pulse-proxy/src/config_test.rs:36
↓ 9 callersFunctionmake_carbon_wire_protocol
()
pulse-metrics/src/test/mod.rs:257
↓ 9 callersFunctionparse_lyft_tags
()
pulse-metrics/src/protos/statsd_test.rs:20
↓ 9 callersMethodrecv_samples
(self: Arc<Self>, samples: Vec<ParsedMetric>)
pulse-metrics/src/pipeline/processor/drop/mod.rs:359
↓ 9 callersMethodstate_slot_handle
(&self)
pulse-metrics/src/pipeline/metric_cache.rs:407
↓ 9 callersMethodthread_synchronizer
(&self)
pulse-metrics/src/pipeline/processor/aggregation/test/mod.rs:320
↓ 9 callersFunctionto_write_request
( metrics: Vec<ParsedMetric>, options: &ToWriteRequestOptions, changed_type_tracker: &ChangedTypeTracker
pulse-metrics/src/protos/prom.rs:1167
↓ 8 callersMethodadd_sample
Add a sample to the quantile streamer.
pulse-metrics/src/pipeline/processor/aggregation/cm_quantile.rs:127
↓ 8 callersMethoddecide
( &self, metric: &Metric, decision: FilterDecision, emit_override: Option<&EmitConfig>, )
pulse-metrics/src/pipeline/processor/elision/state.rs:172
↓ 8 callersFunctionfile_descriptor
`FileDescriptor` object which allows dynamic access to files
pulse-protobuf/src/protos/pulse/internode/v1/internode.rs:982
↓ 8 callersFunctionfinal_tags_for_timeseries
Create the final tags for an outgoing timeseries.
pulse-metrics/src/protos/prom.rs:1075
↓ 8 callersFunctionmake_metric
(name: &str, tags: &[(&str, &str)], timestamp: u64)
pulse-metrics/src/test/mod.rs:87
↓ 8 callersMethodrecv_samples
(self: Arc<Self>, samples: Vec<ParsedMetric>)
pulse-metrics/src/pipeline/processor/buffer/mod.rs:134
next →1–100 of 2,474, ranked by callers