task

Documentation

Index

• Constants
• func PipeArtifactName(meta renderer.Metadata, key string) string
• func PipePodName(meta renderer.Metadata) string
• type ApplyTask
  • func (at ApplyTask) Run(ctx Context) (bool, error)
• type Context
• type DeleteTask
  • func (dt DeleteTask) Run(ctx Context) (bool, error)
• type DummyTask
  • func (dt DummyTask) Run(ctx Context) (bool, error)
• type PipeFile
• type PipeFileKind
• type PipeTask
  • func (pt PipeTask) Run(ctx Context) (bool, error)
• type Tasker
  • func Build(task *v1beta1.Task) (Tasker, error)

Constants

const (
	ApplyTaskKind  = "Apply"
	DeleteTaskKind = "Delete"
	DummyTaskKind  = "Dummy"
	PipeTaskKind   = "Pipe"
)

Available tasks kinds

const (
	PipePodAnnotation = "kudo.dev/pipepod"
)

Functions

func PipeArtifactName

func PipeArtifactName(meta renderer.Metadata, key string) string

PipeArtifactName returns a deterministic name for pipe artifact (ConfigMap, Secret)

func PipePodName

func PipePodName(meta renderer.Metadata) string

PipePodName returns a deterministic name for a pipe pod

Types

type ApplyTask

type ApplyTask struct {
	Name      string
	Resources []string
}

ApplyTask will apply a set of given resources to the cluster. See Run method for more details.

func (ApplyTask) Run

func (at ApplyTask) Run(ctx Context) (bool, error)

Run method for the ApplyTask. Given the task context, it renders the templates using context parameters creates runtime objects and enhances them, and applies them using the controller client. Finally, resources are checked for health.

type Context

type Context struct {
	Client     client.Client
	Enhancer   renderer.Enhancer
	Meta       renderer.Metadata
	Templates  map[string]string // Raw templates
	Parameters map[string]string // Instance and OperatorVersion parameters merged
	Pipes      map[string]string // Pipe artifacts
}

Context is a engine.task execution context containing k8s client, templates parameters etc.

type DeleteTask

type DeleteTask struct {
	Name      string
	Resources []string
}

DeleteTask will delete a set of given resources from the cluster. See Run method for more details.

func (DeleteTask) Run

func (dt DeleteTask) Run(ctx Context) (bool, error)

Run method for the DeleteTask. Given the task context, it renders the templates using context parameters creates runtime objects and enhances them, and finally removes them using the controller client.

type DummyTask

type DummyTask struct {
	Name    string
	WantErr bool
	Fatal   bool
	Done    bool
}

DummyTask is a task that can fail or succeed on demand

func (DummyTask) Run

func (dt DummyTask) Run(ctx Context) (bool, error)

Run method for the tDummyTask. It has no side effects and returns a dummy error if WantErr is true

type PipeFile

type PipeFile struct {
	File string
	Kind PipeFileKind
	Key  string
}

type PipeFileKind

type PipeFileKind string

const (
	// PipeFile will be persisted as a Secret
	PipeFileKindSecret PipeFileKind = "Secret"
	// PipeFile will be persisted as a ConfigMap
	PipeFileKindConfigMap PipeFileKind = "ConfigMap"
)

type PipeTask

type PipeTask struct {
	Name      string
	Pod       string
	PipeFiles []PipeFile
}

func (PipeTask) Run

func (pt PipeTask) Run(ctx Context) (bool, error)

type Tasker

type Tasker interface {
	Run(ctx Context) (bool, error)
}

Tasker is an interface that represents any runnable task for an operator. This method is treated as idempotent and will be called multiple times during the life-cycle of the plan execution. Method returns a boolean, signalizing that the task has finished successfully, and an error. An error can wrap the ErrFatalExecution for errors that should not be retried e.g. failed template rendering. This will result in a v1beta1.ExecutionFatalError in the plan execution status. A normal error e.g. failure during accessing the API server will be treated as "transient", meaning plan execution engine can retry it next time. Only a (true, nil) return value will be treated as successful task execution.

func Build

func Build(task *v1beta1.Task) (Tasker, error)

Build factory method takes an v1beta1.Task and returns a corresponding Tasker object