#[repr(i32)]pub enum TaskQueueKind {
Unspecified = 0,
Normal = 1,
Sticky = 2,
}Variants§
Unspecified = 0
Tasks from any non workflow task may be unspecified.
Task queue kind is used to differentiate whether a workflow task queue is sticky or normal. If a task is not a workflow task, Task queue kind will sometimes be unspecified.
Normal = 1
Tasks from a normal workflow task queue always include complete workflow history
The task queue specified by the user is always a normal task queue. There can be as many workers as desired for a single normal task queue. All those workers may pick up tasks from that queue.
Sticky = 2
A sticky queue only includes new history since the last workflow task, and they are per-worker.
Sticky queues are created dynamically by each worker during their start up. They only exist for the lifetime of the worker process. Tasks in a sticky task queue are only available to the worker that created the sticky queue.
Sticky queues are only for workflow tasks. There are no sticky task queues for activities.
Implementations§
Source§impl TaskQueueKind
impl TaskQueueKind
Source§impl TaskQueueKind
impl TaskQueueKind
Sourcepub fn as_str_name(&self) -> &'static str
pub fn as_str_name(&self) -> &'static str
String value of the enum field names used in the ProtoBuf definition.
The values are not transformed in any way and thus are considered stable (if the ProtoBuf definition does not change) and safe for programmatic use.
Sourcepub fn from_str_name(value: &str) -> Option<Self>
pub fn from_str_name(value: &str) -> Option<Self>
Creates an enum from field names used in the ProtoBuf definition.
Trait Implementations§
Source§impl Clone for TaskQueueKind
impl Clone for TaskQueueKind
Source§fn clone(&self) -> TaskQueueKind
fn clone(&self) -> TaskQueueKind
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Debug for TaskQueueKind
impl Debug for TaskQueueKind
Source§impl Default for TaskQueueKind
impl Default for TaskQueueKind
Source§fn default() -> TaskQueueKind
fn default() -> TaskQueueKind
§impl<'de> Deserialize<'de> for TaskQueueKind
impl<'de> Deserialize<'de> for TaskQueueKind
§fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>where
D: Deserializer<'de>,
fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>where
D: Deserializer<'de>,
Source§impl From<TaskQueueKind> for i32
impl From<TaskQueueKind> for i32
Source§fn from(value: TaskQueueKind) -> i32
fn from(value: TaskQueueKind) -> i32
Source§impl Hash for TaskQueueKind
impl Hash for TaskQueueKind
Source§impl Ord for TaskQueueKind
impl Ord for TaskQueueKind
Source§fn cmp(&self, other: &TaskQueueKind) -> Ordering
fn cmp(&self, other: &TaskQueueKind) -> Ordering
1.21.0 · Source§fn max(self, other: Self) -> Selfwhere
Self: Sized,
fn max(self, other: Self) -> Selfwhere
Self: Sized,
Source§impl PartialEq for TaskQueueKind
impl PartialEq for TaskQueueKind
Source§impl PartialOrd for TaskQueueKind
impl PartialOrd for TaskQueueKind
§impl Serialize for TaskQueueKind
impl Serialize for TaskQueueKind
Source§impl TryFrom<i32> for TaskQueueKind
impl TryFrom<i32> for TaskQueueKind
Source§type Error = UnknownEnumValue
type Error = UnknownEnumValue
Source§fn try_from(value: i32) -> Result<TaskQueueKind, UnknownEnumValue>
fn try_from(value: i32) -> Result<TaskQueueKind, UnknownEnumValue>
impl Copy for TaskQueueKind
impl Eq for TaskQueueKind
impl StructuralPartialEq for TaskQueueKind
Auto Trait Implementations§
impl Freeze for TaskQueueKind
impl RefUnwindSafe for TaskQueueKind
impl Send for TaskQueueKind
impl Sync for TaskQueueKind
impl Unpin for TaskQueueKind
impl UnsafeUnpin for TaskQueueKind
impl UnwindSafe for TaskQueueKind
Blanket Implementations§
Source§impl<T> AsJsonPayloadExt for Twhere
T: Serialize,
impl<T> AsJsonPayloadExt for Twhere
T: Serialize,
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<Q, K> Comparable<K> for Q
impl<Q, K> Comparable<K> for Q
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
key and return true if they are equal.Source§impl<T> FromJsonPayloadExt for Twhere
T: for<'de> Deserialize<'de>,
impl<T> FromJsonPayloadExt for Twhere
T: for<'de> Deserialize<'de>,
fn from_json_payload(payload: &Payload) -> Result<T, PayloadDeserializeErr>
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
T in a tonic::RequestSource§impl<T> Serialize for T
impl<T> Serialize for T
fn erased_serialize(&self, serializer: &mut dyn Serializer) -> Result<(), Error>
fn do_erased_serialize( &self, serializer: &mut dyn Serializer, ) -> Result<(), ErrorImpl>
Source§impl<T> TemporalDeserializable for Twhere
T: DeserializeOwned,
impl<T> TemporalDeserializable for Twhere
T: DeserializeOwned,
Source§fn from_serde(
pc: &dyn ErasedSerdePayloadConverter,
context: &SerializationContext<'_>,
payload: Payload,
) -> Result<T, PayloadConversionError>
fn from_serde( pc: &dyn ErasedSerdePayloadConverter, context: &SerializationContext<'_>, payload: Payload, ) -> Result<T, PayloadConversionError>
Source§fn from_payload(
ctx: &SerializationContext<'_>,
payload: Payload,
) -> Result<Self, PayloadConversionError>
fn from_payload( ctx: &SerializationContext<'_>, payload: Payload, ) -> Result<Self, PayloadConversionError>
Payload.Source§fn from_payloads(
ctx: &SerializationContext<'_>,
payloads: Vec<Payload>,
) -> Result<Self, PayloadConversionError>
fn from_payloads( ctx: &SerializationContext<'_>, payloads: Vec<Payload>, ) -> Result<Self, PayloadConversionError>
Source§impl<T> TemporalSerializable for Twhere
T: Serialize,
impl<T> TemporalSerializable for Twhere
T: Serialize,
Source§fn as_serde(&self) -> Result<&dyn Serialize, PayloadConversionError>
fn as_serde(&self) -> Result<&dyn Serialize, PayloadConversionError>
Source§fn to_payload(
&self,
_: &SerializationContext<'_>,
) -> Result<Payload, PayloadConversionError>
fn to_payload( &self, _: &SerializationContext<'_>, ) -> Result<Payload, PayloadConversionError>
Payload.