use config.Config

ConduitIO · May 28, 2024 · 9f3a673 · 9f3a673
1 parent 4ae468b
commit 9f3a673
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 10 deletions.
diff --git a/cplugin/destination.go b/cplugin/destination.go
@@ -17,6 +17,7 @@ package cplugin
 import (
 	"context"
 
+	"github.com/conduitio/conduit-commons/config"
 	"github.com/conduitio/conduit-commons/opencdc"
 )
 
@@ -56,7 +57,7 @@ type DestinationRunStreamServer interface {
 }
 
 type DestinationConfigureRequest struct {
-	Config map[string]string
+	Config config.Config
 }
 type DestinationConfigureResponse struct{}
 
@@ -84,17 +85,17 @@ type DestinationTeardownRequest struct{}
 type DestinationTeardownResponse struct{}
 
 type DestinationLifecycleOnCreatedRequest struct {
-	Config map[string]string
+	Config config.Config
 }
 type DestinationLifecycleOnCreatedResponse struct{}
 
 type DestinationLifecycleOnUpdatedRequest struct {
-	ConfigBefore map[string]string
-	ConfigAfter  map[string]string
+	ConfigBefore config.Config
+	ConfigAfter  config.Config
 }
 type DestinationLifecycleOnUpdatedResponse struct{}
 
 type DestinationLifecycleOnDeletedRequest struct {
-	Config map[string]string
+	Config config.Config
 }
 type DestinationLifecycleOnDeletedResponse struct{}
diff --git a/cplugin/source.go b/cplugin/source.go
@@ -17,6 +17,7 @@ package cplugin
 import (
 	"context"
 
+	"github.com/conduitio/conduit-commons/config"
 	"github.com/conduitio/conduit-commons/opencdc"
 )
 
@@ -56,7 +57,7 @@ type SourceRunStreamServer interface {
 }
 
 type SourceConfigureRequest struct {
-	Config map[string]string
+	Config config.Config
 }
 type SourceConfigureResponse struct{}
 
@@ -81,17 +82,17 @@ type SourceTeardownRequest struct{}
 type SourceTeardownResponse struct{}
 
 type SourceLifecycleOnCreatedRequest struct {
-	Config map[string]string
+	Config config.Config
 }
 type SourceLifecycleOnCreatedResponse struct{}
 
 type SourceLifecycleOnUpdatedRequest struct {
-	ConfigBefore map[string]string
-	ConfigAfter  map[string]string
+	ConfigBefore config.Config
+	ConfigAfter  config.Config
 }
 type SourceLifecycleOnUpdatedResponse struct{}
 
 type SourceLifecycleOnDeletedRequest struct {
-	Config map[string]string
+	Config config.Config
 }
 type SourceLifecycleOnDeletedResponse struct{}