Versions in this module Expand all Collapse all v0 v0.0.1 Sep 28, 2025 Changes in this version + func LoadConfig(path string) (*cfg.Config, error) + func NewHTTPServer(addr, basePath string, m *Manager) (*http.Server, error) + func NewTLSServer(serverConfig cfg.ServerConfig, m *Manager) (*http.Server, error) + func RegisterMetrics(r prometheus.Registerer) error + func RegisterMetricsDefault() error + func RegisterMetricsWithProcessMetricsDefault(processMetricsConfig ProcessMetricsConfig) error + func ServeMetrics(addr string) error + type CronJob = cronjob.CronJobSpec + type CronScheduler struct + func NewCronScheduler(m *Manager) *CronScheduler + func (s *CronScheduler) Add(j CronJob) error + func (s *CronScheduler) Start() error + func (s *CronScheduler) Stop() error + type Group struct + func NewGroup(m *Manager) *Group + func (g *Group) Start(gs ServiceGroup) error + func (g *Group) Status(gs ServiceGroup) (map[string][]Status, error) + func (g *Group) Stop(gs ServiceGroup, wait time.Duration) error + type HistoryConfig = cfg.HistoryConfig + type HistorySink = history.Sink + type JobManager struct + func NewJobManager(m *Manager) *JobManager + func (jm *JobManager) CreateJob(spec JobSpec) error + func (jm *JobManager) DeleteJob(name string) error + func (jm *JobManager) GetJob(name string) (JobStatus, bool) + func (jm *JobManager) ListJobs() map[string]JobStatus + func (jm *JobManager) Shutdown() error + func (jm *JobManager) UpdateJob(name string, spec JobSpec) error + type JobSpec = job.Spec + type JobStatus = job.JobStatus + type Manager struct + func New() *Manager + func (m *Manager) ApplyConfig(specs []Spec) error + func (m *Manager) Count(base string) (int, error) + func (m *Manager) GetAllProcessMetrics() map[string]metrics.ProcessMetrics + func (m *Manager) GetProcessMetrics(name string) (metrics.ProcessMetrics, bool) + func (m *Manager) GetProcessMetricsHistory(name string) ([]metrics.ProcessMetrics, bool) + func (m *Manager) InstanceGroupStart(groupName string) error + func (m *Manager) InstanceGroupStatus(groupName string) (map[string][]Status, error) + func (m *Manager) InstanceGroupStop(groupName string, wait time.Duration) error + func (m *Manager) IsProcessMetricsEnabled() bool + func (m *Manager) Register(s Spec) error + func (m *Manager) RegisterN(s Spec) error + func (m *Manager) SetGlobalEnv(kvs []string) + func (m *Manager) SetInstanceGroups(groups []ManagerInstanceGroup) + func (m *Manager) SetProcessMetricsCollector(collector *metrics.ProcessMetricsCollector) error + func (m *Manager) Start(name string) error + func (m *Manager) Status(name string) (Status, error) + func (m *Manager) StatusAll(base string) ([]Status, error) + func (m *Manager) Stop(name string, wait time.Duration) error + func (m *Manager) StopAll(base string, wait time.Duration) error + func (m *Manager) Unregister(name string, wait time.Duration) error + func (m *Manager) UnregisterAll(base string, wait time.Duration) error + type ManagerInstanceGroup = manager.InstanceGroup + type ProcessMetrics = metrics.ProcessMetrics + type ProcessMetricsCollector = metrics.ProcessMetricsCollector + func NewProcessMetricsCollector(config ProcessMetricsConfig) *ProcessMetricsCollector + type ProcessMetricsConfig = metrics.ProcessMetricsConfig + type ServiceGroup = pg.ServiceGroup + type Spec = process.Spec + type Status = process.Status
Go to main page