From dd8eda2bc335336f80c95284068cdc719a8888fa Mon Sep 17 00:00:00 2001
From: colmsnowplow <colm@snowplowanalytics.com>
Date: Fri, 25 Oct 2024 15:34:02 +0100
Subject: [PATCH] Patch typos

---
 pkg/source/pubsub/pubsub_source.go | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/pkg/source/pubsub/pubsub_source.go b/pkg/source/pubsub/pubsub_source.go
index 34f9a07a..70cdd6d0 100644
--- a/pkg/source/pubsub/pubsub_source.go
+++ b/pkg/source/pubsub/pubsub_source.go
@@ -33,8 +33,8 @@ type Configuration struct {
 	ConcurrentWrites          int    `hcl:"concurrent_writes,optional"`
 	MaxOutstandingMessages    int    `hcl:"max_outstanding_messages,optional"`
 	MaxOutstandingBytes       int    `hcl:"max_outstanding_bytes,optional"`
-	minExtensionPeriodSeconds int    `hcl:"min_extension_period_seconds,optional"`
-	streamingPullGoRoutines   int    `hcl:"streaming_pull_goroutines,optional"`
+	MinExtensionPeriodSeconds int    `hcl:"min_extension_period_seconds,optional"`
+	StreamingPullGoRoutines   int    `hcl:"streaming_pull_goroutines,optional"`
 }
 
 // pubSubSource holds a new client for reading messages from PubSub
@@ -62,8 +62,8 @@ func configFunction(c *Configuration) (sourceiface.Source, error) {
 		c.SubscriptionID,
 		c.MaxOutstandingMessages,
 		c.MaxOutstandingBytes,
-		c.minExtensionPeriodSeconds,
-		c.streamingPullGoRoutines,
+		c.MinExtensionPeriodSeconds,
+		c.StreamingPullGoRoutines,
 	)
 }
 
@@ -83,8 +83,8 @@ func (f adapter) ProvideDefault() (interface{}, error) {
 		ConcurrentWrites:          50,
 		MaxOutstandingMessages:    1000,
 		MaxOutstandingBytes:       1e9,
-		minExtensionPeriodSeconds: 0,
-		streamingPullGoRoutines:   1,
+		MinExtensionPeriodSeconds: 0,
+		StreamingPullGoRoutines:   1,
 	}
 
 	return cfg, nil