snowflake

package
v0.9.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 2, 2024 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewColumnCheckOperator added in v0.2.0

func NewColumnCheckOperator(manager connectionFetcher) *ansisql.ColumnCheckOperator

func NewMaterializer added in v0.4.8

func NewMaterializer(fullRefresh bool) *pipeline.Materializer

Types

type AcceptedValuesCheck added in v0.2.0

type AcceptedValuesCheck struct {
	// contains filtered or unexported fields
}

func (*AcceptedValuesCheck) Check added in v0.2.0

type BasicOperator added in v0.2.0

type BasicOperator struct {
	// contains filtered or unexported fields
}

func NewBasicOperator added in v0.2.0

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

func (BasicOperator) Run added in v0.2.0

func (BasicOperator) RunTask added in v0.2.0

type Config

type Config struct {
	Account   string `envconfig:"SNOWFLAKE_ACCOUNT"`
	Username  string `envconfig:"SNOWFLAKE_USERNAME"`
	Password  string `envconfig:"SNOWFLAKE_PASSWORD"`
	Region    string `envconfig:"SNOWFLAKE_REGION"`
	Role      string `envconfig:"SNOWFLAKE_ROLE"`
	Database  string `envconfig:"SNOWFLAKE_DATABASE"`
	Schema    string `envconfig:"SNOWFLAKE_SCHEMA"`
	Warehouse string `envconfig:"SNOWFLAKE_WAREHOUSE"`
}

func (Config) DSN

func (c Config) DSN() (string, error)

func (Config) GetIngestrURI added in v0.7.0

func (c Config) GetIngestrURI() (string, error)

func (Config) IsValid

func (c Config) IsValid() bool

type DB

type DB struct {
	// contains filtered or unexported fields
}

func NewDB

func NewDB(c *Config) (*DB, error)

func (*DB) GetIngestrURI added in v0.7.0

func (db *DB) GetIngestrURI() (string, error)

func (*DB) IsValid

func (db *DB) IsValid(ctx context.Context, query *query.Query) (bool, error)

func (*DB) RunQueryWithoutResult added in v0.2.0

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

func (*DB) Select added in v0.2.0

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

type QuerySensor added in v0.4.7

type QuerySensor struct {
	// contains filtered or unexported fields
}

func NewQuerySensor added in v0.4.7

func NewQuerySensor(conn connectionFetcher, renderer renderer, secondsToSleep int64) *QuerySensor

func (*QuerySensor) Run added in v0.4.7

func (*QuerySensor) RunTask added in v0.4.7

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

type SfClient added in v0.2.0

type SfClient interface {
	RunQueryWithoutResult(ctx context.Context, query *query.Query) error
	Select(ctx context.Context, query *query.Query) ([][]interface{}, error)
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL