manager

Documentation

Index

• func NewUpgradeClusterManager(orchestrationStorage storage.Orchestrations, ...) process.Executor
• func NewUpgradeKymaManager(orchestrationStorage storage.Orchestrations, ...) process.Executor
• type OperationFactory

Functions

func NewUpgradeClusterManager

func NewUpgradeClusterManager(orchestrationStorage storage.Orchestrations, operationStorage storage.Operations, instanceStorage storage.Instances,
	kymaClusterExecutor orchestration.OperationExecutor, resolver orchestration.RuntimeResolver, pollingInterval time.Duration,
	log logrus.FieldLogger, cli client.Client, cfg internalOrchestration.Config, bundleBuilder notification.BundleBuilder, speedFactor int) process.Executor

func NewUpgradeKymaManager

func NewUpgradeKymaManager(orchestrationStorage storage.Orchestrations, operationStorage storage.Operations, instanceStorage storage.Instances,
	kymaUpgradeExecutor orchestration.OperationExecutor, resolver orchestration.RuntimeResolver, pollingInterval time.Duration,
	log logrus.FieldLogger, cli client.Client, cfg *internalOrchestration.Config, bundleBuilder notification.BundleBuilder, speedFactor int) process.Executor

Types

type OperationFactory

type OperationFactory interface {
	NewOperation(o internal.Orchestration, r orchestration.Runtime, i internal.Instance, state domain.LastOperationState) (orchestration.RuntimeOperation, error)
	ResumeOperations(orchestrationID string) ([]orchestration.RuntimeOperation, error)
	CancelOperation(orchestrationID string, runtimeID string) error
	CancelOperations(orchestrationID string) error
	RetryOperations(operationIDs []string) ([]orchestration.RuntimeOperation, error)
	QueryOperation(orchestrationID string, r orchestration.Runtime) (bool, orchestration.RuntimeOperation, error)
	QueryOperations(orchestrationID string) ([]orchestration.RuntimeOperation, error)
	NotifyOperation(orchestrationID string, runtimeID string, oState string, notifyState orchestration.NotificationStateType) error
}