step

package

v0.0.0-...-1298597 Latest Latest Go to latest Published: Oct 27, 2023 License: MIT Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/lobshunter/dorisctl

Links

Open Source Insights

Documentation ¶

Index ¶

type Parallel
- func NewParallel(inner ...task.Task) *Parallel
type Serial
- func NewSerial(inner ...task.Task) *Serial
type Step
type StepDisplay
- func NewStepDisplay(prefix string, step Step) *StepDisplay

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL