Documentation
¶
Index ¶
- func QuoteLiteral(literal string) string
- type DbDesc
- type ShareDesc
- type ShareObject
- type SnowflakeScrapper
- func (e *SnowflakeScrapper) Close() error
- func (e *SnowflakeScrapper) DialectType() string
- func (e *SnowflakeScrapper) Executor() *dwhexecsnowflake.SnowflakeExecutor
- func (e *SnowflakeScrapper) GetExistingDbs() ([]*DbDesc, error)
- func (e *SnowflakeScrapper) IsPermissionError(err error) bool
- func (e *SnowflakeScrapper) QueryCatalog(ctx context.Context) ([]*scrapper.CatalogColumnRow, error)
- func (e *SnowflakeScrapper) QueryCustomMetrics(ctx context.Context, sql string, args ...any) ([]*scrapper.CustomMetricsRow, error)
- func (e *SnowflakeScrapper) QueryDatabases(ctx context.Context) ([]*scrapper.DatabaseRow, error)
- func (e *SnowflakeScrapper) QuerySegments(ctx context.Context, sql string, args ...any) ([]*scrapper.SegmentRow, error)
- func (e *SnowflakeScrapper) QuerySqlDefinitions(ctx context.Context) ([]*scrapper.SqlDefinitionRow, error)
- func (e *SnowflakeScrapper) QueryTableMetrics(ctx context.Context, lastMetricsFetchTime time.Time) ([]*scrapper.TableMetricsRow, error)
- func (e *SnowflakeScrapper) QueryTables(ctx context.Context) ([]*scrapper.TableRow, error)
- func (e *SnowflakeScrapper) SqlDialect() sqldialect.Dialect
- func (e *SnowflakeScrapper) ValidateConfiguration(ctx context.Context) ([]string, error)
- type SnowflakeScrapperConf
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func QuoteLiteral ¶
Types ¶
type DbDesc ¶
type ShareObject ¶
type ShareObject struct {
}
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 (e *SnowflakeScrapper) Executor() *dwhexecsnowflake.SnowflakeExecutor
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 (*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
Click to show internal directories.
Click to hide internal directories.