vertica

package

v0.11.783 Latest Latest Go to latest Published: Oct 19, 2026 License: Apache-2.0 Imports: 20 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/bruin-data/bruin

Links

Open Source Insights

Documentation ¶

Index ¶

func NewColumnCheckOperator(manager config.ConnectionGetter) *ansisql.ColumnCheckOperator
func NewMaterializer(fullRefresh bool) *pipeline.Materializer
func QuoteIdentifier(identifier string) string
type AcceptedValuesCheck
- func (c *AcceptedValuesCheck) Check(ctx context.Context, ti *scheduler.ColumnCheckInstance) error
type BasicOperator
- func NewBasicOperator(conn config.ConnectionGetter, extractor query.QueryExtractor, ...) *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 Config
- func (c *Config) GetIngestrURI() string
- func (c *Config) ToDBConnectionURI() string
type DB
- func NewDB(c *Config) (*DB, error)
type PatternCheck
- func (c *PatternCheck) Check(ctx context.Context, ti *scheduler.ColumnCheckInstance) error
type VerticaClient

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewColumnCheckOperator ¶

func NewColumnCheckOperator(manager config.ConnectionGetter) *ansisql.ColumnCheckOperator

func NewMaterializer ¶

func NewMaterializer(fullRefresh bool) *pipeline.Materializer

func QuoteIdentifier ¶

func QuoteIdentifier(identifier string) string

QuoteIdentifier quotes a Vertica identifier (table, column, etc.) with double quotes. It splits the identifier on "." and quotes each part separately.

Types ¶

type AcceptedValuesCheck ¶

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

func (*AcceptedValuesCheck) Check ¶

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

type BasicOperator ¶

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

func NewBasicOperator ¶

func NewBasicOperator(conn config.ConnectionGetter, extractor query.QueryExtractor, materializer materializer, parser *sqlparser.SQLParser) *BasicOperator

func (BasicOperator) Run ¶

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

func (BasicOperator) RunTask ¶

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

type Config ¶

type Config struct {
	Username              string
	Password              string
	Host                  string
	Port                  int
	Database              string
	Schema                string
	TLSMode               string
	ConnectionLoadBalance *int
	BackupServerNode      string
}

func (*Config) GetIngestrURI ¶

func (c *Config) GetIngestrURI() string

func (*Config) ToDBConnectionURI ¶

func (c *Config) ToDBConnectionURI() string

type DB ¶

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

func NewDB ¶

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

func (*DB) BuildTableExistsQuery ¶

func (db *DB) BuildTableExistsQuery(tableName string) (string, error)

func (*DB) CreateSchemaIfNotExist ¶

func (db *DB) CreateSchemaIfNotExist(ctx context.Context, asset *pipeline.Asset) error

func (*DB) GetColumns ¶

func (db *DB) GetColumns(ctx context.Context, databaseName, tableName string) ([]*ansisql.DBColumn, error)

func (*DB) GetDatabaseSummary ¶

func (db *DB) GetDatabaseSummary(ctx context.Context) (*ansisql.DBDatabase, error)

func (*DB) GetDatabases ¶

func (db *DB) GetDatabases(ctx context.Context) ([]string, error)

func (*DB) GetIngestrURI ¶

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

func (*DB) GetTablesWithSchemas ¶

func (db *DB) GetTablesWithSchemas(ctx context.Context, databaseName string) (map[string][]string, error)

func (*DB) Limit ¶

func (db *DB) Limit(query string, limit int64) string

func (*DB) Ping ¶

func (db *DB) Ping(ctx context.Context) error

func (*DB) RunQueryWithoutResult ¶

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

func (*DB) Select ¶

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

func (*DB) SelectWithSchema ¶

func (db *DB) SelectWithSchema(ctx context.Context, queryObj *query.Query) (*query.QueryResult, error)

type PatternCheck ¶

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

func (*PatternCheck) Check ¶

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

type VerticaClient ¶

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

Source Files ¶

View all Source files

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