cdc

type BackpressureMonitor struct {
	ThresholdLagBytes   int64
	ThresholdLagSeconds int64
	WarningMultiplier   float64 // warn at this fraction of threshold (e.g. 0.8)
}

type BackpressureStatus struct {
	SourceID   string
	LagBytes   int64
	LagSeconds int64
	Status     string // "healthy", "warning", "critical"
}

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

type CDCProvider interface {
	// Connect establishes a connection and starts the CDC stream.
	Connect(ctx context.Context, config SourceConfig) error
	// Disconnect stops the CDC stream and releases resources.
	Disconnect(ctx context.Context, sourceID string) error
	// Status returns the current status of a CDC stream.
	Status(ctx context.Context, sourceID string) (*CDCStatus, error)
	// Snapshot triggers a full table snapshot for the given tables.
	Snapshot(ctx context.Context, sourceID string, tables []string) error
	// SchemaHistory returns the schema change history for a table.
	SchemaHistory(ctx context.Context, sourceID string, table string) ([]SchemaVersion, error)
	// RegisterEventHandler registers a callback for CDC events from a source stream.
	RegisterEventHandler(sourceID string, h EventHandler) error
}

type CDCStatus struct {
	SourceID   string `json:"source_id"              yaml:"source_id"`
	State      string `json:"state"                  yaml:"state"`
	Provider   string `json:"provider"               yaml:"provider"`
	LastEvent  string `json:"last_event"             yaml:"last_event"`
	Error      string `json:"error,omitempty"        yaml:"error,omitempty"`
	LagBytes   int64  `json:"lag_bytes,omitempty"    yaml:"lag_bytes,omitempty"`
	LagSeconds int64  `json:"lag_seconds,omitempty"  yaml:"lag_seconds,omitempty"`
}

type DMSClient interface {
	CreateReplicationTask(ctx context.Context, params *dms.CreateReplicationTaskInput, optFns ...func(*dms.Options)) (*dms.CreateReplicationTaskOutput, error)
	StartReplicationTask(ctx context.Context, params *dms.StartReplicationTaskInput, optFns ...func(*dms.Options)) (*dms.StartReplicationTaskOutput, error)
	StopReplicationTask(ctx context.Context, params *dms.StopReplicationTaskInput, optFns ...func(*dms.Options)) (*dms.StopReplicationTaskOutput, error)
	DescribeReplicationTasks(ctx context.Context, params *dms.DescribeReplicationTasksInput, optFns ...func(*dms.Options)) (*dms.DescribeReplicationTasksOutput, error)
	DeleteReplicationTask(ctx context.Context, params *dms.DeleteReplicationTaskInput, optFns ...func(*dms.Options)) (*dms.DeleteReplicationTaskOutput, error)
	DescribeTableStatistics(ctx context.Context, params *dms.DescribeTableStatisticsInput, optFns ...func(*dms.Options)) (*dms.DescribeTableStatisticsOutput, error)
}

type DMSConfig struct {
	SourceEndpointARN      string `json:"source_endpoint_arn"      yaml:"source_endpoint_arn"`
	TargetEndpointARN      string `json:"target_endpoint_arn"      yaml:"target_endpoint_arn"`
	ReplicationInstanceARN string `json:"replication_instance_arn" yaml:"replication_instance_arn"`
	MigrationType          string `json:"migration_type"           yaml:"migration_type"` // cdc, full-load-and-cdc
}

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

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

type EventHandler func(sourceID string, event map[string]any) error

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

type SchemaVersion struct {
	Table     string `json:"table"      yaml:"table"`
	Version   int64  `json:"version"    yaml:"version"`
	DDL       string `json:"ddl"        yaml:"ddl"`
	AppliedAt string `json:"applied_at" yaml:"applied_at"`
}

type SourceConfig struct {
	Provider   string         `json:"provider"    yaml:"provider"`
	SourceID   string         `json:"source_id"   yaml:"source_id"`
	SourceType string         `json:"source_type" yaml:"source_type"`
	Connection string         `json:"connection"  yaml:"connection"`
	Tables     []string       `json:"tables"      yaml:"tables"`
	Options    map[string]any `json:"options"     yaml:"options"`
}

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

type ThrottleableProvider interface {
	PauseSource(ctx context.Context, sourceID string) error
	ResumeSource(ctx context.Context, sourceID string) error
}

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

type TriggerConfig struct {
	// SourceID references a running cdc.source module by source_id.
	SourceID string `json:"source_id" yaml:"source_id"`
	// Tables filters events to the given table names. Empty = all tables.
	Tables []string `json:"tables" yaml:"tables"`
	// Actions filters events by DML operation type (INSERT, UPDATE, DELETE). Empty = all.
	Actions []string `json:"actions" yaml:"actions"`
}