pub struct TaskQueueVersioningInfo {
pub current_deployment_version: Option<WorkerDeploymentVersion>,
pub current_version: String,
pub ramping_deployment_version: Option<WorkerDeploymentVersion>,
pub ramping_version: String,
pub ramping_version_percentage: f32,
pub update_time: Option<Timestamp>,
}Expand description
Experimental. Worker Deployments are experimental and might significantly change in the future.
Fields§
§current_deployment_version: Option<WorkerDeploymentVersion>Specifies which Deployment Version should receive new workflow executions and tasks of
existing unversioned or AutoUpgrade workflows.
Nil value represents all the unversioned workers (those with UNVERSIONED (or unspecified) WorkerVersioningMode.)
Note: Current Version is overridden by the Ramping Version for a portion of traffic when ramp percentage
is non-zero (see ramping_deployment_version and ramping_version_percentage).
current_version: StringDeprecated. Use current_deployment_version.
ramping_deployment_version: Option<WorkerDeploymentVersion>When ramp percentage is non-zero, that portion of traffic is shifted from the Current Version to the Ramping Version.
Must always be different from current_deployment_version unless both are nil.
Nil value represents all the unversioned workers (those with UNVERSIONED (or unspecified) WorkerVersioningMode.)
Note that it is possible to ramp from one Version to another Version, or from unversioned
workers to a particular Version, or from a particular Version to unversioned workers.
ramping_version: StringDeprecated. Use ramping_deployment_version.
ramping_version_percentage: f32Percentage of tasks that are routed to the Ramping Version instead of the Current Version. Valid range: [0, 100]. A 100% value means the Ramping Version is receiving full traffic but not yet “promoted” to be the Current Version, likely due to pending validations. A 0% value means the Ramping Version is receiving no traffic.
update_time: Option<Timestamp>Last time versioning information of this Task Queue changed.
Trait Implementations§
Source§impl Clone for TaskQueueVersioningInfo
impl Clone for TaskQueueVersioningInfo
Source§fn clone(&self) -> TaskQueueVersioningInfo
fn clone(&self) -> TaskQueueVersioningInfo
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moreSource§impl Debug for TaskQueueVersioningInfo
impl Debug for TaskQueueVersioningInfo
Source§impl Default for TaskQueueVersioningInfo
impl Default for TaskQueueVersioningInfo
Source§impl Message for TaskQueueVersioningInfo
impl Message for TaskQueueVersioningInfo
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 TaskQueueVersioningInfo
impl Name for TaskQueueVersioningInfo
Source§const NAME: &'static str = "TaskQueueVersioningInfo"
const NAME: &'static str = "TaskQueueVersioningInfo"
Message.
This name is the same as it appears in the source .proto file, e.g. FooBar.Source§const PACKAGE: &'static str = "temporal.api.taskqueue.v1"
const PACKAGE: &'static str = "temporal.api.taskqueue.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.Source§impl PartialEq for TaskQueueVersioningInfo
impl PartialEq for TaskQueueVersioningInfo
impl StructuralPartialEq for TaskQueueVersioningInfo
Auto Trait Implementations§
impl Freeze for TaskQueueVersioningInfo
impl RefUnwindSafe for TaskQueueVersioningInfo
impl Send for TaskQueueVersioningInfo
impl Sync for TaskQueueVersioningInfo
impl Unpin for TaskQueueVersioningInfo
impl UnsafeUnpin for TaskQueueVersioningInfo
impl UnwindSafe for TaskQueueVersioningInfo
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