Versions in this module Expand all Collapse all v0 v0.3.0 Sep 1, 2026 Changes in this version + type CDCConfig struct + BatchSize int + BufferSize int + ConnectionString string + CreateSlot bool + HeartbeatIntervalSec int + MaxChanges int + Operations []string + Plugin string + PollInterval time.Duration + PublicationName string + SchemaMapping map[string]string + SlotName string + SourceID string + SourceType string + StartLSN string + Tables []string + Transforms []adapters.Transformation + type CDCFactory struct + func (f *CDCFactory) Create(config adapters.SourceConfig) (adapters.FactSource, error) + func (f *CDCFactory) GetConfigSchema() adapters.ConfigSchema + func (f *CDCFactory) ValidateConfig(config adapters.SourceConfig) error + type CDCSource struct + func NewCDCSource(config *CDCConfig) (*CDCSource, error) + func (c *CDCSource) GetMetadata() adapters.SourceMetadata + func (c *CDCSource) GetSourceSchema() *adapters.Schema + func (c *CDCSource) HealthCheck() error + func (c *CDCSource) Start(ctx context.Context) error + func (c *CDCSource) Stop(ctx context.Context) error + func (c *CDCSource) Subscribe(ctx context.Context, factTypes []string) (<-chan *adapters.TypedFact, error) + type ChangeEvent struct + After map[string]interface{} + Before map[string]interface{} + LSN string + Operation string + Schema string + Table string + Timestamp time.Time + TxID uint32 + type ChangeTransformer struct + func NewChangeTransformer(config *CDCConfig) *ChangeTransformer + func (t *ChangeTransformer) TransformChange(change *ChangeEvent) (*adapters.TypedFact, error) + type PollerConfig struct + ConnectionString string + IntervalSeconds int + MaxRows int + ProcessedLedger string + Query string + SchemaName string + StartTieBreak interface{} + StartTimestamp string + TieBreakColumn string + TimestampColumn string + type PostgresPollerFactory struct + func (f *PostgresPollerFactory) Create(config adapters.SourceConfig) (adapters.FactSource, error) + func (f *PostgresPollerFactory) GetConfigSchema() adapters.ConfigSchema + func (f *PostgresPollerFactory) ValidateConfig(config adapters.SourceConfig) error + type PostgresPollerSource struct + func NewPostgresPollerSource(sourceID string, config PollerConfig) (*PostgresPollerSource, error) + func (p *PostgresPollerSource) GetMetadata() adapters.SourceMetadata + func (p *PostgresPollerSource) GetSourceSchema() *adapters.Schema + func (p *PostgresPollerSource) HealthCheck() error + func (p *PostgresPollerSource) Start(ctx context.Context) error + func (p *PostgresPollerSource) Stop(ctx context.Context) error + func (p *PostgresPollerSource) Subscribe(ctx context.Context, factTypes []string) (<-chan *adapters.TypedFact, error)
Go to main page