Documentation
¶
Overview ¶
Package reject provides a Scrapper decorator that drops rows whose identity fields (the parts forming an object's fully-qualified name) contain NUL bytes or invalid UTF-8.
Unlike sanitize, which repairs bad strings in place, reject discards the row entirely — because a sanitised identifier might collide with another object or fail to resolve against the warehouse. For non-identity content (descriptions, SQL, tag values), compose with sanitize:
sanitize.NewSanitizingScrapper(reject.NewRejectingScrapper(inner))
Index ¶
- type RejectingScrapper
- func (s *RejectingScrapper) Capabilities() scrapper.Capabilities
- func (s *RejectingScrapper) Close() error
- func (s *RejectingScrapper) DialectType() string
- func (s *RejectingScrapper) IsPermissionError(err error) bool
- func (s *RejectingScrapper) QueryCatalog(ctx context.Context) ([]*scrapper.CatalogColumnRow, error)
- func (s *RejectingScrapper) QueryCustomMetrics(ctx context.Context, sql string, args ...any) ([]*scrapper.CustomMetricsRow, error)
- func (s *RejectingScrapper) QueryDatabases(ctx context.Context) ([]*scrapper.DatabaseRow, error)
- func (s *RejectingScrapper) QuerySegments(ctx context.Context, sql string, args ...any) ([]*scrapper.SegmentRow, error)
- func (s *RejectingScrapper) QueryShape(ctx context.Context, sql string) ([]*scrapper.QueryShapeColumn, error)
- func (s *RejectingScrapper) QuerySqlDefinitions(ctx context.Context) ([]*scrapper.SqlDefinitionRow, error)
- func (s *RejectingScrapper) QueryTableConstraints(ctx context.Context) ([]*scrapper.TableConstraintRow, error)
- func (s *RejectingScrapper) QueryTableMetrics(ctx context.Context, lastMetricsFetchTime time.Time) ([]*scrapper.TableMetricsRow, error)
- func (s *RejectingScrapper) QueryTables(ctx context.Context, opts ...scrapper.QueryTablesOption) ([]*scrapper.TableRow, error)
- func (s *RejectingScrapper) SqlDialect() sqldialect.Dialect
- func (s *RejectingScrapper) ValidateConfiguration(ctx context.Context) (warnings []string, err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type RejectingScrapper ¶
type RejectingScrapper struct {
// contains filtered or unexported fields
}
func NewRejectingScrapper ¶
func NewRejectingScrapper(inner scrapper.Scrapper) *RejectingScrapper
func (*RejectingScrapper) Capabilities ¶
func (s *RejectingScrapper) Capabilities() scrapper.Capabilities
func (*RejectingScrapper) Close ¶
func (s *RejectingScrapper) Close() error
func (*RejectingScrapper) DialectType ¶
func (s *RejectingScrapper) DialectType() string
func (*RejectingScrapper) IsPermissionError ¶
func (s *RejectingScrapper) IsPermissionError(err error) bool
func (*RejectingScrapper) QueryCatalog ¶
func (s *RejectingScrapper) QueryCatalog(ctx context.Context) ([]*scrapper.CatalogColumnRow, error)
func (*RejectingScrapper) QueryCustomMetrics ¶
func (s *RejectingScrapper) QueryCustomMetrics(ctx context.Context, sql string, args ...any) ([]*scrapper.CustomMetricsRow, error)
func (*RejectingScrapper) QueryDatabases ¶
func (s *RejectingScrapper) QueryDatabases(ctx context.Context) ([]*scrapper.DatabaseRow, error)
func (*RejectingScrapper) QuerySegments ¶
func (s *RejectingScrapper) QuerySegments(ctx context.Context, sql string, args ...any) ([]*scrapper.SegmentRow, error)
func (*RejectingScrapper) QueryShape ¶
func (s *RejectingScrapper) QueryShape(ctx context.Context, sql string) ([]*scrapper.QueryShapeColumn, error)
func (*RejectingScrapper) QuerySqlDefinitions ¶
func (s *RejectingScrapper) QuerySqlDefinitions(ctx context.Context) ([]*scrapper.SqlDefinitionRow, error)
func (*RejectingScrapper) QueryTableConstraints ¶
func (s *RejectingScrapper) QueryTableConstraints(ctx context.Context) ([]*scrapper.TableConstraintRow, error)
func (*RejectingScrapper) QueryTableMetrics ¶
func (s *RejectingScrapper) QueryTableMetrics(ctx context.Context, lastMetricsFetchTime time.Time) ([]*scrapper.TableMetricsRow, error)
func (*RejectingScrapper) QueryTables ¶
func (s *RejectingScrapper) QueryTables(ctx context.Context, opts ...scrapper.QueryTablesOption) ([]*scrapper.TableRow, error)
func (*RejectingScrapper) SqlDialect ¶
func (s *RejectingScrapper) SqlDialect() sqldialect.Dialect
func (*RejectingScrapper) ValidateConfiguration ¶
func (s *RejectingScrapper) ValidateConfiguration(ctx context.Context) (warnings []string, err error)
Source Files
Click to show internal directories.
Click to hide internal directories.