MCPcopy Create free account

hub / github.com/bitdriftlabs/pulse / functions

Functions2,474 in github.com/bitdriftlabs/pulse

⨍ Functions 2,474◇ Types & classes 540
↓ 8 callersMethodrecv_samples
(self: Arc<Self>, samples: Vec<ParsedMetric>)
pulse-metrics/src/pipeline/processor/sampler/mod.rs:73
↓ 8 callersMethodrecv_samples
(self: Arc<Self>, samples: Vec<ParsedMetric>)
pulse-metrics/src/pipeline/processor/cardinality_limiter/mod.rs:321
↓ 8 callersMethodretry_notify
This appears to be a compiler bug in this function.
pulse-metrics/src/clients/retry.rs:97
↓ 8 callersFunctiontimeseries_common
Common timeseries creation for both simple metrics and histograms.
pulse-metrics/src/protos/prom.rs:896
↓ 8 callersMethodto_histogram
(&self)
pulse-metrics/src/protos/metric.rs:326
↓ 8 callersFunctionyaml_to_proto
Convert a YAML string to a proto by round tripping through JSON, and then run PGV on it.
pulse-common/src/proto.rs:50
↓ 7 callersMethodcontains
(&self, namespace: &str, pod_name: &str)
pulse-common/src/k8s/pods_info.rs:194
↓ 7 callersFunctionexpect_finish
(size: usize)
pulse-metrics/src/batch_test.rs:24
↓ 7 callersFunctionf64_or_stale_marker_eq
(lhs: f64, rhs: f64)
pulse-metrics/src/protos/prom.rs:101
↓ 7 callersFunctionfile_descriptor
`FileDescriptor` object which allows dynamic access to files
pulse-protobuf/src/protos/pulse/config/common/v1/common.rs:1550
↓ 7 callersMethodget
(&mut self)
pulse-metrics/src/pipeline/inflow/prom_scrape/scraper_test.rs:879
↓ 7 callersMethodis_match
(&self, value: &[u8])
pulse-metrics/src/pipeline/processor/drop/mod.rs:48
↓ 7 callersFunctionmake_abs_counter_with_metadata
( name: &str, tags: &[(&str, &str)], timestamp: u64, value: f64, metadata: Metadata, )
pulse-metrics/src/test/mod.rs:153
↓ 7 callersFunctionparse_tags
(input: bytes::Bytes)
pulse-metrics/src/protos/statsd.rs:27
↓ 7 callersFunctionproto_metric_to_parsed_metric
(m: ProtoMetric)
pulse-metrics/src/pipeline/processor/internode/convert.rs:266
↓ 7 callersFunctionsetup_elision_processor
( regex_overrides: Option<Vec<RegexOverrideConfig>>, emit: Option<EmitConfig>, )
pulse-metrics/src/pipeline/processor/elision/mod_test.rs:36
↓ 7 callersFunctionshardmap_from_config
( cfg: &InternodeConfig, mut factory: F, )
pulse-metrics/src/pipeline/processor/internode/shard_map.rs:151
↓ 7 callersFunctionto_carbon_line
(metric: &Metric)
pulse-metrics/src/protos/carbon.rs:146
↓ 7 callersFunctionto_statsd_line
(metric: &Metric)
pulse-metrics/src/protos/statsd.rs:219
↓ 7 callersMethodupdate_and_decide
( &self, now: Instant, sample: &ParsedMetric, emit_interval: Duration, startup_interval: D
pulse-metrics/src/pipeline/processor/sampler/mod.rs:125
↓ 6 callersFunctionassert_cardinality_gauge
( helper: &crate::test::ProcessorFactoryContextHelper, value: i64, labels: &[(&str, &str)], )
pulse-metrics/src/pipeline/processor/cardinality_tracker/mod_test.rs:41
↓ 6 callersFunctioncurrent_time
()
pulse-proxy/src/test/integration/mod.rs:87
↓ 6 callersMethoddependencies
(&self)
pulse-metrics/src/pipeline/mod.rs:250
↓ 6 callersFunctionexpect_metric
( fake_upstream: &mut FakeHttpUpstream, storage_policy: &str, metric: ParsedMetric, )
pulse-proxy/src/test/integration/prom.rs:203
↓ 6 callersFunctionfile_descriptor
`FileDescriptor` object which allows dynamic access to files
pulse-protobuf/src/protos/opentelemetry/common.rs:1351
↓ 6 callersMethodgenerate_metrics
( &mut self, count: usize, wire_protocol: &WireProtocol, )
pulse-metrics/src/metric_generator.rs:114
↓ 6 callersMethodget
( singleton_manager: Arc<SingletonManager>, k8s_config: KubernetesBootstrapConfig, shutdown: Compo
pulse-common/src/k8s/pods_info.rs:111
↓ 6 callersMethodhistogram
(&self)
pulse-protobuf/src/protos/opentelemetry/metrics.rs:607
↓ 6 callersMethoditem
(&self)
pulse-metrics/src/pipeline/mod.rs:82
↓ 6 callersMethodlisten
(self)
pulse-common/src/bind_resolver.rs:24
↓ 6 callersFunctionmake_tag
(tag: &'static str, value: &'static str)
pulse-metrics/src/test/mod.rs:61
↓ 6 callersFunctionmake_timeseries
( name: Chars, mut labels: Vec<Label>, value: f64, timestamp: i64, extra_labels: Vec<Label>, )
pulse-metrics/src/protos/prom.rs:115
↓ 6 callersFunctionprocess_buffer_newlines
( buf: &mut BytesMut, expect_new_lines: bool, )
pulse-metrics/src/pipeline/inflow/wire/util.rs:77
↓ 6 callersMethodpush
(&mut self, items: impl Iterator<Item = ParsedMetric>)
pulse-metrics/src/pipeline/outflow/http/remote_write.rs:658
↓ 6 callersMethodreceived_at
(&self)
pulse-metrics/src/protos/metric.rs:837
↓ 6 callersMethodrecv_samples
(self: Arc<Self>, samples: Vec<ParsedMetric>)
pulse-metrics/src/pipeline/processor/cardinality_tracker/mod.rs:479
↓ 6 callersMethodrecv_samples
(self: Arc<Self>, samples: Vec<ParsedMetric>)
pulse-metrics/src/pipeline/processor/mutate/mod.rs:213
↓ 6 callersMethodsend
(&self, samples: Vec<ParsedMetric>)
pulse-metrics/src/pipeline/outflow/http/remote_write.rs:579
↓ 6 callersMethodsend_write_request
( &self, compressed_write_request: Bytes, extra_headers: Option<&'a HeaderMap>, )
pulse-metrics/src/clients/http.rs:216
↓ 6 callersMethodshutdown
(self, component_type: &str, name: String)
pulse-metrics/src/pipeline/mod.rs:74
↓ 6 callersMethodto_metric_id
(&self)
pulse-metrics/src/pipeline/metric_cache.rs:265
↓ 6 callersMethodto_summary
(&self)
pulse-metrics/src/protos/metric.rs:334
↓ 6 callersMethodupdate_file
(&self, path: &str, file: Bytes)
pulse-proxy/src/test/integration/mod.rs:337
↓ 5 callersFunctionassert_cardinality_gauge_absent
( helper: &crate::test::ProcessorFactoryContextHelper, labels: &[(&str, &str)], )
pulse-metrics/src/pipeline/processor/cardinality_tracker/mod_test.rs:61
↓ 5 callersMethodconnect
(&mut self)
pulse-metrics/src/clients/client.rs:38
↓ 5 callersMethodexpect_make_inflow
(&mut self, name: &'static str, expect_start: ExpectStart)
pulse-metrics/src/pipeline/mod_test.rs:93
↓ 5 callersMethodexpect_make_ouflow
(&mut self, name: &'static str)
pulse-metrics/src/pipeline/mod_test.rs:165
↓ 5 callersMethodexpect_make_processor
(&mut self, name: &'static str, expect_start: ExpectStart)
pulse-metrics/src/pipeline/mod_test.rs:127
↓ 5 callersFunctionexpect_send_write_request
( mock_client: &mut MockHttpRemoteWriteClient, call_count_tx: mpsc::Sender<()>, n_expected_samples: usiz
pulse-metrics/src/pipeline/outflow/http/remote_write_test.rs:99
↓ 5 callersMethodextended_gauges
(mut self)
pulse-metrics/src/pipeline/processor/aggregation/test/mod.rs:75
↓ 5 callersFunctionfile_descriptor
`FileDescriptor` object which allows dynamic access to files
pulse-protobuf/src/protos/pulse/vrl_tester/v1/vrl_tester.rs:1349
↓ 5 callersFunctionfile_descriptor
`FileDescriptor` object which allows dynamic access to files
pulse-protobuf/src/protos/pulse/config/processor/v1/cardinality_tracker.rs:1063
↓ 5 callersFunctionfile_descriptor
`FileDescriptor` object which allows dynamic access to files
pulse-protobuf/src/protos/pulse/config/inflow/v1/wire.rs:994
↓ 5 callersFunctionfile_descriptor
`FileDescriptor` object which allows dynamic access to files
pulse-protobuf/src/protos/pulse/config/outflow/v1/wire.rs:774
↓ 5 callersMethodfinish
(&mut self)
pulse-metrics/src/batch_test.rs:59
↓ 5 callersMethodget_or_insert_map
Under write lock, get or insert a value, and returned a mapped result given whether the key already existed in the map. Additionally, if a value was i
pulse-metrics/src/lru_map.rs:248
↓ 5 callersFunctionglobal_initialize
()
pulse-common/src/lib.rs:23
↓ 5 callersMethodkey
(&self)
pulse-metrics/src/lru_map.rs:117
↓ 5 callersMethodlocal_addr
(&self)
pulse-common/src/bind_resolver.rs:33
↓ 5 callersFunctionmake_label
(name: Chars, value: Chars)
pulse-metrics/src/protos/prom.rs:106
↓ 5 callersFunctionmake_metric
( name: &str, group_key: &prometheus_parser::GroupKey, mtype: Option<MetricType>, value: MetricValue,
pulse-metrics/src/pipeline/inflow/prom_scrape/parser.rs:167
↓ 5 callersFunctionmake_namespace_and_name
(namespace: &str, name: &str)
pulse-common/src/k8s/pods_info.rs:43
↓ 5 callersFunctionmake_reuse_port_tcp_socket
(name: &str)
pulse-common/src/bind_resolver.rs:82
↓ 5 callersFunctionobject_namespace
Returns the namespace for the provided object.
pulse-common/src/k8s/mod.rs:27
↓ 5 callersMethodpipeline
(&self)
pulse-protobuf/src/protos/pulse/config/bootstrap/v1/bootstrap.rs:1927
↓ 5 callersFunctionprom_name
( input: &Bytes, translate_dot_colon_to: u8, convert_name: bool, source: &MetricSource, )
pulse-metrics/src/protos/prom.rs:52
↓ 5 callersMethodremove_pod
(&mut self, pod: &Pod)
pulse-common/src/k8s/pods_info.rs:612
↓ 5 callersFunctionrun
(config: &str, proxy_config: Option<&str>)
pulse-vrl-tester/src/lib.rs:248
↓ 5 callersMethodsend
(&self, samples: Vec<ParsedMetric>)
pulse-metrics/src/pipeline/mod.rs:259
↓ 5 callersMethodset_metadata
(&mut self, metadata: Option<Arc<Metadata>>)
pulse-metrics/src/protos/metric.rs:853
↓ 5 callersMethodsignal
Signal an event such that a thread that is blocked within sync_point() will now proceed.
pulse-metrics/src/test/thread_synchronizer.rs:118
↓ 5 callersFunctionstring
()
pulse-metrics/src/protos/carbon.rs:58
↓ 5 callersFunctiontest_equivalent
(metric_id: &MetricId, metric_key: &Arc<MetricKey>, expect_equal: bool)
pulse-metrics/src/pipeline/metric_cache_test.rs:212
↓ 5 callersMethodtimer_type
(mut self, timer_type: TimerType)
pulse-metrics/src/pipeline/processor/aggregation/test/mod.rs:80
↓ 5 callersMethodupdate
( &mut self, metric: &ParsedMetric, metric_filters: &[DynamicMetricFilter], )
pulse-metrics/src/pipeline/processor/elision/state.rs:89
↓ 5 callersMethodwait_on
The next time the sync point registered with name is invoked via sync_point(), the calling code will block until signaled. Note that this is a one-sho
pulse-metrics/src/test/thread_synchronizer.rs:91
↓ 5 callersMethodwait_until_modified
(&mut self)
pulse-metrics/src/file_watcher/local.rs:87
↓ 4 callersFunctionassert_admin
(admin: &MockAdmin, expected: &str)
pulse-metrics/src/pipeline/processor/cardinality_tracker/mod_test.rs:25
↓ 4 callersMethodbarrier_on
This call will block until the next time the sync point registered with name is invoked. The name must have been previously registered for blocking vi
pulse-metrics/src/test/thread_synchronizer.rs:103
↓ 4 callersFunctionbind_k8s_metadata
( metrics: &mut Vec<ParsedMetric>, downstream_id: &DownstreamId, no_k8s_pod_metadata: &IntCounter, k8s
pulse-metrics/src/pipeline/inflow/wire/util.rs:107
↓ 4 callersFunctionbuild_filter_counter
(f: &DynamicMetricFilter, scope: &Scope)
pulse-metrics/src/pipeline/processor/elision/mod.rs:91
↓ 4 callersFunctionbuild_filter_scope
(name: &str, scope: &Scope)
pulse-metrics/src/pipeline/processor/elision/mod.rs:85
↓ 4 callersMethodcached_metric
(&self)
pulse-metrics/src/protos/metric.rs:825
↓ 4 callersFunctioncompress_write_request
(write_request: &WriteRequest)
pulse-metrics/src/pipeline/outflow/prom/mod.rs:34
↓ 4 callersMethodcreate
(&mut self, config_yaml: &str)
pulse-metrics/src/pipeline/mod_test.rs:62
↓ 4 callersFunctiondefault_aggregation_flush_interval
()
pulse-metrics/src/pipeline/processor/aggregation/mod.rs:85
↓ 4 callersMethodenable_emit_prometheus_stale_markers
(mut self)
pulse-metrics/src/pipeline/processor/aggregation/test/mod.rs:105
↓ 4 callersFunctionenv_or_inline_to_string
Convert an EnvOrInline proto to an optional string.
pulse-common/src/proto.rs:20
↓ 4 callersMethodexpect_outflow_recv
(&self, name: &str, index: usize)
pulse-metrics/src/pipeline/mod_test.rs:208
↓ 4 callersMethodexpect_processor_recv
(&self, name: &str, index: usize)
pulse-metrics/src/pipeline/mod_test.rs:198
↓ 4 callersMethodextended_counters
(mut self)
pulse-metrics/src/pipeline/processor/aggregation/test/mod.rs:70
↓ 4 callersFunctionfile_descriptor
`FileDescriptor` object which allows dynamic access to files
pulse-protobuf/src/protos/pulse/config/processor/v1/internode.rs:767
↓ 4 callersFunctionfile_descriptor
`FileDescriptor` object which allows dynamic access to files
pulse-protobuf/src/protos/pulse/config/common/v1/retry.rs:783
↓ 4 callersFunctionfile_descriptor
`FileDescriptor` object which allows dynamic access to files
pulse-protobuf/src/protos/pulse/config/outflow/v1/outflow_common.rs:959
↓ 4 callersMethodflush
Flush to get the most accurate query results.
pulse-metrics/src/pipeline/processor/aggregation/cm_quantile.rs:376
↓ 4 callersFunctioninsert
( map: &TestMap, key: &MetricId, value: &str, evict: impl Fn(&MetricKey, &mut String) -> bool, )
pulse-metrics/src/lru_map_test.rs:17
↓ 4 callersMethodis_match
(&self, name: &[u8])
pulse-metrics/src/filters/fst.rs:59
↓ 4 callersFunctionload_from_file
(path: &str)
pulse-proxy/src/config.rs:28
↓ 4 callersFunctionmake_metric
( name: &'static str, received_at: Instant, metric_cache: &Arc<MetricCache>, )
pulse-metrics/src/pipeline/processor/sampler/mod_test.rs:33
↓ 4 callersFunctionmake_regex_filter
( metrics: Vec<&str>, match_decision: MetricFilterDecision, prom: bool, name: String, )
pulse-metrics/src/filters/regex_test.rs:36
← previousnext →101–200 of 2,474, ranked by callers