doris

package
v0.0.0-...-1298597 Latest Latest
Warning

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

Go to latest
Published: Oct 27, 2023 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AddBes

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

func NewAddBes

func NewAddBes(taskCtx *task.Context, feMaster topologyyaml.FeInstance, bes []topologyyaml.BESpec) *AddBes

func (*AddBes) Execute

func (t *AddBes) Execute(ctx context.Context) error

func (*AddBes) Name

func (t *AddBes) Name() string

type CheckDorisNodesStatus

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

func NewCheckDorisClusterStatus

func NewCheckDorisClusterStatus(ctx *task.Context, feMaster topologyyaml.FeInstance) *CheckDorisNodesStatus

func (*CheckDorisNodesStatus) Execute

func (t *CheckDorisNodesStatus) Execute(ctx context.Context) error

func (*CheckDorisNodesStatus) Name

func (t *CheckDorisNodesStatus) Name() string

type WaitClusterHealthy

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

func NewWaitClusterHealthy

func NewWaitClusterHealthy(feMaster topologyyaml.FeInstance) *WaitClusterHealthy

func (*WaitClusterHealthy) Execute

func (t *WaitClusterHealthy) Execute(ctx context.Context) error

func (*WaitClusterHealthy) Name

func (t *WaitClusterHealthy) Name() string

type WaitFeMasterReady

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

func NewWaitFeMasterReady

func NewWaitFeMasterReady(feMaster topologyyaml.FeInstance) *WaitFeMasterReady

func (*WaitFeMasterReady) Execute

func (t *WaitFeMasterReady) Execute(ctx context.Context) error

func (*WaitFeMasterReady) Name

func (t *WaitFeMasterReady) Name() string

Jump to

Keyboard shortcuts

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