upgrade_kyma

package
v0.0.0-...-34ee2f8 Latest Latest
Warning

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

 Go to latest Published: Apr 1, 2021 License: Apache-2.0, Apache-2.0 Imports: 30 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
)
View Source 
const DryRunPrefix = "dry_run-"

Variables

This section is empty.

Functions

func NewClsUpgradeProvisionStep 

func NewClsUpgradeProvisionStep(config *cls.Config, provisioner provisioning.ClsProvisioner, repo storage.Operations) *clsUpgradeProvisionStep

Types

type ClsCheckStatusStep 

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

func NewClsCheckStatus 

func NewClsCheckStatus(config *cls.Config, sc ClsStatusChecker, os storage.Operations) *ClsCheckStatusStep

func (*ClsCheckStatusStep) Name 

func (s *ClsCheckStatusStep) Name() string

func (*ClsCheckStatusStep) Run 

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

type ClsStatusChecker 

type ClsStatusChecker interface {
	CheckProvisionStatus(smClient servicemanager.Client, instanceKey servicemanager.InstanceKey, log logrus.FieldLogger) (cls.ProvisionStatus, error)
}

type ClsUpgradeAuditLogOverridesStep 

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

TODO: delete this step after all SKR clusters are migrated to 1.20! the only reason why it's there is the old rigid way of configuring FluentBit (via extra.conf), which makes it impossible to decouple CLS overrides from Audit Log overrides (both will end up in the same FluentBit config section)

func NewClsUpgradeAuditLogOverridesStep 

func NewClsUpgradeAuditLogOverridesStep(os storage.Operations, cfg auditlog.Config, secretKey string) *ClsUpgradeAuditLogOverridesStep

func (*ClsUpgradeAuditLogOverridesStep) Name 

func (alo *ClsUpgradeAuditLogOverridesStep) Name() string

func (*ClsUpgradeAuditLogOverridesStep) Run 

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

type ClsUpgradeBindStep 

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

func NewClsUpgradeBindStep 

func NewClsUpgradeBindStep(config *cls.Config, bp provisioning.ClsBindingProvider, os storage.Operations, secretKey string) *ClsUpgradeBindStep

func (*ClsUpgradeBindStep) Name 

func (s *ClsUpgradeBindStep) Name() string

func (*ClsUpgradeBindStep) Run 

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

type ClsUpgradeOfferingStep 

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

func NewClsUpgradeOfferingStep 

func NewClsUpgradeOfferingStep(config *cls.Config, repo storage.Operations) *ClsUpgradeOfferingStep

func (*ClsUpgradeOfferingStep) Name 

func (s *ClsUpgradeOfferingStep) Name() string

func (*ClsUpgradeOfferingStep) Run 

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

type DeprovisionAzureEventHubStep 

type DeprovisionAzureEventHubStep struct {
	OperationManager *process.UpgradeKymaOperationManager
	processazure.EventHub
}

func NewDeprovisionAzureEventHubStep 

func NewDeprovisionAzureEventHubStep(os storage.Operations, hyperscalerProvider azure.HyperscalerProvider,
	accountProvider hyperscaler.AccountProvider,
	ctx context.Context) DeprovisionAzureEventHubStep

func (DeprovisionAzureEventHubStep) Name 

func (s DeprovisionAzureEventHubStep) Name() string

func (DeprovisionAzureEventHubStep) Run 

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

type EmsUpgradeBindStep 

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

func NewEmsUpgradeBindStep 

func NewEmsUpgradeBindStep(os storage.Operations, secretKey string) *EmsUpgradeBindStep

func (*EmsUpgradeBindStep) Name 

func (s *EmsUpgradeBindStep) Name() string

func (*EmsUpgradeBindStep) Run 

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

type EmsUpgradeProvisionStep 

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

func NewEmsUpgradeProvisionStep 

func NewEmsUpgradeProvisionStep(os storage.Operations) *EmsUpgradeProvisionStep

func (*EmsUpgradeProvisionStep) Name 

func (s *EmsUpgradeProvisionStep) Name() string

func (*EmsUpgradeProvisionStep) Run 

func (s *EmsUpgradeProvisionStep) 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, b input.CreatorForPlan, em *avs.EvaluationManager,
	timeSchedule *TimeSchedule, rvc RuntimeVersionConfiguratorForUpgrade, smcf *servicemanager.ClientFactory) *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)

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 ServiceManagerOfferingStep 

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

ServiceManagerOfferingStep checks if the ServiceManager has the expected offering and stores IDs of the offering, the broker and the plan

func NewServiceManagerOfferingStep 

func NewServiceManagerOfferingStep(stepName, offeringName, planName string,
	extractor func(po *internal.UpgradeKymaOperation,
	) *internal.ServiceManagerInstanceInfo, repo storage.Operations) *ServiceManagerOfferingStep

func (*ServiceManagerOfferingStep) Name 

func (s *ServiceManagerOfferingStep) Name() string

func (*ServiceManagerOfferingStep) Run 

func (s *ServiceManagerOfferingStep) 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 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)

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.