Struct googapis::google::dataflow::v1beta3::WorkerSettings [−][src]
pub struct WorkerSettings {
pub base_url: String,
pub reporting_enabled: bool,
pub service_path: String,
pub shuffle_service_path: String,
pub worker_id: String,
pub temp_storage_prefix: String,
}
Expand description
Provides data to pass through to the worker harness.
Fields
base_url: String
The base URL for 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/"
reporting_enabled: bool
Whether to send work progress updates to the service.
service_path: String
The Cloud Dataflow service path relative to the root URL, for example, “dataflow/v1b3/projects”.
shuffle_service_path: String
The Shuffle service path relative to the root URL, for example, “shuffle/v1beta1”.
worker_id: String
The ID of the worker running this pipeline.
temp_storage_prefix: String
The prefix of the resources the system should use for temporary storage.
The supported resource type is:
Google Cloud Storage:
storage.googleapis.com/{bucket}/{object} bucket.storage.googleapis.com/{object}
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 WorkerSettings
impl Send for WorkerSettings
impl Sync for WorkerSettings
impl Unpin for WorkerSettings
impl UnwindSafe for WorkerSettings
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