pool

Sep 2, 2021

Changes in this version

type Watcher

+ Release func(w worker.BaseProcess)

+ Take func(ctx context.Context) (worker.BaseProcess, error)

Jul 14, 2021

Changes in this version

+ type Watcher interface

+ Allocate func() error

+ Destroy func(ctx context.Context)

+ Get func(ctx context.Context) (worker.BaseProcess, error)

+ List func() []worker.BaseProcess

+ Push func(w worker.BaseProcess)

+ Remove func(wb worker.BaseProcess)

+ Watch func(workers []worker.BaseProcess) error

Mar 2, 2021

Changes in this version

+ const MB

+ const NSEC_IN_SEC

+ const StopRequest

+ type Command func() *exec.Cmd

+ type Config struct

+ AllocateTimeout time.Duration

+ Debug bool

+ DestroyTimeout time.Duration

+ MaxJobs uint64

+ NumWorkers uint64

+ Supervisor *SupervisorConfig

+ func (cfg *Config) InitDefaults()

+ type ErrorEncoder func(err error, w worker.BaseProcess) (payload.Payload, error)

+ type Options func(p *StaticPool)

+ func AddListeners(listeners ...events.Listener) Options

+ type Pool interface

+ Destroy func(ctx context.Context)

+ Exec func(rqs payload.Payload) (payload.Payload, error)

+ GetConfig func() interface{}

+ RemoveWorker func(worker worker.BaseProcess) error

+ Workers func() (workers []worker.BaseProcess)

+ func Initialize(ctx context.Context, cmd Command, factory transport.Factory, cfg Config, ...) (Pool, error)

+ type StaticPool struct

+ func (sp *StaticPool) Destroy(ctx context.Context)

+ func (sp *StaticPool) Exec(p payload.Payload) (payload.Payload, error)

+ func (sp *StaticPool) GetConfig() interface{}

+ func (sp *StaticPool) RemoveWorker(wb worker.BaseProcess) error

+ func (sp *StaticPool) Workers() (workers []worker.BaseProcess)

+ type Supervised interface

+ Start func()

+ type SupervisorConfig struct

+ ExecTTL time.Duration

+ IdleTTL time.Duration

+ MaxWorkerMemory uint64

+ TTL time.Duration

+ WatchTick time.Duration

+ func (cfg *SupervisorConfig) InitDefaults()