From aed8db644de71a4995a75fe37adca4d54c70759f Mon Sep 17 00:00:00 2001 From: Grigoriy Narizhnyy Date: Wed, 26 Jan 2022 17:15:48 +0300 Subject: [PATCH] Add defaultReplication command line parameter from CR value --- controllers/controller_master_statefulset.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/controllers/controller_master_statefulset.go b/controllers/controller_master_statefulset.go index 6c9e55c..1e95f18 100644 --- a/controllers/controller_master_statefulset.go +++ b/controllers/controller_master_statefulset.go @@ -31,6 +31,10 @@ func buildMasterStartupScript(m *seaweedv1.Seaweed) string { command = append(command, fmt.Sprintf("-pulseSeconds=%d", *spec.PulseSeconds)) } + if spec.DefaultReplication != nil { + command = append(command, fmt.Sprintf("-defaultReplication=%s", *spec.DefaultReplication)) + } + command = append(command, fmt.Sprintf("-ip=$(POD_NAME).%s-master-peer.%s", m.Name, m.Namespace)) command = append(command, fmt.Sprintf("-peers=%s", getMasterPeersString(m))) return strings.Join(command, " ")