operations

Documentation

Index

• Variables
• func ConvertToAppError(err error) apperrors.AppError
• type Executor
  • func NewExecutor(session dbsession.ReadWriteSession, operation model.OperationType, ...) *Executor
  • func (e *Executor) Execute(operationID string) ProcessingResult
• type FailureHandler
• type NonRecoverableError
  • func NewNonRecoverableError(err error) NonRecoverableError
  • func (r NonRecoverableError) Error() string
• type ProcessingResult
• type StageResult
• type Step

Variables

var ErrKubeconfigNil = errors.New("cluster kubeconfig is nil")

Functions

func ConvertToAppError

func ConvertToAppError(err error) apperrors.AppError

Types

type Executor

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

func NewExecutor

func NewExecutor(
	session dbsession.ReadWriteSession,
	operation model.OperationType,
	stages map[model.OperationStage]Step,
	failureHandler FailureHandler) *Executor

func (*Executor) Execute

func (e *Executor) Execute(operationID string) ProcessingResult

type FailureHandler

type FailureHandler interface {
	HandleFailure(operation model.Operation, cluster model.Cluster) error
}

type NonRecoverableError

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

func NewNonRecoverableError

func NewNonRecoverableError(err error) NonRecoverableError

func (NonRecoverableError) Error

func (r NonRecoverableError) Error() string

type ProcessingResult

type ProcessingResult struct {
	Requeue bool
	Delay   time.Duration
}

type StageResult

type StageResult struct {
	Stage model.OperationStage
	Delay time.Duration
}

type Step

type Step interface {
	Name() model.OperationStage
	Run(cluster model.Cluster, operation model.Operation, logger logrus.FieldLogger) (StageResult, error)
	TimeLimit() time.Duration
}