feat(fxgcppubsub): Added schemas support

ankorstore · Jun 7, 2024 · a4368e5 · a4368e5
1 parent 3912f1d
commit a4368e5
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 55 deletions.
diff --git a/fxgcppubsub/module.go b/fxgcppubsub/module.go
@@ -6,7 +6,6 @@ import (
 
 	"cloud.google.com/go/pubsub"
 	"cloud.google.com/go/pubsub/pstest"
-	"github.com/ankorstore/yokai-contrib/fxgcppubsub/schema"
 	"github.com/ankorstore/yokai/config"
 	"go.uber.org/fx"
 	"google.golang.org/api/option"
@@ -25,7 +24,6 @@ var FxGcpPubSubModule = fx.Module(
 	fx.Provide(
 		NewFxGcpPubSubClient,
 		NewFxGcpPubSubSchemaClient,
-		NewFxGcpPubSubSchemaRegistry,
 	),
 )
 
@@ -104,15 +102,3 @@ func NewFxGcpPubSubSchemaClient(p FxGcpPubSubSchemaClientParam) (*pubsub.SchemaC
 	return pubsub.NewSchemaClient(p.Context, p.Config.GetString("modules.gcppubsub.project.id"))
 
 }
-
-// FxGcpPubSubSchemaRegistryParam allows injection of the required dependencies in [NewFxGcpPubSubSchemaRegistry].
-type FxGcpPubSubSchemaRegistryParam struct {
-	fx.In
-	Client *pubsub.SchemaClient
-}
-
-// NewFxGcpPubSubSchemaRegistry returns a [schema.SchemaRegistry].
-func NewFxGcpPubSubSchemaRegistry(p FxGcpPubSubSchemaRegistryParam) *schema.SchemaRegistry {
-	return schema.NewSchemaRegistry(p.Client)
-
-}
diff --git a/fxgcppubsub/schema/registry.go b/fxgcppubsub/schema/registry.go