custom validation/parsing

ConduitIO · Dec 3, 2024 · e928991 · e928991
1 parent 5377c33
commit e928991
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 0 deletions.
diff --git a/destination.go b/destination.go
@@ -21,6 +21,11 @@ type DestinationConfig struct {
 	DestinationConfigParam string `validate:"inclusion=yes|no" default:"yes"`
 }
 
+func (s *DestinationConfig) Validate(ctx context.Context) error {
+	// Custom validation or parsing should be implemented here.
+	return nil
+}
+
 func NewDestination() sdk.Destination {
 	// Create Destination and wrap it in the default middleware.
 	return sdk.DestinationWithMiddleware(&Destination{})

diff --git a/source.go b/source.go
@@ -22,6 +22,11 @@ type SourceConfig struct {
 	SourceConfigParam string `json:"foo" validate:"required"`
 }
 
+func (s *SourceConfig) Validate(ctx context.Context) error {
+	// Custom validation or parsing should be implemented here.
+	return nil
+}
+
 func NewSource() sdk.Source {
 	// Create Source and wrap it in the default middleware.
 	return sdk.SourceWithMiddleware(&Source{})