workflows

package
v0.15.3 Latest Latest
Warning

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

 Go to latest Published: Apr 28, 2023 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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) Name added in v0.6.1 

func (s *CollectWorkloadClusterDiagnosticsTask) Name() string

func (*CollectWorkloadClusterDiagnosticsTask) Run added in v0.6.1 

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

type Create 

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

func NewCreate 

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

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,
	clusterUpgrader interfaces.ClusterUpgrader,
) *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.