Documentation
¶
Index ¶
- Constants
- func Bootstrap(executor ext.Executor, services *service.Services) error
- func CheckClusterStatus(executor ext.Executor, services *service.Services) error
- func RemoveAlertService(executor ext.Executor, services *service.Services) error
- func RemoveCluster(executor ext.Executor, services *service.Services) error
- func RemoveElasticSearch(executor ext.Executor, services *service.Services) error
- func RemoveFilebeat(executor ext.Executor, services *service.Services) error
- func RemoveGrafanaService(executor ext.Executor, services *service.Services) error
- func RemoveHAdminCluster(executor ext.Executor, services *service.Services) error
- func RemoveHServerCluster(executor ext.Executor, services *service.Services) error
- func RemoveHStoreCluster(executor ext.Executor, services *service.Services) error
- func RemoveHStreamConsole(executor ext.Executor, services *service.Services) error
- func RemoveHStreamExporterService(executor ext.Executor, services *service.Services) error
- func RemoveHStreamMonitorStack(executor ext.Executor, services *service.Services) error
- func RemoveHttpServerService(executor ext.Executor, services *service.Services) error
- func RemoveKibana(executor ext.Executor, services *service.Services) error
- func RemoveMetaStoreCluster(executor ext.Executor, services *service.Services) error
- func RemovePrometheusService(executor ext.Executor, services *service.Services) error
- func SetUpAlertService(executor ext.Executor, services *service.Services) error
- func SetUpCluster(executor ext.Executor, services *service.Services) error
- func SetUpElasticSearch(executor ext.Executor, services *service.Services) error
- func SetUpFilebeat(executor ext.Executor, services *service.Services) error
- func SetUpGrafanaService(executor ext.Executor, services *service.Services) error
- func SetUpHAdminCluster(executor ext.Executor, services *service.Services) error
- func SetUpHServerCluster(executor ext.Executor, services *service.Services) error
- func SetUpHStoreCluster(executor ext.Executor, services *service.Services) error
- func SetUpHStreamConsole(executor ext.Executor, services *service.Services) error
- func SetUpHStreamExporterService(executor ext.Executor, services *service.Services) error
- func SetUpHStreamMonitorStack(executor ext.Executor, services *service.Services) error
- func SetUpHttpServerService(executor ext.Executor, services *service.Services) error
- func SetUpKibana(executor ext.Executor, services *service.Services) error
- func SetUpMetaStoreCluster(executor ext.Executor, services *service.Services) error
- func SetUpPrometheusService(executor ext.Executor, services *service.Services) error
- type BootstrapCtx
- type CheckClusterStatusCtx
- type HServerClusterCtx
- type HServerInit
- type HStoreClusterCtx
- type InitStoreEnv
- type KibanaClusterCtx
- type MetaStoreClusterCtx
- type MetaStoreGetValue
- type MetaStoreStoreValue
- type MountDisk
- type StartStoreCluster
- type SyncStoreConfig
- type Task
- type WaitKibanaReady
- type WaitMetaStoreReady
- type WaitServerReady
- type WaitStoreReady
Constants ¶
View Source
const ( InitEnv basicExecuteTask = iota + 1 Deploy Remove )
Variables ¶
This section is empty.
Functions ¶
func CheckClusterStatus ¶
func RemoveAlertService ¶ added in v0.2.0
func RemoveElasticSearch ¶ added in v0.3.0
func RemoveFilebeat ¶ added in v0.3.0
func RemoveGrafanaService ¶
func RemoveHAdminCluster ¶ added in v0.3.0
func RemoveHServerCluster ¶
func RemoveHStoreCluster ¶
func RemoveHStreamConsole ¶ added in v0.3.1
func RemoveHStreamExporterService ¶ added in v0.2.0
func RemoveHttpServerService ¶ added in v0.2.0
func RemoveKibana ¶ added in v0.3.0
func RemoveMetaStoreCluster ¶
func RemovePrometheusService ¶
func SetUpAlertService ¶ added in v0.2.0
func SetUpElasticSearch ¶ added in v0.3.0
func SetUpFilebeat ¶ added in v0.3.0
func SetUpGrafanaService ¶
func SetUpHAdminCluster ¶ added in v0.3.0
func SetUpHServerCluster ¶
func SetUpHStoreCluster ¶
func SetUpHStreamConsole ¶ added in v0.3.1
func SetUpHStreamExporterService ¶ added in v0.2.0
func SetUpHttpServerService ¶ added in v0.2.0
func SetUpKibana ¶ added in v0.3.0
func SetUpMetaStoreCluster ¶
Types ¶
type BootstrapCtx ¶ added in v0.3.0
type BootstrapCtx struct {
// contains filtered or unexported fields
}
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) String ¶
func (s *HServerInit) String() string
type HStoreClusterCtx ¶
type HStoreClusterCtx struct {
// contains filtered or unexported fields
}
type InitStoreEnv ¶
type InitStoreEnv struct {
HStoreClusterCtx
}
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) String ¶
func (m *MetaStoreGetValue) String() string
type MetaStoreStoreValue ¶
type MetaStoreStoreValue struct {
MetaStoreClusterCtx
Key string
Value string
}
func (*MetaStoreStoreValue) String ¶
func (m *MetaStoreStoreValue) String() string
type MountDisk ¶
type MountDisk struct {
HStoreClusterCtx
}
type StartStoreCluster ¶
type StartStoreCluster struct {
HStoreClusterCtx
}
func (*StartStoreCluster) String ¶
func (s *StartStoreCluster) String() string
type SyncStoreConfig ¶
type SyncStoreConfig struct {
HStoreClusterCtx
}
func (*SyncStoreConfig) String ¶
func (s *SyncStoreConfig) String() string
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) String ¶
func (w *WaitMetaStoreReady) String() string
type WaitServerReady ¶
type WaitServerReady struct {
HServerClusterCtx
}
func (*WaitServerReady) String ¶
func (w *WaitServerReady) String() string
type WaitStoreReady ¶
type WaitStoreReady struct {
HStoreClusterCtx
}
func (*WaitStoreReady) String ¶
func (w *WaitStoreReady) String() string
Click to show internal directories.
Click to hide internal directories.