Function NewRuler

integration/e2ecortex/services.go:425–449

(name string, consulAddress string, flags map[string]string, image string)

}

func NewRuler(name string, consulAddress string, flags map[string]string, image string) *CortexService {
	if image == "" {
		image = GetDefaultImage()
	}

	return NewCortexService(
		name,
		image,
		e2e.NewCommandWithoutEntrypoint("cortex", e2e.BuildArgs(e2e.MergeFlags(map[string]string{
			"-target":    "ruler",
			"-log.level": "warn",
			// Configure the ring backend
			"-ring.store":                                  "consul",
			"-store-gateway.sharding-ring.store":           "consul",
			"-consul.hostname":                             consulAddress,
			"-store-gateway.sharding-ring.consul.hostname": consulAddress,
			// Store-gateway ring backend.
			"-store-gateway.sharding-enabled":                 "true",
			"-store-gateway.sharding-ring.replication-factor": "1",
		}, flags))...),
		e2e.NewHTTPReadinessProbe(httpPort, "/ready", 200, 299),
		httpPort,
		grpcPort,
	)
}