postgres

Jun 24, 2026

Changes in this version

+ func New(params map[string]any) (source.Connector, error)

+ type Connector struct

+ func (c *Connector) DescribeTable(ctx context.Context, table string) (source.TableSchema, bool, error)

+ func (c *Connector) ListTables(ctx context.Context, opts source.ListOptions) ([]string, error)

+ func (c *Connector) Scan(ctx context.Context, req source.ScanRequest, emit func(*source.Rows) error) error

+ func (c *Connector) Tables() []source.TableSchema