Struct QueueItemDocument 

pub struct QueueItemDocument {

    pub id: String,
    pub instance_id: String,
    pub doc_type: String,
    pub work_item: String,
    pub dispatch_slot: u8,
    pub visible_at: u64,
    pub enqueued_at: u64,
    pub lock_token: Option<String>,
    pub locked_until: Option<u64>,
    pub attempt_count: i32,
    pub execution_id: Option<u64>,
    pub activity_id: Option<u64>,
    pub session_id: Option<String>,
    pub tag: Option<String>,
    pub etag: Option<String>,
    pub rid: Option<String>,
    pub self_link: Option<String>,
    pub ts: Option<u64>,
    pub attachments: Option<String>,
}

Queue item document (orchestrator or worker). id = random UUID Partition key = instanceId

Fields

id: String

instance_id: String

doc_type: String

work_item: String

dispatch_slot: u8

visible_at: u64

enqueued_at: u64

lock_token: Option<String>

locked_until: Option<u64>

attempt_count: i32

execution_id: Option<u64>

For worker queue items: execution context

activity_id: Option<u64>

session_id: Option<String>

tag: Option<String>

Activity routing tag (None = untagged/default)

etag: Option<String>

CosmosDB system fields

rid: Option<String>

self_link: Option<String>

ts: Option<u64>

attachments: Option<String>

Implementations

impl QueueItemDocument

pub fn new_orch_queue( instance_id: &str, work_item_json: String, visible_at: u64, now_ms: u64, ) -> Self

pub fn new_worker_queue( instance_id: &str, work_item_json: String, execution_id: Option<u64>, activity_id: Option<u64>, session_id: Option<String>, tag: Option<String>, now_ms: u64, ) -> Self

Trait Implementations

impl Clone for QueueItemDocument

fn clone(&self) -> QueueItemDocument

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueueItemDocument

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for QueueItemDocument

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for QueueItemDocument

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

where __S: Serializer,

Serialize this value into the given Serde serializer.