Fix setting placement on stream update

piotrpio · piotrpio · commit 790ca284e196 · 2024-03-18T17:32:29.000+01:00
Signed-off-by: Piotr Piotrowski &lt;piotr@synadia.com&gt;
diff --git a/controllers/jetstream/stream.go b/controllers/jetstream/stream.go
@@ -514,6 +514,13 @@ func updateStream(ctx context.Context, c jsmClient, spec apis.StreamSpec) (err e
 		config.Sources[i] = jss
 	}
 
+	if spec.Placement != nil {
+		config.Placement = &jsmapi.Placement{
+			Cluster: spec.Placement.Cluster,
+			Tags:    spec.Placement.Tags,
+		}
+	}
+
 	if spec.Metadata != nil {
 		config.Metadata = spec.Metadata
 	}

Original file line number	Diff line number	Diff line change
`@@ -514,6 +514,13 @@ func updateStream(ctx context.Context, c jsmClient, spec apis.StreamSpec) (err e`
`514`	`514`	`config.Sources[i] = jss`
`515`	`515`	`}`
`516`	`516`
	`517`	`+ if spec.Placement != nil {`
	`518`	`+ config.Placement = &jsmapi.Placement{`
	`519`	`+ Cluster: spec.Placement.Cluster,`
	`520`	`+ Tags: spec.Placement.Tags,`
	`521`	`+ }`
	`522`	`+ }`
	`523`	`+`
`517`	`524`	`if spec.Metadata != nil {`
`518`	`525`	`config.Metadata = spec.Metadata`
`519`	`526`	`}`