transform

Documentation

Index

• Constants
• type Transformer
  • func NewTransformer(appCtx context.Context, loader dsref.Loader, pub event.Publisher) *Transformer
  • func (t Transformer) Apply(ctx context.Context, target *dataset.Dataset, runID string, wait bool, ...) error

Constants

const (
	// SyntaxStarlark identifies steps & scripts written in starlark syntax
	// they're executed by the startf subpackage
	SyntaxStarlark = "starlark"
	// SyntaxQri is not currently in use. It's planned for deprecation & removal
	SyntaxQri = "qri"
)

const (
	// StatusWaiting is the canonical constant for "waiting" execution state
	StatusWaiting = "waiting"
	// StatusRunning is the canonical constant for "running" execution state
	StatusRunning = "running"
	// StatusSucceeded is the canonical constant for "succeeded" execution state
	StatusSucceeded = "succeeded"
	// StatusFailed is the canonical constant for "failed" execution state
	StatusFailed = "failed"
	// StatusSkipped is the canonical constant for "skipped" execution state
	StatusSkipped = "skipped"
)

Types

type Transformer

type Transformer struct {
	// contains filtered or unexported fields
}

Transformer holds dependencies needed for applying a transform

func NewTransformer

func NewTransformer(appCtx context.Context, loader dsref.Loader, pub event.Publisher) *Transformer

NewTransformer returns a new transformer

func (Transformer) Apply

func (t Transformer) Apply(
	ctx context.Context,
	target *dataset.Dataset,
	runID string,
	wait bool,
	scriptOut io.Writer,
	secrets map[string]string,
) error

Apply applies the transform script to a target dataset