upgrade_kyma

Documentation

Index

• Constants
• type InitialisationStep
  • func NewInitialisationStep(os storage.Operations, is storage.Instances, pc provisioner.Client, ...) *InitialisationStep
  • func (s *InitialisationStep) Name() string
  • func (s *InitialisationStep) Run(operation internal.UpgradeKymaOperation, log logrus.FieldLogger) (internal.UpgradeKymaOperation, 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)
  • func (m *Manager) Execute(operationID string) (time.Duration, error)
  • func (m *Manager) InitStep(step Step)
• type OverridesFromSecretsAndConfigStep
  • func NewOverridesFromSecretsAndConfigStep(c context.Context, cli client.Client, os storage.Operations) *OverridesFromSecretsAndConfigStep
  • func (s *OverridesFromSecretsAndConfigStep) Name() string
  • func (s *OverridesFromSecretsAndConfigStep) Run(operation internal.UpgradeKymaOperation, log logrus.FieldLogger) (internal.UpgradeKymaOperation, time.Duration, error)
• type Step
• type TimeSchedule
• type UpgradeKymaStep
  • func NewUpgradeKymaStep(os storage.Operations, runtimeStorage storage.RuntimeStates, ...) *UpgradeKymaStep
  • func (s *UpgradeKymaStep) Name() string
  • func (s *UpgradeKymaStep) Run(operation internal.UpgradeKymaOperation, log logrus.FieldLogger) (internal.UpgradeKymaOperation, time.Duration, error)

Constants

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, is storage.Instances, pc provisioner.Client, b input.CreatorForPlan, timeSchedule *TimeSchedule) *InitialisationStep

func (*InitialisationStep) Name

func (s *InitialisationStep) Name() string

func (*InitialisationStep) Run

func (s *InitialisationStep) Run(operation internal.UpgradeKymaOperation, log logrus.FieldLogger) (internal.UpgradeKymaOperation, 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)

func (*Manager) Execute

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

func (*Manager) InitStep

func (m *Manager) InitStep(step Step)

type OverridesFromSecretsAndConfigStep

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

func NewOverridesFromSecretsAndConfigStep

func NewOverridesFromSecretsAndConfigStep(c context.Context, cli client.Client, os storage.Operations) *OverridesFromSecretsAndConfigStep

func (*OverridesFromSecretsAndConfigStep) Name

func (s *OverridesFromSecretsAndConfigStep) Name() string

func (*OverridesFromSecretsAndConfigStep) Run

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

type Step

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

type TimeSchedule

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

type UpgradeKymaStep

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

func NewUpgradeKymaStep

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

func (*UpgradeKymaStep) Name

func (s *UpgradeKymaStep) Name() string

func (*UpgradeKymaStep) Run

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