service

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: 17 Imported by: 0

Documentation

Index

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 AdminServerCmd(globalCtx *GlobalCtx, adminCtx AdminInfo, serverHost string,
	serverPort int, cmd string) *executor.ExecuteCtx

func AdminStoreCmd added in v0.3.0

func AdminStoreCmd(globalCtx *GlobalCtx, adminCtx AdminInfo, cmd string) *executor.ExecuteCtx

func Bootstrap added in v0.3.0

func Bootstrap(globalCtx *GlobalCtx, adminCtx AdminInfo) *executor.ExecuteCtx

Types

type AdminInfo added in v0.3.0

type AdminInfo struct {
	Host          string
	Port          int
	ContainerName string
}

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 (f *Filebeat) GetServiceName() string

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) Deploy

func (g *Grafana) Deploy(globalCtx *GlobalCtx) *executor.ExecuteCtx

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 (g *Grafana) GetServiceName() string

func (*Grafana) InitEnv

func (g *Grafana) InitEnv(globalCtx *GlobalCtx) *executor.ExecuteCtx

func (*Grafana) Remove

func (g *Grafana) Remove(globalCtx *GlobalCtx) *executor.ExecuteCtx

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 NewHAdmin added in v0.3.0

func NewHAdmin(id uint32, adminSpec spec.HAdminSpec) *HAdmin

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 (h *HAdmin) GetServiceName() string

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) Deploy

func (h *HServer) Deploy(globalCtx *GlobalCtx) *executor.ExecuteCtx

func (*HServer) Display added in v0.3.0

func (h *HServer) Display() map[string]utils.DisplayedComponent

func (*HServer) GetHost

func (h *HServer) GetHost() string

func (*HServer) GetServiceName added in v0.3.0

func (h *HServer) GetServiceName() string

func (*HServer) Init

func (h *HServer) Init(ctx *GlobalCtx) *executor.ExecuteCtx

func (*HServer) InitEnv

func (h *HServer) InitEnv(globalCtx *GlobalCtx) *executor.ExecuteCtx

func (*HServer) Remove

func (h *HServer) Remove(globalCtx *GlobalCtx) *executor.ExecuteCtx

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 NewHStore

func NewHStore(id uint32, storeSpec spec.HStoreSpec) *HStore

func (*HStore) CheckReady

func (h *HStore) CheckReady(globalCtx *GlobalCtx) *executor.ExecuteCtx

func (*HStore) Deploy

func (h *HStore) Deploy(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 (h *HStore) GetServiceName() string

func (*HStore) InitEnv

func (h *HStore) InitEnv(globalCtx *GlobalCtx) *executor.ExecuteCtx

func (*HStore) IsAdmin

func (h *HStore) IsAdmin() bool

func (*HStore) MountDisk

func (h *HStore) MountDisk() *executor.ExecuteCtx

func (*HStore) Remove

func (h *HStore) Remove(globalCtx *GlobalCtx) *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 (*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 (k *Kibana) GetSSHHost() int

func (*Kibana) GetServiceName added in v0.3.0

func (k *Kibana) GetServiceName() string

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) Deploy

func (m *MetaStore) Deploy(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 (m *MetaStore) GetServiceName() string

func (*MetaStore) GetValue

func (m *MetaStore) GetValue(key string) *executor.ExecuteCtx

func (*MetaStore) InitEnv

func (m *MetaStore) InitEnv(globalCtx *GlobalCtx) *executor.ExecuteCtx

func (*MetaStore) Remove

func (m *MetaStore) Remove(globalCtx *GlobalCtx) *executor.ExecuteCtx

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()

Jump to

Keyboard shortcuts

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