provisioning

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

Documentation

Index

Constants

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

Variables

This section is empty.

Functions

func DoForOwnClusterPlanOnly 

func DoForOwnClusterPlanOnly(operation internal.Operation) bool

func SkipForOwnClusterPlan 

func SkipForOwnClusterPlan(operation internal.Operation) bool

func WhenBTPOperatorCredentialsProvided 

func WhenBTPOperatorCredentialsProvided(op internal.Operation) bool

Types

type ApplyKymaStep 

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

func NewApplyKymaStep 

func NewApplyKymaStep(os storage.Operations, cli client.Client) *ApplyKymaStep

func (*ApplyKymaStep) Name 

func (a *ApplyKymaStep) Name() string

func (*ApplyKymaStep) Run 

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

type BTPOperatorOverridesStep 

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

func NewBTPOperatorOverridesStep 

func NewBTPOperatorOverridesStep(os storage.Operations) *BTPOperatorOverridesStep

func (*BTPOperatorOverridesStep) Name 

func (s *BTPOperatorOverridesStep) Name() string

func (*BTPOperatorOverridesStep) Run 

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

type CheckClusterConfigurationStep 

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

CheckClusterConfigurationStep checks if the SKR configuration is applied (by reconciler)

func NewCheckClusterConfigurationStep 

func NewCheckClusterConfigurationStep(os storage.Operations,
	reconcilerClient reconciler.Client,
	provisioningTimeout time.Duration) *CheckClusterConfigurationStep

func (*CheckClusterConfigurationStep) Name 

func (s *CheckClusterConfigurationStep) Name() string

func (*CheckClusterConfigurationStep) Run 

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

type CheckRuntimeStep 

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

CheckRuntimeStep checks if the SKR is provisioned

func NewCheckRuntimeStep 

func NewCheckRuntimeStep(os storage.Operations,
	provisionerClient provisioner.Client,
	provisioningTimeout time.Duration) *CheckRuntimeStep

func (*CheckRuntimeStep) Name 

func (s *CheckRuntimeStep) Name() string

func (*CheckRuntimeStep) Run 

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

type CreateClusterConfigurationStep 

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

func NewCreateClusterConfiguration 

func NewCreateClusterConfiguration(os storage.Operations, runtimeStorage storage.RuntimeStates, reconcilerClient reconciler.Client) *CreateClusterConfigurationStep

func (*CreateClusterConfigurationStep) Name 

func (s *CreateClusterConfigurationStep) Name() string

func (*CreateClusterConfigurationStep) Run 

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

type CreateRuntimeForOwnCluster 

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

func NewCreateRuntimeForOwnClusterStep 

func NewCreateRuntimeForOwnClusterStep(os storage.Operations, is storage.Instances) *CreateRuntimeForOwnCluster

func (*CreateRuntimeForOwnCluster) Name 

func (s *CreateRuntimeForOwnCluster) Name() string

func (*CreateRuntimeForOwnCluster) Run 

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

type CreateRuntimeWithoutKymaStep 

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

func NewCreateRuntimeWithoutKymaStep 

func NewCreateRuntimeWithoutKymaStep(os storage.Operations, runtimeStorage storage.RuntimeStates, is storage.Instances, cli provisioner.Client) *CreateRuntimeWithoutKymaStep

func (*CreateRuntimeWithoutKymaStep) Name 

func (s *CreateRuntimeWithoutKymaStep) Name() string

func (*CreateRuntimeWithoutKymaStep) Run 

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

type DirectorClient 

type DirectorClient interface {
	SetLabel(accountID, runtimeID, key, value string) error
}

type EDPClient 

type EDPClient interface {
	CreateDataTenant(data edp.DataTenantPayload) error
	CreateMetadataTenant(name, env string, data edp.MetadataTenantPayload) error

	DeleteDataTenant(name, env string) error
	DeleteMetadataTenant(name, env, key string) error
}

type EDPRegistrationStep 

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

func NewEDPRegistrationStep 

func NewEDPRegistrationStep(os storage.Operations, client EDPClient, config edp.Config) *EDPRegistrationStep

func (*EDPRegistrationStep) Name 

func (s *EDPRegistrationStep) Name() string

func (*EDPRegistrationStep) Run 

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

type EnableForTrialPlanStep 

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

func NewEnableForTrialPlanStep 

func NewEnableForTrialPlanStep(step process.Step) EnableForTrialPlanStep

func (EnableForTrialPlanStep) Name 

func (s EnableForTrialPlanStep) Name() string

func (EnableForTrialPlanStep) Run 

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

type ExternalEvalCreator 

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

func NewExternalEvalCreator 

func NewExternalEvalCreator(delegator *avs.Delegator, disabled bool, assistant *avs.ExternalEvalAssistant) *ExternalEvalCreator

type ExternalEvalStep 

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

func NewExternalEvalStep 

func NewExternalEvalStep(externalEvalCreator *ExternalEvalCreator) *ExternalEvalStep

func (ExternalEvalStep) Name 

func (e ExternalEvalStep) Name() string

func (*ExternalEvalStep) Run 

func (s *ExternalEvalStep) 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(kubeconfig 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 InitialisationStep 

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

func NewInitialisationStep 

func NewInitialisationStep(os storage.Operations, is storage.Instances, b input.CreatorForPlan, rvc RuntimeVersionConfiguratorForProvisioning) *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 InjectBTPOperatorCredentialsStep 

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

func NewInjectBTPOperatorCredentialsStep 

func NewInjectBTPOperatorCredentialsStep(os storage.Operations, k8sClientProvider func(kcfg string) (client.Client, error)) *InjectBTPOperatorCredentialsStep

func (*InjectBTPOperatorCredentialsStep) Name 

func (s *InjectBTPOperatorCredentialsStep) Name() string

func (*InjectBTPOperatorCredentialsStep) Run 

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

type InternalEvalUpdater 

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

func NewInternalEvalUpdater 

func NewInternalEvalUpdater(delegator *avs.Delegator, assistant *avs.InternalEvalAssistant, config avs.Config) *InternalEvalUpdater

func (*InternalEvalUpdater) AddTagsToEval 

func (ieu *InternalEvalUpdater) AddTagsToEval(tags []*avs.Tag, operation internal.Operation, url string, logger logrus.FieldLogger) (internal.Operation, time.Duration, error)

type InternalEvaluationStep 

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

func NewInternalEvaluationStep 

func NewInternalEvaluationStep(delegator *avs.Delegator, assistant *avs.InternalEvalAssistant) *InternalEvaluationStep

func (*InternalEvaluationStep) Name 

func (ies *InternalEvaluationStep) Name() string

func (*InternalEvaluationStep) Run 

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

type KymaVersionConfigurator 

type KymaVersionConfigurator interface {
	ForGlobalAccount(string) (string, bool, error)
}

type OverridesFromSecretsAndConfigStep 

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

func NewOverridesFromSecretsAndConfigStep 

func NewOverridesFromSecretsAndConfigStep(os storage.Operations, runtimeOverrides RuntimeOverridesAppender,
	rvc RuntimeVersionConfiguratorForProvisioning) *OverridesFromSecretsAndConfigStep

func (*OverridesFromSecretsAndConfigStep) Name 

func (s *OverridesFromSecretsAndConfigStep) Name() string

func (*OverridesFromSecretsAndConfigStep) Run 

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

type ResolveCredentialsStep 

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

func NewResolveCredentialsStep 

func NewResolveCredentialsStep(os storage.Operations, accountProvider hyperscaler.AccountProvider) *ResolveCredentialsStep

func (*ResolveCredentialsStep) Name 

func (s *ResolveCredentialsStep) Name() string

func (*ResolveCredentialsStep) Run 

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

type RuntimeOverridesAppender 

type RuntimeOverridesAppender interface {
	Append(input runtimeoverrides.InputAppender, planName, overridesVersion string) error
}

type RuntimeTagsStep 

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

func NewRuntimeTagsStep 

func NewRuntimeTagsStep(internalEvalUpdater *InternalEvalUpdater, provisionerClient provisioner.Client) *RuntimeTagsStep

func (*RuntimeTagsStep) Name 

func (e *RuntimeTagsStep) Name() string

func (*RuntimeTagsStep) Run 

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

type RuntimeVersionConfiguratorForProvisioning 

type RuntimeVersionConfiguratorForProvisioning interface {
	ForProvisioning(op internal.Operation) (*internal.RuntimeVersionData, error)
}

type SkipForTrialPlanStep 

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

func NewSkipForTrialPlanStep 

func NewSkipForTrialPlanStep(step process.Step) SkipForTrialPlanStep

func (SkipForTrialPlanStep) Name 

func (s SkipForTrialPlanStep) Name() string

func (SkipForTrialPlanStep) Run 

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

type StartStep 

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

StartStep changes the state from pending to in progress if necessary

func NewStartStep 

func NewStartStep(os storage.Operations, is storage.Instances) *StartStep

func (*StartStep) Name 

func (s *StartStep) Name() string

func (*StartStep) Run 

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