Versions in this module Expand all Collapse all v0 v0.0.0 Dec 15, 2022 Changes in this version + var DefaultPoolSize = 15 + var ErrTimeoutExceeded = errors.New("Execution timeout exceeded") + type Executor interface + Execute func(context.Context) error + type ExecutorFunc func(context.Context) error + type Http struct + Body string + Headers map[string]string + LogResponse bool + Method string + Timeout int + URL string + func NewHttp(logger logrus.FieldLogger, client http.Client) *Http + func (http *Http) Execute(ctx context.Context) error + type Job struct + Executor ExecutorFunc + Service string + type Pool struct + func NewPool(logger logrus.FieldLogger, size int) *Pool + func (pool *Pool) Enqueue(job Job) + func (pool *Pool) Start() + func (pool *Pool) Stop(ctx context.Context) error + type Shell struct + Command string + LogOutput bool + Shell string + Timeout int + func NewShell(logger logrus.FieldLogger) *Shell + func (shell *Shell) Execute(ctx context.Context) error
Go to main page