binding.go

package config

import (
	"fmt"
	"github.com/kubemq-io/kubemq-sources/types"
)

type BindingConfig struct {
	Name       string         `json:"name"`
	Source     Spec           `json:"source"`
	Target     Spec           `json:"target"`
	Properties types.Metadata `json:"properties"`
}

func (b BindingConfig) Validate() error {
	if b.Name == "" {
		return fmt.Errorf("binding must have name")
	}
	if err := b.Source.Validate(); err != nil {
		return fmt.Errorf("binding source error, %w", err)
	}
	if err := b.Target.Validate(); err != nil {
		return fmt.Errorf("binding target error, %w", err)
	}
	return nil
}