upgrade_cluster

Documentation

Index

• Constants
• type InitialisationStep
  • func NewInitialisationStep(os storage.Operations, ors storage.Orchestrations, pc provisioner.Client, ...) *InitialisationStep
  • func (s *InitialisationStep) Name() string
  • func (s *InitialisationStep) Run(operation internal.UpgradeClusterOperation, log logrus.FieldLogger) (internal.UpgradeClusterOperation, time.Duration, error)
• type LogSkippingUpgradeStep
  • func NewLogSkippingUpgradeStep(os storage.Operations) *LogSkippingUpgradeStep
  • func (s *LogSkippingUpgradeStep) Name() string
  • func (s *LogSkippingUpgradeStep) Run(operation internal.UpgradeClusterOperation, log logrus.FieldLogger) (internal.UpgradeClusterOperation, time.Duration, error)
• type Manager
  • func NewManager(storage storage.Operations, pub event.Publisher, logger logrus.FieldLogger) *Manager
  • func (m *Manager) AddStep(weight int, step Step, condition StepCondition)
  • func (m *Manager) Execute(operationID string) (time.Duration, error)
  • func (m *Manager) InitStep(step Step)
  • func (m Manager) Reschedule(operationID string, maintenanceWindowBegin, maintenanceWindowEnd time.Time) error
• type SendNotificationStep
  • func NewSendNotificationStep(os storage.Operations, bundleBuilder notification.BundleBuilder) *SendNotificationStep
  • func (s *SendNotificationStep) Name() string
  • func (s *SendNotificationStep) Run(operation internal.UpgradeClusterOperation, log logrus.FieldLogger) (internal.UpgradeClusterOperation, time.Duration, error)
• type Step
• type StepCondition
• type StepWithCondition
• type TimeSchedule
• type UpgradeClusterStep
  • func NewUpgradeClusterStep(os storage.Operations, runtimeStorage storage.RuntimeStates, ...) *UpgradeClusterStep
  • func (s *UpgradeClusterStep) Name() string
  • func (s *UpgradeClusterStep) Run(operation internal.UpgradeClusterOperation, log logrus.FieldLogger) (internal.UpgradeClusterOperation, time.Duration, error)

Constants

const (
	UpgradeInitSteps int = iota + 1
	UpgradeFinishSteps
)

const (
	// the time after which the operation is marked as expired
	CheckStatusTimeout = 3 * time.Hour
)

const DryRunPrefix = "dry_run-"

Types

type InitialisationStep

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

func NewInitialisationStep

func NewInitialisationStep(os storage.Operations, ors storage.Orchestrations, pc provisioner.Client, b input.CreatorForPlan, em *avs.EvaluationManager,
	timeSchedule *TimeSchedule, bundleBuilder notification.BundleBuilder) *InitialisationStep

func (*InitialisationStep) Name

func (s *InitialisationStep) Name() string

func (*InitialisationStep) Run

func (s *InitialisationStep) Run(operation internal.UpgradeClusterOperation, log logrus.FieldLogger) (internal.UpgradeClusterOperation, time.Duration, error)

type LogSkippingUpgradeStep

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

func NewLogSkippingUpgradeStep

func NewLogSkippingUpgradeStep(os storage.Operations) *LogSkippingUpgradeStep

func (*LogSkippingUpgradeStep) Name

func (s *LogSkippingUpgradeStep) Name() string

func (*LogSkippingUpgradeStep) Run

func (s *LogSkippingUpgradeStep) Run(operation internal.UpgradeClusterOperation, log logrus.FieldLogger) (internal.UpgradeClusterOperation, time.Duration, error)

type Manager

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

func NewManager

func NewManager(storage storage.Operations, pub event.Publisher, logger logrus.FieldLogger) *Manager

func (*Manager) AddStep

func (m *Manager) AddStep(weight int, step Step, condition StepCondition)

func (*Manager) Execute

func (m *Manager) Execute(operationID string) (time.Duration, error)

func (*Manager) InitStep

func (m *Manager) InitStep(step Step)

func (Manager) Reschedule

func (m Manager) Reschedule(operationID string, maintenanceWindowBegin, maintenanceWindowEnd time.Time) error

type SendNotificationStep

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

func NewSendNotificationStep

func NewSendNotificationStep(os storage.Operations, bundleBuilder notification.BundleBuilder) *SendNotificationStep

func (*SendNotificationStep) Name

func (s *SendNotificationStep) Name() string

func (*SendNotificationStep) Run

func (s *SendNotificationStep) Run(operation internal.UpgradeClusterOperation, log logrus.FieldLogger) (internal.UpgradeClusterOperation, time.Duration, error)

type Step

type Step interface {
	Name() string
	Run(operation internal.UpgradeClusterOperation, logger logrus.FieldLogger) (internal.UpgradeClusterOperation, time.Duration, error)
}

type StepCondition

type StepCondition func(operation internal.Operation) bool

type StepWithCondition

type StepWithCondition struct {
	Step
	// contains filtered or unexported fields
}

type TimeSchedule

type TimeSchedule struct {
	Retry                 time.Duration
	StatusCheck           time.Duration
	UpgradeClusterTimeout time.Duration
}

type UpgradeClusterStep

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

func NewUpgradeClusterStep

func NewUpgradeClusterStep(
	os storage.Operations,
	runtimeStorage storage.RuntimeStates,
	cli provisioner.Client,
	timeSchedule *TimeSchedule) *UpgradeClusterStep

func (*UpgradeClusterStep) Name

func (s *UpgradeClusterStep) Name() string

func (*UpgradeClusterStep) Run

func (s *UpgradeClusterStep) Run(operation internal.UpgradeClusterOperation, log logrus.FieldLogger) (internal.UpgradeClusterOperation, time.Duration, error)