deprovisioning

Documentation

Index

• Constants
• type AvsEvaluationRemovalStep
  • func NewAvsEvaluationsRemovalStep(delegator *avs.Delegator, operationsStorage storage.Operations, ...) *AvsEvaluationRemovalStep
  • func (ars *AvsEvaluationRemovalStep) Name() string
  • func (ars *AvsEvaluationRemovalStep) Run(deProvisioningOperation internal.DeprovisioningOperation, ...) (internal.DeprovisioningOperation, time.Duration, error)
• type DeprovisionAzureEventHubStep
  • func NewDeprovisionAzureEventHubStep(os storage.Operations, hyperscalerProvider azure.HyperscalerProvider, ...) DeprovisionAzureEventHubStep
  • func (s DeprovisionAzureEventHubStep) Name() string
  • func (s DeprovisionAzureEventHubStep) Run(operation internal.DeprovisioningOperation, log logrus.FieldLogger) (internal.DeprovisioningOperation, time.Duration, error)
• type EDPClient
• type EDPDeregistrationStep
  • func NewEDPDeregistrationStep(client EDPClient, config edp.Config) *EDPDeregistrationStep
  • func (s *EDPDeregistrationStep) Name() string
  • func (s *EDPDeregistrationStep) Run(operation internal.DeprovisioningOperation, log logrus.FieldLogger) (internal.DeprovisioningOperation, time.Duration, error)
• type IASDeregistrationStep
  • func NewIASDeregistrationStep(os storage.Operations, bundleBuilder ias.BundleBuilder) *IASDeregistrationStep
  • func (s *IASDeregistrationStep) Name() string
  • func (s *IASDeregistrationStep) Run(operation internal.DeprovisioningOperation, log logrus.FieldLogger) (internal.DeprovisioningOperation, time.Duration, error)
• type InitialisationStep
  • func NewInitialisationStep(os storage.Operations, is storage.Instances, pc provisioner.Client) *InitialisationStep
  • func (s *InitialisationStep) Name() string
  • func (s *InitialisationStep) Run(operation internal.DeprovisioningOperation, log logrus.FieldLogger) (internal.DeprovisioningOperation, time.Duration, error)
• type Manager
  • func NewManager(storage storage.Operations, pub event.Publisher, logger logrus.FieldLogger) *Manager
  • func (m *Manager) AddStep(weight int, step Step)
  • func (m *Manager) Execute(operationID string) (time.Duration, error)
  • func (m *Manager) InitStep(step Step)
• type RemoveRuntimeStep
  • func NewRemoveRuntimeStep(os storage.Operations, is storage.Instances, cli provisioner.Client) *RemoveRuntimeStep
  • func (s *RemoveRuntimeStep) Name() string
  • func (s *RemoveRuntimeStep) Run(operation internal.DeprovisioningOperation, log logrus.FieldLogger) (internal.DeprovisioningOperation, time.Duration, error)
• type Step

Constants

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

const (
	// the time after which the operation is marked as expired
	RemoveRuntimeTimeout = 1 * time.Hour
)

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(deProvisioningOperation internal.DeprovisioningOperation, logger logrus.FieldLogger) (internal.DeprovisioningOperation, time.Duration, error)

type DeprovisionAzureEventHubStep

type DeprovisionAzureEventHubStep struct {
	OperationManager *process.DeprovisionOperationManager
	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.DeprovisioningOperation, log logrus.FieldLogger) (
	internal.DeprovisioningOperation, 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(client EDPClient, config edp.Config) *EDPDeregistrationStep

func (*EDPDeregistrationStep) Name

func (s *EDPDeregistrationStep) Name() string

func (*EDPDeregistrationStep) Run

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

type InitialisationStep

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

func NewInitialisationStep

func NewInitialisationStep(os storage.Operations, is storage.Instances, pc provisioner.Client) *InitialisationStep

func (*InitialisationStep) Name

func (s *InitialisationStep) Name() string

func (*InitialisationStep) Run

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

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

func NewRemoveRuntimeStep

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

func (*RemoveRuntimeStep) Name

func (s *RemoveRuntimeStep) Name() string

func (*RemoveRuntimeStep) Run

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