pipeline

type BasicRemotePipelineProvider struct {
}

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

type DefinitionConfig struct {
	Name   string          `json:"name"`
	Tasks  []TaskConfig    `json:"structure"`
	Input  []PipelineInput `json:"input"`
	Output PipelineOutput  `json:"output"`
}

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

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

type NewDefaultMapperFactory struct {
}

type PipelineInput struct {
	Type      string      `json:"type"`
	Dimension int         `json:"dimension"`
	Shape     []int       `json:"shape"`
	Label     interface{} `json:"label"`
}

type PipelineOutput struct {
	Type string      `json:"type"`
	Data interface{} `json:"data"`
}

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

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

type StageConfig struct {
	*operation.Config
}

type Task interface {
	Eval(scope data.Scope, logger log.Logger) (data.Scope, error)
	Name() string
	Position()
}

type TaskConfig struct {
	Operation string      `json:"operation,required"`
	Params    interface{} `json:"params,omitempty"`
	Input     interface{} `json:"input,omitempty"`
	Output    interface{} `json:"output,required"`
}

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