plugins

type Jar map[string]Plugin

type JobRunner interface {
	// PluginByName returns plugin constructor
	PluginByName(pluginName string) (p PluginFactory, err error)

	// RunJob starts job in separate goroutine.
	//
	// Use ctx.Error channel to track job result and ctx.Cancel() to cancel it.
	RunJob(j manifest.Job, ctx *job.RunContext)
}

type Plugin interface {
	// Call calls a plugin
	Call(*job.RunContext, JobRunner) error

	// Cancel stops plugin execution
	Cancel(*job.RunContext) error
}

type PluginFactory func(*scope.Scope, manifest.RawParams, log.Logger) (Plugin, error)