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) EstimateQuery(ctx context.Context, sql string) (*scrapper.QueryEstimate, error)
- 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) QueryPlatformUsers(ctx context.Context) (*scrapper.PlatformUsers, error)
- func (s *RejectingScrapper) QueryRoutines(ctx context.Context) ([]*scrapper.RoutineRow, error)
- func (s *RejectingScrapper) QuerySchemas(ctx context.Context) ([]*scrapper.SchemaRow, 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) RunRawQuery(ctx context.Context, sql string) (scrapper.RawQueryRowIterator, error)
- func (s *RejectingScrapper) SqlDialect() sqldialect.Dialect
- func (s *RejectingScrapper) Unwrap() scrapper.Scrapper
- 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) EstimateQuery ¶ added in v0.16.0
func (s *RejectingScrapper) EstimateQuery(ctx context.Context, sql string) (*scrapper.QueryEstimate, error)
EstimateQuery returns a numeric estimate with no identity fields, so there is nothing to reject — pass through.
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) QueryPlatformUsers ¶ added in v0.21.0
func (s *RejectingScrapper) QueryPlatformUsers(ctx context.Context) (*scrapper.PlatformUsers, error)
QueryPlatformUsers drops users whose login is not a valid string; the listing's other fields are not identities and are left to sanitize.
func (*RejectingScrapper) QueryRoutines ¶ added in v0.23.0
func (s *RejectingScrapper) QueryRoutines(ctx context.Context) ([]*scrapper.RoutineRow, error)
func (*RejectingScrapper) QuerySchemas ¶ added in v0.14.5
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) RunRawQuery ¶ added in v0.13.7
func (s *RejectingScrapper) RunRawQuery(ctx context.Context, sql string) (scrapper.RawQueryRowIterator, error)
func (*RejectingScrapper) SqlDialect ¶
func (s *RejectingScrapper) SqlDialect() sqldialect.Dialect
func (*RejectingScrapper) Unwrap ¶ added in v0.13.3
func (s *RejectingScrapper) Unwrap() scrapper.Scrapper
Unwrap returns the inner scrapper, letting callers walk the decorator chain (via scrapper.As) to reach concrete types or interfaces this wrapper does not itself implement.
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.