Function NewIngesterWithConfigFile

integration/e2ecortex/services.go:172–205

(name string, store RingStore, address, configFile string, flags map[string]string, image string)

}

func NewIngesterWithConfigFile(name string, store RingStore, address, configFile string, flags map[string]string, image string) *CortexService {
	if configFile != "" {
		flags["-config.file"] = filepath.Join(e2e.ContainerSharedDir, configFile)
	}

	// Configure the ingesters ring backend
	flags["-ring.store"] = string(store)
	switch store {
	case RingStoreConsul:
		flags["-consul.hostname"] = address
	case RingStoreEtcd:
		flags["-etcd.endpoints"] = address
	}

	if image == "" {
		image = GetDefaultImage()
	}

	return NewCortexService(
		name,
		image,
		e2e.NewCommandWithoutEntrypoint("cortex", e2e.BuildArgs(e2e.MergeFlags(map[string]string{
			"-target":                      "ingester",
			"-log.level":                   "warn",
			"-ingester.final-sleep":        "0s",
			"-ingester.join-after":         "0s",
			"-ingester.min-ready-duration": "0s",
			"-ingester.num-tokens":         "512",
		}, flags))...),
		e2e.NewHTTPReadinessProbe(httpPort, "/ready", 200, 299),
		httpPort,
		grpcPort,
	)
}

func NewParquetConverter(name string, store RingStore, address string, flags map[string]string, image string) *CortexService {
	return NewParquetConverterWithConfigFile(name, store, address, "", flags, image)