spec

type BaseInstance struct {
	InstanceSpec

	Name       string
	Host       string
	ManageHost string
	ListenHost string
	Port       int
	SSHP       int
	Source     string

	Ports    []int
	Dirs     []string
	StatusFn func(ctx context.Context, timeout time.Duration, tlsCfg *tls.Config, tsMetaHosts ...string) string
	UptimeFn func(ctx context.Context, timeout time.Duration, tlsCfg *tls.Config) time.Duration
}

type BaseMeta struct {
	User    string
	Group   string
	Version string
}

type BaseTopo struct {
	GlobalOptions    *GlobalOptions
	MonitoredOptions *TSMonitoredOptions
	MasterList       []string

	GrafanaVersion *string
	Monitors       []*TSServerSpec
	Grafanas       []*GrafanaSpec
}

type BindVersion func(comp string, version string) (bindVersion string)

type ClusterMeta struct {
	User     string         `yaml:"user"`               // the user to run and manage cluster on remote
	Version  string         `yaml:"openGemini_version"` // the version of openGemini cluster
	Topology *Specification `yaml:"topology"`
}

type Component interface {
	Name() string
	Role() string
	Instances() []Instance
}

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

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

type FullHostType string

type GlobalOptions struct {
	User            string               `yaml:"user,omitempty" default:"gemini"`
	Group           string               `yaml:"group,omitempty"`
	SSHPort         int                  `yaml:"ssh_port,omitempty" default:"22" validate:"ssh_port:editable"`
	TLSEnabled      bool                 `yaml:"enable_tls,omitempty"`
	ListenHost      string               `yaml:"listen_host,omitempty" validate:"listen_host:editable"`
	DeployDir       string               `yaml:"deploy_dir,omitempty" default:"deploy"`
	LogDir          string               `yaml:"log_dir,omitempty" default:"logs"`
	DataDir         string               `yaml:"data_dir,omitempty" default:"data"`
	ResourceControl meta.ResourceControl `yaml:"resource_control,omitempty" validate:"resource_control:editable"`
	OS              string               `yaml:"os,omitempty" default:"linux"`
	Arch            string               `yaml:"arch,omitempty" default:"amd64"`
}

type GrafanaComponent struct{ Topology }

type GrafanaInstance struct {
	BaseInstance
	// contains filtered or unexported fields
}

type GrafanaSpec struct {
	Host            string               `yaml:"host"`
	ManageHost      string               `yaml:"manage_host,omitempty" validate:"manage_host:editable"`
	SSHPort         int                  `yaml:"ssh_port,omitempty" validate:"ssh_port:editable"`
	Port            int                  `yaml:"port" default:"3000"`
	DeployDir       string               `yaml:"deploy_dir,omitempty"`
	Config          map[string]string    `yaml:"config,omitempty" validate:"config:ignore"`
	ResourceControl meta.ResourceControl `yaml:"resource_control,omitempty" validate:"resource_control:editable"`
	Arch            string               `yaml:"arch,omitempty"`
	OS              string               `yaml:"os,omitempty"`
	DashboardDir    string               `yaml:"dashboard_dir,omitempty" validate:"dashboard_dir:editable"`
	Username        string               `yaml:"username,omitempty" default:"admin" validate:"username:editable"`
	Password        string               `yaml:"password,omitempty" default:"admin" validate:"password:editable"`
	AnonymousEnable bool                 `yaml:"anonymous_enable" default:"false" validate:"anonymous_enable:editable"`
	RootURL         string               `yaml:"root_url" validate:"root_url:editable"`
	Domain          string               `yaml:"domain" validate:"domain:editable"`
	DefaultTheme    string               `yaml:"default_theme,omitempty" validate:"default_theme:editable"`
	OrgName         string               `yaml:"org_name,omitempty" validate:"org_name:editable"`
	OrgRole         string               `yaml:"org_role,omitempty" validate:"org_role:editable"`
}

type Instance interface {
	InstanceSpec
	ID() string
	Ready(context.Context, ctxt.Executor, uint64, *tls.Config) error
	InitConfig(ctx context.Context, e ctxt.Executor, clusterName string, clusterVersion string, deployUser string, paths meta.DirPaths) error
	//ScaleConfig(ctx context.Context, e ctxt.Executor, topo Topology, clusterName string, clusterVersion string, deployUser string, paths meta.DirPaths) error
	PrepareStart(ctx context.Context, tlsCfg *tls.Config) error
	ComponentName() string
	ComponentSource() string
	InstanceName() string
	ServiceName() string
	GetHost() string
	GetManageHost() string
	GetPort() int
	GetSSHPort() int
	DeployDir() string
	UsedPorts() []int
	UsedDirs() []string
	Status(ctx context.Context, timeout time.Duration, tlsCfg *tls.Config, tsMetaList ...string) string
	Uptime(ctx context.Context, timeout time.Duration, tlsCfg *tls.Config) time.Duration
	DataDir() string
	LogDir() string
	OS() string // only linux supported now
	Arch() string
}

type InstanceSpec interface {
	Role() string
	SSH() (string, int)
}

type Metadata interface {
	GetTopology() Topology
	SetTopology(topo Topology)
	GetBaseMeta() *BaseMeta
}

type MonitorHostInfo struct {
	Ssh          int    // ssh port of host
	Os           string // operating system
	Arch         string // cpu architecture
	MetricPath   string
	ErrorLogPath string
	DataPath     string
	WALPath      string
	ProcessName  set.StringSet
	MonitorAddr  string
}

type ServerConfigs struct {
	TsMeta    map[string]any    `yaml:"ts-meta"`
	TsSql     map[string]any    `yaml:"ts-sql"`
	TsStore   map[string]any    `yaml:"ts-store"`
	TsMonitor map[string]any    `yaml:"ts-monitor"`
	Grafana   map[string]string `yaml:"grafana"`
}

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

type Specification struct {
	GlobalOptions    GlobalOptions      `yaml:"global,omitempty" validate:"global:editable"`
	MonitoredOptions TSMonitoredOptions `yaml:"monitored,omitempty" validate:"monitored:editable"`
	ServerConfigs    ServerConfigs      `yaml:"server_configs,omitempty" validate:"server_configs:ignore"`
	TSMetaServers    []*TSMetaSpec      `yaml:"ts_meta_servers"`
	TSSqlServers     []*TSSqlSpec       `yaml:"ts_sql_servers"`
	TSStoreServers   []*TSStoreSpec     `yaml:"ts_store_servers"`
	Monitors         []*TSServerSpec    `yaml:"monitoring_servers"`
	Grafanas         []*GrafanaSpec     `yaml:"grafana_servers,omitempty"`
}

type TSMetaComponent struct{ Topology *Specification }

type TSMetaInstance struct {
	Name string
	BaseInstance
	// contains filtered or unexported fields
}

type TSMetaSpec struct {
	Arch string `yaml:"arch,omitempty"`
	OS   string `yaml:"os,omitempty"`

	Source string `yaml:"source,omitempty" validate:"source:editable"`

	// Use Name to get the name with a default value if it's empty.
	Name string `yaml:"name"`

	Host       string `yaml:"host"`
	ManageHost string `yaml:"manage_host,omitempty" validate:"manage_host:editable"`
	ListenHost string `yaml:"listen_host,omitempty"`
	SSHPort    int    `yaml:"ssh_port,omitempty" validate:"ssh_port:editable"`

	LogDir    string `yaml:"log_dir,omitempty"`
	DeployDir string `yaml:"deploy_dir,omitempty"`
	DataDir   string `yaml:"data_dir,omitempty"`

	// port specification
	ClientPort int `yaml:"client_port" default:"8091"`
	PeerPort   int `yaml:"peer_port" default:"8092"`
	RaftPort   int `yaml:"raft_port"  default:"8088"`
	GossipPort int `yaml:"gossip_port"  default:"8010"`

	Config map[string]any `yaml:"config,omitempty" validate:"config:ignore"`
}

type TSMonitorComponent struct{ Topology *Specification }

type TSMonitorInstance struct {
	Name string
	BaseInstance
	// contains filtered or unexported fields
}

type TSMonitorSpec struct {
	Arch string `yaml:"arch,omitempty"`
	OS   string `yaml:"os,omitempty"`

	Source string `yaml:"source,omitempty" validate:"source:editable"`

	// Use Name to get the name with a default value if it's empty.
	Name string `yaml:"name"`

	Host       string `yaml:"host"`
	ManageHost string `yaml:"manage_host,omitempty" validate:"manage_host:editable"`
	ListenHost string `yaml:"listen_host,omitempty"`
	SSHPort    int    `yaml:"ssh_port,omitempty" validate:"ssh_port:editable"`

	LogDir    string `yaml:"log_dir,omitempty"`
	DeployDir string `yaml:"deploy_dir,omitempty"`

	MonitorProcess map[string]struct{}
	Config         map[string]any `yaml:"config,omitempty" validate:"config:ignore"`
}

type TSMonitoredOptions struct {
	TSMonitorEnabled bool   `yaml:"ts_monitor_enabled,omitempty" default:"false"`
	DeployDir        string `yaml:"deploy_dir,omitempty"`
	LogDir           string `yaml:"log_dir,omitempty"`
}

type TSServerComponent struct{ Topology }

type TSServerInstance struct {
	BaseInstance
	// contains filtered or unexported fields
}

type TSServerSpec struct {
	Arch string `yaml:"arch,omitempty"`
	OS   string `yaml:"os,omitempty"`

	Source string `yaml:"source,omitempty" validate:"source:editable"`

	// Use Name to get the name with a default value if it's empty.
	Name string `yaml:"name"`

	Host       string `yaml:"host"`
	ManageHost string `yaml:"manage_host,omitempty" validate:"manage_host:editable"`
	ListenHost string `yaml:"listen_host,omitempty"`
	SSHPort    int    `yaml:"ssh_port,omitempty" validate:"ssh_port:editable"`

	LogDir    string `yaml:"log_dir,omitempty"`
	DeployDir string `yaml:"deploy_dir,omitempty"`
	DataDir   string `yaml:"data_dir,omitempty"`

	// port specification
	Port       int `yaml:"port" default:"8186"`
	RaftPort   int `yaml:"raft_port"  default:"8188"`
	ClientPort int `yaml:"client_port" default:"8191"`
	PeerPort   int `yaml:"peer_port" default:"8192"`
	IngestPort int `yaml:"ingest_port" default:"8410"`
	SelectPort int `yaml:"select_port" default:"8411"`

	Config map[string]any `yaml:"config,omitempty" validate:"config:ignore"`
}

type TSSqlComponent struct{ Topology *Specification }

type TSSqlInstance struct {
	Name string
	BaseInstance
	// contains filtered or unexported fields
}

type TSSqlSpec struct {
	Arch string `yaml:"arch,omitempty"`
	OS   string `yaml:"os,omitempty"`

	Source string `yaml:"source,omitempty" validate:"source:editable"`

	// Use Name to get the name with a default value if it's empty.
	Name           string `yaml:"name"`
	IgnoreExporter bool   `yaml:"ignore_exporter,omitempty"`

	Host       string `yaml:"host"`
	ManageHost string `yaml:"manage_host,omitempty" validate:"manage_host:editable"`
	ListenHost string `yaml:"listen_host,omitempty"`
	SSHPort    int    `yaml:"ssh_port,omitempty" validate:"ssh_port:editable"`

	LogDir    string `yaml:"log_dir,omitempty"`
	DeployDir string `yaml:"deploy_dir,omitempty"`

	// port specification
	Port int `yaml:"port" default:"8086"`

	Config map[string]any `yaml:"config,omitempty" validate:"config:ignore"`
}

type TSStoreComponent struct{ Topology *Specification }

type TSStoreInstance struct {
	Name string
	BaseInstance
	// contains filtered or unexported fields
}

type TSStoreSpec struct {
	Arch string `yaml:"arch,omitempty"`
	OS   string `yaml:"os,omitempty"`

	Source string `yaml:"source,omitempty" validate:"source:editable"`

	// Use Name to get the name with a default value if it's empty.
	Name string `yaml:"name"`

	Host       string `yaml:"host"`
	ManageHost string `yaml:"manage_host,omitempty" validate:"manage_host:editable"`
	ListenHost string `yaml:"listen_host,omitempty"`
	SSHPort    int    `yaml:"ssh_port,omitempty" validate:"ssh_port:editable"`

	LogDir    string `yaml:"log_dir,omitempty"`
	DeployDir string `yaml:"deploy_dir,omitempty"`
	DataDir   string `yaml:"data_dir,omitempty"`

	// port specification
	IngestPort int `yaml:"ingest_port" default:"8400"`
	SelectPort int `yaml:"select_port" default:"8401"`
	GossipPort int `yaml:"gossip_port" default:"8011"`

	Config map[string]any `yaml:"config,omitempty" validate:"config:ignore"`
}

type Topology interface {
	BaseTopo() *BaseTopo
	// Validate validates the topology specification and produce error if the
	// specification invalid (e.g: port conflicts or directory conflicts)
	Validate() error

	ComponentsByStartOrder() []Component
	ComponentsByStopOrder() []Component
	//ComponentsByUpdateOrder(curVer string) []Component
	IterInstance(fn func(instance Instance), concurrency ...int)
	GetMonitoredOptions() *TSMonitoredOptions
	CountDir(host string, dir string) int // count how many time a path is used by instances in cluster
	//TLSConfig(dir string) (*tls.Config, error)
	//Merge(that Topology) Topology // TODO: for update
	FillHostArchOrOS(hostArchmap map[string]string, fullType FullHostType) error
	GetGrafanaConfig() map[string]string
}