duckdb

Documentation

Index

• type DuckDBChange
• type DuckDBReader
  • func NewDuckDBReader(sourcePath, metadataPath, outputDir string) (*DuckDBReader, error)
  • func (d *DuckDBReader) Close() error
  • func (d *DuckDBReader) StartMonitoring(ctx context.Context, tables []string) error

Types

type DuckDBChange

type DuckDBChange struct {
	Timestamp time.Time              `json:"timestamp"`
	Table     string                 `json:"table"`
	Operation string                 `json:"operation"`
	Data      map[string]interface{} `json:"data"`
}

DuckDBChange represents a single database change from DuckDB

type DuckDBReader

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

DuckDBReader handles CDC operations for DuckDB

func NewDuckDBReader

func NewDuckDBReader(sourcePath, metadataPath, outputDir string) (*DuckDBReader, error)

NewDuckDBReader creates a new DuckDB CDC reader

func (*DuckDBReader) Close

func (d *DuckDBReader) Close() error

func (*DuckDBReader) StartMonitoring

func (d *DuckDBReader) StartMonitoring(ctx context.Context, tables []string) error