Versions in this module Expand all Collapse all v0 v0.3.0 Sep 1, 2026 Changes in this version + type Config struct + ColumnMapping map[string]string + DSN string + Driver string + MaxRows int + Mode string + PollInterval time.Duration + Query string + SchemaName string + SchemaVersion string + SourceID string + SourceKey string + StartWatermark string + StreamingQuery string + Table string + Timeout time.Duration + WatermarkColumn string + WatermarkType string + type Factory struct + func (f *Factory) Create(config adapters.SourceConfig) (adapters.FactSource, error) + func (f *Factory) GetConfigSchema() adapters.ConfigSchema + func (f *Factory) ValidateConfig(config adapters.SourceConfig) error + type SchemaConfig struct + Catalog string + ColumnMapping map[string]string + DSN string + Driver string + ExcludeCols []string + IncludeCols []string + Schema string + SchemaName string + SchemaVersion string + Table string + type SchemaFactory struct + func (f *SchemaFactory) Create(config adapters.SchemaSourceConfig) (adapters.SchemaProvider, error) + func (f *SchemaFactory) GetConfigSchema() adapters.ConfigSchema + func (f *SchemaFactory) ValidateConfig(config adapters.SchemaSourceConfig) error + type SchemaProvider struct + func (p *SchemaProvider) Close() error + func (p *SchemaProvider) LoadSchemas(ctx context.Context) ([]adapters.SchemaDefinition, error) + type Source struct + func NewSource(config *Config) (*Source, error) + func (s *Source) GetMetadata() adapters.SourceMetadata + func (s *Source) GetSourceSchema() *adapters.Schema + func (s *Source) HealthCheck() error + func (s *Source) Start(ctx context.Context) error + func (s *Source) Stop(ctx context.Context) error + func (s *Source) Subscribe(ctx context.Context, factTypes []string) (<-chan *adapters.TypedFact, error)
Go to main page