Merge pull request #233 from batchcorp/blinktag/send_dynamic_id

Passing DynamicID into dproxy's AuthRequest()
streamdal · Feb 14, 2022 · bca5e9b · bca5e9b
2 parents c550ec5 + d1c5d82
commit bca5e9b
Show file tree

Hide file tree

Showing 5 changed files with 47 additions and 44 deletions.
diff --git a/dynamic/dynamic.go b/dynamic/dynamic.go
@@ -261,6 +261,7 @@ func (d *Client) connect(ctx context.Context, bus string) (services.DProxy_Conne
 				MessageBus:       bus,
 				PlumberClusterId: d.PlumberClusterID,
 				Name:             d.Options.Name,
+				DynamicId:        d.Options.XDynamicId,
 			},
 		},
 	}

diff --git a/go.mod b/go.mod
@@ -8,7 +8,7 @@ require (
 	github.com/Azure/azure-service-bus-go v0.11.5
 	github.com/apache/pulsar-client-go v0.7.0
 	github.com/aws/aws-sdk-go v1.34.28
-	github.com/batchcorp/collector-schemas v0.0.13
+	github.com/batchcorp/collector-schemas v0.0.14
 	github.com/batchcorp/kong v0.2.17-batch-fix
 	github.com/batchcorp/natty v0.0.16
 	github.com/batchcorp/pgoutput v0.3.2

diff --git a/go.sum b/go.sum
@@ -119,6 +119,8 @@ github.com/batchcorp/collector-schemas v0.0.12 h1:IfSPmdQBy5oi++wZt0DOi7+8U1f4lz
 github.com/batchcorp/collector-schemas v0.0.12/go.mod h1:qSVA1UcrApoLX2mS4cj+aH+IvNwcSfm50vWa0UAN/WU=
 github.com/batchcorp/collector-schemas v0.0.13 h1:zgQ969GJd0qmMz5jYW00b4NWlrnnSYmPskohBooXV6Q=
 github.com/batchcorp/collector-schemas v0.0.13/go.mod h1:qSVA1UcrApoLX2mS4cj+aH+IvNwcSfm50vWa0UAN/WU=
+github.com/batchcorp/collector-schemas v0.0.14 h1:gZILTtA/BzKC03O0obZ0IKnGpTc30cqoY/qr3RDlcGM=
+github.com/batchcorp/collector-schemas v0.0.14/go.mod h1:qSVA1UcrApoLX2mS4cj+aH+IvNwcSfm50vWa0UAN/WU=
 github.com/batchcorp/kong v0.2.17-batch-fix h1:H6sOfst2NcL2T/EZVNLukG7YRimJDHg9DhbRq7gE+KQ=
 github.com/batchcorp/kong v0.2.17-batch-fix/go.mod h1:ut4pbR4KLPWzKHbpEHZspWpRqjFr4UiPY3D2xf2tzf8=
 github.com/batchcorp/natty v0.0.15 h1:+Bz8jYUYaCJBK8WsiITJhWUNNlAi3CyKsGfW1Q6A2io=

diff --git a/vendor/github.com/batchcorp/collector-schemas/build/go/protos/events/dynamic_replay.pb.go b/vendor/github.com/batchcorp/collector-schemas/build/go/protos/events/dynamic_replay.pb.go
diff --git a/vendor/modules.txt b/vendor/modules.txt
@@ -129,7 +129,7 @@ github.com/aws/aws-sdk-go/service/sqs
 github.com/aws/aws-sdk-go/service/sqs/sqsiface
 github.com/aws/aws-sdk-go/service/sts
 github.com/aws/aws-sdk-go/service/sts/stsiface
-# github.com/batchcorp/collector-schemas v0.0.13
+# github.com/batchcorp/collector-schemas v0.0.14
 ## explicit
 github.com/batchcorp/collector-schemas/build/go/protos/common
 github.com/batchcorp/collector-schemas/build/go/protos/events