Changes

Signed-off-by: Byron Ruth <[email protected]>

examples/use-cases/faux-active-active/cli/main.sh

@@ -51,17 +51,26 @@ curl --fail --silent \
   http://localhost:8222/healthz > /dev/null
 
 # Create the two streams with their own respective subjects.
-nats stream add --config n1.json
-nats stream add --config n2.json
+nats kv add n1 --history=10
+nats kv add n2 --history=10
 
 # Edit the streams to source from each other, filtered to the
 # stream's bounded subject.
-nats stream edit --force --config n1-edit.json n1
-nats stream edit --force --config n2-edit.json n2
+nats stream edit --force --config n1-edit.json KV_n1
+nats stream edit --force --config n2-edit.json KV_n2
 
 # Publish a message to each stream.
-nats req 'n1.1' ''
-nats req 'n2.1' ''
+nats kv put n1 foo
+nats kv put n2 bar
 
 # Both streams should have two messages (in different orders).
+echo 'List n1:'
+nats kv list n1
+nats stream view KV_n1
+
+echo 'List n2:'
+nats kv list n2
+nats stream view KV_n2
+
+nats stream report
 nats stream report

examples/use-cases/faux-active-active/cli/n1-edit.json

@@ -1,30 +1,29 @@
 {
-  "name": "n1",
+  "name": "KV_n1",
   "subjects": [
-    "n1.\u003e"
+    "$KV.n1.\u003e"
   ],
   "retention": "limits",
   "max_consumers": -1,
-  "max_msgs_per_subject": -1,
+  "max_msgs_per_subject": 5,
   "max_msgs": -1,
   "max_bytes": -1,
   "max_age": 0,
   "max_msg_size": -1,
   "storage": "file",
-  "discard": "old",
+  "discard": "new",
   "num_replicas": 1,
   "duplicate_window": 12000000000,
   "sealed": false,
-  "deny_delete": false,
+  "deny_delete": true,
   "deny_purge": false,
   "allow_rollup_hdrs": true,
+  "allow_direct": true,
   "sources": [
     {
-      "name": "n2",
-      "filter_subject": "n2.\u003e",
-      "opt_start_seq": 0,
-      "opt_start_time": "0001-01-01T00:00:00Z",
-      "external": null
+      "name": "KV_n2",
+      "filter_subject": "$KV.n2.\u003e",
+      "subject_transform_dest": "$KV.n1.\u003e"
     }
   ]
 }

examples/use-cases/faux-active-active/cli/n1.json

@@ -1,11 +1,11 @@
 {
-  "name": "n1",
+  "name": "KV_n1",
   "subjects": [
     "n1.\u003e"
   ],
   "retention": "limits",
   "max_consumers": -1,
-  "max_msgs_per_subject": -1,
+  "max_msgs_per_subject": 10,
   "max_msgs": -1,
   "max_bytes": -1,
   "max_age": 0,

examples/use-cases/faux-active-active/cli/n2-edit.json

@@ -1,27 +1,29 @@
 {
-  "name": "n2",
+  "name": "KV_n2",
   "subjects": [
-    "n2.\u003e"
+    "$KV.n2.\u003e"
   ],
   "retention": "limits",
   "max_consumers": -1,
-  "max_msgs_per_subject": -1,
+  "max_msgs_per_subject": 5,
   "max_msgs": -1,
   "max_bytes": -1,
   "max_age": 0,
   "max_msg_size": -1,
   "storage": "file",
-  "discard": "old",
+  "discard": "new",
   "num_replicas": 1,
   "duplicate_window": 12000000000,
   "sealed": false,
-  "deny_delete": false,
+  "deny_delete": true,
   "deny_purge": false,
   "allow_rollup_hdrs": true,
+  "allow_direct": true,
   "sources": [
     {
-      "name": "n1",
-      "filter_subject": "n1.\u003e"
+      "name": "KV_n1",
+      "filter_subject": "$KV.n1.\u003e",
+      "subject_transform_dest": "$KV.n2.\u003e"
     }
   ]
 }

examples/use-cases/faux-active-active/cli/n2.json

@@ -1,11 +1,11 @@
 {
-  "name": "n2",
+  "name": "KV_n2",
   "subjects": [
     "n2.\u003e"
   ],
   "retention": "limits",
   "max_consumers": -1,
-  "max_msgs_per_subject": -1,
+  "max_msgs_per_subject": 10,
   "max_msgs": -1,
   "max_bytes": -1,
   "max_age": 0,