prometheus

Documentation

Index

• Variables
• type Fanout
  • func NewFanout(children []storage.Appendable, componentID string) *Fanout
  • func (f *Fanout) Appender(ctx context.Context) storage.Appender
  • func (f *Fanout) UpdateChildren(children []storage.Appendable)
• type GlobalRefMap
  • func (g *GlobalRefMap) AddStaleMarker(globalRefID uint64, l labels.Labels)
  • func (g *GlobalRefMap) CheckStaleMarkers()
  • func (g *GlobalRefMap) GetGlobalRefID(componentID string, localRefID uint64) uint64
  • func (g *GlobalRefMap) GetLocalRefID(componentID string, globalRefID uint64) uint64
  • func (g *GlobalRefMap) GetOrAddGlobalRefID(l labels.Labels) uint64
  • func (g *GlobalRefMap) GetOrAddLink(componentID string, localRefID uint64, lbls labels.Labels) uint64
  • func (g *GlobalRefMap) RemoveStaleMarker(globalRefID uint64)
• type Intercept
• type Interceptor
  • func NewInterceptor(inter Intercept, next storage.Appendable, componentID string) (*Interceptor, error)
  • func (f *Interceptor) Appender(ctx context.Context) storage.Appender
  • func (f *Interceptor) UpdateChild(child storage.Appendable)
• type NoopMetadataStore
  • func (ms NoopMetadataStore) GetMetadata(familyName string) (scrape.MetricMetadata, bool)
  • func (ms NoopMetadataStore) LengthMetadata() int
  • func (ms NoopMetadataStore) ListMetadata() []scrape.MetricMetadata
  • func (ms NoopMetadataStore) SizeMetadata() int

Variables

var (
	ErrExemplarsNotSupported = fmt.Errorf("appendExemplar not supported yet")
	ErrMetadataNotSupported  = fmt.Errorf("updateMetadata not supported yet")
)

Custom errors to return until we implement support for exemplars and metadata.

var GlobalRefMapping = &GlobalRefMap{}

GlobalRefMapping is used when translating to and from remote writes and the rest of the system (mostly scrapers) normal components except those should in general NOT need this.

Types

type Fanout

type Fanout struct {
	// contains filtered or unexported fields
}

Fanout supports the default Flow 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) *Fanout

NewFanout creates a fanout appendable.

func (*Fanout) Appender

func (f *Fanout) Appender(ctx context.Context) storage.Appender

Appender satisfies the Appendable interface.

func (*Fanout) UpdateChildren

func (f *Fanout) UpdateChildren(children []storage.Appendable)

UpdateChildren allows changing of the children of the fanout.

type GlobalRefMap

type GlobalRefMap struct {
	// contains filtered or unexported fields
}

GlobalRefMap allows conversion from remote_write refids to global refs ids that everything else can use

func (*GlobalRefMap) AddStaleMarker

func (g *GlobalRefMap) AddStaleMarker(globalRefID uint64, l labels.Labels)

AddStaleMarker adds a stale marker

func (*GlobalRefMap) CheckStaleMarkers

func (g *GlobalRefMap) CheckStaleMarkers()

CheckStaleMarkers is called to garbage collect and items that have grown stale over stale duration (10m)

func (*GlobalRefMap) GetGlobalRefID

func (g *GlobalRefMap) GetGlobalRefID(componentID string, localRefID uint64) uint64

GetGlobalRefID returns the global refid for a component local combo, or 0 if not found

func (*GlobalRefMap) GetLocalRefID

func (g *GlobalRefMap) GetLocalRefID(componentID string, globalRefID uint64) uint64

GetLocalRefID returns the local refid for a component global combo, or 0 if not found

func (*GlobalRefMap) GetOrAddGlobalRefID

func (g *GlobalRefMap) GetOrAddGlobalRefID(l labels.Labels) uint64

GetOrAddGlobalRefID is used to create a global refid for a labelset

func (*GlobalRefMap) GetOrAddLink

func (g *GlobalRefMap) GetOrAddLink(componentID string, localRefID uint64, lbls labels.Labels) uint64

GetOrAddLink is called by a remote_write endpoint component to add mapping and get back the global id.

func (*GlobalRefMap) RemoveStaleMarker

func (g *GlobalRefMap) RemoveStaleMarker(globalRefID uint64)

RemoveStaleMarker removes a stale marker

type Intercept

type Intercept func(ref storage.SeriesRef, l labels.Labels, t int64, v float64, next storage.Appender) (storage.SeriesRef, error)

Intercept func allows interceptor owners to inject custom behavior.

type Interceptor

type Interceptor struct {
	// contains filtered or unexported fields
}

Interceptor supports the concept of an appendable/appender that you can add a func to be called before the values are sent to the child appendable/append.

func NewInterceptor

func NewInterceptor(inter Intercept, next storage.Appendable, componentID string) (*Interceptor, error)

NewInterceptor creates a interceptor appendable.

func (*Interceptor) Appender

func (f *Interceptor) Appender(ctx context.Context) storage.Appender

Appender satisfies the Appendable interface.

func (*Interceptor) UpdateChild

func (f *Interceptor) UpdateChild(child storage.Appendable)

UpdateChild allows changing of the child of the interceptor.

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.