Update NATS JetStream Stream CRD (#776)

Author: oliverlambson

jetstream.nats.io/stream_v1beta2.json

@@ -7,9 +7,29 @@
             "pattern": "^[^.*>]*$",
             "type": "string"
           },
+          "allowAtomicPublish": {
+            "default": false,
+            "description": "When true, enables atomic batch publishing.",
+            "type": "boolean"
+          },
           "allowDirect": {
             "default": false,
-            "description": "When true, allow higher performance, direct access to get individual messages",
+            "description": "When true, allow higher performance, direct access to get individual messages.",
+            "type": "boolean"
+          },
+          "allowMsgCounter": {
+            "default": false,
+            "description": "When true, enables message counters for the stream.",
+            "type": "boolean"
+          },
+          "allowMsgSchedules": {
+            "default": false,
+            "description": "When true, enables message scheduling.",
+            "type": "boolean"
+          },
+          "allowMsgTtl": {
+            "default": false,
+            "description": "When true, allows header initiated per-message TTLs. If disabled, then the `NATS-TTL` header will be ignored.",
             "type": "boolean"
           },
           "allowRollup": {
@@ -27,16 +47,36 @@
             ],
             "type": "string"
           },
+          "consumerLimits": {
+            "description": "Consumer limits for the stream.",
+            "properties": {
+              "inactiveThreshold": {
+                "description": "The duration of inactivity after which a consumer is considered inactive.",
+                "type": "string"
+              },
+              "maxAckPending": {
+                "description": "Maximum number of outstanding unacknowledged messages.",
+                "type": "integer"
+              }
+            },
+            "type": "object",
+            "additionalProperties": false
+          },
           "creds": {
             "default": "",
-            "description": "NATS user credentials for connecting to servers. Please make sure your controller has mounted the cerds on its path.",
+            "description": "NATS user credentials for connecting to servers. Please make sure your controller has mounted the creds on this path.",
             "type": "string"
           },
           "denyDelete": {
             "default": false,
             "description": "When true, restricts the ability to delete messages from a stream via the API. Cannot be changed once set to true.",
             "type": "boolean"
           },
+          "denyPurge": {
+            "default": false,
+            "description": "When true, restricts the ability to purge a stream via the API. Cannot be changed once set to true.",
+            "type": "boolean"
+          },
           "description": {
             "description": "The description of the stream.",
             "type": "string"
@@ -52,7 +92,7 @@
           },
           "discardPerSubject": {
             "default": false,
-            "description": "Allows to discard messages on a subject basis.",
+            "description": "Applies discard policy on a per-subject basis. Requires discard policy 'new' and 'maxMsgs' to be set.",
             "type": "boolean"
           },
           "duplicateWindow": {
@@ -64,6 +104,10 @@
             "description": "Sequence number from which the Stream will start.",
             "type": "number"
           },
+          "jsDomain": {
+            "description": "The JetStream domain to use for the stream.",
+            "type": "string"
+          },
           "maxAge": {
             "default": "",
             "description": "Maximum age of any message in the stream, expressed in Go's time.Duration format. Empty for unlimited.",
@@ -95,7 +139,7 @@
           },
           "maxMsgsPerSubject": {
             "default": 0,
-            "description": "The maximum of messages per subject.",
+            "description": "The maximum number of messages per subject.",
             "type": "integer"
           },
           "metadata": {
@@ -150,6 +194,11 @@
             "type": "object",
             "additionalProperties": false
           },
+          "mirrorDirect": {
+            "default": false,
+            "description": "When true, enables direct access to messages from the origin stream.",
+            "type": "boolean"
+          },
           "name": {
             "description": "A unique name for the Stream.",
             "minLength": 1,
@@ -166,6 +215,11 @@
             "description": "Disables acknowledging messages that are received by the Stream.",
             "type": "boolean"
           },
+          "persistMode": {
+            "default": "",
+            "description": "Configures stream persistence settings (async or default).",
+            "type": "string"
+          },
           "placement": {
             "description": "A stream's placement.",
             "properties": {
@@ -184,12 +238,12 @@
           },
           "preventDelete": {
             "default": false,
-            "description": "When true, the managed Stream will not be deleted when the resource is deleted",
+            "description": "When true, the managed Stream will not be deleted when the resource is deleted.",
             "type": "boolean"
           },
           "preventUpdate": {
             "default": false,
-            "description": "When true, the managed Stream will not be updated when the resource is updated",
+            "description": "When true, the managed Stream will not be updated when the resource is updated.",
             "type": "boolean"
           },
           "replicas": {
@@ -202,11 +256,11 @@
             "description": "Republish configuration of the stream.",
             "properties": {
               "destination": {
-                "description": "Messages will be additionally published to that subject.",
+                "description": "Messages will be additionally published to this subject.",
                 "type": "string"
               },
               "source": {
-                "description": "Messages will be published from that subject to the destination subject.",
+                "description": "Messages will be published from this subject to the destination subject.",
                 "type": "string"
               }
             },
@@ -223,9 +277,14 @@
             ],
             "type": "string"
           },
+          "sealed": {
+            "default": false,
+            "description": "Seal an existing stream so no new messages may be added.",
+            "type": "boolean"
+          },
           "servers": {
             "default": [],
-            "description": "A list of servers for creating stream",
+            "description": "A list of servers for creating stream.",
             "items": {
               "type": "string"
             },
@@ -288,15 +347,20 @@
             ],
             "type": "string"
           },
+          "subjectDeleteMarkerTtl": {
+            "default": "",
+            "description": "Enables and sets a duration for adding server markers for delete, purge and max age limits.",
+            "type": "string"
+          },
           "subjectTransform": {
-            "description": "SubjectTransform is for applying a subject transform (to matching messages) when a new message is received",
+            "description": "SubjectTransform is for applying a subject transform (to matching messages) when a new message is received.",
             "properties": {
               "dest": {
-                "description": "Destination subject to transform into",
+                "description": "Destination subject to transform into.",
                 "type": "string"
               },
               "source": {
-                "description": "Source subject",
+                "description": "Source subject.",
                 "type": "string"
               }
             },
@@ -333,6 +397,11 @@
             },
             "type": "object",
             "additionalProperties": false
+          },
+          "tlsFirst": {
+            "default": false,
+            "description": "When true, the KV Store will initiate TLS before server INFO.",
+            "type": "boolean"
           }
         },
         "type": "object",
@@ -374,4 +443,3 @@
     },
     "type": "object"
   }
-