Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Arguments ¶
type Arguments struct { // Where the relabelled metrics should be forwarded to. ForwardTo []*metrics.Receiver `river:"forward_to,attr"` // The relabelling steps to apply to each metric before it's forwarded. MetricRelabelConfigs []*flow_relabel.Config `river:"metric_relabel_config,block,optional"` }
Arguments holds values which are used to configure the metrics.mutate component.
type Component ¶
type Component struct {
// contains filtered or unexported fields
}
Component implements the metrics.mutate component.
func (*Component) Receive ¶
func (c *Component) Receive(ts int64, metricArr []*metrics.FlowMetric)
Receive implements the receiver.Receive func that allows an array of metrics to be passed around. TODO (@tpaschalis) The relabelling process will run _every_ time, for all metrics, resulting in some serious CPU overhead. We should be caching the relabeling results per refID and clearing entries for dropped or stale series. This is a blocker for releasing a production-grade of the metrics.mutate component.
Click to show internal directories.
Click to hide internal directories.