Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Fanout ¶
type Fanout struct {
// contains filtered or unexported fields
}
Fanout supports the default Alloy style of appendables since it can go to multiple outputs. It also allows the intercepting of appends.
func NewFanout ¶
func NewFanout(children []storage.Appendable, componentID string, register prometheus.Registerer, ls labelstore.LabelStore) *Fanout
NewFanout creates a fanout appendable.
func (*Fanout) UpdateChildren ¶
func (f *Fanout) UpdateChildren(children []storage.Appendable)
UpdateChildren allows changing of the children of the fanout.
type Interceptor ¶
type Interceptor struct {
// contains filtered or unexported fields
}
Interceptor is a storage.Appendable which invokes callback functions upon getting data. Interceptor should not be modified once created. All callback fields are optional.
func NewInterceptor ¶
func NewInterceptor(next storage.Appendable, ls labelstore.LabelStore, opts ...InterceptorOption) *Interceptor
NewInterceptor creates a new Interceptor storage.Appendable. Options can be provided to NewInterceptor to install custom hooks for different methods.
type InterceptorOption ¶
type InterceptorOption func(*Interceptor)
InterceptorOption is an option argument passed to NewInterceptor.
func WithAppendHook ¶
func WithAppendHook(f func(ref storage.SeriesRef, l labels.Labels, t int64, v float64, next storage.Appender) (storage.SeriesRef, error)) InterceptorOption
WithAppendHook returns an InterceptorOption which hooks into calls to Append.
func WithCTZeroSampleHook ¶ added in v1.2.0
func WithCTZeroSampleHook(f func(ref storage.SeriesRef, l labels.Labels, t, ct int64, next storage.Appender) (storage.SeriesRef, error)) InterceptorOption
WithCTZeroSampleHook returns an InterceptorOption which hooks into calls to AppendCTZeroSample.
func WithExemplarHook ¶
func WithExemplarHook(f func(ref storage.SeriesRef, l labels.Labels, e exemplar.Exemplar, next storage.Appender) (storage.SeriesRef, error)) InterceptorOption
WithExemplarHook returns an InterceptorOption which hooks into calls to AppendExemplar.
func WithHistogramHook ¶
func WithHistogramHook(f func(ref storage.SeriesRef, l labels.Labels, t int64, h *histogram.Histogram, fh *histogram.FloatHistogram, next storage.Appender) (storage.SeriesRef, error)) InterceptorOption
WithHistogramHook returns an InterceptorOption which hooks into calls to AppendHistogram.
type NoopMetadataStore ¶
type NoopMetadataStore map[string]scrape.MetricMetadata
NoopMetadataStore implements the MetricMetadataStore interface.
func (NoopMetadataStore) GetMetadata ¶
func (ms NoopMetadataStore) GetMetadata(familyName string) (scrape.MetricMetadata, bool)
GetMetadata implements the MetricMetadataStore interface.
func (NoopMetadataStore) LengthMetadata ¶
func (ms NoopMetadataStore) LengthMetadata() int
LengthMetadata implements the MetricMetadataStore interface.
func (NoopMetadataStore) ListMetadata ¶
func (ms NoopMetadataStore) ListMetadata() []scrape.MetricMetadata
ListMetadata implements the MetricMetadataStore interface.
func (NoopMetadataStore) SizeMetadata ¶
func (ms NoopMetadataStore) SizeMetadata() int
SizeMetadata implements the MetricMetadataStore interface.