update

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: 22 Imported by: 0

Documentation

Index

Constants

View Source
const BTPOperatorComponentName = "btp-operator"
View Source
const DryRunPrefix = "dry_run-"

Variables

Functions

func CheckReconcilerStatus

func CheckReconcilerStatus(op internal.Operation) bool

func ForBTPOperatorCredentialsProvided

func ForBTPOperatorCredentialsProvided(op internal.Operation) bool

func RequiresBTPOperatorCredentials

func RequiresBTPOperatorCredentials(op internal.Operation) bool

func RequiresReconcilerUpdate

func RequiresReconcilerUpdate(op internal.Operation) bool

func SkipForOwnClusterPlan

func SkipForOwnClusterPlan(op internal.Operation) bool

Types

type ApplyReconcilerConfigurationStep

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

func NewApplyReconcilerConfigurationStep

func NewApplyReconcilerConfigurationStep(os storage.Operations, runtimeStorage storage.RuntimeStates, reconcilerClient reconciler.Client) *ApplyReconcilerConfigurationStep

func (*ApplyReconcilerConfigurationStep) Name

func (*ApplyReconcilerConfigurationStep) Run

type BTPOperatorOverridesStep

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

func (*BTPOperatorOverridesStep) Name

func (s *BTPOperatorOverridesStep) Name() string

func (*BTPOperatorOverridesStep) Run

type CheckReconcilerState

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

func NewCheckReconcilerState

func NewCheckReconcilerState(os storage.Operations, reconcilerClient reconciler.Client) *CheckReconcilerState

func (*CheckReconcilerState) Name

func (s *CheckReconcilerState) Name() string

func (*CheckReconcilerState) Run

type CheckStep

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

CheckStep checks if the SKR is updated

func NewCheckStep

func NewCheckStep(os storage.Operations,
	provisionerClient provisioner.Client,
	provisioningTimeout time.Duration) *CheckStep

func (*CheckStep) Name

func (s *CheckStep) Name() string

func (*CheckStep) Run

type GetKubeconfigStep

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

func NewGetKubeconfigStep

func NewGetKubeconfigStep(os storage.Operations, provisionerClient provisioner.Client, k8sClientProvider func(kcfg string) (client.Client, error)) *GetKubeconfigStep

func (*GetKubeconfigStep) Name

func (s *GetKubeconfigStep) Name() string

func (*GetKubeconfigStep) Run

type InitKymaVersionStep

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

func (*InitKymaVersionStep) Name

func (s *InitKymaVersionStep) Name() string

func (*InitKymaVersionStep) Run

type InitialisationStep

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

func (*InitialisationStep) Name

func (s *InitialisationStep) Name() string

func (*InitialisationStep) Run

type Manager

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

func NewManager

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

func (*Manager) AddStep

func (m *Manager) AddStep(stageName string, step Step, cnd StepCondition) error

func (*Manager) DefineStages

func (m *Manager) DefineStages(names []string)

func (*Manager) Execute

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

func (*Manager) GetAllStages

func (m *Manager) GetAllStages() []string

func (*Manager) SpeedUp

func (m *Manager) SpeedUp(speedFactor int64)

SpeedUp changes speedFactor parameter to reduce the sleep time if a step needs a retry. This method should only be used for testing purposes

type RuntimeVersionConfiguratorForUpdating

type RuntimeVersionConfiguratorForUpdating interface {
	ForUpdating(op internal.Operation) (*internal.RuntimeVersionData, error)
}

type Step

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

type StepCondition

type StepCondition func(operation internal.UpdatingOperation) bool

type StepWithCondition

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

type UpgradeShootStep

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

func NewUpgradeShootStep

func NewUpgradeShootStep(
	os storage.Operations,
	runtimeStorage storage.RuntimeStates,
	cli provisioner.Client) *UpgradeShootStep

func (*UpgradeShootStep) Name

func (s *UpgradeShootStep) Name() string

func (*UpgradeShootStep) Run

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL