test

package
v1.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 7, 2022 License: Apache-2.0 Imports: 31 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	// SeriesNamespace is the expected namespace for the generated series
	SeriesNamespace string
	// TestTags is the expected tags for the generated series
	TestTags map[string]string
	// BlockSize is the expected block size for the generated series
	BlockSize time.Duration
	// Start is the expected start time for the first block in the generated series
	Start xtime.UnixNano
	// SeriesStart is the expected start time for the generated series
	SeriesStart xtime.UnixNano
	// Middle is the expected end for the first block, and start of the second block
	Middle xtime.UnixNano
	// End is the expected end time for the generated series
	End xtime.UnixNano
)

Functions

func BuildCustomIterator added in v0.5.0 

func BuildCustomIterator(
	dps [][]Datapoint,
	testTags map[string]string,
	seriesID, seriesNamespace string,
	start xtime.UnixNano,
	blockSize, stepSize time.Duration,
) (encoding.SeriesIterator, models.Bounds, error)

BuildCustomIterator builds a custom iterator with bounds

func BuildTestSeriesIterator 

func BuildTestSeriesIterator(id string) (encoding.SeriesIterator, error)

BuildTestSeriesIterator creates a sample SeriesIterator This series iterator has two identical replicas. Each replica has two blocks. The first block in each replica is merged and has values 1->30 The values 1 and 2 appear before the SeriesIterator start time, and are not expected to appear when reading through the iterator The second block is unmerged; when it was merged, it has values 101 -> 130 from two readers, one with even values and other with odd values Expected data points for reading through the iterator: [3..30,101..130], 58 in total SeriesIterator ID is given, namespace is 'namespace' Tags are "foo": "bar" and "baz": "qux"

func GeneratePromReadBody 

func GeneratePromReadBody(t *testing.T) io.Reader

GeneratePromReadBody generates a sample snappy encoded prometheus remote read request body

func GeneratePromReadRequest 

func GeneratePromReadRequest() *prompb.ReadRequest

GeneratePromReadRequest generates a sample prometheus remote read request

func GenerateValuesAndBounds 

func GenerateValuesAndBounds(
	vals [][]float64,
	b *models.Bounds,
) ([][]float64, models.Bounds)

GenerateValuesAndBounds generates a list of sample values and bounds while allowing overrides.

func MustMakeMeta added in v0.15.0 

func MustMakeMeta(bounds models.Bounds, tags ...string) block.Metadata

MustMakeMeta returns block metadata or panics (unsafe for use).

func MustMakeSeriesMeta added in v0.15.0 

func MustMakeSeriesMeta(tags ...string) block.SeriesMeta

MustMakeSeriesMeta returns series metadata or panics (unsafe for use).

func NewBlockFromValues 

func NewBlockFromValues(
	bounds models.Bounds,
	seriesValues [][]float64,
) block.Block

NewBlockFromValues creates a new block using the provided values.

func NewBlockFromValuesWithMetaAndSeriesMeta added in v0.4.1 

func NewBlockFromValuesWithMetaAndSeriesMeta(
	meta block.Metadata,
	seriesMeta []block.SeriesMeta,
	seriesValues [][]float64,
) block.Block

NewBlockFromValuesWithMetaAndSeriesMeta creates a new block using the provided values.

func NewBlockFromValuesWithSeriesMeta added in v0.4.1 

func NewBlockFromValuesWithSeriesMeta(
	bounds models.Bounds,
	seriesMeta []block.SeriesMeta,
	seriesValues [][]float64,
) block.Block

NewBlockFromValuesWithSeriesMeta creates a new block using the provided values.

func NewSeriesMeta added in v0.4.1 

func NewSeriesMeta(tagPrefix string, count int) []block.SeriesMeta

NewSeriesMeta creates new metadata tags in the format [tagPrefix:i] for the number of series.

func NewSeriesMetaWithoutName added in v0.11.0 

func NewSeriesMetaWithoutName(tagPrefix string, count int) []block.SeriesMeta

NewSeriesMetaWithoutName creates new metadata tags in the format [tagPrefix:i] for the number of series, without including the __name__.

func NewSlowStorage 

func NewSlowStorage(
	storage storage.Storage,
	delay time.Duration,
) storage.Storage

NewSlowStorage creates a new slow storage

func NewUnconsolidatedBlockFromDatapointsWithMeta added in v0.4.6 

func NewUnconsolidatedBlockFromDatapointsWithMeta(
	bounds models.Bounds,
	seriesMetas []block.SeriesMeta,
	resultMeta block.ResultMetadata,
	seriesValues [][]float64,
	enableBatched bool,
) block.Block

NewUnconsolidatedBlockFromDatapointsWithMeta creates a new unconsolidated block using the provided values and metadata.

func NoopMod added in v0.4.1 

func NoopMod(v []float64) []float64

NoopMod can be used to generate multi blocks when no value modification is needed.

func StringTagsSliceToTagSlice added in v0.4.6 

func StringTagsSliceToTagSlice(s []StringTags) []models.Tags

StringTagsSliceToTagSlice converts a slice of string tags to a slice of tags.

func StringTagsToTags added in v0.4.6 

func StringTagsToTags(s StringTags) models.Tags

StringTagsToTags converts string tags to tags.

func TagSliceSliceToTagSlice added in v0.4.8 

func TagSliceSliceToTagSlice(s [][]models.Tag) []models.Tags

TagSliceSliceToTagSlice converts a slice of tag slices to a slice of tags.

func TagSliceToTags added in v0.4.8 

func TagSliceToTags(s []models.Tag) models.Tags

TagSliceToTags converts a slice of tags to tags.

Types

type Datapoint added in v0.5.0 

type Datapoint struct {
	Value  float64
	Offset time.Duration
}

Datapoint is a datapoint with a value and an offset for building a custom iterator

type MockIteratorPool added in v0.4.6 

type MockIteratorPool struct {
	MriPoolUsed, SiPoolUsed, MriaPoolUsed,
	CbwPoolUsed, IdentPoolUsed, EncodePoolUsed, DecodePoolUsed bool
}

MockIteratorPool is an iterator pool used for testing

func MakeMockIteratorPool added in v0.4.6 

func MakeMockIteratorPool() *MockIteratorPool

MakeMockIteratorPool builds a mock iterator pool

func (*MockIteratorPool) CheckedBytesWrapper added in v0.4.6 

func (ip *MockIteratorPool) CheckedBytesWrapper() xpool.CheckedBytesWrapperPool

CheckedBytesWrapper exposes the session's CheckedBytesWrapperPool

func (*MockIteratorPool) ID added in v0.4.6 

func (ip *MockIteratorPool) ID() ident.Pool

ID exposes the session's identity pool

func (*MockIteratorPool) MultiReaderIterator added in v0.4.6 

func (ip *MockIteratorPool) MultiReaderIterator() encoding.MultiReaderIteratorPool

MultiReaderIterator exposes the session's MultiReaderIteratorPool

func (*MockIteratorPool) MultiReaderIteratorArray added in v0.4.6 

func (ip *MockIteratorPool) MultiReaderIteratorArray() encoding.MultiReaderIteratorArrayPool

MultiReaderIteratorArray exposes the session's MultiReaderIteratorArrayPool

func (*MockIteratorPool) SeriesIterator added in v0.4.6 

func (ip *MockIteratorPool) SeriesIterator() encoding.SeriesIteratorPool

SeriesIterator exposes the session's SeriesIteratorPool

func (*MockIteratorPool) TagDecoder added in v0.4.6 

func (ip *MockIteratorPool) TagDecoder() serialize.TagDecoderPool

TagDecoder exposes the session's tag decoder pool

func (*MockIteratorPool) TagEncoder added in v0.4.6 

func (ip *MockIteratorPool) TagEncoder() serialize.TagEncoderPool

TagEncoder exposes the session's tag encoder pool

type SlowHandler 

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

SlowHandler slows down a request by delay

func NewSlowHandler 

func NewSlowHandler(handler http.Handler, delay time.Duration) *SlowHandler

NewSlowHandler creates a new slow handler

func (*SlowHandler) ServeHTTP 

func (h *SlowHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

ServeHTTP implements http.handler

type StringTag added in v0.4.6 

type StringTag struct {
	N, V string
}

StringTag is a tag containing string key value pairs.

type StringTags added in v0.4.6 

type StringTags []StringTag

StringTags is a slice of string tags.

type ValueMod added in v0.4.1 

type ValueMod func([]float64) []float64

ValueMod can be used to modify provided values for testing.

Source Files

View all Source files

Directories

Path Synopsis
Package compare provides comparison functions for testing.
 Package compare provides comparison functions for testing.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.