connector

type Event struct {
	ID              string          `json:"id"`
	Source          string          `json:"source"`
	Type            string          `json:"type"`
	Subject         string          `json:"subject,omitempty"`
	Time            time.Time       `json:"time"`
	Data            json.RawMessage `json:"data"`
	DataSchema      string          `json:"dataschema,omitempty"`
	DataContentType string          `json:"datacontenttype,omitempty"`
	// Internal metadata (not serialized to CloudEvents)
	TenantID       string `json:"-"`
	PipelineID     string `json:"-"`
	IdempotencyKey string `json:"-"`
}

type EventSink interface {
	Name() string
	Type() string
	Deliver(ctx context.Context, event Event) error
	DeliverBatch(ctx context.Context, events []Event) []error
	Stop(ctx context.Context) error
	Healthy() bool
}

type EventSource interface {
	Name() string
	Type() string
	Start(ctx context.Context, output chan<- Event) error
	Stop(ctx context.Context) error
	Healthy() bool
	Checkpoint(ctx context.Context) error
}

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

type SinkFactory func(name string, config map[string]any) (EventSink, error)

type SourceFactory func(name string, config map[string]any) (EventSource, error)

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

type WebhookSinkRetryConfig struct {
	MaxAttempts int           `json:"max_attempts" yaml:"max_attempts"`
	Backoff     time.Duration `json:"backoff" yaml:"backoff"`
}

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