Struct google_api_proto::google::pubsub::v1::CloudStorageConfig
source · pub struct CloudStorageConfig {
pub bucket: String,
pub filename_prefix: String,
pub filename_suffix: String,
pub filename_datetime_format: String,
pub max_duration: Option<Duration>,
pub max_bytes: i64,
pub state: i32,
pub output_format: Option<OutputFormat>,
}
Expand description
Configuration for a Cloud Storage subscription.
Fields§
§bucket: String
Required. User-provided name for the Cloud Storage bucket. The bucket must be created by the user. The bucket name must be without any prefix like “gs://”. See the [bucket naming requirements] (https://cloud.google.com/storage/docs/buckets#naming).
filename_prefix: String
Optional. User-provided prefix for Cloud Storage filename. See the object naming requirements.
filename_suffix: String
Optional. User-provided suffix for Cloud Storage filename. See the object naming requirements. Must not end in “/”.
filename_datetime_format: String
Optional. User-provided format string specifying how to represent datetimes in Cloud Storage filenames. See the datetime format guidance.
max_duration: Option<Duration>
Optional. The maximum duration that can elapse before a new Cloud Storage file is created. Min 1 minute, max 10 minutes, default 5 minutes. May not exceed the subscription’s acknowledgement deadline.
max_bytes: i64
Optional. The maximum bytes that can be written to a Cloud Storage file before a new file is created. Min 1 KB, max 10 GiB. The max_bytes limit may be exceeded in cases where messages are larger than the limit.
state: i32
Output only. An output-only field that indicates whether or not the subscription can receive messages.
output_format: Option<OutputFormat>
Defaults to text format.
Implementations§
Trait Implementations§
source§impl Clone for CloudStorageConfig
impl Clone for CloudStorageConfig
source§fn clone(&self) -> CloudStorageConfig
fn clone(&self) -> CloudStorageConfig
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moresource§impl Debug for CloudStorageConfig
impl Debug for CloudStorageConfig
source§impl Default for CloudStorageConfig
impl Default for CloudStorageConfig
source§impl Message for CloudStorageConfig
impl Message for CloudStorageConfig
source§fn encoded_len(&self) -> usize
fn encoded_len(&self) -> usize
source§fn encode<B>(&self, buf: &mut B) -> Result<(), EncodeError>where
B: BufMut,
Self: Sized,
fn encode<B>(&self, buf: &mut B) -> Result<(), EncodeError>where
B: BufMut,
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<B>(&self, buf: &mut B) -> Result<(), EncodeError>where
B: BufMut,
Self: Sized,
fn encode_length_delimited<B>(&self, buf: &mut B) -> Result<(), EncodeError>where
B: BufMut,
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<B>(buf: B) -> Result<Self, DecodeError>where
B: Buf,
Self: Default,
fn decode<B>(buf: B) -> Result<Self, DecodeError>where
B: Buf,
Self: Default,
source§fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError>where
B: Buf,
Self: Default,
fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError>where
B: Buf,
Self: Default,
source§fn merge<B>(&mut self, buf: B) -> Result<(), DecodeError>where
B: Buf,
Self: Sized,
fn merge<B>(&mut self, buf: B) -> Result<(), DecodeError>where
B: Buf,
Self: Sized,
self
. Read moresource§fn merge_length_delimited<B>(&mut self, buf: B) -> Result<(), DecodeError>where
B: Buf,
Self: Sized,
fn merge_length_delimited<B>(&mut self, buf: B) -> Result<(), DecodeError>where
B: Buf,
Self: Sized,
self
.source§impl PartialEq for CloudStorageConfig
impl PartialEq for CloudStorageConfig
source§fn eq(&self, other: &CloudStorageConfig) -> bool
fn eq(&self, other: &CloudStorageConfig) -> bool
self
and other
values to be equal, and is used
by ==
.impl StructuralPartialEq for CloudStorageConfig
Auto Trait Implementations§
impl Freeze for CloudStorageConfig
impl RefUnwindSafe for CloudStorageConfig
impl Send for CloudStorageConfig
impl Sync for CloudStorageConfig
impl Unpin for CloudStorageConfig
impl UnwindSafe for CloudStorageConfig
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