snowflake

package
v0.2.0 Latest Latest
Warning

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

Go to latest
Published: Mar 31, 2025 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func QuoteLiteral

func QuoteLiteral(literal string) string

Types

type DbDesc

type DbDesc struct {
	Name    string `db:"name" json:"name"`
	Origin  string `db:"origin" json:"origin"`
	Owner   string `db:"owner" json:"owner"`
	Comment string `db:"comment" json:"comment"`
	Kind    string `db:"kind" json:"kind"`
}

func (*DbDesc) String

func (d *DbDesc) String() string

type ShareDesc

type ShareDesc struct {
	Name              string         `db:"name" json:"name"`
	Kind              string         `db:"kind" json:"kind"`
	OwnerAccount      string         `db:"owner_account" json:"owner_account"`
	DatabaseName      string         `db:"database_name" json:"database_name"`
	To                string         `db:"to" json:"to"`
	Owner             string         `db:"owner" json:"owner"`
	Comment           string         `db:"comment" json:"comment"`
	ListingGlobalName string         `db:"listing_global_name" json:"listing_global_name"`
	Objects           []*ShareObject `json:"objects"`
}

func (*ShareDesc) String

func (d *ShareDesc) String() string

type ShareObject

type ShareObject struct {
	Kind     string    `db:"kind" json:"kind"`
	Name     string    `db:"name" json:"name"`
	SharedOn time.Time `db:"shared_on" json:"shared_on"`
}

type SnowflakeScrapper

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

func NewSnowflakeScrapper

func NewSnowflakeScrapper(ctx context.Context, conf *SnowflakeScrapperConf) (*SnowflakeScrapper, error)

func (*SnowflakeScrapper) Close

func (e *SnowflakeScrapper) Close() error

func (*SnowflakeScrapper) DialectType added in v0.1.8

func (e *SnowflakeScrapper) DialectType() string

func (*SnowflakeScrapper) Executor

func (*SnowflakeScrapper) GetExistingDbs

func (e *SnowflakeScrapper) GetExistingDbs() ([]*DbDesc, error)

func (*SnowflakeScrapper) IsPermissionError added in v0.1.1

func (e *SnowflakeScrapper) IsPermissionError(err error) bool

func (*SnowflakeScrapper) QueryCatalog

func (e *SnowflakeScrapper) QueryCatalog(ctx context.Context) ([]*scrapper.CatalogColumnRow, error)

func (*SnowflakeScrapper) QueryCustomMetrics

func (e *SnowflakeScrapper) QueryCustomMetrics(ctx context.Context, sql string, args ...any) ([]*scrapper.CustomMetricsRow, error)

func (*SnowflakeScrapper) QueryDatabases

func (e *SnowflakeScrapper) QueryDatabases(ctx context.Context) ([]*scrapper.DatabaseRow, error)

func (*SnowflakeScrapper) QuerySegments

func (e *SnowflakeScrapper) QuerySegments(ctx context.Context, sql string, args ...any) ([]*scrapper.SegmentRow, error)

func (*SnowflakeScrapper) QuerySqlDefinitions

func (e *SnowflakeScrapper) QuerySqlDefinitions(ctx context.Context) ([]*scrapper.SqlDefinitionRow, error)

func (*SnowflakeScrapper) QueryTableMetrics

func (e *SnowflakeScrapper) QueryTableMetrics(ctx context.Context, lastMetricsFetchTime time.Time) ([]*scrapper.TableMetricsRow, error)

func (*SnowflakeScrapper) QueryTables

func (e *SnowflakeScrapper) QueryTables(ctx context.Context) ([]*scrapper.TableRow, error)

func (*SnowflakeScrapper) SqlDialect added in v0.1.8

func (e *SnowflakeScrapper) SqlDialect() sqldialect.Dialect

func (*SnowflakeScrapper) ValidateConfiguration

func (e *SnowflakeScrapper) ValidateConfiguration(ctx context.Context) ([]string, error)

type SnowflakeScrapperConf

type SnowflakeScrapperConf struct {
	dwhexecsnowflake.SnowflakeConf
	NoGetDll bool
}

func (*SnowflakeScrapperConf) UpperDatabasesLiteral

func (c *SnowflakeScrapperConf) UpperDatabasesLiteral() string

FIXME: I couldn't make it work with `foo IN (?)` binding, so I'm using this

Jump to

Keyboard shortcuts

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