Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Config ¶
type Config = internalcdc.CDCConfig
Config controls change_log flushing and export behavior.
type FlushRunner ¶
type FlushRunner struct {
// contains filtered or unexported fields
}
FlushRunner reuses AWS/S3/DuckDB initialization across multiple flush passes.
func NewFlushRunner ¶
func NewFlushRunner(logger *zap.Logger) *FlushRunner
NewFlushRunner creates a reusable CDC flush runner.
func NewRunner ¶
func NewRunner(logger *zap.Logger) *FlushRunner
NewRunner creates a reusable CDC flush runner.
func (*FlushRunner) Close ¶
func (r *FlushRunner) Close() error
Close releases any cached DuckDB exporters held by the runner.
func (*FlushRunner) RunOnce ¶
func (r *FlushRunner) RunOnce( ctx context.Context, cfg Config, s3Client S3ObjectClient, dryRun bool, schemaRegistry forma.SchemaRegistry, ) error
RunOnce performs one full CDC flush pass using the reusable runner.
type S3FullClient ¶
type S3FullClient = internalcdc.S3FullClient
S3FullClient extends S3ObjectClient with manifest read/write operations.
type S3ObjectClient ¶
type S3ObjectClient = internalcdc.S3ObjectClient
S3ObjectClient is the minimal S3 interface required by the flush path.
Source Files
Click to show internal directories.
Click to hide internal directories.