workflows

Documentation

Index

• func CreateNamespaceIfNotPresent(ctx context.Context, namespace string, client kubernetes.Client) error
• type CollectDiagnosticsTask
  • func (s *CollectDiagnosticsTask) Checkpoint() *task.CompletedTask
  • func (s *CollectDiagnosticsTask) Name() string
  • func (s *CollectDiagnosticsTask) Restore(ctx context.Context, commandContext *task.CommandContext, ...) (task.Task, error)
  • func (s *CollectDiagnosticsTask) Run(ctx context.Context, commandContext *task.CommandContext) task.Task
• type CollectMgmtClusterDiagnosticsTask
  • func (s *CollectMgmtClusterDiagnosticsTask) Checkpoint() *task.CompletedTask
  • func (s *CollectMgmtClusterDiagnosticsTask) Name() string
  • func (s *CollectMgmtClusterDiagnosticsTask) Restore(ctx context.Context, commandContext *task.CommandContext, ...) (task.Task, error)
  • func (s *CollectMgmtClusterDiagnosticsTask) Run(ctx context.Context, commandContext *task.CommandContext) task.Task
• type CollectWorkloadClusterDiagnosticsTask
  • func (s *CollectWorkloadClusterDiagnosticsTask) Checkpoint() *task.CompletedTask
  • func (s *CollectWorkloadClusterDiagnosticsTask) Name() string
  • func (s *CollectWorkloadClusterDiagnosticsTask) Restore(ctx context.Context, commandContext *task.CommandContext, ...) (task.Task, error)
  • func (s *CollectWorkloadClusterDiagnosticsTask) Run(ctx context.Context, commandContext *task.CommandContext) task.Task

Functions

func CreateNamespaceIfNotPresent

func CreateNamespaceIfNotPresent(ctx context.Context, namespace string, client kubernetes.Client) error

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

Types

type CollectDiagnosticsTask

type CollectDiagnosticsTask struct {
	*CollectWorkloadClusterDiagnosticsTask
	*CollectMgmtClusterDiagnosticsTask
}

func (*CollectDiagnosticsTask) Checkpoint

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

func (*CollectDiagnosticsTask) Name

func (s *CollectDiagnosticsTask) Name() string

func (*CollectDiagnosticsTask) Restore

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

func (*CollectDiagnosticsTask) Run

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

type CollectMgmtClusterDiagnosticsTask

type CollectMgmtClusterDiagnosticsTask struct{}

func (*CollectMgmtClusterDiagnosticsTask) Checkpoint

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

func (*CollectMgmtClusterDiagnosticsTask) Name

func (s *CollectMgmtClusterDiagnosticsTask) Name() string

func (*CollectMgmtClusterDiagnosticsTask) Restore

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

func (*CollectMgmtClusterDiagnosticsTask) Run

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

type CollectWorkloadClusterDiagnosticsTask

type CollectWorkloadClusterDiagnosticsTask struct{}

func (*CollectWorkloadClusterDiagnosticsTask) Checkpoint

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

Checkpoint sets a checkpoint at CollectWorkloadClusterDiagnosticsTask.

func (*CollectWorkloadClusterDiagnosticsTask) Name

func (s *CollectWorkloadClusterDiagnosticsTask) Name() string

Name returns the name of CollectWorkloadClusterDiagnosticsTask.

func (*CollectWorkloadClusterDiagnosticsTask) Restore

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

Restore restores from CollectWorkloadClusterDiagnosticsTask.

func (*CollectWorkloadClusterDiagnosticsTask) Run

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

Run starts collecting the logs for workload cluster diagnostics.