upgrade_kyma

package
v0.0.0-...-f7d1ac2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 11, 2023 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	UpgradeInitSteps int = iota + 1
	UpgradeFinishSteps
)
View Source 
const (
	// the time after which the operation is marked as expired
	CheckStatusTimeout = 3 * time.Hour
)

Variables

View Source 
var ConfigMapGetter internal.ClusterIDGetter = internal.GetClusterIDWithKubeconfig

Functions

func ForKyma1 

func ForKyma1(op internal.UpgradeKymaOperation) bool

func ForKyma2 

func ForKyma2(op internal.UpgradeKymaOperation) bool

func RestoreAvsStatus 

func RestoreAvsStatus(evaluationManager *avs.EvaluationManager, operationManager *process.UpgradeKymaOperationManager, operation internal.UpgradeKymaOperation, log logrus.FieldLogger) (internal.UpgradeKymaOperation, error)

func SetAvsStatusMaintenance 

func SetAvsStatusMaintenance(evaluationManager *avs.EvaluationManager, operationManager *process.UpgradeKymaOperationManager, operation internal.UpgradeKymaOperation, log logrus.FieldLogger) (internal.UpgradeKymaOperation, error)

func SkipForPreviewPlan 

func SkipForPreviewPlan(op internal.UpgradeKymaOperation) bool

func WhenBTPOperatorCredentialsProvided 

func WhenBTPOperatorCredentialsProvided(op internal.UpgradeKymaOperation) bool

Types

type ApplyClusterConfigurationStep 

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

func NewApplyClusterConfigurationStep 

func NewApplyClusterConfigurationStep(os storage.Operations, rs storage.RuntimeStates, reconcilerClient reconciler.Client) *ApplyClusterConfigurationStep

func (*ApplyClusterConfigurationStep) Name 

func (s *ApplyClusterConfigurationStep) Name() string

func (*ApplyClusterConfigurationStep) Run 

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

type ApplyKymaStep 

type ApplyKymaStep struct {
	*provisioning.ApplyKymaStep
}

NOTE: adapter for upgrade_kyma which is currently not using shared staged_manager

func NewApplyKymaStep 

func NewApplyKymaStep(os storage.Operations, cli client.Client) *ApplyKymaStep

func (*ApplyKymaStep) Run 

func (s *ApplyKymaStep) Run(o internal.UpgradeKymaOperation, logger logrus.FieldLogger) (internal.UpgradeKymaOperation, time.Duration, error)

type BTPOperatorOverridesStep 

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

func NewBTPOperatorOverridesStep 

func NewBTPOperatorOverridesStep(os storage.Operations) *BTPOperatorOverridesStep

func (*BTPOperatorOverridesStep) Name 

func (s *BTPOperatorOverridesStep) Name() string

func (*BTPOperatorOverridesStep) Run 

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

type CheckClusterConfigurationStep 

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

CheckClusterConfigurationStep checks if the SKR configuration is applied (by reconciler)

func NewCheckClusterConfigurationStep 

func NewCheckClusterConfigurationStep(os storage.Operations,
	reconcilerClient reconciler.Client,
	evaluationManager *avs.EvaluationManager,
	provisioningTimeout time.Duration) *CheckClusterConfigurationStep

func (*CheckClusterConfigurationStep) Name 

func (s *CheckClusterConfigurationStep) Name() string

func (*CheckClusterConfigurationStep) Run 

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

type GetKubeconfigStep 

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

func NewGetKubeconfigStep 

func NewGetKubeconfigStep(os storage.Operations,
	provisionerClient provisioner.Client) *GetKubeconfigStep

func (*GetKubeconfigStep) Name 

func (s *GetKubeconfigStep) Name() string

func (*GetKubeconfigStep) Run 

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

type InitialisationStep 

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

func NewInitialisationStep 

func NewInitialisationStep(os storage.Operations, ors storage.Orchestrations, is storage.Instances, pc provisioner.Client, inputBuilder input.CreatorForPlan, em *avs.EvaluationManager,
	timeSchedule *TimeSchedule, rvc RuntimeVersionConfiguratorForUpgrade, bundleBuilder notification.BundleBuilder) *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, cnd 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 OverridesFromSecretsAndConfigStep 

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

func NewOverridesFromSecretsAndConfigStep 

func NewOverridesFromSecretsAndConfigStep(os storage.Operations, runtimeOverrides RuntimeOverridesAppender,
	rvc RuntimeVersionConfiguratorForUpgrade) *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 RuntimeOverridesAppender 

type RuntimeOverridesAppender interface {
	Append(input runtimeoverrides.InputAppender, planID, kymaVersion string) error
}

type RuntimeVersionConfiguratorForUpgrade 

type RuntimeVersionConfiguratorForUpgrade interface {
	ForUpgrade(op internal.UpgradeKymaOperation) (*internal.RuntimeVersionData, 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.UpgradeKymaOperation, log logrus.FieldLogger) (internal.UpgradeKymaOperation, time.Duration, error)

type SkipForTrialPlanStep 

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

func NewSkipForTrialPlanStep 

func NewSkipForTrialPlanStep(step Step) SkipForTrialPlanStep

func (SkipForTrialPlanStep) Name 

func (s SkipForTrialPlanStep) Name() string

func (SkipForTrialPlanStep) Run 

func (s SkipForTrialPlanStep) 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 StepCondition 

type StepCondition func(operation internal.UpgradeKymaOperation) bool

type StepWithCondition 

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

type TimeSchedule 

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.