From b21756ad7a66c29a3c28f19b66bcab15880ec82f Mon Sep 17 00:00:00 2001 From: Abel Simon Date: Tue, 17 Dec 2024 22:43:07 +0100 Subject: [PATCH] chore: fix base branch diff --- test/e2e/e2ethanos/services.go | 39 ++++++++++++++++++++++------------ 1 file changed, 25 insertions(+), 14 deletions(-) diff --git a/test/e2e/e2ethanos/services.go b/test/e2e/e2ethanos/services.go index fad7e52df5..5e0a005c48 100644 --- a/test/e2e/e2ethanos/services.go +++ b/test/e2e/e2ethanos/services.go @@ -546,20 +546,21 @@ type ReceiveBuilder struct { f e2e.FutureRunnable - maxExemplars int - capnp bool - ingestion bool - limit int - tenantsLimits receive.TenantsWriteLimitsConfig - metaMonitoring string - metaMonitoringQuery string - hashringConfigs []receive.HashringConfig - relabelConfigs []*relabel.Config - replication int - image string - nativeHistograms bool - labels []string - tenantSplitLabel string + maxExemplars int + capnp bool + ingestion bool + expandedPostingsCache bool + limit int + tenantsLimits receive.TenantsWriteLimitsConfig + metaMonitoring string + metaMonitoringQuery string + hashringConfigs []receive.HashringConfig + relabelConfigs []*relabel.Config + replication int + image string + nativeHistograms bool + labels []string + tenantSplitLabel string } func NewReceiveBuilder(e e2e.Environment, name string) *ReceiveBuilder { @@ -590,6 +591,11 @@ func (r *ReceiveBuilder) WithIngestionEnabled() *ReceiveBuilder { return r } +func (r *ReceiveBuilder) WithExpandedPostingsCache() *ReceiveBuilder { + r.expandedPostingsCache = true + return r +} + func (r *ReceiveBuilder) WithLabel(name, value string) *ReceiveBuilder { r.labels = append(r.labels, fmt.Sprintf(`%s="%s"`, name, value)) return r @@ -669,6 +675,11 @@ func (r *ReceiveBuilder) Init() *e2eobs.Observable { args["--receive.local-endpoint"] = r.InternalEndpoint("grpc") } + if r.expandedPostingsCache { + args["--tsdb.head.expanded-postings-cache-size"] = "1000" + args["--tsdb.block.expanded-postings-cache-size"] = "1000" + } + if r.limit != 0 && r.metaMonitoring != "" { cfg := receive.RootLimitsConfig{ WriteLimits: receive.WriteLimitsConfig{