Struct ClaimForWorkerResponse 

pub struct ClaimForWorkerResponse {
    pub execution_id: String,
    pub partition_key: PartitionKey,
    pub grant_key: String,
    pub expires_at_ms: u64,
}

Response body for POST /v1/workers/{worker_id}/claim.

Wire shape of ff_core::contracts::ClaimGrant. Carries the opaque ff_core::partition::PartitionKey directly on the wire (issue #91); the SDK reconstructs the core type via Self::into_grant.

Fields

execution_id: String

partition_key: PartitionKey

grant_key: String

expires_at_ms: u64

Implementations

impl ClaimForWorkerResponse

pub fn into_grant(self) -> Result<ClaimGrant, SdkError>

Convert the wire DTO into a typed ff_core::contracts::ClaimGrant for handoff to crate::FlowFabricWorker::claim_from_grant. Returns SdkError::AdminApi on malformed execution_id — a drift signal that the server and SDK disagree on the wire shape, so failing loud prevents routing to a ghost partition.

The partition_key itself is not eagerly parsed here: it is carried opaquely to the claim_from_grant hot path, which parses it there and surfaces a typed error on malformed keys.

Trait Implementations

impl Clone for ClaimForWorkerResponse

fn clone(&self) -> ClaimForWorkerResponse

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ClaimForWorkerResponse

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ClaimForWorkerResponse

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.