ingestr

Documentation

Index

• type BasicOperator
  • func NewBasicOperator() *BasicOperator
  • func (o BasicOperator) Run(ctx context.Context, ti scheduler.TaskInstance) error
  • func (o BasicOperator) RunTask(ctx context.Context, p *pipeline.Pipeline, t *pipeline.Asset) error
• type IngestrCheckOperator
  • func NewColumnCheckOperator(configs *map[pipeline.AssetType]executor.Config) *IngestrCheckOperator
  • func (i IngestrCheckOperator) Run(ctx context.Context, ti scheduler.TaskInstance) error
• type IngestrCustomCheckOperator
  • func NewCustomCheckOperator(configs *map[pipeline.AssetType]executor.Config) *IngestrCustomCheckOperator
  • func (i IngestrCustomCheckOperator) Run(ctx context.Context, ti scheduler.TaskInstance) error

Types

type BasicOperator

type BasicOperator struct{}

func NewBasicOperator

func NewBasicOperator() *BasicOperator

func (BasicOperator) Run

func (o BasicOperator) Run(ctx context.Context, ti scheduler.TaskInstance) error

func (BasicOperator) RunTask

func (o BasicOperator) RunTask(ctx context.Context, p *pipeline.Pipeline, t *pipeline.Asset) 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