Versions in this module Expand all Collapse all v0 v0.0.6 Aug 5, 2023 v0.0.5 Aug 5, 2023 v0.0.4 Aug 4, 2023 v0.0.3 Aug 4, 2023 v0.0.2 Aug 4, 2023 Changes in this version + const ComponentAlertmanager + const ComponentDMMaster + const ComponentDMWorker + const ComponentGrafana + const ComponentPrometheus + func AllDMComponentNames() (roles []string) + func DMComponentVersion(comp, version string) string + func GetSpecManager() *cspec.SpecManager + type AlertmanagerSpec = spec.AlertmanagerSpec + type Component = spec.Component + type DMMasterComponent struct + Topology *Specification + func (c *DMMasterComponent) Instances() []Instance + func (c *DMMasterComponent) Name() string + func (c *DMMasterComponent) Role() string + type DMServerConfigs struct + Master map[string]interface{} + Worker map[string]interface{} + type DMWorkerComponent struct + Topology *Specification + func (c *DMWorkerComponent) Instances() []Instance + func (c *DMWorkerComponent) Name() string + func (c *DMWorkerComponent) Role() string + type GlobalOptions = spec.GlobalOptions + type GrafanaSpec = spec.GrafanaSpec + type Instance = spec.Instance + type InstanceSpec interface + GetMainPort func() int + IgnoreMonitorAgent func() bool + IsImported func() bool + Role func() string + SSH func() (string, int) + type MasterInstance struct + Name string + func (i *MasterInstance) InitConfig(ctx context.Context, e ctxt.Executor, ...) error + func (i *MasterInstance) ScaleConfig(ctx context.Context, e ctxt.Executor, topo spec.Topology, ...) error + type MasterSpec struct + Arch string + Config map[string]interface{} + DataDir string + DeployDir string + Host string + IgnoreExporter bool + Imported bool + LogDir string + Name string + NumaNode string + OS string + Patched bool + PeerPort int + Port int + ResourceControl ResourceControl + SSHPort int + V1SourcePath string + func (s *MasterSpec) GetMainPort() int + func (s *MasterSpec) IgnoreMonitorAgent() bool + func (s *MasterSpec) IsImported() bool + func (s *MasterSpec) Role() string + func (s *MasterSpec) SSH() (string, int) + func (s *MasterSpec) Status(tlsCfg *tls.Config, _ ...string) string + type Metadata struct + Topology *Specification + User string + Version string + func (m *Metadata) GetBaseMeta() *cspec.BaseMeta + func (m *Metadata) GetTopology() cspec.Topology + func (m *Metadata) SetTopology(topo cspec.Topology) + func (m *Metadata) SetUser(s string) + func (m *Metadata) SetVersion(s string) + type MonitoredOptions = spec.MonitoredOptions + type PrometheusSpec = spec.PrometheusSpec + type ResourceControl = meta.ResourceControl + type Specification struct + Alertmanagers []*spec.AlertmanagerSpec + GlobalOptions GlobalOptions + Grafanas []*spec.GrafanaSpec + Masters []*MasterSpec + MonitoredOptions *MonitoredOptions + Monitors []*spec.PrometheusSpec + ServerConfigs DMServerConfigs + Workers []*WorkerSpec + func (s *Specification) BaseTopo() *spec.BaseTopo + func (s *Specification) CountDir(targetHost, dirPrefix string) int + func (s *Specification) FillHostArch(hostArch map[string]string) error + func (s *Specification) GetMasterList() []string + func (s *Specification) Merge(that spec.Topology) spec.Topology + func (s *Specification) MergeTopo(rhs spec.Topology) spec.Topology + func (s *Specification) NewPart() spec.Topology + func (s *Specification) TLSConfig(dir string) (*tls.Config, error) + func (s *Specification) Type() string + func (s *Specification) UnmarshalYAML(unmarshal func(interface{}) error) error + func (s *Specification) Validate() error + func (topo *Specification) ComponentsByStartOrder() (comps []Component) + func (topo *Specification) ComponentsByStopOrder() (comps []Component) + func (topo *Specification) ComponentsByUpdateOrder() (comps []Component) + func (topo *Specification) Endpoints(user string) []*scripts.DMMasterScript + func (topo *Specification) GetGlobalOptions() spec.GlobalOptions + func (topo *Specification) GetMonitoredOptions() *spec.MonitoredOptions + func (topo *Specification) IterComponent(fn func(comp Component)) + func (topo *Specification) IterHost(fn func(instance Instance)) + func (topo *Specification) IterInstance(fn func(instance Instance)) + type WorkerInstance struct + Name string + func (i *WorkerInstance) InitConfig(ctx context.Context, e ctxt.Executor, ...) error + func (i *WorkerInstance) ScaleConfig(ctx context.Context, e ctxt.Executor, topo spec.Topology, ...) error + type WorkerSpec struct + Arch string + Config map[string]interface{} + DataDir string + DeployDir string + Host string + IgnoreExporter bool + Imported bool + LogDir string + Name string + NumaNode string + OS string + Patched bool + Port int + ResourceControl ResourceControl + SSHPort int + func (s *WorkerSpec) GetMainPort() int + func (s *WorkerSpec) IgnoreMonitorAgent() bool + func (s *WorkerSpec) IsImported() bool + func (s *WorkerSpec) Role() string + func (s *WorkerSpec) SSH() (string, int) + func (s *WorkerSpec) Status(tlsCfg *tls.Config, masterList ...string) string
Go to main page