service

type Service struct {
	Cfg *ServiceCfg
	Log *log.Logger

	Name           string
	Implementation ServiceImplementation

	Program *program.Program

	Hostname string

	Influx *influx.Client

	PgClients map[string]*pg.Client

	HTTPClients map[string]*shttp.Client
	HTTPServers map[string]*shttp.Server

	ServiceAPI *ServiceAPI

	Workers map[string]*Worker

	TextTemplate *texttemplate.Template
	HTMLTemplate *htmltemplate.Template
	// contains filtered or unexported fields
}

type ServiceAPI struct {
	Cfg     ServiceAPICfg
	Service *Service
	Log     *log.Logger

	HTTPServer *shttp.Server
}

type ServiceAPICfg struct {
	Log     *log.Logger `json:"-"`
	Service *Service    `json:"-"`

	HTTPServer string `json:"http_server"`
}

type ServiceCfg struct {
	Logger *log.LoggerCfg `json:"logger"`

	DataDirectory string `json:"data_directory"`

	Influx *influx.ClientCfg `json:"influx"`

	PgClients map[string]*pg.ClientCfg `json:"pg_clients"`

	HTTPClients map[string]*shttp.ClientCfg `json:"http_clients"`
	HTTPServers map[string]*shttp.ServerCfg `json:"http_servers"`

	ServiceAPI *ServiceAPICfg `json:"service_api"`

	Workers map[string]*WorkerCfg `json:"workers"`

	TemplateFuncMap map[string]interface{} `json:"-"`
	// contains filtered or unexported fields
}

type ServiceImplementation interface {
	DefaultCfg() interface{}
	ValidateCfg() error
	ServiceCfg() *ServiceCfg
	Init(*Service) error
	Start(*Service) error
	Stop(*Service)
	Terminate(*Service)
}

type ServiceImplementationWithInitProgram interface {
	ServiceImplementation

	InitProgram(*program.Program)
}

type Worker struct {
	Cfg WorkerCfg
	Log *log.Logger
	// contains filtered or unexported fields
}

type WorkerCfg struct {
	Log          *log.Logger `json:"-"`
	WorkerFunc   WorkerFunc  `json:"-"`
	Disabled     bool        `json:"disabled"`
	InitialDelay int         `json:"initial_delay"` // seconds
}

type WorkerFunc func(*Worker) (time.Duration, error)