util

Documentation

Index

• func IsConnCanceled(err error) bool
• func LabelsToMetric(ls labels.Labels) model.Metric
• func ModelLabelSetToMap(m model.LabelSet) map[string]string
• func RoundToMilliseconds(from, through time.Time) (model.Time, model.Time)
• func StringRef(value string) *string
• func StringSliceContains(slice []string, value string) bool
• func ToClientLabels(labels string) ([]client.LabelAdapter, error)
• func TokenFor(userID, labels string) uint32
• type ExtendedMock
  • func (m *ExtendedMock) GetMockedCallsByMethod(method string) []mock.Call
• type LogAdapater
  • func NewLogAdapater(l log.Logger) LogAdapater
  • func (l LogAdapater) Fatal(v ...interface{})
  • func (l LogAdapater) Fatalf(format string, v ...interface{})
  • func (l LogAdapater) Fatalln(v ...interface{})
  • func (l LogAdapater) Panic(v ...interface{})
  • func (l LogAdapater) Panicf(format string, v ...interface{})
  • func (l LogAdapater) Panicln(v ...interface{})
  • func (l LogAdapater) Print(v ...interface{})
  • func (l LogAdapater) Printf(format string, v ...interface{})
  • func (l LogAdapater) Println(v ...interface{})
• type MultiError
  • func (es *MultiError) Add(err error)
  • func (es MultiError) Err() error
  • func (es MultiError) Error() string
• type QueryStringBuilder
  • func NewQueryStringBuilder() *QueryStringBuilder
  • func (b *QueryStringBuilder) Encode() string
  • func (b *QueryStringBuilder) EncodeWithPath(path string) string
  • func (b *QueryStringBuilder) SetFloat(name string, value float64)
  • func (b *QueryStringBuilder) SetFloat32(name string, value float32)
  • func (b *QueryStringBuilder) SetInt(name string, value int64)
  • func (b *QueryStringBuilder) SetInt32(name string, value int)
  • func (b *QueryStringBuilder) SetString(name, value string)

Functions

func IsConnCanceled

func IsConnCanceled(err error) bool

IsConnCanceled returns true, if error is from a closed gRPC connection. copied from https://github.com/etcd-io/etcd/blob/7f47de84146bdc9225d2080ec8678ca8189a2d2b/clientv3/client.go#L646

func LabelsToMetric

func LabelsToMetric(ls labels.Labels) model.Metric

LabelsToMetric converts a Labels to Metric Don't do this on any performance sensitive paths.

func ModelLabelSetToMap

func ModelLabelSetToMap(m model.LabelSet) map[string]string

ModelLabelSetToMap convert a model.LabelSet to a map[string]string

func RoundToMilliseconds

func RoundToMilliseconds(from, through time.Time) (model.Time, model.Time)

RoundToMilliseconds returns milliseconds precision time from nanoseconds. from will be rounded down to the nearest milliseconds while through is rounded up.

func StringRef

func StringRef(value string) *string

func StringSliceContains

func StringSliceContains(slice []string, value string) bool

func ToClientLabels

func ToClientLabels(labels string) ([]client.LabelAdapter, error)

ToClientLabels parses the labels and converts them to the Cortex type.

func TokenFor

func TokenFor(userID, labels string) uint32

TokenFor generates a token used for finding ingesters from ring

Types

type ExtendedMock

type ExtendedMock struct {
	mock.Mock
}

func (*ExtendedMock) GetMockedCallsByMethod

func (m *ExtendedMock) GetMockedCallsByMethod(method string) []mock.Call

type LogAdapater

type LogAdapater struct {
	log.Logger
}

func NewLogAdapater

func NewLogAdapater(l log.Logger) LogAdapater

func (LogAdapater) Fatal

func (l LogAdapater) Fatal(v ...interface{})

Fatal implements tail.logger

func (LogAdapater) Fatalf

func (l LogAdapater) Fatalf(format string, v ...interface{})

Fatalf implements tail.logger

func (LogAdapater) Fatalln

func (l LogAdapater) Fatalln(v ...interface{})

Fatalln implements tail.logger

func (LogAdapater) Panic

func (l LogAdapater) Panic(v ...interface{})

Panic implements tail.logger

func (LogAdapater) Panicf

func (l LogAdapater) Panicf(format string, v ...interface{})

Panicf implements tail.logger

func (LogAdapater) Panicln

func (l LogAdapater) Panicln(v ...interface{})

Panicln implements tail.logger

func (LogAdapater) Print

func (l LogAdapater) Print(v ...interface{})

Print implements tail.logger

func (LogAdapater) Printf

func (l LogAdapater) Printf(format string, v ...interface{})

Printf implements tail.logger

func (LogAdapater) Println

func (l LogAdapater) Println(v ...interface{})

Println implements tail.logger

type MultiError

type MultiError []error

The MultiError type implements the error interface, and contains the Errors used to construct it.

func (*MultiError) Add

func (es *MultiError) Add(err error)

Add adds the error to the error list if it is not nil.

func (MultiError) Err

func (es MultiError) Err() error

Err returns the error list as an error or nil if it is empty.

func (MultiError) Error

func (es MultiError) Error() string

Returns a concatenated string of the contained errors

type QueryStringBuilder

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

func NewQueryStringBuilder

func NewQueryStringBuilder() *QueryStringBuilder

func (*QueryStringBuilder) Encode

func (b *QueryStringBuilder) Encode() string

Encode returns the URL-encoded query string based on key-value parameters added to the builder calling Set functions.

func (*QueryStringBuilder) EncodeWithPath

func (b *QueryStringBuilder) EncodeWithPath(path string) string

Encode returns the URL-encoded query string, prefixing it with the input URL path.

func (*QueryStringBuilder) SetFloat

func (b *QueryStringBuilder) SetFloat(name string, value float64)

func (*QueryStringBuilder) SetFloat32

func (b *QueryStringBuilder) SetFloat32(name string, value float32)

func (*QueryStringBuilder) SetInt

func (b *QueryStringBuilder) SetInt(name string, value int64)

func (*QueryStringBuilder) SetInt32

func (b *QueryStringBuilder) SetInt32(name string, value int)

func (*QueryStringBuilder) SetString

func (b *QueryStringBuilder) SetString(name, value string)