Add stream metadata support

Signed-off-by: Tomasz Pietrek <[email protected]>

Author: Jarema

Diff for: controllers/jetstream/stream.go

@@ -434,6 +434,10 @@ func createStream(ctx context.Context, c jsmClient, spec apis.StreamSpec) (err e
 		opts = append(opts, jsm.FirstSequence(uint64(spec.FirstSequence)))
 	}
 
+	if spec.Metadata != nil {
+		opts = append(opts, jsm.StreamMetadata(spec.Metadata))
+	}
+
 	_, err = c.NewStream(ctx, spec.Name, opts)
 	return err
 }
@@ -519,6 +523,10 @@ func updateStream(ctx context.Context, c jsmClient, spec apis.StreamSpec) (err e
 		config.Sources[i] = jss
 	}
 
+	if spec.Metadata != nil {
+		config.Metadata = spec.Metadata
+	}
+
 	switch spec.Compression {
 	case "s2":
 		config.Compression = api.S2Compression

Diff for: deploy/crds.yml

@@ -172,6 +172,11 @@ spec:
                           dest:
                             description: Destination subject.
                             type: string
+              metadata:
+                description: Additional Stream metadata.
+                type: object
+                additionalProperties:
+                  type: string
               servers:
                 description: A list of servers for creating stream
                 type: array

Diff for: pkg/jetstream/apis/jetstream/v1beta2/streamtypes.go

@@ -49,6 +49,7 @@ type StreamSpec struct {
 	SubjectTransform  *SubjectTransform `json:"subjectTransform"`
 	FirstSequence     uint64            `json:"firstSequence"`
 	Compression       string            `json:"compression"`
+	Metadata          map[string]string `json:"metadata"`
 	Retention         string            `json:"retention"`
 	Servers           []string          `json:"servers"`
 	Sources           []*StreamSource   `json:"sources"`