destregistry

type BaseProvider struct {
	// contains filtered or unexported fields
}

type Config struct {
	DestinationMetadataPath string
}

type ErrDestinationPublish struct {
	Err error
}

type ErrDestinationValidation struct {
	Errors []ValidationErrorDetail `json:"errors"`
}

type Provider interface {
	// Metadata returns the metadata for the provider
	Metadata() *metadata.ProviderMetadata

	// Validate destination configuration and credentials
	Validate(ctx context.Context, destination *models.Destination) error

	// Publish an event to the destination
	Publish(ctx context.Context, destination *models.Destination, event *models.Event) error
}

type Registry interface {
	RegisterProvider(destinationType string, provider Provider) error
	GetProvider(destinationType string) (Provider, error)
	RetrieveProviderMetadata(providerType string) (*metadata.ProviderMetadata, error)
	ListProviderMetadata() map[string]*metadata.ProviderMetadata
	MetadataLoader() *metadata.MetadataLoader
}

type ValidationErrorDetail struct {
	Field string `json:"field"`
	Type  string `json:"type"`
}