storetestutil

Aug 23, 2023

Changes in this version

+ func CreateBlockFromHead(t testing.TB, dir string, head *tsdb.Head) ulid.ULID

type SeriesCase

+ HintsCompareFunc func(t testutil.TB, expected, actual hintspb.SeriesResponseHints)

+ type StoreSeriesClient struct

+ Ctx context.Context

+ InjectedError error

+ InjectedErrorIndex int

+ RespDur time.Duration

+ RespSet []*storepb.SeriesResponse

+ SlowSeriesIndex int

+ func (c *StoreSeriesClient) Context() context.Context

+ func (c *StoreSeriesClient) Recv() (*storepb.SeriesResponse, error)

type TestClient

+ StoreTSDBInfos []infopb.TSDBInfo

+ func (c TestClient) TSDBInfos() []infopb.TSDBInfo

Mar 23, 2023

Changes in this version

+ func ReadSeriesFromBlock(t testing.TB, h tsdb.BlockReader, extLabels labels.Labels, skipChunks bool) []*storepb.Series

type HeadGenOptions

+ SampleType chunkenc.ValueType

+ type TestClient struct

+ ExtLset []labels.Labels

+ IsLocalStore bool

+ MaxTime int64

+ MinTime int64

+ Name string

+ Shardable bool

+ WithoutReplicaLabelsEnabled bool

+ func (c TestClient) Addr() (string, bool)

+ func (c TestClient) LabelSets() []labels.Labels

+ func (c TestClient) String() string

+ func (c TestClient) SupportsSharding() bool

+ func (c TestClient) SupportsWithoutReplicaLabels() bool

+ func (c TestClient) TimeRange() (mint, maxt int64)

Apr 28, 2021

Changes in this version

type HeadGenOptions

+ ScrapeInterval time.Duration

Sep 7, 2020

Changes in this version

+ const LabelLongSuffix

+ const RemoteReadFrameLimit

+ func CreateHeadWithSeries(t testing.TB, j int, opts HeadGenOptions) (*tsdb.Head, []*storepb.Series)

+ func RunSeriesInterestingCases(t testutil.TB, maxSamples, maxSeries int, ...)

+ func TestServerSeries(t testutil.TB, store storepb.StoreServer, cases ...*SeriesCase)

+ type HeadGenOptions struct

+ PrependLabels labels.Labels

+ Random *rand.Rand

+ SamplesPerSeries int

+ Series int

+ SkipChunks bool

+ TSDBDir string

+ WithWAL bool

+ type SeriesCase struct

+ ExpectedHints []hintspb.SeriesResponseHints

+ ExpectedSeries []*storepb.Series

+ ExpectedWarnings []string

+ Name string

+ Req *storepb.SeriesRequest

+ type SeriesServer struct

+ HintsSet []*types.Any

+ SeriesSet []*storepb.Series

+ Size int64

+ Warnings []string

+ func NewSeriesServer(ctx context.Context) *SeriesServer

+ func (s *SeriesServer) Context() context.Context

+ func (s *SeriesServer) Send(r *storepb.SeriesResponse) error