metricstore

Documentation

Index

• Constants
• func ContextWithBearerToken(ctx context.Context, token string) context.Context
• func GetBearerToken(ctx context.Context) (string, bool)
• type CompositeWriter
  • func NewCompositeWriter(metricWriters ...Writer) *CompositeWriter
  • func (c *CompositeWriter) WriteMetric(metrics []prompb.TimeSeries) error
• type Writer

Constants

const BearerTokenKey = "bearer.token"

BearerTokenKey is the string literal used internally in the implementation of this context.

const StoragePropagationKey = "storage.propagate.token"

StoragePropagationKey is a key for viper configuration to pass this option to storage plugins.

Functions

func ContextWithBearerToken

func ContextWithBearerToken(ctx context.Context, token string) context.Context

ContextWithBearerToken set bearer token in context

func GetBearerToken

func GetBearerToken(ctx context.Context) (string, bool)

GetBearerToken from context, or empty string if there is no token

Types

type CompositeWriter

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

func NewCompositeWriter

func NewCompositeWriter(metricWriters ...Writer) *CompositeWriter

NewCompositeWriter creates a CompositeWriter

func (*CompositeWriter) WriteMetric

func (c *CompositeWriter) WriteMetric(metrics []prompb.TimeSeries) error

WriteMetric calls WriteMetric on each metric writer. It will sum up failures, it is not transactional

type Writer

type Writer interface {
	WriteMetric(metric []prompb.TimeSeries) error
}