executor

Documentation

Index

• type EntitiesFinder
• type Executor
  • func NewExecutor(kube *kuber.Kube, entitiesFinder EntitiesFinder, workersCount int, dryRun bool) *Executor
  • func (executor *Executor) SetAutomationFeedbackHandler(handler agent.AutomationFeedbackHandler)
  • func (executor *Executor) Start(ctx context.Context) error
  • func (executor *Executor) Stop() error
  • func (executor *Executor) SubmitAutomation(automation *agent.Automation) error

Types

type EntitiesFinder

type EntitiesFinder interface {
	FindController(namespaceName string, controllerKind string, controllerName string) (*unstructured.Unstructured, error)
	FindContainer(namespaceName string, controllerKind string, controllerName string, containerName string) (*kv1.Container, error)
}

type Executor

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

Executor Automation executor

func NewExecutor

func NewExecutor(
	kube *kuber.Kube,
	entitiesFinder EntitiesFinder,
	workersCount int,
	dryRun bool,
) *Executor

NewExecutor creates a new executor

func (*Executor) SetAutomationFeedbackHandler

func (executor *Executor) SetAutomationFeedbackHandler(handler agent.AutomationFeedbackHandler)

func (*Executor) Start

func (executor *Executor) Start(ctx context.Context) error

func (*Executor) Stop

func (executor *Executor) Stop() error

func (*Executor) SubmitAutomation

func (executor *Executor) SubmitAutomation(automation *agent.Automation) error