Runtime

Error types returned by every SDK call, and the adaptive backpressure manager that paces requests when the cluster pushes back.

BackpressureManager

Adaptive backpressure manager shared (via Arc) by an SDK client and all its clones.

Initiating operations call acquire before issuing a request and release afterwards, recording the outcome with record_healthy_hint on success or record_backpressure on a backpressure signal. Drain operations (job completion / failure) bypass the gate entirely.

Methods

Method	Description
acquire	Acquire a permit, awaiting until one is available.
new	Create a manager for the given profile.
record_backpressure	Record a backpressure signal from the server.
record_healthy_hint	Record a successful (non-backpressure) completion, triggering passive recovery.
release	Release a permit and wake one waiter. In the Legacy profile this is a no-op.
severity	The current severity level.
state	A snapshot of the manager's internal state, for observability.

BackpressureProfile

Backpressure tuning profile, configured via CAMUNDA_SDK_BACKPRESSURE_PROFILE.

Variants

Variant	Payload	Description
Balanced	—	Adaptive global concurrency control (default).
Legacy	—	Observe-only: record signals but never gate requests.

BackpressureSeverity

Backpressure severity level reported by the manager.

Variants

Variant	Payload	Description
Healthy	—	No recent backpressure.
Soft	—	Backpressure observed; mild throttling.
Severe	—	Sustained backpressure; aggressive throttling.

BackpressureState

A point-in-time snapshot of the manager's internal state, for observability.

Fields

Field	Type	Description
severity	BackpressureSeverity	Current severity level.
consecutive	u32	Consecutive backpressure signals since the last healthy decay.
permits_max	Option<u32>	Current permit cap, or None when unlimited.
permits_current	u32	Permits currently held.
waiters	u32	Number of callers queued waiting for a permit.
backoff_ms	u64	Current backoff-at-floor delay in milliseconds.

CamundaError

Errors returned by the Camunda SDK.

Variants

Variant	Payload	Description
Config	(String)	Configuration was invalid or incomplete (e.g. missing OAuth credentials).
Auth	(String)	Failed to obtain or refresh an authentication token.
Network	(Error)	A network-level failure occurred (connection, TLS, timeout).
Io	(Error)	An I/O failure occurred (e.g. while streaming a multipart upload).
Api	{ status: u16, body: Option<String> }	The server returned a non-success HTTP status.
Serialization	(Error)	A response payload could not be (de)serialized.
Validation	(String)	A domain-type or input constraint was violated before sending the request.
Backpressure	(String)	The client-side backpressure controller rejected the request to avoid unbounded memory growth (waiter queue at capacity).
EventualConsistencyTimeout	{ elapsed_ms: u64 }	An eventual-consistency polling helper timed out before its predicate was met.

Methods

Method	Description
status	The HTTP status code, if this is a CamundaError::Api error.

Result

Convenience alias used throughout the SDK.

pub type Result<T> = std::result::Result<T, CamundaError>;