Documentation ¶
Index ¶
- Constants
- func AdminServerCmd(globalCtx *GlobalCtx, adminCtx AdminInfo, serverHost string, serverPort int, ...) *executor.ExecuteCtx
- func AdminStoreCmd(globalCtx *GlobalCtx, adminCtx AdminInfo, cmd string) *executor.ExecuteCtx
- func Bootstrap(globalCtx *GlobalCtx, adminCtx AdminInfo) *executor.ExecuteCtx
- type AdminInfo
- type AlertManager
- func (a *AlertManager) Deploy(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (a *AlertManager) Display() map[string]utils.DisplayedComponent
- func (a *AlertManager) GetServiceName() string
- func (a *AlertManager) InitEnv(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (a *AlertManager) Remove(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (a *AlertManager) SyncConfig(globalCtx *GlobalCtx) *executor.TransferCtx
- type ElasticSearch
- func (es *ElasticSearch) Deploy(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (es *ElasticSearch) Display() map[string]utils.DisplayedComponent
- func (es *ElasticSearch) GetServiceName() string
- func (es *ElasticSearch) InitEnv(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (es *ElasticSearch) Remove(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (es *ElasticSearch) SyncConfig(globalCtx *GlobalCtx) *executor.TransferCtx
- type Filebeat
- func (f *Filebeat) Deploy(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (f *Filebeat) Display() map[string]utils.DisplayedComponent
- func (f *Filebeat) GetServiceName() string
- func (f *Filebeat) InitEnv(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (f *Filebeat) Remove(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (f *Filebeat) SyncConfig(globalCtx *GlobalCtx) *executor.TransferCtx
- type GlobalCtx
- type Grafana
- func (g *Grafana) Deploy(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (g *Grafana) Display() map[string]utils.DisplayedComponent
- func (g *Grafana) GetServiceName() string
- func (g *Grafana) InitEnv(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (g *Grafana) Remove(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (g *Grafana) SyncConfig(globalCtx *GlobalCtx) *executor.TransferCtx
- type HAdmin
- func (h *HAdmin) Deploy(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (h *HAdmin) Display() map[string]utils.DisplayedComponent
- func (h *HAdmin) GetServiceName() string
- func (h *HAdmin) InitEnv(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (h *HAdmin) Remove(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (h *HAdmin) SyncConfig(globalCtx *GlobalCtx) *executor.TransferCtx
- type HServer
- func (h *HServer) CheckReady(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (h *HServer) Deploy(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (h *HServer) Display() map[string]utils.DisplayedComponent
- func (h *HServer) GetHost() string
- func (h *HServer) GetServiceName() string
- func (h *HServer) Init(ctx *GlobalCtx) *executor.ExecuteCtx
- func (h *HServer) InitEnv(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (h *HServer) Remove(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (h *HServer) SyncConfig(globalCtx *GlobalCtx) *executor.TransferCtx
- type HStore
- func (h *HStore) CheckReady(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (h *HStore) Deploy(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (h *HStore) Display() map[string]utils.DisplayedComponent
- func (h *HStore) GetServiceName() string
- func (h *HStore) InitEnv(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (h *HStore) IsAdmin() bool
- func (h *HStore) MountDisk() *executor.ExecuteCtx
- func (h *HStore) Remove(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (h *HStore) SyncConfig(globalCtx *GlobalCtx) *executor.TransferCtx
- type HStreamConsole
- func (h *HStreamConsole) Deploy(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (h *HStreamConsole) Display() map[string]utils.DisplayedComponent
- func (h *HStreamConsole) GetServiceName() string
- func (h *HStreamConsole) InitEnv(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (h *HStreamConsole) Remove(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (h *HStreamConsole) SyncConfig(globalCtx *GlobalCtx) *executor.TransferCtx
- type HStreamExporter
- func (h *HStreamExporter) Deploy(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (h *HStreamExporter) Display() map[string]utils.DisplayedComponent
- func (h *HStreamExporter) GetServiceName() string
- func (h *HStreamExporter) InitEnv(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (h *HStreamExporter) Remove(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (h *HStreamExporter) SyncConfig(globalCtx *GlobalCtx) *executor.TransferCtx
- type HttpServer
- func (h *HttpServer) Deploy(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (h *HttpServer) Display() map[string]utils.DisplayedComponent
- func (h *HttpServer) GetServiceName() string
- func (h *HttpServer) InitEnv(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (h *HttpServer) Remove(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (h *HttpServer) SyncConfig(globalCtx *GlobalCtx) *executor.TransferCtx
- type Kibana
- func (k *Kibana) CheckReady() *executor.ExecuteCtx
- func (k *Kibana) Deploy(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (k *Kibana) Display() map[string]utils.DisplayedComponent
- func (k *Kibana) GetSSHHost() int
- func (k *Kibana) GetServiceName() string
- func (k *Kibana) InitEnv(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (k *Kibana) Remove(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (k *Kibana) SyncConfig(globalCtx *GlobalCtx) *executor.TransferCtx
- type MetaStore
- func (m *MetaStore) CheckReady(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (m *MetaStore) Deploy(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (m *MetaStore) Display() map[string]utils.DisplayedComponent
- func (m *MetaStore) GetServiceName() string
- func (m *MetaStore) GetValue(key string) *executor.ExecuteCtx
- func (m *MetaStore) InitEnv(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (m *MetaStore) Remove(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (m *MetaStore) StoreValue(key, value string) *executor.ExecuteCtx
- func (m *MetaStore) SyncConfig(globalCtx *GlobalCtx) *executor.TransferCtx
- type MonitorSuite
- func (m *MonitorSuite) Deploy(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (m *MonitorSuite) Display() map[string]utils.DisplayedComponent
- func (m *MonitorSuite) GetServiceName() string
- func (m *MonitorSuite) InitEnv(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (m *MonitorSuite) Remove(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (m *MonitorSuite) SyncConfig(globalCtx *GlobalCtx) *executor.TransferCtx
- type Prometheus
- func (p *Prometheus) Deploy(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (p *Prometheus) Display() map[string]utils.DisplayedComponent
- func (p *Prometheus) GetServiceName() string
- func (p *Prometheus) InitEnv(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (p *Prometheus) Remove(globalCtx *GlobalCtx) *executor.ExecuteCtx
- func (p *Prometheus) SyncConfig(globalCtx *GlobalCtx) *executor.TransferCtx
- type Service
- type Services
Constants ¶
View Source
const ( // DefaultAdminApiPort TCP port on which the server listens to for admin commands, supports commands over SSL DefaultAdminApiPort = 6440 // DefaultServerListenPort TCP port on which the server listens for non-SSL clients DefaultServerListenPort = 16111 BootStrapCmd = "nodes-config bootstrap --metadata-replicate-across " )
View Source
const (
// FIXME: no way to modify zk monitor port now
DefaultMetaStoreMonitorPort = 2181
)
View Source
const (
DefaultServerMonitorPort = 6570
)
Variables ¶
This section is empty.
Functions ¶
func AdminServerCmd ¶ added in v0.3.0
func AdminStoreCmd ¶ added in v0.3.0
func AdminStoreCmd(globalCtx *GlobalCtx, adminCtx AdminInfo, cmd string) *executor.ExecuteCtx
Types ¶
type AlertManager ¶ added in v0.2.0
type AlertManager struct { ContainerName string DisableLogin bool // contains filtered or unexported fields }
func NewAlertManager ¶ added in v0.2.0
func NewAlertManager(graSpec spec.AlertManagerSpec) *AlertManager
func (*AlertManager) Deploy ¶ added in v0.2.0
func (a *AlertManager) Deploy(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*AlertManager) Display ¶ added in v0.3.0
func (a *AlertManager) Display() map[string]utils.DisplayedComponent
func (*AlertManager) GetServiceName ¶ added in v0.3.0
func (a *AlertManager) GetServiceName() string
func (*AlertManager) InitEnv ¶ added in v0.2.0
func (a *AlertManager) InitEnv(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*AlertManager) Remove ¶ added in v0.2.0
func (a *AlertManager) Remove(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*AlertManager) SyncConfig ¶ added in v0.2.0
func (a *AlertManager) SyncConfig(globalCtx *GlobalCtx) *executor.TransferCtx
type ElasticSearch ¶ added in v0.3.0
type ElasticSearch struct { ContainerName string DisableSecurity bool // contains filtered or unexported fields }
func NewElasticSearch ¶ added in v0.3.0
func NewElasticSearch(esSpec spec.ElasticSearchSpec) *ElasticSearch
func (*ElasticSearch) Deploy ¶ added in v0.3.0
func (es *ElasticSearch) Deploy(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*ElasticSearch) Display ¶ added in v0.3.0
func (es *ElasticSearch) Display() map[string]utils.DisplayedComponent
func (*ElasticSearch) GetServiceName ¶ added in v0.3.0
func (es *ElasticSearch) GetServiceName() string
func (*ElasticSearch) InitEnv ¶ added in v0.3.0
func (es *ElasticSearch) InitEnv(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*ElasticSearch) Remove ¶ added in v0.3.0
func (es *ElasticSearch) Remove(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*ElasticSearch) SyncConfig ¶ added in v0.3.0
func (es *ElasticSearch) SyncConfig(globalCtx *GlobalCtx) *executor.TransferCtx
type Filebeat ¶ added in v0.3.0
type Filebeat struct { ContainerName string ElasticsearchHost string ElasticsearchPort string KibanaHost string KibanaPort string // contains filtered or unexported fields }
func NewFilebeat ¶ added in v0.3.0
func NewFilebeat(fbSpec spec.FilebeatSpec, elasticsearchHost, elasticsearchPort, kibanaHost, kibanaPort string) *Filebeat
func (*Filebeat) Deploy ¶ added in v0.3.0
func (f *Filebeat) Deploy(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*Filebeat) Display ¶ added in v0.3.0
func (f *Filebeat) Display() map[string]utils.DisplayedComponent
func (*Filebeat) GetServiceName ¶ added in v0.3.0
func (*Filebeat) InitEnv ¶ added in v0.3.0
func (f *Filebeat) InitEnv(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*Filebeat) Remove ¶ added in v0.3.0
func (f *Filebeat) Remove(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*Filebeat) SyncConfig ¶ added in v0.3.0
func (f *Filebeat) SyncConfig(globalCtx *GlobalCtx) *executor.TransferCtx
type GlobalCtx ¶
type GlobalCtx struct { User string KeyPath string SSHPort int MetaReplica int EnableGrpcHs bool RemoteCfgPath string DataDir string EnableDscpReflection bool Hosts []string SeedNodes string // for zk: host1:2181,host2:2181 // for rqlite: http://host1:4001,http://host2:4001 MetaStoreUrls string MetaStoreType spec.MetaStoreType // total count of meta store instances MetaStoreCount int // for zk: use zkUrl HStoreConfigInMetaStore string // the origin meta store config file in local LocalMetaStoreConfigFile string // the origin store config file in local LocalHStoreConfigFile string // the origin server config file in local LocalHServerConfigFile string // the origin elastic search config file in local LocalEsConfigFile string HAdminInfos []AdminInfo HStreamServerUrls string HServerEndPoints string PrometheusUrls []string HttpServerUrls []string // contains filtered or unexported fields }
type Grafana ¶
type Grafana struct { ContainerName string DisableLogin bool // contains filtered or unexported fields }
func NewGrafana ¶
func NewGrafana(graSpec spec.GrafanaSpec, disableLogin bool) *Grafana
func (*Grafana) Display ¶ added in v0.3.0
func (g *Grafana) Display() map[string]utils.DisplayedComponent
func (*Grafana) GetServiceName ¶ added in v0.3.0
func (*Grafana) SyncConfig ¶
func (g *Grafana) SyncConfig(globalCtx *GlobalCtx) *executor.TransferCtx
type HAdmin ¶ added in v0.3.0
type HAdmin struct { Host string AdminPort int ContainerName string CheckReadyScriptPath string // contains filtered or unexported fields }
func (*HAdmin) Deploy ¶ added in v0.3.0
func (h *HAdmin) Deploy(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*HAdmin) Display ¶ added in v0.3.0
func (h *HAdmin) Display() map[string]utils.DisplayedComponent
func (*HAdmin) GetServiceName ¶ added in v0.3.0
func (*HAdmin) InitEnv ¶ added in v0.3.0
func (h *HAdmin) InitEnv(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*HAdmin) Remove ¶ added in v0.3.0
func (h *HAdmin) Remove(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*HAdmin) SyncConfig ¶ added in v0.3.0
func (h *HAdmin) SyncConfig(globalCtx *GlobalCtx) *executor.TransferCtx
type HServer ¶
type HServer struct { Host string Port int ContainerName string CheckReadyScriptPath string ServerConfigPath string StoreConfigPath string // contains filtered or unexported fields }
func NewHServer ¶
func NewHServer(id uint32, serverSpec spec.HServerSpec) *HServer
func (*HServer) CheckReady ¶
func (h *HServer) CheckReady(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*HServer) Display ¶ added in v0.3.0
func (h *HServer) Display() map[string]utils.DisplayedComponent
func (*HServer) GetServiceName ¶ added in v0.3.0
func (*HServer) SyncConfig ¶
func (h *HServer) SyncConfig(globalCtx *GlobalCtx) *executor.TransferCtx
type HStore ¶
type HStore struct { Host string // FIXME: check admin port setting AdminPort int ContainerName string CheckReadyScriptPath string MountScriptPath string // contains filtered or unexported fields }
func (*HStore) CheckReady ¶
func (h *HStore) CheckReady(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*HStore) Display ¶ added in v0.3.0
func (h *HStore) Display() map[string]utils.DisplayedComponent
func (*HStore) GetServiceName ¶ added in v0.3.0
func (*HStore) MountDisk ¶
func (h *HStore) MountDisk() *executor.ExecuteCtx
func (*HStore) SyncConfig ¶
func (h *HStore) SyncConfig(globalCtx *GlobalCtx) *executor.TransferCtx
type HStreamConsole ¶ added in v0.3.1
type HStreamConsole struct { ContainerName string // contains filtered or unexported fields }
func NewHStreamConsole ¶ added in v0.3.1
func NewHStreamConsole(id uint32, consoleSPec spec.HStreamConsoleSpec) *HStreamConsole
func (*HStreamConsole) Deploy ¶ added in v0.3.1
func (h *HStreamConsole) Deploy(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*HStreamConsole) Display ¶ added in v0.3.1
func (h *HStreamConsole) Display() map[string]utils.DisplayedComponent
func (*HStreamConsole) GetServiceName ¶ added in v0.3.1
func (h *HStreamConsole) GetServiceName() string
func (*HStreamConsole) InitEnv ¶ added in v0.3.1
func (h *HStreamConsole) InitEnv(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*HStreamConsole) Remove ¶ added in v0.3.1
func (h *HStreamConsole) Remove(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*HStreamConsole) SyncConfig ¶ added in v0.3.1
func (h *HStreamConsole) SyncConfig(globalCtx *GlobalCtx) *executor.TransferCtx
type HStreamExporter ¶ added in v0.2.0
type HStreamExporter struct { ContainerName string // contains filtered or unexported fields }
func NewHStreamExporter ¶ added in v0.2.0
func NewHStreamExporter(exporterSpec spec.HStreamExporterSpec) *HStreamExporter
func (*HStreamExporter) Deploy ¶ added in v0.2.0
func (h *HStreamExporter) Deploy(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*HStreamExporter) Display ¶ added in v0.3.0
func (h *HStreamExporter) Display() map[string]utils.DisplayedComponent
func (*HStreamExporter) GetServiceName ¶ added in v0.3.0
func (h *HStreamExporter) GetServiceName() string
func (*HStreamExporter) InitEnv ¶ added in v0.2.0
func (h *HStreamExporter) InitEnv(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*HStreamExporter) Remove ¶ added in v0.2.0
func (h *HStreamExporter) Remove(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*HStreamExporter) SyncConfig ¶ added in v0.2.0
func (h *HStreamExporter) SyncConfig(globalCtx *GlobalCtx) *executor.TransferCtx
type HttpServer ¶ added in v0.2.0
type HttpServer struct { ContainerName string // contains filtered or unexported fields }
func NewHttpServer ¶ added in v0.2.0
func NewHttpServer(id uint32, metaSpec spec.HttpServerSpec) *HttpServer
func (*HttpServer) Deploy ¶ added in v0.2.0
func (h *HttpServer) Deploy(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*HttpServer) Display ¶ added in v0.3.0
func (h *HttpServer) Display() map[string]utils.DisplayedComponent
func (*HttpServer) GetServiceName ¶ added in v0.3.0
func (h *HttpServer) GetServiceName() string
func (*HttpServer) InitEnv ¶ added in v0.2.0
func (h *HttpServer) InitEnv(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*HttpServer) Remove ¶ added in v0.2.0
func (h *HttpServer) Remove(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*HttpServer) SyncConfig ¶ added in v0.2.0
func (h *HttpServer) SyncConfig(globalCtx *GlobalCtx) *executor.TransferCtx
type Kibana ¶ added in v0.3.0
type Kibana struct { ContainerName string ElasticSearchHost string ElasticSearchPort int CheckReadyScriptPath string // contains filtered or unexported fields }
func NewKibana ¶ added in v0.3.0
func NewKibana(kibanaSpec spec.KibanaSpec, elasticSearchHost string, elasticSearchPort int) *Kibana
func (*Kibana) CheckReady ¶ added in v0.3.0
func (k *Kibana) CheckReady() *executor.ExecuteCtx
func (*Kibana) Deploy ¶ added in v0.3.0
func (k *Kibana) Deploy(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*Kibana) Display ¶ added in v0.3.0
func (k *Kibana) Display() map[string]utils.DisplayedComponent
func (*Kibana) GetSSHHost ¶ added in v0.3.0
func (*Kibana) GetServiceName ¶ added in v0.3.0
func (*Kibana) InitEnv ¶ added in v0.3.0
func (k *Kibana) InitEnv(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*Kibana) Remove ¶ added in v0.3.0
func (k *Kibana) Remove(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*Kibana) SyncConfig ¶ added in v0.3.0
func (k *Kibana) SyncConfig(globalCtx *GlobalCtx) *executor.TransferCtx
type MetaStore ¶
type MetaStore struct { ContainerName string CheckReadyScriptPath string // contains filtered or unexported fields }
func NewMetaStore ¶
func NewMetaStore(id uint32, metaSpec spec.MetaStoreSpec) *MetaStore
func (*MetaStore) CheckReady ¶
func (m *MetaStore) CheckReady(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*MetaStore) Display ¶ added in v0.3.0
func (m *MetaStore) Display() map[string]utils.DisplayedComponent
func (*MetaStore) GetServiceName ¶ added in v0.3.0
func (*MetaStore) StoreValue ¶
func (m *MetaStore) StoreValue(key, value string) *executor.ExecuteCtx
func (*MetaStore) SyncConfig ¶
func (m *MetaStore) SyncConfig(globalCtx *GlobalCtx) *executor.TransferCtx
type MonitorSuite ¶
type MonitorSuite struct { Host string NodeContainerName string CadvisorContainerName string // contains filtered or unexported fields }
func NewMonitorSuite ¶
func NewMonitorSuite(host string, moSpec spec.MonitorSpec) *MonitorSuite
func (*MonitorSuite) Deploy ¶
func (m *MonitorSuite) Deploy(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*MonitorSuite) Display ¶ added in v0.3.0
func (m *MonitorSuite) Display() map[string]utils.DisplayedComponent
func (*MonitorSuite) GetServiceName ¶ added in v0.3.0
func (m *MonitorSuite) GetServiceName() string
func (*MonitorSuite) InitEnv ¶
func (m *MonitorSuite) InitEnv(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*MonitorSuite) Remove ¶
func (m *MonitorSuite) Remove(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*MonitorSuite) SyncConfig ¶
func (m *MonitorSuite) SyncConfig(globalCtx *GlobalCtx) *executor.TransferCtx
type Prometheus ¶
type Prometheus struct { ContainerName string MonitoredHosts []string NodeExporterPort int CadvisorPort int HStreamExporterAddr []string AlertManagerAddr []string // contains filtered or unexported fields }
func NewPrometheus ¶
func NewPrometheus(promSpec spec.PrometheusSpec, monitorSuites []*MonitorSuite, hstreamExporterAddr []string, alertAddr []string) *Prometheus
func (*Prometheus) Deploy ¶
func (p *Prometheus) Deploy(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*Prometheus) Display ¶ added in v0.3.0
func (p *Prometheus) Display() map[string]utils.DisplayedComponent
func (*Prometheus) GetServiceName ¶ added in v0.3.0
func (p *Prometheus) GetServiceName() string
func (*Prometheus) InitEnv ¶
func (p *Prometheus) InitEnv(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*Prometheus) Remove ¶
func (p *Prometheus) Remove(globalCtx *GlobalCtx) *executor.ExecuteCtx
func (*Prometheus) SyncConfig ¶
func (p *Prometheus) SyncConfig(globalCtx *GlobalCtx) *executor.TransferCtx
type Service ¶
type Service interface { InitEnv(cfg *GlobalCtx) *executor.ExecuteCtx Deploy(cfg *GlobalCtx) *executor.ExecuteCtx Remove(cfg *GlobalCtx) *executor.ExecuteCtx SyncConfig(cfg *GlobalCtx) *executor.TransferCtx GetServiceName() string }
type Services ¶
type Services struct { Global *GlobalCtx MonitorSuite []*MonitorSuite HServer []*HServer HStore []*HStore HAdmin []*HAdmin MetaStore []*MetaStore HStreamConsole []*HStreamConsole Prometheus []*Prometheus Grafana []*Grafana AlertManager []*AlertManager HStreamExporter []*HStreamExporter HttpServer []*HttpServer ElasticSearch []*ElasticSearch Kibana []*Kibana Filebeat []*Filebeat }
func NewServices ¶
func NewServices(c spec.ComponentsSpec) (*Services, error)
func (*Services) ShowAllServices ¶ added in v0.3.0
func (s *Services) ShowAllServices()
Click to show internal directories.
Click to hide internal directories.