worker

May 2, 2024

Changes in this version

type Process

+ func (w *Process) MaxExecs() uint64

Apr 11, 2024

Changes in this version

type Options

+ func WithMaxExecs(maxExecs uint64) Options

type Process

+ func (w *Process) MaxExecsReached() bool

Jan 4, 2024

Changes in this version

type Process

+ func (w *Process) StreamIterWithContext(ctx context.Context) (*payload.Payload, bool, error)

Sep 24, 2023

Changes in this version

type Process

+ func (w *Process) AddCallback(cb func())

+ func (w *Process) Callback()

Sep 9, 2023

Changes in this version

type Process

+ func (w *Process) StreamCancel(ctx context.Context) error

+ func (w *Process) StreamIter() (*payload.Payload, bool, error)

Jan 8, 2023

Changes in this version

+ type Options func(p *Process)

+ func WithLog(z *zap.Logger) Options

+ type Process struct

+ func InitBaseWorker(cmd *exec.Cmd, options ...Options) (*Process, error)

+ func (w *Process) AttachRelay(rl relay.Relay)

+ func (w *Process) Created() time.Time

+ func (w *Process) Exec(p *payload.Payload) (*payload.Payload, error)

+ func (w *Process) ExecWithTTL(ctx context.Context, p *payload.Payload) (*payload.Payload, error)

+ func (w *Process) Kill() error

+ 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) String() string

+ func (w *Process) Wait() error

+ func (w *Process) Write(p []byte) (int, error)