server

Dec 21, 2020

Changes in this version

+ const PluginName

+ type Config struct

+ Command string

+ Env Env

+ Group string

+ Relay string

+ RelayTimeout time.Duration

+ User string

+ func (cfg *Config) InitDefaults()

+ type Env map[string]string

+ type Plugin struct

+ func (server *Plugin) CmdFactory(env Env) (func() *exec.Cmd, error)

+ func (server *Plugin) Init(cfg config.Configurer, log logger.Logger) error

+ func (server *Plugin) Name() string

+ func (server *Plugin) NewWorker(ctx context.Context, env Env) (worker.BaseProcess, error)

+ func (server *Plugin) NewWorkerPool(ctx context.Context, opt poolImpl.Config, env Env) (pool.Pool, error)

+ func (server *Plugin) Serve() chan error

+ func (server *Plugin) Stop() error

+ type Server interface

+ CmdFactory func(env Env) (func() *exec.Cmd, error)

+ NewWorker func(ctx context.Context, env Env) (worker.BaseProcess, error)

+ NewWorkerPool func(ctx context.Context, opt poolImpl.Config, env Env) (pool.Pool, error)