Struct googapis::google::dataflow::v1beta3::LaunchFlexTemplateParameter [−][src]
pub struct LaunchFlexTemplateParameter {
pub job_name: String,
pub parameters: HashMap<String, String>,
pub launch_options: HashMap<String, String>,
pub environment: Option<FlexTemplateRuntimeEnvironment>,
pub update: bool,
pub transform_name_mappings: HashMap<String, String>,
pub template: Option<Template>,
}
Expand description
Launch FlexTemplate Parameter.
Fields
job_name: String
Required. The job name to use for the created job. For update job request, job name should be same as the existing running job.
parameters: HashMap<String, String>
The parameters for FlexTemplate. Ex. {“num_workers”:“5”}
launch_options: HashMap<String, String>
Launch options for this flex template job. This is a common set of options across languages and templates. This should not be used to pass job parameters.
environment: Option<FlexTemplateRuntimeEnvironment>
The runtime environment for the FlexTemplate job
update: bool
Set this to true if you are sending a request to update a running streaming job. When set, the job name should be the same as the running job.
transform_name_mappings: HashMap<String, String>
Use this to pass transform_name_mappings for streaming update jobs. Ex:{“oldTransformName”:“newTransformName”,…}’
template: Option<Template>
Launch Mechanism.
Trait Implementations
fn merge_field<B>(
&mut self,
tag: u32,
wire_type: WireType,
buf: &mut B,
ctx: DecodeContext
) -> Result<(), DecodeError> where
B: Buf,
Returns the encoded length of the message without a length delimiter.
Encodes the message to a buffer. Read more
Encodes the message to a newly allocated buffer.
Encodes the message with a length-delimiter to a buffer. Read more
Encodes the message with a length-delimiter to a newly allocated buffer.
Decodes an instance of the message from a buffer. Read more
fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError> where
Self: Default,
B: Buf,
fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError> where
Self: Default,
B: Buf,
Decodes a length-delimited instance of the message from the buffer.
Decodes an instance of the message from a buffer, and merges it into self
. Read more
Decodes a length-delimited instance of the message from buffer, and
merges it into self
. Read more
This method tests for self
and other
values to be equal, and is used
by ==
. Read more
This method tests for !=
.
Auto Trait Implementations
impl RefUnwindSafe for LaunchFlexTemplateParameter
impl Send for LaunchFlexTemplateParameter
impl Sync for LaunchFlexTemplateParameter
impl Unpin for LaunchFlexTemplateParameter
impl UnwindSafe for LaunchFlexTemplateParameter
Blanket Implementations
Mutably borrows from an owned value. Read more
Wrap the input message T
in a tonic::Request
pub fn vzip(self) -> V
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more