postgres

May 15, 2024

Changes in this version

+ type PatternCheck struct

+ func (c *PatternCheck) Check(ctx context.Context, ti *scheduler.ColumnCheckInstance) error

Mar 22, 2024

Changes in this version

type Client

+ func (c *Client) GetIngestrURI() (string, error)

type Config

+ func (c Config) GetIngestrURI() string

+ type PgConfig interface

+ GetIngestrURI func() string

+ ToDBConnectionURI func() string

+ type RedShiftConfig struct

+ Database string

+ Host string

+ Password string

+ PoolMaxConns int

+ Port int

+ Schema string

+ SslMode string

+ Username string

+ func (c RedShiftConfig) GetIngestrURI() string

+ func (c RedShiftConfig) ToDBConnectionURI() string

Mar 20, 2024

Changes in this version

type Client

+ func (c *Client) GetConnectionURI() (string, error)

type Config

+ func (c Config) ToIngestrURL() string

Feb 8, 2024

Changes in this version

type Config

+ Schema string

Feb 7, 2024

Changes in this version

+ func NewColumnCheckOperator(manager connectionFetcher) *ansisql.ColumnCheckOperator

+ type AcceptedValuesCheck struct

+ func (c *AcceptedValuesCheck) Check(ctx context.Context, ti *scheduler.ColumnCheckInstance) error

+ type BasicOperator struct

+ func NewBasicOperator(conn connectionFetcher, extractor queryExtractor, materializer materializer) *BasicOperator

+ func (o BasicOperator) Run(ctx context.Context, ti scheduler.TaskInstance) error

+ func (o BasicOperator) RunTask(ctx context.Context, p *pipeline.Pipeline, t *pipeline.Asset) error

+ type Client struct

+ func NewClient(ctx context.Context, c Config) (*Client, error)

+ func (c *Client) RunQueryWithoutResult(ctx context.Context, query *query.Query) error

+ func (c *Client) Select(ctx context.Context, query *query.Query) ([][]interface{}, error)

+ type Config struct

+ Database string

+ Host string

+ Password string

+ PoolMaxConns int

+ Port int

+ SslMode string

+ Username string

+ func (c Config) ToDBConnectionURI() string

+ type Materializer struct

+ func NewMaterializer() *Materializer

+ func (m Materializer) Render(task *pipeline.Asset, query string) (string, error)

+ type PgClient interface

+ RunQueryWithoutResult func(ctx context.Context, query *query.Query) error

+ Select func(ctx context.Context, query *query.Query) ([][]interface{}, error)