Struct CreateExecutionArgs 

pub struct CreateExecutionArgs {

    pub execution_id: ExecutionId,
    pub namespace: Namespace,
    pub lane_id: LaneId,
    pub execution_kind: String,
    pub input_payload: Vec<u8>,
    pub payload_encoding: Option<String>,
    pub priority: i32,
    pub creator_identity: String,
    pub idempotency_key: Option<String>,
    pub tags: HashMap<String, String>,
    pub policy: Option<ExecutionPolicy>,
    pub delay_until: Option<TimestampMs>,
    pub execution_deadline_at: Option<TimestampMs>,
    pub partition_id: u16,
    pub now: TimestampMs,
}

Fields

execution_id: ExecutionId

namespace: Namespace

lane_id: LaneId

execution_kind: String

input_payload: Vec<u8>

payload_encoding: Option<String>

priority: i32

creator_identity: String

idempotency_key: Option<String>

tags: HashMap<String, String>

policy: Option<ExecutionPolicy>

Execution policy (retry, timeout, suspension, routing, etc.).

delay_until: Option<TimestampMs>

If set and in the future, execution starts delayed.

execution_deadline_at: Option<TimestampMs>

Absolute deadline timestamp (ms). Execution expires if not complete by this time.

partition_id: u16

Partition ID (pre-computed).

now: TimestampMs

Trait Implementations

impl Clone for CreateExecutionArgs

fn clone(&self) -> CreateExecutionArgs

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CreateExecutionArgs

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for CreateExecutionArgs

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for CreateExecutionArgs

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.