Add stream and sources subject mappings

Signed-off-by: Tomasz Pietrek <tomasz@nats.io>
nats-io · Sep 22, 2023 · 44512a0 · 44512a0
1 parent c8510d6
commit 44512a0
Show file tree

Hide file tree

Showing 5 changed files with 73 additions and 9 deletions.
diff --git a/controllers/jetstream/stream.go b/controllers/jetstream/stream.go
@@ -681,5 +681,12 @@ func getStreamSource(ss *apis.StreamSource) (*jsmapi.StreamSource, error) {
 		}
 	}
 
+	for _, transform := range ss.SubjectTransforms {
+		jss.SubjectTransforms = append(jss.SubjectTransforms, jsmapi.SubjectTransformConfig{
+			Source:      transform.Source,
+			Destination: transform.Dest,
+		})
+	}
+
 	return jss, nil
 }
diff --git a/deploy/crds.yml b/deploy/crds.yml
@@ -117,6 +117,19 @@ spec:
                     type: string
                   externalDeliverPrefix:
                     type: string
+                  subjectTransforms:
+                    description: List of subject transforms for this mirror.
+                    type: array
+                    items:
+                      description: A subject transform pair.
+                      type: object
+                      properties:
+                        source:
+                          description: Source subject.
+                          type: string
+                        dest:
+                          description: Destination subject.
+                          type: string
               placement:
                 description: A stream's placement.
                 type: object
@@ -146,6 +159,19 @@ spec:
                       type: string
                     externalDeliverPrefix:
                       type: string
+                    subjectTransforms:
+                      description: List of subject transforms for this mirror.
+                      type: array
+                      items:
+                        description: A subject transform pair.
+                        type: object
+                        properties:
+                          source:
+                            description: Source subject.
+                            type: string
+                          dest:
+                            description: Destination subject.
+                            type: string
               servers:
                 description: A list of servers for creating stream
                 type: array
@@ -209,7 +235,7 @@ spec:
                     description: Source subject
                   dest:
                     type: string
-                    description: Destination subject to transform to
+                    description: Destination subject to transform into
               preventDelete:
                 description: When true, the managed Stream will not be deleted when the resource is deleted
                 type: boolean

diff --git a/pkg/jetstream/apis/jetstream/v1beta2/streamtypes.go b/pkg/jetstream/apis/jetstream/v1beta2/streamtypes.go
@@ -75,6 +75,8 @@ type StreamSource struct {
 
 	ExternalAPIPrefix     string `json:"externalApiPrefix"`
 	ExternalDeliverPrefix string `json:"externalDeliverPrefix"`
+
+	SubjectTransforms []*SubjectTransform `json:"subjectTransforms"`
 }
 
 type RePublish struct {

diff --git a/pkg/jetstream/apis/jetstream/v1beta2/zz_generated.deepcopy.go b/pkg/jetstream/apis/jetstream/v1beta2/zz_generated.deepcopy.go
diff --git a/pkg/jetstream/generated/applyconfiguration/jetstream/v1beta2/streamsource.go b/pkg/jetstream/generated/applyconfiguration/jetstream/v1beta2/streamsource.go