supervisor

Documentation

Index

• Variables
• type Config
  • func DefaultConfig() Config
  • func RawConfig(key string) *Config
  • func StdConfig(key string) *Config
  • func (c *Config) Build() *Scanner
• type Program
• type ProgramExt
  • func (program *ProgramExt) Unwrap() *structs.ProgramExt
• type Scanner
  • func (s *Scanner) C() <-chan *ProgramExt
  • func (s *Scanner) GetStatus(appName string) ([]structs.AgentConfigStatus, error)
  • func (s *Scanner) ListPrograms() (tasks map[string]*ProgramExt, err error)
  • func (s *Scanner) ProcessStatus() (processList []structs.ProcessStatus, err error)
  • func (s *Scanner) Show() map[string]interface{}
  • func (s *Scanner) Start() error

Variables

var DefaultSupervisorDir = "/etc/supervisor/conf.d"

DefaultSupervisorDir ...

Types

type Config

type Config struct {
	Dir    string `json:"dir"`    // 配置中心supervisor具体配置路径
	Enable bool   `json:"enable"` // 是否开启开插件
}

Config ...

func DefaultConfig

func DefaultConfig() Config

DefaultConfig return default config

func RawConfig

func RawConfig(key string) *Config

RawConfig ...

func StdConfig

func StdConfig(key string) *Config

StdConfig 返回标准配置信息

func (*Config) Build

func (c *Config) Build() *Scanner

Build new a instance

type Program

type Program struct {
	Directory             string `ini:"directory"`
	Environment           string `ini:"environment"`
	Command               string `ini:"command"`
	User                  string `ini:"user"`
	Autostart             bool   `ini:"autostart"`
	Autorestart           bool   `ini:"autorestart"`
	Startsecs             int    `ini:"startsecs"`
	StdoutLogfile         string `ini:"stdout_logfile"`
	StdoutLogfileMaxbytes string `ini:"stdout_logfile_maxbytes"`
	StdoutLogfileBackups  int    `ini:"stdout_logfile_backups"`
	StdoutCaptureMaxbytes string `ini:"stdout_capture_maxbytes"`
	StderrLogfile         string `ini:"stderr_logfile"`
	StderrLogfileMaxbytes string `ini:"stderr_logfile_maxbytes"`
	StderrLogfileBackups  int    `ini:"stderr_logfile_backups"`
	Stopsignal            string `ini:"stopsignal"`
	Config                string `ini:"-"`
}

Program ...

type ProgramExt

type ProgramExt struct {
	Manager  string `json:"manager" toml:"manager"` // systemd|supervisor
	Status   string `json:"status" toml:"status"`
	*Program `json:"program" toml:"program"`
	Content  string `json:"content" toml:"content"`
	FileName string `json:"file_name" toml:"file_name"`
	FilePath string `json:"file_path" toml:"file_path"`
	AppName  string `json:"app_name" toml:"app_name"`
}

ProgramExt ...

func (*ProgramExt) Unwrap

func (program *ProgramExt) Unwrap() *structs.ProgramExt

Unwrap ...

type Scanner

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

Scanner supervisor sacnner

func (*Scanner) C

func (s *Scanner) C() <-chan *ProgramExt

C consume the chan program

func (*Scanner) GetStatus

func (s *Scanner) GetStatus(appName string) ([]structs.AgentConfigStatus, error)

GetStatus ...

func (*Scanner) ListPrograms

func (s *Scanner) ListPrograms() (tasks map[string]*ProgramExt, err error)

ListPrograms list the supervisor list

func (*Scanner) ProcessStatus

func (s *Scanner) ProcessStatus() (processList []structs.ProcessStatus, err error)

ProcessStatus ...

func (*Scanner) Show

func (s *Scanner) Show() map[string]interface{}

Show ...

func (*Scanner) Start

func (s *Scanner) Start() error

Start ...