feat(fxgcppubsub): Added Avro and Protobuf schemas support

ankorstore · Jun 10, 2024 · d7ed86d · d7ed86d
1 parent cd12977
commit d7ed86d
Show file tree

Hide file tree

Showing 8 changed files with 22 additions and 318 deletions.
diff --git a/fxgcppubsub/.golangci.yml b/fxgcppubsub/.golangci.yml
@@ -10,15 +10,13 @@ linters:
     - bodyclose
     - containedctx
     - contextcheck
-    - cyclop
     - decorder
     - dogsled
     - durationcheck
     - errcheck
     - errchkjson
     - errname
     - errorlint
-    - exhaustive
     - forbidigo
     - forcetypeassert
     - gocognit

diff --git a/fxgcppubsub/healthcheck/subscription_test.go b/fxgcppubsub/healthcheck/subscription_test.go
diff --git a/fxgcppubsub/healthcheck/topic_test.go b/fxgcppubsub/healthcheck/topic_test.go
diff --git a/fxgcppubsub/module.go b/fxgcppubsub/module.go
@@ -44,6 +44,8 @@ func NewFxGcpPubSubTestServer() *pstest.Server {
 }
 
 // FxGcpPubSubClientParam allows injection of the required dependencies in [NewFxGcpPubSubClient].
+//
+//nolint:containedctx
 type FxGcpPubSubClientParam struct {
 	fx.In
 	LifeCycle fx.Lifecycle
@@ -84,6 +86,8 @@ func NewFxGcpPubSubClient(p FxGcpPubSubClientParam) (*pubsub.Client, error) {
 }
 
 // FxGcpPubSubSchemaClientParam allows injection of the required dependencies in [NewFxGcpPubSubSchemaClient].
+//
+//nolint:containedctx
 type FxGcpPubSubSchemaClientParam struct {
 	fx.In
 	LifeCycle fx.Lifecycle