task

package
v0.3.1 Latest Latest
Warning

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

Go to latest
Published: Feb 27, 2023 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source
const (
	InitEnv basicExecuteTask = iota + 1
	Deploy
	Remove
)

Variables

This section is empty.

Functions

func Bootstrap added in v0.3.0

func Bootstrap(executor ext.Executor, services *service.Services) error

func CheckClusterStatus

func CheckClusterStatus(executor ext.Executor, services *service.Services) error

func RemoveAlertService added in v0.2.0

func RemoveAlertService(executor ext.Executor, services *service.Services) error

func RemoveCluster

func RemoveCluster(executor ext.Executor, services *service.Services) error

func RemoveElasticSearch added in v0.3.0

func RemoveElasticSearch(executor ext.Executor, services *service.Services) error

func RemoveFilebeat added in v0.3.0

func RemoveFilebeat(executor ext.Executor, services *service.Services) error

func RemoveGrafanaService

func RemoveGrafanaService(executor ext.Executor, services *service.Services) error

func RemoveHAdminCluster added in v0.3.0

func RemoveHAdminCluster(executor ext.Executor, services *service.Services) error

func RemoveHServerCluster

func RemoveHServerCluster(executor ext.Executor, services *service.Services) error

func RemoveHStoreCluster

func RemoveHStoreCluster(executor ext.Executor, services *service.Services) error

func RemoveHStreamConsole added in v0.3.1

func RemoveHStreamConsole(executor ext.Executor, services *service.Services) error

func RemoveHStreamExporterService added in v0.2.0

func RemoveHStreamExporterService(executor ext.Executor, services *service.Services) error

func RemoveHStreamMonitorStack

func RemoveHStreamMonitorStack(executor ext.Executor, services *service.Services) error

func RemoveHttpServerService added in v0.2.0

func RemoveHttpServerService(executor ext.Executor, services *service.Services) error

func RemoveKibana added in v0.3.0

func RemoveKibana(executor ext.Executor, services *service.Services) error

func RemoveMetaStoreCluster

func RemoveMetaStoreCluster(executor ext.Executor, services *service.Services) error

func RemovePrometheusService

func RemovePrometheusService(executor ext.Executor, services *service.Services) error

func SetUpAlertService added in v0.2.0

func SetUpAlertService(executor ext.Executor, services *service.Services) error

func SetUpCluster

func SetUpCluster(executor ext.Executor, services *service.Services) error

func SetUpElasticSearch added in v0.3.0

func SetUpElasticSearch(executor ext.Executor, services *service.Services) error

func SetUpFilebeat added in v0.3.0

func SetUpFilebeat(executor ext.Executor, services *service.Services) error

func SetUpGrafanaService

func SetUpGrafanaService(executor ext.Executor, services *service.Services) error

func SetUpHAdminCluster added in v0.3.0

func SetUpHAdminCluster(executor ext.Executor, services *service.Services) error

func SetUpHServerCluster

func SetUpHServerCluster(executor ext.Executor, services *service.Services) error

func SetUpHStoreCluster

func SetUpHStoreCluster(executor ext.Executor, services *service.Services) error

func SetUpHStreamConsole added in v0.3.1

func SetUpHStreamConsole(executor ext.Executor, services *service.Services) error

func SetUpHStreamExporterService added in v0.2.0

func SetUpHStreamExporterService(executor ext.Executor, services *service.Services) error

func SetUpHStreamMonitorStack

func SetUpHStreamMonitorStack(executor ext.Executor, services *service.Services) error

func SetUpHttpServerService added in v0.2.0

func SetUpHttpServerService(executor ext.Executor, services *service.Services) error

func SetUpKibana added in v0.3.0

func SetUpKibana(executor ext.Executor, services *service.Services) error

func SetUpMetaStoreCluster

func SetUpMetaStoreCluster(executor ext.Executor, services *service.Services) error

func SetUpPrometheusService

func SetUpPrometheusService(executor ext.Executor, services *service.Services) error

Types

type BootstrapCtx added in v0.3.0

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

func (*BootstrapCtx) Run added in v0.3.0

func (b *BootstrapCtx) Run(executor ext.Executor) error

func (*BootstrapCtx) String added in v0.3.0

func (b *BootstrapCtx) String() string

type CheckClusterStatusCtx added in v0.3.0

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

func (*CheckClusterStatusCtx) Run added in v0.3.0

func (c *CheckClusterStatusCtx) Run(executor ext.Executor) error

func (*CheckClusterStatusCtx) String added in v0.3.0

func (c *CheckClusterStatusCtx) String() string

type HServerClusterCtx

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

type HServerInit

type HServerInit struct {
	HServerClusterCtx
}

func (*HServerInit) Run

func (s *HServerInit) Run(executor ext.Executor) error

func (*HServerInit) String

func (s *HServerInit) String() string

type HStoreClusterCtx

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

type InitStoreEnv

type InitStoreEnv struct {
	HStoreClusterCtx
}

func (*InitStoreEnv) Run

func (s *InitStoreEnv) Run(executor ext.Executor) error

func (*InitStoreEnv) String

func (s *InitStoreEnv) String() string

type KibanaClusterCtx added in v0.3.0

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

type MetaStoreClusterCtx

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

type MetaStoreGetValue

type MetaStoreGetValue struct {
	MetaStoreClusterCtx
	Key string
}

func (*MetaStoreGetValue) Run

func (m *MetaStoreGetValue) Run(executor ext.Executor) error

func (*MetaStoreGetValue) String

func (m *MetaStoreGetValue) String() string

type MetaStoreStoreValue

type MetaStoreStoreValue struct {
	MetaStoreClusterCtx
	Key   string
	Value string
}

func (*MetaStoreStoreValue) Run

func (m *MetaStoreStoreValue) Run(executor ext.Executor) error

func (*MetaStoreStoreValue) String

func (m *MetaStoreStoreValue) String() string

type MountDisk

type MountDisk struct {
	HStoreClusterCtx
}

func (*MountDisk) Run

func (m *MountDisk) Run(executor ext.Executor) error

func (*MountDisk) String

func (m *MountDisk) String() string

type StartStoreCluster

type StartStoreCluster struct {
	HStoreClusterCtx
}

func (*StartStoreCluster) Run

func (s *StartStoreCluster) Run(executor ext.Executor) error

func (*StartStoreCluster) String

func (s *StartStoreCluster) String() string

type SyncStoreConfig

type SyncStoreConfig struct {
	HStoreClusterCtx
}

func (*SyncStoreConfig) Run

func (s *SyncStoreConfig) Run(executor ext.Executor) error

func (*SyncStoreConfig) String

func (s *SyncStoreConfig) String() string

type Task

type Task interface {
	Run(executor ext.Executor) error
}

type WaitKibanaReady added in v0.3.0

type WaitKibanaReady struct {
	KibanaClusterCtx
}

func (*WaitKibanaReady) Run added in v0.3.0

func (w *WaitKibanaReady) Run(executor ext.Executor) error

func (*WaitKibanaReady) String added in v0.3.0

func (w *WaitKibanaReady) String() string

type WaitMetaStoreReady

type WaitMetaStoreReady struct {
	MetaStoreClusterCtx
}

func (*WaitMetaStoreReady) Run

func (w *WaitMetaStoreReady) Run(executor ext.Executor) error

func (*WaitMetaStoreReady) String

func (w *WaitMetaStoreReady) String() string

type WaitServerReady

type WaitServerReady struct {
	HServerClusterCtx
}

func (*WaitServerReady) Run

func (w *WaitServerReady) Run(executor ext.Executor) error

func (*WaitServerReady) String

func (w *WaitServerReady) String() string

type WaitStoreReady

type WaitStoreReady struct {
	HStoreClusterCtx
}

func (*WaitStoreReady) Run

func (w *WaitStoreReady) Run(executor ext.Executor) error

func (*WaitStoreReady) String

func (w *WaitStoreReady) String() string

Jump to

Keyboard shortcuts

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