Struct PollWorkerTaskRegister 

pub struct PollWorkerTaskRegister {
    pub queue: String,
    pub app_worker_id: String,
    pub flow_types: Vec<String>,
    pub sdk_name: String,
    pub sdk_version: String,
    pub supports_reserved_slot_dispatch: bool,
    pub slot_kind: i32,
}

Registers one queue stream or reserved execution slot for a Worker process.

Fields

queue: String

Names this stream’s queue: app_worker_id or one declared flow_type. Workers declaring supports_reserved_slot_dispatch leave it empty; the stream serves its own sticky queue (app_worker_id) and every Flow type in flow_types. Dex rejects a reserved-slot registration with a non-empty queue with INVALID_ARGUMENT.

app_worker_id: String

Identifies this Worker process across reconnects; a restart uses a new ID.

flow_types: Vec<String>

Lists the Flow types this Worker can execute.

sdk_name: String

Identifies the SDK implementation for diagnostics.

sdk_version: String

Identifies the SDK release for diagnostics.

supports_reserved_slot_dispatch: bool

When true, this stream is one reserved Worker execution slot, ready whenever idle. The Worker never rejects a task for capacity. It rejects only unknown Step types or RPC names. While stopping, it drops task frames without sending any frame for them. See the PollWorkerTask rpc. When false, the stream serves only the queue named in queue and may reject with NO_CAPACITY. Requires Server protocol version 4 or later.

slot_kind: i32

Selects which tasks this slot accepts; unspecified means STEP_AND_RPC. Applies only to reserved-slot streams. Dex rejects a registration with INVALID_ARGUMENT when supports_reserved_slot_dispatch is false and slot_kind is not UNSPECIFIED. Requires Server protocol version 4 or later.

Implementations

impl PollWorkerTaskRegister

pub fn slot_kind(&self) -> PollWorkerSlotKind

Returns the enum value of slot_kind, or the default if the field is set to an invalid enum value.

pub fn set_slot_kind(&mut self, value: PollWorkerSlotKind)

Sets slot_kind to the provided enum value.

Trait Implementations

impl Clone for PollWorkerTaskRegister

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PollWorkerTaskRegister

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

Formats the value using the given formatter.

impl Default for PollWorkerTaskRegister

fn default() -> Self

Returns the “default value” for a type.

impl Eq for PollWorkerTaskRegister

impl Hash for PollWorkerTaskRegister

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl Message for PollWorkerTaskRegister

fn encoded_len(&self) -> usize

Returns the encoded length of the message without a length delimiter.

fn clear(&mut self)

Clears the message, resetting all fields to their default.

fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>

where Self: Sized,

Encodes the message to a buffer.

fn encode_to_vec(&self) -> Vec<u8>

where Self: Sized,

Encodes the message to a newly allocated buffer.

fn encode_length_delimited( &self, buf: &mut impl BufMut, ) -> Result<(), EncodeError>

where Self: Sized,

Encodes the message with a length-delimiter to a buffer.

fn encode_length_delimited_to_vec(&self) -> Vec<u8>

where Self: Sized,

Encodes the message with a length-delimiter to a newly allocated buffer.

fn decode(buf: impl Buf) -> Result<Self, DecodeError>

where Self: Default,

Decodes an instance of the message from a buffer.

fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>

where Self: Default,

Decodes a length-delimited instance of the message from the buffer.

fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>

where Self: Sized,

Decodes an instance of the message from a buffer, and merges it into self.

fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>

where Self: Sized,

Decodes a length-delimited instance of the message from buffer, and merges it into self.

impl PartialEq for PollWorkerTaskRegister

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for PollWorkerTaskRegister