Struct google_api_proto::google::dataflow::v1beta3::TaskRunnerSettings
source · pub struct TaskRunnerSettings {Show 19 fields
pub task_user: String,
pub task_group: String,
pub oauth_scopes: Vec<String>,
pub base_url: String,
pub dataflow_api_version: String,
pub parallel_worker_settings: Option<WorkerSettings>,
pub base_task_dir: String,
pub continue_on_exception: bool,
pub log_to_serialconsole: bool,
pub alsologtostderr: bool,
pub log_upload_location: String,
pub log_dir: String,
pub temp_storage_prefix: String,
pub harness_command: String,
pub workflow_file_name: String,
pub commandlines_file_name: String,
pub vm_id: String,
pub language_hint: String,
pub streaming_worker_main_class: String,
}
Expand description
Taskrunner configuration settings.
Fields§
§task_user: String
The UNIX user ID on the worker VM to use for tasks launched by taskrunner; e.g. “root”.
task_group: String
The UNIX group ID on the worker VM to use for tasks launched by taskrunner; e.g. “wheel”.
oauth_scopes: Vec<String>
The OAuth2 scopes to be requested by the taskrunner in order to access the Cloud Dataflow API.
base_url: String
The base URL for the taskrunner to use when accessing Google Cloud APIs.
When workers access Google Cloud APIs, they logically do so via relative URLs. If this field is specified, it supplies the base URL to use for resolving these relative URLs. The normative algorithm used is defined by RFC 1808, “Relative Uniform Resource Locators”.
If not specified, the default value is “http://www.googleapis.com/"
dataflow_api_version: String
The API version of endpoint, e.g. “v1b3”
parallel_worker_settings: Option<WorkerSettings>
The settings to pass to the parallel worker harness.
base_task_dir: String
The location on the worker for task-specific subdirectories.
continue_on_exception: bool
Whether to continue taskrunner if an exception is hit.
log_to_serialconsole: bool
Whether to send taskrunner log info to Google Compute Engine VM serial console.
alsologtostderr: bool
Whether to also send taskrunner log info to stderr.
log_upload_location: String
Indicates where to put logs. If this is not specified, the logs will not be uploaded.
The supported resource type is:
Google Cloud Storage: storage.googleapis.com/{bucket}/{object} bucket.storage.googleapis.com/{object}
log_dir: String
The directory on the VM to store logs.
temp_storage_prefix: String
The prefix of the resources the taskrunner should use for temporary storage.
The supported resource type is:
Google Cloud Storage: storage.googleapis.com/{bucket}/{object} bucket.storage.googleapis.com/{object}
harness_command: String
The command to launch the worker harness.
workflow_file_name: String
The file to store the workflow in.
commandlines_file_name: String
The file to store preprocessing commands in.
vm_id: String
The ID string of the VM.
language_hint: String
The suggested backend language.
streaming_worker_main_class: String
The streaming worker main class name.
Trait Implementations§
source§impl Clone for TaskRunnerSettings
impl Clone for TaskRunnerSettings
source§fn clone(&self) -> TaskRunnerSettings
fn clone(&self) -> TaskRunnerSettings
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moresource§impl Debug for TaskRunnerSettings
impl Debug for TaskRunnerSettings
source§impl Default for TaskRunnerSettings
impl Default for TaskRunnerSettings
source§impl Message for TaskRunnerSettings
impl Message for TaskRunnerSettings
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 PartialEq for TaskRunnerSettings
impl PartialEq for TaskRunnerSettings
source§fn eq(&self, other: &TaskRunnerSettings) -> bool
fn eq(&self, other: &TaskRunnerSettings) -> bool
self
and other
values to be equal, and is used
by ==
.impl StructuralPartialEq for TaskRunnerSettings
Auto Trait Implementations§
impl Freeze for TaskRunnerSettings
impl RefUnwindSafe for TaskRunnerSettings
impl Send for TaskRunnerSettings
impl Sync for TaskRunnerSettings
impl Unpin for TaskRunnerSettings
impl UnwindSafe for TaskRunnerSettings
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
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
§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