Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BasicOperator ¶
type BasicOperator struct {
// contains filtered or unexported fields
}
func NewBasicOperator ¶
func NewBasicOperator(conn *connection.Manager) (*BasicOperator, error)
func (*BasicOperator) Run ¶
func (o *BasicOperator) Run(ctx context.Context, ti scheduler.TaskInstance) error
type IngestrCheckOperator ¶
type IngestrCheckOperator struct {
// contains filtered or unexported fields
}
func NewColumnCheckOperator ¶
func NewColumnCheckOperator(configs *map[pipeline.AssetType]executor.Config) *IngestrCheckOperator
func (IngestrCheckOperator) Run ¶
func (i IngestrCheckOperator) Run(ctx context.Context, ti scheduler.TaskInstance) error
type IngestrCustomCheckOperator ¶
type IngestrCustomCheckOperator struct {
// contains filtered or unexported fields
}
func NewCustomCheckOperator ¶
func NewCustomCheckOperator(configs *map[pipeline.AssetType]executor.Config) *IngestrCustomCheckOperator
func (IngestrCustomCheckOperator) Run ¶
func (i IngestrCustomCheckOperator) Run(ctx context.Context, ti scheduler.TaskInstance) error
Source Files
Click to show internal directories.
Click to hide internal directories.