Struct WorkerTarget 

pub struct WorkerTarget {
    pub is_pull_mode: bool,
    pub task_queue: String,
}

Fields

is_pull_mode: bool

Routes work through a connected pull Worker. Dex requires true whenever a target is set.

task_queue: String

Names the task queue whose pull Workers run this Flow’s Steps and RPCs. Only Workers registered on this task queue receive the Flow’s work, through its sticky Worker or its Flow type queue inside the task queue. The task queue is fixed when the Flow starts. At StartFlow, an empty name selects the default task queue. In a SubFlow override, an empty name keeps the parent’s task queue, and “dex.default” selects the default task queue. In UpdateFlowConfig, an empty name keeps the run’s task queue, and Dex rejects another task queue with INVALID_ARGUMENT. A name has 1 to 63 characters from A-Z, a-z, 0-9, ‘.’, ‘_’, and ‘-’. Names starting with “dex.” are reserved; only “dex.default” is accepted, and Dex stores it as the empty default name. Dex rejects a name with INVALID_ARGUMENT when is_pull_mode is false or the name is invalid. Requires Server protocol version 5 or later.

Trait Implementations

impl Clone for WorkerTarget

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 WorkerTarget

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

Formats the value using the given formatter.

impl Default for WorkerTarget

fn default() -> Self

Returns the “default value” for a type.

impl Eq for WorkerTarget

impl Hash for WorkerTarget

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 WorkerTarget

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 WorkerTarget

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for WorkerTarget