Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CheckRunner ¶
type CheckRunner interface {
Check(ctx context.Context, ti *scheduler.ColumnCheckInstance) error
}
type ColumnCheckOperator ¶
type ColumnCheckOperator struct {
// contains filtered or unexported fields
}
func NewColumnCheckOperator ¶
func NewColumnCheckOperator(checks map[string]CheckRunner) *ColumnCheckOperator
func (ColumnCheckOperator) Run ¶
func (o ColumnCheckOperator) Run(ctx context.Context, ti scheduler.TaskInstance) error
type CountableQueryCheck ¶
type CountableQueryCheck struct {
// contains filtered or unexported fields
}
func NewCountableQueryCheck ¶
func (*CountableQueryCheck) Check ¶
func (c *CountableQueryCheck) Check(ctx context.Context, ti *scheduler.ColumnCheckInstance) error
func (*CountableQueryCheck) CustomCheck ¶
func (c *CountableQueryCheck) CustomCheck(ctx context.Context, ti *scheduler.CustomCheckInstance) error
type CustomCheck ¶
type CustomCheck struct {
// contains filtered or unexported fields
}
func NewCustomCheck ¶
func NewCustomCheck(conn connectionFetcher) *CustomCheck
func (*CustomCheck) Check ¶
func (c *CustomCheck) Check(ctx context.Context, ti *scheduler.CustomCheckInstance) error
type CustomCheckOperator ¶
type CustomCheckOperator struct {
// contains filtered or unexported fields
}
func NewCustomCheckOperator ¶
func NewCustomCheckOperator(manager connectionFetcher, r *jinja.Renderer) *CustomCheckOperator
func (*CustomCheckOperator) Run ¶
func (o *CustomCheckOperator) Run(ctx context.Context, ti scheduler.TaskInstance) error
type CustomCheckRunner ¶
type CustomCheckRunner interface {
Check(ctx context.Context, ti *scheduler.CustomCheckInstance) error
}
type NegativeCheck ¶ added in v0.10.1
type NegativeCheck struct {
// contains filtered or unexported fields
}
func NewNegativeCheck ¶ added in v0.10.1
func NewNegativeCheck(conn connectionFetcher) *NegativeCheck
func (*NegativeCheck) Check ¶ added in v0.10.1
func (c *NegativeCheck) Check(ctx context.Context, ti *scheduler.ColumnCheckInstance) error
type NonNegativeCheck ¶
type NonNegativeCheck struct {
// contains filtered or unexported fields
}
func NewNonNegativeCheck ¶
func NewNonNegativeCheck(conn connectionFetcher) *NonNegativeCheck
func (*NonNegativeCheck) Check ¶
func (c *NonNegativeCheck) Check(ctx context.Context, ti *scheduler.ColumnCheckInstance) error
type NotNullCheck ¶
type NotNullCheck struct {
// contains filtered or unexported fields
}
func NewNotNullCheck ¶
func NewNotNullCheck(conn connectionFetcher) *NotNullCheck
func (*NotNullCheck) Check ¶
func (c *NotNullCheck) Check(ctx context.Context, ti *scheduler.ColumnCheckInstance) error
type PositiveCheck ¶
type PositiveCheck struct {
// contains filtered or unexported fields
}
func NewPositiveCheck ¶
func NewPositiveCheck(conn connectionFetcher) *PositiveCheck
func (*PositiveCheck) Check ¶
func (c *PositiveCheck) Check(ctx context.Context, ti *scheduler.ColumnCheckInstance) error
type UniqueCheck ¶
type UniqueCheck struct {
// contains filtered or unexported fields
}
func NewUniqueCheck ¶
func NewUniqueCheck(conn connectionFetcher) *UniqueCheck
func (*UniqueCheck) Check ¶
func (c *UniqueCheck) Check(ctx context.Context, ti *scheduler.ColumnCheckInstance) error
Source Files
Click to show internal directories.
Click to hide internal directories.