vero

Oct 14, 2026

Changes in this version

+ var ErrCancelled = errors.New("vero: the request was cancelled")

type State

+ func (s *State[T]) Snapshot() (T, error)

type WorkerOptions

+ Lock string

Oct 3, 2026

Changes in this version

+ func Hosting() bool

+ func InProcessWorker() func(in io.Reader, out io.Writer) error

+ func ServeInProcess(serve func(in io.Reader, out io.Writer) error)

type Envelope

+ Code string

type SupervisorOptions

+ Serve func(in io.Reader, out io.Writer) error

type WorkerOptions

+ In io.Reader

+ Out io.Writer

Sep 27, 2026

Changes in this version

+ const DefaultStateInterval

+ const MaxLineSize

+ var ErrAlreadyRunning = errors.New("a worker is already running for this application")

+ var ErrWorkerNotRunning = errors.New("vero: the worker is not running")

+ var ShutdownGrace = 5 * time.Second

+ func Edit[T Keyed[K], K comparable](items []T, key K, change func(*T)) error

+ func Handle[Req any, Rep any](w *Worker, name string, fn func(ctx context.Context, request Req) (Rep, error))

+ func UpdateItem[T any, J Keyed[K], K comparable](s *State[T], name string, change func(*J) error)

+ func UpdateWith[T any, Req any](s *State[T], name string, fn func(state *T, request Req) error)

+ func Update[T any](s *State[T], name string, fn func(*T) error)

+ type Envelope struct

+ Error string

+ ID uint64

+ Kind string

+ Name string

+ Payload json.RawMessage

+ type Handler func(ctx context.Context, request json.RawMessage) (reply any, err error)

+ type ID struct

+ ID T

+ type Keyed interface

+ Key func() K

+ type RemoteError struct

+ Message string

+ func (e *RemoteError) Error() string

+ type RunState int

+ const Restarting

+ const Running

+ const Starting

+ const Stopped

+ func (s RunState) String() string

+ type State struct

+ func NewState[T any](w *Worker, initial T) *State[T]

+ func (s *State[T]) Do(f func(*T))

+ func (s *State[T]) Every(interval time.Duration, fn func(*T))

+ func (s *State[T]) JSON() (json.RawMessage, error)

+ type Supervisor struct

+ func Supervise(opts SupervisorOptions) *Supervisor

+ func (s *Supervisor) Call(ctx context.Context, name string, request any) (json.RawMessage, error)

+ func (s *Supervisor) Err() error

+ func (s *Supervisor) Latest() json.RawMessage

+ func (s *Supervisor) Request(ctx context.Context, request any) (json.RawMessage, error)

+ func (s *Supervisor) Restarts() int

+ func (s *Supervisor) State() RunState

+ func (s *Supervisor) Stop() error

+ type SupervisorOptions struct

+ Args []string

+ Backoff time.Duration

+ Dir string

+ Env []string

+ Healthy time.Duration

+ Lock string

+ MaxBackoff time.Duration

+ NoLock bool

+ OnEvent func(event json.RawMessage)

+ OnLog func(line string)

+ OnStateChange func(RunState)

+ Path string

+ type Worker struct

+ func NewWorker(opts WorkerOptions) *Worker

+ func (w *Worker) EmitOnChange(ctx context.Context, interval time.Duration, snapshot func() any)

+ func (w *Worker) Fallback(h Handler)

+ func (w *Worker) FallbackCalls() uint64

+ func (w *Worker) Log(format string, a ...any)

+ func (w *Worker) Serve() error

+ func (w *Worker) Supervised() bool

+ type WorkerOptions struct

+ JSON bool

+ Quiet bool

+ ShowVersion bool

+ StateInterval time.Duration

+ Version string

+ func (o *WorkerOptions) PrintVersionAndExit()

+ func (o *WorkerOptions) RegisterFlags(fs *flag.FlagSet)