deprovisioning

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

Documentation

Index

Constants

View Source 
const (
	// the time after which the operation is marked as expired
	CheckStatusTimeout = 5 * time.Hour
)

Variables

This section is empty.

Functions

This section is empty.

Types

type AvsEvaluationRemovalStep 

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

func NewAvsEvaluationsRemovalStep 

func NewAvsEvaluationsRemovalStep(delegator *avs.Delegator, operationsStorage storage.Operations, externalEvalAssistant, internalEvalAssistant avs.EvalAssistant) *AvsEvaluationRemovalStep

func (*AvsEvaluationRemovalStep) Name 

func (ars *AvsEvaluationRemovalStep) Name() string

func (*AvsEvaluationRemovalStep) Run 

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

type BTPOperatorCleanupStep 

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

func NewBTPOperatorCleanupStep 

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

func (*BTPOperatorCleanupStep) Name 

func (s *BTPOperatorCleanupStep) Name() string

func (*BTPOperatorCleanupStep) Run 

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

type CheckClusterDeregistrationStep 

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

func NewCheckClusterDeregistrationStep 

func NewCheckClusterDeregistrationStep(os storage.Operations, cli reconciler.Client, timeout time.Duration) *CheckClusterDeregistrationStep

func (*CheckClusterDeregistrationStep) Name 

func (s *CheckClusterDeregistrationStep) Name() string

func (*CheckClusterDeregistrationStep) Run 

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

type CheckKymaResourceDeletedStep 

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

func NewCheckKymaResourceDeletedStep 

func NewCheckKymaResourceDeletedStep(operations storage.Operations, kcpClient client.Client) *CheckKymaResourceDeletedStep

func (*CheckKymaResourceDeletedStep) Name 

func (step *CheckKymaResourceDeletedStep) Name() string

func (*CheckKymaResourceDeletedStep) Run 

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

type CheckRuntimeRemovalStep 

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

func NewCheckRuntimeRemovalStep 

func NewCheckRuntimeRemovalStep(operations storage.Operations, instances storage.Instances, provisionerClient provisioner.Client) *CheckRuntimeRemovalStep

func (*CheckRuntimeRemovalStep) Name 

func (s *CheckRuntimeRemovalStep) Name() string

func (*CheckRuntimeRemovalStep) Run 

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

type DeleteKymaResourceStep 

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

func NewDeleteKymaResourceStep 

func NewDeleteKymaResourceStep(operations storage.Operations, kcpClient client.Client, configProvider input.ConfigurationProvider, defaultKymaVersion string) *DeleteKymaResourceStep

func (*DeleteKymaResourceStep) Name 

func (step *DeleteKymaResourceStep) Name() string

func (*DeleteKymaResourceStep) Run 

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

type DeregisterClusterStep 

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

func NewDeregisterClusterStep 

func NewDeregisterClusterStep(os storage.Operations, cli reconciler.Client) *DeregisterClusterStep

func (*DeregisterClusterStep) Name 

func (s *DeregisterClusterStep) Name() string

func (*DeregisterClusterStep) Run 

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

type EDPClient 

type EDPClient interface {
	DeleteDataTenant(name, env string) error
	DeleteMetadataTenant(name, env, key string) error
}

type EDPDeregistrationStep 

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

func NewEDPDeregistrationStep 

func NewEDPDeregistrationStep(os storage.Operations, client EDPClient, config edp.Config) *EDPDeregistrationStep

func (*EDPDeregistrationStep) Name 

func (s *EDPDeregistrationStep) Name() string

func (*EDPDeregistrationStep) Run 

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

type IASDeregistrationStep 

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

func NewIASDeregistrationStep 

func NewIASDeregistrationStep(os storage.Operations, bundleBuilder ias.BundleBuilder) *IASDeregistrationStep

func (*IASDeregistrationStep) Name 

func (s *IASDeregistrationStep) Name() string

func (*IASDeregistrationStep) Run 

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

type InitStep 

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

func NewInitStep 

func NewInitStep(operations storage.Operations, instances storage.Instances, operationTimeout time.Duration) *InitStep

func (*InitStep) Name 

func (s *InitStep) Name() string

func (*InitStep) Run 

func (s *InitStep) 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, 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 ReleaseSubscriptionStep 

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

func NewReleaseSubscriptionStep 

func NewReleaseSubscriptionStep(os storage.Operations, instanceStorage storage.Instances, accountProvider hyperscaler.AccountProvider) ReleaseSubscriptionStep

func (ReleaseSubscriptionStep) Name 

func (s ReleaseSubscriptionStep) Name() string

func (ReleaseSubscriptionStep) Run 

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

type RemoveInstanceStep 

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

func NewRemoveInstanceStep 

func NewRemoveInstanceStep(instanceStorage storage.Instances, operationStorage storage.Operations) *RemoveInstanceStep

func (*RemoveInstanceStep) Name 

func (s *RemoveInstanceStep) Name() string

func (*RemoveInstanceStep) Run 

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

type RemoveRuntimeStep 

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

func NewRemoveRuntimeStep 

func NewRemoveRuntimeStep(os storage.Operations, is storage.Instances, cli provisioner.Client, provisionerTimeout time.Duration) *RemoveRuntimeStep

func (*RemoveRuntimeStep) Name 

func (s *RemoveRuntimeStep) Name() string

func (*RemoveRuntimeStep) Run 

func (s *RemoveRuntimeStep) Run(operation internal.Operation, log logrus.FieldLogger) (internal.Operation, 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.DeprovisioningOperation, log logrus.FieldLogger) (internal.DeprovisioningOperation, time.Duration, error)

type Step 

type Step interface {
	Name() string
	Run(operation internal.DeprovisioningOperation, logger logrus.FieldLogger) (internal.DeprovisioningOperation, 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.