workflows

package
v0.19.5 Latest Latest
Warning

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

 Go to latest Published: May 1, 2024 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateNamespaceIfNotPresent added in v0.19.0 

func CreateNamespaceIfNotPresent(ctx context.Context, namespace, kubeconfig string, clientFactory interfaces.ClientFactory) error

CreateNamespaceIfNotPresent creates the namespace on the cluster if it does not already exist.

Types

type CollectDiagnosticsTask added in v0.6.1 

type CollectDiagnosticsTask struct {
	*CollectWorkloadClusterDiagnosticsTask
	*CollectMgmtClusterDiagnosticsTask
}

func (*CollectDiagnosticsTask) Checkpoint added in v0.9.2 

func (s *CollectDiagnosticsTask) Checkpoint() *task.CompletedTask

func (*CollectDiagnosticsTask) Name added in v0.6.1 

func (s *CollectDiagnosticsTask) Name() string

func (*CollectDiagnosticsTask) Restore added in v0.9.2 

func (s *CollectDiagnosticsTask) Restore(ctx context.Context, commandContext *task.CommandContext, completedTask *task.CompletedTask) (task.Task, error)

func (*CollectDiagnosticsTask) Run added in v0.6.1 

func (s *CollectDiagnosticsTask) Run(ctx context.Context, commandContext *task.CommandContext) task.Task

type CollectMgmtClusterDiagnosticsTask added in v0.6.1 

type CollectMgmtClusterDiagnosticsTask struct{}

func (*CollectMgmtClusterDiagnosticsTask) Checkpoint added in v0.9.2 

func (s *CollectMgmtClusterDiagnosticsTask) Checkpoint() *task.CompletedTask

func (*CollectMgmtClusterDiagnosticsTask) Name added in v0.6.1 

func (s *CollectMgmtClusterDiagnosticsTask) Name() string

func (*CollectMgmtClusterDiagnosticsTask) Restore added in v0.9.2 

func (s *CollectMgmtClusterDiagnosticsTask) Restore(ctx context.Context, commandContext *task.CommandContext, completedTask *task.CompletedTask) (task.Task, error)

func (*CollectMgmtClusterDiagnosticsTask) Run added in v0.6.1 

func (s *CollectMgmtClusterDiagnosticsTask) Run(ctx context.Context, commandContext *task.CommandContext) task.Task

type CollectWorkloadClusterDiagnosticsTask added in v0.6.1 

type CollectWorkloadClusterDiagnosticsTask struct{}

func (*CollectWorkloadClusterDiagnosticsTask) Checkpoint added in v0.19.0 

func (s *CollectWorkloadClusterDiagnosticsTask) Checkpoint() *task.CompletedTask

Checkpoint sets a checkpoint at CollectWorkloadClusterDiagnosticsTask.

func (*CollectWorkloadClusterDiagnosticsTask) Name added in v0.6.1 

func (s *CollectWorkloadClusterDiagnosticsTask) Name() string

Name returns the name of CollectWorkloadClusterDiagnosticsTask.

func (*CollectWorkloadClusterDiagnosticsTask) Restore added in v0.19.0 

func (s *CollectWorkloadClusterDiagnosticsTask) Restore(ctx context.Context, commandContext *task.CommandContext, completedTask *task.CompletedTask) (task.Task, error)

Restore restores from CollectWorkloadClusterDiagnosticsTask.

func (*CollectWorkloadClusterDiagnosticsTask) Run added in v0.6.1 

func (s *CollectWorkloadClusterDiagnosticsTask) Run(ctx context.Context, commandContext *task.CommandContext) task.Task

Run starts collecting the logs for workload cluster diagnostics.

type Create 

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

func NewCreate 

func NewCreate(clientFactory interfaces.ClientFactory, bootstrapper interfaces.Bootstrapper, provider providers.Provider,
	clusterManager interfaces.ClusterManager, gitOpsManager interfaces.GitOpsManager,
	writer filewriter.FileWriter, eksdInstaller interfaces.EksdInstaller,
	packageInstaller interfaces.PackageInstaller,
) *Create

NewCreate returns a Create instance.

func (*Create) Run 

func (c *Create) Run(ctx context.Context, clusterSpec *cluster.Spec, validator interfaces.Validator, forceCleanup bool) error

type CreateBootStrapClusterTask 

type CreateBootStrapClusterTask struct{}

func (*CreateBootStrapClusterTask) Checkpoint added in v0.9.2 

func (s *CreateBootStrapClusterTask) Checkpoint() *task.CompletedTask

func (*CreateBootStrapClusterTask) Name 

func (s *CreateBootStrapClusterTask) Name() string

func (*CreateBootStrapClusterTask) Restore added in v0.9.2 

func (s *CreateBootStrapClusterTask) Restore(ctx context.Context, commandContext *task.CommandContext, completedTask *task.CompletedTask) (task.Task, error)

func (*CreateBootStrapClusterTask) Run 

func (s *CreateBootStrapClusterTask) Run(ctx context.Context, commandContext *task.CommandContext) task.Task

type CreateWorkloadClusterTask 

type CreateWorkloadClusterTask struct{}

func (*CreateWorkloadClusterTask) Checkpoint added in v0.9.2 

func (s *CreateWorkloadClusterTask) Checkpoint() *task.CompletedTask

func (*CreateWorkloadClusterTask) Name 

func (s *CreateWorkloadClusterTask) Name() string

func (*CreateWorkloadClusterTask) Restore added in v0.9.2 

func (s *CreateWorkloadClusterTask) Restore(ctx context.Context, commandContext *task.CommandContext, completedTask *task.CompletedTask) (task.Task, error)

func (*CreateWorkloadClusterTask) Run 

func (s *CreateWorkloadClusterTask) Run(ctx context.Context, commandContext *task.CommandContext) task.Task

type Delete 

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

func NewDelete 

func NewDelete(bootstrapper interfaces.Bootstrapper, provider providers.Provider,
	clusterManager interfaces.ClusterManager, gitOpsManager interfaces.GitOpsManager,
	writer filewriter.FileWriter,
) *Delete

func (*Delete) Run 

func (c *Delete) Run(ctx context.Context, workloadCluster *types.Cluster, clusterSpec *cluster.Spec, forceCleanup bool, kubeconfig string) error

type DeleteBootstrapClusterTask 

type DeleteBootstrapClusterTask struct {
	*CollectDiagnosticsTask
}

func (*DeleteBootstrapClusterTask) Name 

func (s *DeleteBootstrapClusterTask) Name() string

func (*DeleteBootstrapClusterTask) Run 

func (s *DeleteBootstrapClusterTask) Run(ctx context.Context, commandContext *task.CommandContext) task.Task

type InstallCuratedPackagesTask added in v0.9.2 

type InstallCuratedPackagesTask struct{}

func (*InstallCuratedPackagesTask) Checkpoint added in v0.9.2 

func (s *InstallCuratedPackagesTask) Checkpoint() *task.CompletedTask

func (*InstallCuratedPackagesTask) Name added in v0.9.2 

func (cp *InstallCuratedPackagesTask) Name() string

func (*InstallCuratedPackagesTask) Restore added in v0.9.2 

func (s *InstallCuratedPackagesTask) Restore(ctx context.Context, commandContext *task.CommandContext, completedTask *task.CompletedTask) (task.Task, error)

func (*InstallCuratedPackagesTask) Run added in v0.9.2 

func (cp *InstallCuratedPackagesTask) Run(ctx context.Context, commandContext *task.CommandContext) task.Task

type InstallEksaComponentsTask 

type InstallEksaComponentsTask struct{}

func (*InstallEksaComponentsTask) Checkpoint added in v0.9.2 

func (s *InstallEksaComponentsTask) Checkpoint() *task.CompletedTask

func (*InstallEksaComponentsTask) Name 

func (s *InstallEksaComponentsTask) Name() string

func (*InstallEksaComponentsTask) Restore added in v0.9.2 

func (s *InstallEksaComponentsTask) Restore(ctx context.Context, commandContext *task.CommandContext, completedTask *task.CompletedTask) (task.Task, error)

func (*InstallEksaComponentsTask) Run 

func (s *InstallEksaComponentsTask) Run(ctx context.Context, commandContext *task.CommandContext) task.Task

type InstallGitOpsManagerTask added in v0.11.0 

type InstallGitOpsManagerTask struct{}

func (*InstallGitOpsManagerTask) Checkpoint added in v0.11.0 

func (s *InstallGitOpsManagerTask) Checkpoint() *task.CompletedTask

func (*InstallGitOpsManagerTask) Name added in v0.11.0 

func (s *InstallGitOpsManagerTask) Name() string

func (*InstallGitOpsManagerTask) Restore added in v0.11.0 

func (s *InstallGitOpsManagerTask) Restore(ctx context.Context, commandContext *task.CommandContext, completedTask *task.CompletedTask) (task.Task, error)

func (*InstallGitOpsManagerTask) Run added in v0.11.0 

func (s *InstallGitOpsManagerTask) Run(ctx context.Context, commandContext *task.CommandContext) task.Task

type InstallResourcesOnManagementTask added in v0.9.2 

type InstallResourcesOnManagementTask struct{}

func (*InstallResourcesOnManagementTask) Checkpoint added in v0.9.2 

func (s *InstallResourcesOnManagementTask) Checkpoint() *task.CompletedTask

func (*InstallResourcesOnManagementTask) Name added in v0.9.2 

func (s *InstallResourcesOnManagementTask) Name() string

func (*InstallResourcesOnManagementTask) Restore added in v0.9.2 

func (s *InstallResourcesOnManagementTask) Restore(ctx context.Context, commandContext *task.CommandContext, completedTask *task.CompletedTask) (task.Task, error)

func (*InstallResourcesOnManagementTask) Run added in v0.9.2 

func (s *InstallResourcesOnManagementTask) Run(ctx context.Context, commandContext *task.CommandContext) task.Task

InstallResourcesOnManagement implementation.

type MoveClusterManagementTask 

type MoveClusterManagementTask struct{}

func (*MoveClusterManagementTask) Checkpoint added in v0.9.2 

func (s *MoveClusterManagementTask) Checkpoint() *task.CompletedTask

func (*MoveClusterManagementTask) Name 

func (s *MoveClusterManagementTask) Name() string

func (*MoveClusterManagementTask) Restore added in v0.9.2 

func (s *MoveClusterManagementTask) Restore(ctx context.Context, commandContext *task.CommandContext, completedTask *task.CompletedTask) (task.Task, error)

func (*MoveClusterManagementTask) Run 

func (s *MoveClusterManagementTask) Run(ctx context.Context, commandContext *task.CommandContext) task.Task

type SetAndValidateTask 

type SetAndValidateTask struct{}

func (*SetAndValidateTask) Checkpoint added in v0.9.2 

func (s *SetAndValidateTask) Checkpoint() *task.CompletedTask

func (*SetAndValidateTask) Name 

func (s *SetAndValidateTask) Name() string

func (*SetAndValidateTask) Restore added in v0.9.2 

func (s *SetAndValidateTask) Restore(ctx context.Context, commandContext *task.CommandContext, completedTask *task.CompletedTask) (task.Task, error)

func (*SetAndValidateTask) Run 

func (s *SetAndValidateTask) Run(ctx context.Context, commandContext *task.CommandContext) task.Task

type Upgrade 

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

func NewUpgrade 

func NewUpgrade(bootstrapper interfaces.Bootstrapper, provider providers.Provider,
	capiManager interfaces.CAPIManager,
	clusterManager interfaces.ClusterManager,
	gitOpsManager interfaces.GitOpsManager,
	writer filewriter.FileWriter,
	eksdUpgrader interfaces.EksdUpgrader,
	eksdInstaller interfaces.EksdInstaller,
) *Upgrade

func (*Upgrade) Run 

func (c *Upgrade) Run(ctx context.Context, clusterSpec *cluster.Spec, managementCluster *types.Cluster, workloadCluster *types.Cluster, validator interfaces.Validator, forceCleanup bool) error

type WriteClusterConfigTask 

type WriteClusterConfigTask struct{}

func (*WriteClusterConfigTask) Checkpoint added in v0.9.2 

func (s *WriteClusterConfigTask) Checkpoint() *task.CompletedTask

func (*WriteClusterConfigTask) Name 

func (s *WriteClusterConfigTask) Name() string

func (*WriteClusterConfigTask) Restore added in v0.9.2 

func (s *WriteClusterConfigTask) Restore(ctx context.Context, commandContext *task.CommandContext, completedTask *task.CompletedTask) (task.Task, error)

func (*WriteClusterConfigTask) Run 

func (s *WriteClusterConfigTask) Run(ctx context.Context, commandContext *task.CommandContext) task.Task

Source Files

View all Source files

Directories

Path Synopsis
mocks
Package mocks is a generated GoMock package.
 Package mocks is a generated GoMock package.

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.