add replicas in instance config

Signed-off-by: Thibault Mange <[email protected]>
rhobs · Sep 25, 2023 · b94992a · b94992a
1 parent d000c98
commit b94992a
Show file tree

Hide file tree

Showing 3 changed files with 17 additions and 16 deletions.
diff --git a/services_go/instances/rhobs/rhobs.go b/services_go/instances/rhobs/rhobs.go
@@ -7,16 +7,18 @@ import (
 func ClusterConfigs() []observatorium.InstanceConfiguration {
 	return []observatorium.InstanceConfiguration{
 		{
-			Cluster:   "app-sre-stage-01",
-			Namespace: "rhobs",
-			Instance:  "rhobs",
-			Tenants:   []observatorium.TenantInstanceConfiguration{},
+			Cluster:             "app-sre-stage-01",
+			Namespace:           "rhobs",
+			Instance:            "rhobs",
+			Tenants:             []observatorium.TenantInstanceConfiguration{},
+			ThanosStoreReplicas: 2,
 		},
 		{
-			Cluster:   "telemeter-prod-01",
-			Namespace: "rhobs",
-			Instance:  "rhobs",
-			Tenants:   []observatorium.TenantInstanceConfiguration{},
+			Cluster:             "telemeter-prod-01",
+			Namespace:           "rhobs",
+			Instance:            "rhobs",
+			Tenants:             []observatorium.TenantInstanceConfiguration{},
+			ThanosStoreReplicas: 3,
 		},
 	}
 }
diff --git a/services_go/observatorium/metrics.go b/services_go/observatorium/metrics.go
@@ -60,9 +60,8 @@ func makeCompactor(namespace string) (*compactor.CompactorStatefulSet, []PostPro
 
 }
 
-func makeStore(namespace string) (*store.StoreStatefulSet, []PostProcessFunc) {
+func makeStore(namespace string, replicas int32) (*store.StoreStatefulSet, []PostProcessFunc) {
 	// K8s config
-	replicas := int32(1)
 	storeStatefulSet := store.NewStore()
 	storeStatefulSet.Image = thanosImage
 	storeStatefulSet.ImageTag = thanosImageTag

diff --git a/services_go/observatorium/observatorium.go b/services_go/observatorium/observatorium.go
@@ -32,11 +32,11 @@ type TenantInstanceConfiguration struct {
 // type ComponentsConfig struct {
 
 type InstanceConfiguration struct {
-	Cluster   string
-	Instance  string
-	Namespace string
-	Tenants   []TenantInstanceConfiguration
-	// Components
+	Cluster             string
+	Instance            string
+	Namespace           string
+	Tenants             []TenantInstanceConfiguration
+	ThanosStoreReplicas int32
 }
 
 type PostProcessFunc func(obj runtime.Object)
@@ -50,7 +50,7 @@ type Observatorium struct {
 
 func NewObservatorium(cfg *InstanceConfiguration) *Observatorium {
 	postProcessFuncs := []PostProcessFunc{updateServiceMonitorNamespace}
-	storeComponent, postProcess := makeStore(cfg.Namespace)
+	storeComponent, postProcess := makeStore(cfg.Namespace, cfg.ThanosStoreReplicas)
 	postProcessFuncs = append(postProcessFuncs, postProcess...)
 	compactorComponent, postProcess := makeCompactor(cfg.Namespace)
 	postProcessFuncs = append(postProcessFuncs, postProcess...)