Versions in this module Expand all Collapse all v0 v0.1.0 Aug 29, 2026 Changes in this version + type ConfigError struct + Message string + func (e *ConfigError) Error() string + type LogSource string + const Stderr + const Stdout + type Option struct + func WithConnectTimeout(value time.Duration) Option + func WithConsoleCapture(value bool) Option + func WithCoreToken(value string) Option + func WithCoreURL(value string) Option + func WithEnabled(enabled bool) Option + func WithFailFast(value bool) Option + func WithHeartbeatInterval(value time.Duration) Option + func WithHost(value string) Option + func WithLogger(value *slog.Logger) Option + func WithRequestTimeout(value time.Duration) Option + func WithWorkerName(value string) Option + type Process struct + func Endless(name string, run func() error, options ...ProcessOption) Process + func EndlessContext(name string, run func(context.Context) error, options ...ProcessOption) Process + func Progressive(name string, run func() error, options ...ProcessOption) Process + func ProgressiveContext(name string, run func(context.Context) error, options ...ProcessOption) Process + type ProcessOption struct + func WithOnStop(hook func() error) ProcessOption + type ProcessState string + const StateFailed + const StateIdle + const StateRunning + const StateStopping + type ProcessStatus struct + AckToken int64 + Name string + RunID *int64 + State ProcessState + Type ProcessType + type ProcessType string + const TypeEndless + const TypeProgressive + type Settings struct + CaptureConsole bool + ConnectTimeout time.Duration + CoreURL string + Enabled bool + FailFast bool + HeartbeatInterval time.Duration + Host string + RequestTimeout time.Duration + WorkerName string + type StartupError struct + Cause error + func (e *StartupError) Error() string + func (e *StartupError) Unwrap() error + type Worker struct + func New(options ...Option) (*Worker, error) + func (w *Worker) Logger(processName string) *slog.Logger + func (w *Worker) Processes() []ProcessStatus + func (w *Worker) Register(declarations ...Process) error + func (w *Worker) Settings() Settings + func (w *Worker) Start() error + func (w *Worker) Stop(ctx context.Context) error + func (w *Worker) Writer(processName string, source LogSource, next io.Writer) io.Writer