Merge pull request #341 from batchcorp/blinktag/azure_write_fix

Doc and Azure Service Bus fixes
streamdal · Feb 27, 2023 · 361fd81 · 361fd81
2 parents 0fd38f1 + c65e929
commit 361fd81
Show file tree

Hide file tree

Showing 8 changed files with 93 additions and 93 deletions.
diff --git a/README.md b/README.md
@@ -115,7 +115,7 @@ INFO[0000] Successfully wrote message to topic 'foo'  pkg=kafka/write.go
 $ cat mydata.json
 [{"key": "value1"},{"key": "value2"}]
 
-$ cat mydata.json | plumber write kafka --topics foo --json-array
+$ cat mydata.json | plumber write kafka --topics foo --input-as-json-array
 
 INFO[0000] Successfully wrote message to topic 'foo'  pkg=kafka/write.go
 INFO[0000] Successfully wrote message to topic 'foo'  pkg=kafka/write.go

diff --git a/docs/examples.md b/docs/examples.md
@@ -379,15 +379,15 @@ Publishing to a topic
 ```bash
 export SERVICEBUS_CONNECTION_STRING="Endpoint=sb://plumbertopictest.servicebus.windows.net/;SharedAccessKeyName=...."
 
-plumber write azure --topic="new-orders" --input="{\"order_id\": \"A-3458-654-1\", \"status\": \"processed\"}"
+plumber write azure-service-bus --topic="new-orders" --input="{\"order_id\": \"A-3458-654-1\", \"status\": \"processed\"}"
 ```
 
 Publishing to a queue
 
 ```bash
 export SERVICEBUS_CONNECTION_STRING="Endpoint=sb://plumbertopictest.servicebus.windows.net/;SharedAccessKeyName=...."
 
-plumber write azure --queue="new-orders" --input="{\"order_id\": \"A-3458-654-1\", \"status\": \"processed\"}"
+plumber write azure-service-bus --queue="new-orders" --input="{\"order_id\": \"A-3458-654-1\", \"status\": \"processed\"}"
 ```
 
 ##### Azure Event Hub

diff --git a/go.mod b/go.mod
@@ -15,7 +15,7 @@ require (
 	github.com/batchcorp/kong v0.2.17-batch-fix
 	github.com/batchcorp/natty v0.0.16
 	github.com/batchcorp/pgoutput v0.3.2
-	github.com/batchcorp/plumber-schemas v0.0.177
+	github.com/batchcorp/plumber-schemas v0.0.178
 	github.com/batchcorp/rabbit v0.1.17
 	github.com/batchcorp/thrifty v0.0.10
 	github.com/eclipse/paho.mqtt.golang v1.2.0

diff --git a/go.sum b/go.sum
@@ -125,8 +125,8 @@ github.com/batchcorp/natty v0.0.16 h1:RN20W2rlA1GtPzY3ioYIjqY0UlIFnH9Rs2c1nWajxc
 github.com/batchcorp/natty v0.0.16/go.mod h1:9vbgoZghKr/2FtueAquAlRacCSnEgfgTSA2eX2gpO54=
 github.com/batchcorp/pgoutput v0.3.2 h1:Jck/nJLwXWmsNHF2iEfjFWrsds5LLGtqu6y6TjjU8Aw=
 github.com/batchcorp/pgoutput v0.3.2/go.mod h1:xzkr73rAlqUdvt2oMAQav1lIt6xnG8bqYYXt4GrXM/I=
-github.com/batchcorp/plumber-schemas v0.0.177 h1:2u+1VPTUpFexl+u/H1tlSMiJV9OPzlQjXJLqeWgzJqs=
-github.com/batchcorp/plumber-schemas v0.0.177/go.mod h1:KxBXjHwZhPZoJryfv0c+aGFntx+rw2euYOqcNgqQlik=
+github.com/batchcorp/plumber-schemas v0.0.178 h1:wgp0oHIiMr2qJ8CjLjOh5bjKZILCfpVEJxPQ5yzOEiI=
+github.com/batchcorp/plumber-schemas v0.0.178/go.mod h1:KxBXjHwZhPZoJryfv0c+aGFntx+rw2euYOqcNgqQlik=
 github.com/batchcorp/plz v0.9.2 h1:bPqb+sn7OUrpHjeTEI9YO4BJS9IQ7AstDDz2gn+tcn8=
 github.com/batchcorp/plz v0.9.2/go.mod h1:3gacX+hQo+xvl0vtLqCMufzxuNCwt4geAVOMt2LQYfE=
 github.com/batchcorp/rabbit v0.1.17 h1:dui1W7FLTrNxyVlDN+G+6d8LXz8HBhVAcUethXql9vQ=

diff --git a/main.go b/main.go
@@ -190,7 +190,7 @@ func convertJSONInput(value string) []string {
 
 	jsonArray := gjson.Parse(value)
 	if !jsonArray.IsArray() {
-		logrus.Fatal("--json-array option was passed, but input data is not a valid JSON array")
+		logrus.Fatal("--input-as-json-array option was passed, but input data is not a valid JSON array")
 	}
 
 	jsonArray.ForEach(func(key, value gjson.Result) bool {

diff --git a/...github.com/batchcorp/plumber-schemas/build/go/protos/args/ps_args_azure_service_bus.pb.go b/...github.com/batchcorp/plumber-schemas/build/go/protos/args/ps_args_azure_service_bus.pb.go
diff --git a/.../github.com/batchcorp/plumber-schemas/build/go/protos/opts/batch_connection_options.pb.go b/.../github.com/batchcorp/plumber-schemas/build/go/protos/opts/batch_connection_options.pb.go
diff --git a/vendor/modules.txt b/vendor/modules.txt
@@ -164,7 +164,7 @@ github.com/batchcorp/natty
 # github.com/batchcorp/pgoutput v0.3.2
 ## explicit; go 1.15
 github.com/batchcorp/pgoutput
-# github.com/batchcorp/plumber-schemas v0.0.177
+# github.com/batchcorp/plumber-schemas v0.0.178
 ## explicit; go 1.16
 github.com/batchcorp/plumber-schemas/build/go/protos
 github.com/batchcorp/plumber-schemas/build/go/protos/args