Versions in this module Expand all Collapse all v2 v2.0.0 Oct 8, 2026 Changes in this version + type Options func(p *Process) + func WithLog(z *slog.Logger) Options + func WithMaxExecs(maxExecs uint64) Options + type Process struct + func InitBaseWorker(cmd *exec.Cmd, options ...Options) (*Process, error) + func (w *Process) AddCallback(cb func()) + func (w *Process) AttachRelay(rl relay.Relay) + func (w *Process) Callback() + func (w *Process) Created() time.Time + func (w *Process) Exec(ctx context.Context, p *payload.Payload) (*payload.Payload, error) + func (w *Process) Kill() error + func (w *Process) MaxExecs() uint64 + func (w *Process) MaxExecsReached() bool + func (w *Process) Pid() int64 + func (w *Process) Relay() relay.Relay + func (w *Process) Start() error + func (w *Process) State() *fsm.Fsm + func (w *Process) Stop() error + func (w *Process) StreamCancel(ctx context.Context) error + func (w *Process) StreamIter() (*payload.Payload, bool, error) + func (w *Process) StreamIterWithContext(ctx context.Context) (*payload.Payload, bool, error) + func (w *Process) String() string + func (w *Process) Wait() error + func (w *Process) Write(p []byte) (int, error) v2.0.0-beta.1 Mar 20, 2026 Other modules containing this package github.com/roadrunner-server/pool
Go to main page