step

Documentation

Index

• type Parallel
  • func NewParallel(inner ...task.Task) *Parallel
  • func (p *Parallel) Execute(ctx context.Context) error
  • func (p *Parallel) Name() string
  • func (p *Parallel) StepName() string
• type Serial
  • func NewSerial(inner ...task.Task) *Serial
  • func (s *Serial) Execute(ctx context.Context) error
  • func (s *Serial) Name() string
  • func (s *Serial) StepName() string
• type Step
  • func NewAddBes(ctx *task.Context) Step
  • func NewCheckClusterStatus(ctx *task.Context) Step
  • func NewCheckHostsConfig(ctx *task.Context) Step
  • func NewCompleteTopology(ctx *task.Context) Step
  • func NewDownloadPackage(ctx *task.Context) Step
  • func NewExecCmd(ctx *task.Context, hostsExec map[string]*topologyyaml.ExecOutput, ...) Step
  • func NewInitConfig(ctx *task.Context) Step
  • func NewInitHost(ctx *task.Context) Step
  • func NewInstallPackage(ctx *task.Context) Step
  • func NewRemoveManifest(ctx *task.Context) Step
  • func NewResetHost(ctx *task.Context) Step
  • func NewSaveManifest(ctx *task.Context) Step
  • func NewStartCluster(ctx *task.Context) Step
  • func NewStopCluster(ctx *task.Context) Step
  • func NewUniqueCluster(ctx *task.Context) Step
  • func NewWaitClusterHealthy(ctx *task.Context) Step
• type StepDisplay
  • func NewStepDisplay(prefix string, step Step) *StepDisplay
  • func (s *StepDisplay) Execute(ctx context.Context) error
  • func (s *StepDisplay) Name() string
  • func (s *StepDisplay) StepName() string

Types

type Parallel

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

func NewParallel

func NewParallel(inner ...task.Task) *Parallel

func (*Parallel) Execute

func (p *Parallel) Execute(ctx context.Context) error

func (*Parallel) Name

func (p *Parallel) Name() string

func (*Parallel) StepName

func (p *Parallel) StepName() string

type Serial

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

func NewSerial

func NewSerial(inner ...task.Task) *Serial

func (*Serial) Execute

func (s *Serial) Execute(ctx context.Context) error

func (*Serial) Name

func (s *Serial) Name() string

func (*Serial) StepName

func (s *Serial) StepName() string

type Step

type Step interface {
	task.Task
	StepName() string // StepName is used to seprate Task and Step type
}

func NewAddBes

func NewAddBes(ctx *task.Context) Step

func NewCheckClusterStatus

func NewCheckClusterStatus(ctx *task.Context) Step

func NewCheckHostsConfig

func NewCheckHostsConfig(ctx *task.Context) Step

func NewCompleteTopology

func NewCompleteTopology(ctx *task.Context) Step

CompleteTopology retrives necessary info from cluster(via ssh and sql)

func NewDownloadPackage

func NewDownloadPackage(ctx *task.Context) Step

func NewExecCmd

func NewExecCmd(ctx *task.Context, hostsExec map[string]*topologyyaml.ExecOutput, command string) Step

func NewInitConfig

func NewInitConfig(ctx *task.Context) Step

func NewInitHost

func NewInitHost(ctx *task.Context) Step

func NewInstallPackage

func NewInstallPackage(ctx *task.Context) Step

func NewRemoveManifest

func NewRemoveManifest(ctx *task.Context) Step

func NewResetHost

func NewResetHost(ctx *task.Context) Step

func NewSaveManifest

func NewSaveManifest(ctx *task.Context) Step

func NewStartCluster

func NewStartCluster(ctx *task.Context) Step

func NewStopCluster

func NewStopCluster(ctx *task.Context) Step

func NewUniqueCluster

func NewUniqueCluster(ctx *task.Context) Step

func NewWaitClusterHealthy

func NewWaitClusterHealthy(ctx *task.Context) Step

type StepDisplay

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

func NewStepDisplay

func NewStepDisplay(prefix string, step Step) *StepDisplay

func (*StepDisplay) Execute

func (s *StepDisplay) Execute(ctx context.Context) error

func (*StepDisplay) Name

func (s *StepDisplay) Name() string

func (*StepDisplay) StepName

func (s *StepDisplay) StepName() string