lifecycle

Documentation

Index

• type Config
• type DoWithMessage
• type DoWithProgress
• type HelmIntro
• type HelmValues
• type KubectlApply
• type KustomizeIntro
• type Kustomizer
• type Messenger
• type Renderer
• type Runner
  • func NewRunner(logger log.Logger, executor StepExecutor) *Runner
  • func (r *Runner) Run(ctx context.Context, release *api.Release) error
• type StepExecutor
  • func (s *StepExecutor) Execute(ctx context.Context, release *api.Release, step *api.Step) error
• type Terraformer

Types

type Config

type Config interface {
	ResolveConfig(context.Context, *api.Release) (map[string]interface{}, error)
}

Config is a thing that can resolve configuration options

type DoWithMessage

type DoWithMessage func(progress daemontypes.Message)

type DoWithProgress

type DoWithProgress func(progress daemontypes.Progress)

type HelmIntro

type HelmIntro interface {
	Execute(context.Context, *api.Release, *api.HelmIntro) error
}

type HelmValues

type HelmValues interface {
	Execute(context.Context, *api.Release, *api.HelmValues) error
}

type KubectlApply

type KubectlApply interface {
	Execute(ctx context.Context, release api.Release, step api.KubectlApply, confirmChan chan bool) error
	WithStatusReceiver(receiver daemontypes.StatusReceiver) KubectlApply
}

type KustomizeIntro

type KustomizeIntro interface {
	Execute(ctx context.Context, release *api.Release, step api.KustomizeIntro) error
}

type Kustomizer

type Kustomizer interface {
	PreExecute(ctx context.Context, step api.Step) error
	Execute(ctx context.Context, release *api.Release, step api.Kustomize) error
}

type Messenger

type Messenger interface {
	Execute(ctx context.Context, release *api.Release, step *api.Message) error
}

type Renderer

type Renderer interface {
	Execute(ctx context.Context, release *api.Release, step *api.Render) error
	WithStatusReceiver(receiver daemontypes.StatusReceiver) Renderer
	WithPlanner(planner planner.Planner) Renderer
}

type Runner

type Runner struct {
	Logger   log.Logger
	Executor *StepExecutor
}

A Runner runs a lifecycle using the passed Spec

func NewRunner

func NewRunner(
	logger log.Logger,
	executor StepExecutor,
) *Runner

func (*Runner) Run

func (r *Runner) Run(ctx context.Context, release *api.Release) error

Run runs a lifecycle using the passed Spec

type StepExecutor

type StepExecutor struct {
	dig.In

	Logger       log.Logger
	Messenger    Messenger
	Renderer     Renderer
	Terraformer  Terraformer
	HelmIntro    HelmIntro
	HelmValues   HelmValues
	KubectlApply KubectlApply
	Kustomizer   Kustomizer
}

func (*StepExecutor) Execute

func (s *StepExecutor) Execute(ctx context.Context, release *api.Release, step *api.Step) error

type Terraformer

type Terraformer interface {
	Execute(ctx context.Context, release api.Release, step api.Terraform, confirmChan chan bool) error
	WithStatusReceiver(receiver daemontypes.StatusReceiver) Terraformer
}