pub struct DescribeTaskQueueResponse {
pub pollers: Vec<PollerInfo>,
pub stats: Option<TaskQueueStats>,
pub stats_by_priority_key: HashMap<i32, TaskQueueStats>,
pub versioning_info: Option<TaskQueueVersioningInfo>,
pub config: Option<TaskQueueConfig>,
pub effective_rate_limit: Option<EffectiveRateLimit>,
pub task_queue_status: Option<TaskQueueStatus>,
pub versions_info: HashMap<String, TaskQueueVersionInfo>,
}Fields§
§pollers: Vec<PollerInfo>§stats: Option<TaskQueueStats>Statistics for the task queue.
Only set if report_stats is set on the request.
stats_by_priority_key: HashMap<i32, TaskQueueStats>Task queue stats breakdown by priority key. Only contains actively used priority keys.
Only set if report_stats is set on the request.
(– api-linter: core::0140::prepositions=disabled
aip.dev/not-precedent: “by” is used to clarify the keys and values. –)
versioning_info: Option<TaskQueueVersioningInfo>Specifies which Worker Deployment Version(s) Server routes this Task Queue’s tasks to. When not present, it means the tasks are routed to Unversioned workers (workers with UNVERSIONED or unspecified WorkerVersioningMode.) Task Queue Versioning info is updated indirectly by calling SetWorkerDeploymentCurrentVersion and SetWorkerDeploymentRampingVersion on Worker Deployments. Note: This information is not relevant to Pinned workflow executions and their activities as they are always routed to their Pinned Deployment Version. However, new workflow executions are typically not Pinned until they complete their first task (unless they are started with a Pinned VersioningOverride or are Child Workflows of a Pinned parent).
config: Option<TaskQueueConfig>Only populated if report_task_queue_config is set to true.
effective_rate_limit: Option<EffectiveRateLimit>§task_queue_status: Option<TaskQueueStatus>Deprecated.
Status of the task queue. Only populated when include_task_queue_status is set to true in the request.
versions_info: HashMap<String, TaskQueueVersionInfo>Deprecated. Only returned in ENHANCED mode. This map contains Task Queue information for each Build ID. Empty string as key value means unversioned.
Trait Implementations§
Source§impl Clone for DescribeTaskQueueResponse
impl Clone for DescribeTaskQueueResponse
Source§fn clone(&self) -> DescribeTaskQueueResponse
fn clone(&self) -> DescribeTaskQueueResponse
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Debug for DescribeTaskQueueResponse
impl Debug for DescribeTaskQueueResponse
Source§impl Default for DescribeTaskQueueResponse
impl Default for DescribeTaskQueueResponse
Source§impl Message for DescribeTaskQueueResponse
impl Message for DescribeTaskQueueResponse
Source§fn encoded_len(&self) -> usize
fn encoded_len(&self) -> usize
Source§fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>where
Self: Sized,
fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>where
Self: Sized,
Source§fn encode_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
fn encode_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
Source§fn encode_length_delimited(
&self,
buf: &mut impl BufMut,
) -> Result<(), EncodeError>where
Self: Sized,
fn encode_length_delimited(
&self,
buf: &mut impl BufMut,
) -> Result<(), EncodeError>where
Self: Sized,
Source§fn encode_length_delimited_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
fn encode_length_delimited_to_vec(&self) -> Vec<u8> ⓘwhere
Self: Sized,
Source§fn decode(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
fn decode(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
Source§fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>where
Self: Default,
Source§fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
self. Read moreSource§fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>where
Self: Sized,
self.Source§impl Name for DescribeTaskQueueResponse
impl Name for DescribeTaskQueueResponse
Source§const NAME: &'static str = "DescribeTaskQueueResponse"
const NAME: &'static str = "DescribeTaskQueueResponse"
Message.
This name is the same as it appears in the source .proto file, e.g. FooBar.Source§const PACKAGE: &'static str = "temporal.api.workflowservice.v1"
const PACKAGE: &'static str = "temporal.api.workflowservice.v1"
., e.g. google.protobuf.Source§fn full_name() -> String
fn full_name() -> String
Message.
It’s prefixed with the package name and names of any parent messages,
e.g. google.rpc.BadRequest.FieldViolation.
By default, this is the package name followed by the message name.
Fully-qualified names must be unique within a domain of Type URLs.impl StructuralPartialEq for DescribeTaskQueueResponse
Auto Trait Implementations§
impl Freeze for DescribeTaskQueueResponse
impl RefUnwindSafe for DescribeTaskQueueResponse
impl Send for DescribeTaskQueueResponse
impl Sync for DescribeTaskQueueResponse
impl Unpin for DescribeTaskQueueResponse
impl UnsafeUnpin for DescribeTaskQueueResponse
impl UnwindSafe for DescribeTaskQueueResponse
Blanket Implementations§
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<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::Request