workerclient

var (

	// ErrWorkerAuthentication is returned when the gateway has conclusively
	// rejected the worker credential. Retrying the same credential cannot heal
	// a 401/403/407, so both initial dial and reconnect treat it as terminal.
	ErrWorkerAuthentication = errors.New("gateway rejected worker credentials")
	// ErrWorkerHandshake is returned for a conclusive non-retryable HTTP or
	// WebSocket handshake response (for example a wrong 404 endpoint).
	ErrWorkerHandshake = errors.New("gateway permanently rejected worker handshake")
	// ErrWorkerAlreadyConnected means another Human worker process currently
	// owns the same authenticated subject. The incumbent is never displaced;
	// this client waits with bounded backoff so it can recover automatically
	// when the incumbent was merely a half-open connection.
	ErrWorkerAlreadyConnected = errors.New("worker token is already active in another Human worker")
	// ErrWorkerOwnershipViolation is terminal for this Client instance. The
	// authenticated worker tried to publish to another worker's completion;
	// retrying the same durable outbox head cannot change that authorization
	// decision and would only flap the connection.
	ErrWorkerOwnershipViolation = errors.New("worker event targets another worker's completion")
	// ErrAssignmentWorkerMismatch means an assignment is leased to a different
	// authenticated worker subject. Reject it before touching the durable outbox:
	// assignment JSON is not an authority source and must never cross subjects.
	ErrAssignmentWorkerMismatch = errors.New("assignment lease owner does not match authenticated worker")
	// ErrEventNotStored marks a deterministic failure which occurred before the
	// exact event could enter the durable outbox. Errors without this marker are
	// commit-ambiguous and callers must retry the same event ID instead of
	// restoring its source draft as though delivery were impossible.
	ErrEventNotStored = errors.New("worker event was definitely not stored")
)

var (

	// ErrEventQuarantined reports that an event ID belongs to a corrupt durable
	// record which was isolated from delivery. The raw record remains available
	// for operator inspection and the ID must not be reused implicitly.
	ErrEventQuarantined = errors.New("worker event is quarantined after durable outbox corruption")
	// ErrEventPreviouslyRejected reports that an exact event is already in the
	// confirmed rejection tombstone, rather than the send outbox.
	ErrEventPreviouslyRejected = errors.New("worker event was already rejected")
	// ErrEventRejectionPending reports that the exact rejected event remains in
	// the durable inbox and will be offered through Client.Messages.
	ErrEventRejectionPending = errors.New("worker event rejection is pending local recovery")
)

var ErrWorkerIdentityUnavailable = errors.New("worker identity is not established")