Versions in this module Expand all Collapse all v0 v0.0.2 Jun 23, 2026 v0.0.1 Jun 20, 2026 Changes in this version + const StatusError + const StatusOK + const StatusRetry + func Serve(nc *nats.Conn, subject string, h Handler) (*nats.Subscription, error) + func ServeNamespaced(nc *nats.Conn, namespace, subject string, h Handler) (*nats.Subscription, error) + type Handler func(ctx context.Context, req TaskRequest) (TaskResponse, error) + type TaskRequest struct + Attempt int + Deadline time.Time + ExecutionID string + NodeID string + Payload json.RawMessage + type TaskResponse struct + Error string + Payload json.RawMessage + Status string
Go to main page