core

type BatchContext struct {
	// SkillName is the skill being executed (for sink logging)
	SkillName string

	// BatchID is a unique identifier for each poll cycle (root trace ID)
	// Format: {timestamp-ms}-{uuid-short-8chars}
	BatchID string

	// StartTime is when this poll cycle started
	StartTime time.Time
}

type CaptureChange map[string]interface{}

type CaptureResult struct {
	Changes      []CaptureChange
	BatchID      string       // Unique identifier for this fetch batch
	NextCapturer CapturerName // Which capturer to use for next fetch
}

type Capturer interface {
	// Fetch returns the next batch of changes and indicates which capturer to use next.
	Fetch(ctx context.Context) *CaptureResult

	// Stop signals the capturer to stop fetching.
	// Called by Runtime when the overall system is shutting down.
	Stop()
}

type CapturerName string

type Change struct {
	Table         string                 `json:"table"`
	TransactionID string                 `json:"transaction_id"`
	LSN           []byte                 `json:"lsn"`
	Operation     Operation              `json:"operation"`
	Data          map[string]interface{} `json:"data"`
	CommitTime    time.Time              `json:"commit_time"` // Transaction commit time from source database
	ID            string                 `json:"id"`          // Content-based hash ID for deduplication
	TableKeys     string                 `json:"table_keys"`  // Primary key values (comma-separated)
}

type DataSet struct {
	Columns []string
	Rows    [][]any
}

type DeliveryReason string

type LSN []byte

type Operation int

type RunState string

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

type Sink struct {
	Config  SinkConfig
	DataSet *DataSet
	OpType  Operation // Uses core.Operation from transaction.go
}

type SinkConfig struct {
	Name       string
	Database   string // Database name (maps to platform-configured storage)
	Output     string
	PrimaryKey string
	OnConflict string
}

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

type Transaction struct {
	TraceID        string    `json:"trace_id"` // Human-readable trace ID for log correlation
	ID             string    `json:"id"`       // Internal transaction ID
	Changes        []Change  `json:"changes"`
	CreatedAt      time.Time `json:"created_at"`
	CommitTime     time.Time `json:"commit_time"`     // Transaction commit time (from first change)
	FirstSeenTime  time.Time `json:"first_seen_time"` // When first change was added to buffer
	InvolvedTables []string  `json:"involved_tables"` // Tables that have changes in this transaction
}

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

type TransactionWithBatch struct {
	Transaction *Transaction
	BatchCtx    *BatchContext
}

type Transformer interface {
	Transform(ctx context.Context, changes []Change, batchCtx *BatchContext) error
}