From 5785cf628c531e9e3fb7744406f18e4f784b3fac Mon Sep 17 00:00:00 2001 From: Jim Marino Date: Fri, 3 Oct 2025 12:14:26 +0200 Subject: [PATCH 1/2] Fix typo --- examples/sync-pull-dataplane/main.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/examples/sync-pull-dataplane/main.go b/examples/sync-pull-dataplane/main.go index 3d4f436..3e1bc1b 100644 --- a/examples/sync-pull-dataplane/main.go +++ b/examples/sync-pull-dataplane/main.go @@ -46,7 +46,7 @@ func main() { consumerProcessID := uuid.NewString() _, err = cp.ConsumerPrepare(ctx, consumerProcessID, agreementID, datasetID) if err != nil { - log.Fatalf("Unable to send prepate to consumer control plane: %v\n", err) + log.Fatalf("Unable to send prepare to consumer control plane: %v\n", err) } // Signal to the provider data plane From 42743c5237666eea595de5fa89670bf36e4847a2 Mon Sep 17 00:00:00 2001 From: Jim Marino Date: Wed, 8 Oct 2025 09:39:22 +0200 Subject: [PATCH 2/2] Fix typo --- examples/streaming-push-dataplane/consumer/dataplane.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/examples/streaming-push-dataplane/consumer/dataplane.go b/examples/streaming-push-dataplane/consumer/dataplane.go index c40b151..533c330 100644 --- a/examples/streaming-push-dataplane/consumer/dataplane.go +++ b/examples/streaming-push-dataplane/consumer/dataplane.go @@ -40,7 +40,8 @@ func NewDataPlane(authService *natsservices.AuthService, natsUrl string, eventSubscriber *natsservices.EventSubscriber) (*ConsumerDataPlane, error) { - providerDataPlane := &ConsumerDataPlane{authService: authService, + providerDataPlane := &ConsumerDataPlane{ + authService: authService, connectionInvalidator: invalidator, natsUrl: natsUrl, eventSubscriber: eventSubscriber}