MCPcopy Index your code
hub / github.com/cortexproject/cortex / NewSingleBinary

Function NewSingleBinary

integration/e2ecortex/services.go:329–362  ·  view source on GitHub ↗
(name string, flags map[string]string, image string, otherPorts ...int)

Source from the content-addressed store, hash-verified

327}
328
329func NewSingleBinary(name string, flags map[string]string, image string, otherPorts ...int) *CortexService {
330 if image == "" {
331 image = GetDefaultImage()
332 }
333
334 return NewCortexService(
335 name,
336 image,
337 e2e.NewCommandWithoutEntrypoint("cortex", e2e.BuildArgs(e2e.MergeFlags(map[string]string{
338 "-target": "all",
339 "-log.level": "warn",
340 "-auth.enabled": "true",
341 // Query-frontend worker.
342 "-querier.frontend-client.backoff-min-period": "100ms",
343 "-querier.frontend-client.backoff-max-period": "100ms",
344 "-querier.frontend-client.backoff-retries": "1",
345 "-querier.worker-parallelism": "1",
346 // Distributor.
347 "-distributor.replication-factor": "1",
348 // Ingester.
349 "-ingester.final-sleep": "0s",
350 "-ingester.join-after": "0s",
351 "-ingester.min-ready-duration": "0s",
352 "-ingester.num-tokens": "512",
353 // Startup quickly.
354 "-store-gateway.sharding-ring.wait-stability-min-duration": "0",
355 "-store-gateway.sharding-ring.wait-stability-max-duration": "0",
356 }, flags))...),
357 e2e.NewHTTPReadinessProbe(httpPort, "/ready", 200, 299),
358 httpPort,
359 grpcPort,
360 otherPorts...,
361 )
362}
363
364func NewSingleBinaryWithConfigFile(name string, configFile string, flags map[string]string, image string, httpPort, grpcPort int, otherPorts ...int) *CortexService {
365 if image == "" {

Calls 6

BuildArgsFunction · 0.92
MergeFlagsFunction · 0.92
NewHTTPReadinessProbeFunction · 0.92
GetDefaultImageFunction · 0.85
NewCortexServiceFunction · 0.85