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

View Source 
var ConfigMapGetter internal.ClusterIDGetter = internal.GetClusterIDWithKubeconfig

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 (s *ApplyReconcilerConfigurationStep) Name() string

func (*ApplyReconcilerConfigurationStep) Run 

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

type BTPOperatorOverridesStep 

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

func NewBTPOperatorOverridesStep 

func NewBTPOperatorOverridesStep(os storage.Operations, components input.ComponentListProvider) *BTPOperatorOverridesStep

func (*BTPOperatorOverridesStep) Name 

func (s *BTPOperatorOverridesStep) Name() string

func (*BTPOperatorOverridesStep) Run 

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

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 

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

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 

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

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 

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

type InitKymaVersionStep 

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

func NewInitKymaVersionStep 

func NewInitKymaVersionStep(os storage.Operations, rvc *runtimeversion.RuntimeVersionConfigurator, runtimeStatesDb storage.RuntimeStates) *InitKymaVersionStep

func (*InitKymaVersionStep) Name 

func (s *InitKymaVersionStep) Name() string

func (*InitKymaVersionStep) Run 

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

type InitialisationStep 

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

func NewInitialisationStep 

func NewInitialisationStep(is storage.Instances, os storage.Operations, rvc RuntimeVersionConfiguratorForUpdating, b input.CreatorForPlan) *InitialisationStep

func (*InitialisationStep) Name 

func (s *InitialisationStep) Name() string

func (*InitialisationStep) Run 

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

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 

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

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.