Versions in this module Expand all Collapse all v0 v0.3.0 Mar 29, 2026 Changes in this version + func NewChecksModule(name string, config map[string]any) (sdk.ModuleInstance, error) + func NewDBTTestStep(name string, _ map[string]any) (sdk.StepInstance, error) + func NewGEValidateStep(name string, _ map[string]any) (sdk.StepInstance, error) + func NewQualityAnomalyStep(name string, _ map[string]any) (sdk.StepInstance, error) + func NewQualityCheckStep(name string, _ map[string]any) (sdk.StepInstance, error) + func NewQualityCompareStep(name string, _ map[string]any) (sdk.StepInstance, error) + func NewQualityProfileStep(name string, _ map[string]any) (sdk.StepInstance, error) + func NewQualitySchemaValidateStep(name string, _ map[string]any) (sdk.StepInstance, error) + func NewSodaCheckStep(name string, _ map[string]any) (sdk.StepInstance, error) + func RegisterChecksModule(name string, m *ChecksModule) error + func UnregisterChecksModule(name string) + type AnomalyResult struct + Anomalies int + Column string + Method string + SampleSize int + Threshold float64 + func DetectAnomalies(values []float64, method string, threshold float64) *AnomalyResult + type CheckResult struct + Check string + Message string + Passed bool + Value any + func RunCheck(ctx context.Context, exec DBQuerier, checkType, table string, ...) (*CheckResult, error) + type ChecksConfig struct + ContractsDir string + Database string + Provider string + type ChecksModule struct + func LookupChecksModule(name string) (*ChecksModule, error) + func NewChecksModuleWithExecutor(name string, exec DBQuerier) *ChecksModule + func (m *ChecksModule) ContractsDir() string + func (m *ChecksModule) Executor() DBQuerier + func (m *ChecksModule) Init() error + func (m *ChecksModule) SetExecutor(exec DBQuerier) + func (m *ChecksModule) Start(_ context.Context) error + func (m *ChecksModule) Stop(_ context.Context) error + type ColumnProfile struct + DistinctCount int64 + Max any + Mean *float64 + Min any + NullCount int64 + NullRate float64 + Percentiles *Percentiles + StdDev *float64 + type ContractColumn struct + Name string + Nullable bool + Pattern string + Type string + type ContractResult struct + Dataset string + Passed bool + QualityOK bool + QualityResults []CheckResult + SchemaErrors []string + SchemaOK bool + func ValidateContract(ctx context.Context, exec DBQuerier, contract DataContract) (*ContractResult, error) + type ContractSchema struct + Columns []ContractColumn + type DBQuerier interface + QueryContext func(ctx context.Context, query string, args ...any) (*sql.Rows, error) + QueryRowContext func(ctx context.Context, query string, args ...any) *sql.Row + type DBTResult struct + Errors int + Failed int + Passed int + Results []string + Skipped int + type DataContract struct + Dataset string + Owner string + Quality []QualityCheck + Schema ContractSchema + func ParseContract(path string) (*DataContract, error) + type GEResult struct + Evaluated int + Failed int + Success bool + Successful int + type Percentiles struct + P25 float64 + P50 float64 + P75 float64 + P90 float64 + P99 float64 + type ProfileResult struct + Columns map[string]*ColumnProfile + RowCount int64 + Table string + func Profile(ctx context.Context, exec DBQuerier, table string, columns []string) (*ProfileResult, error) + type QualityCheck struct + Config map[string]any + Type string + type QualityChecker interface + Run func(ctx context.Context, exec DBQuerier, table string, config map[string]any) (*CheckResult, error) + type SodaResult struct + Errors int + Failed int + Lines []string + Passed int v0.1.2 Mar 29, 2026 v0.1.1 Mar 29, 2026 v0.1.0 Mar 29, 2026
Go to main page