Struct Stream

pub struct Stream {

    pub backfill_all: Option<BackfillAllStrategy>,
    pub backfill_none: Option<BackfillNoneStrategy>,
    pub create_time: Option<DateTime<Utc>>,
    pub customer_managed_encryption_key: Option<String>,
    pub destination_config: Option<DestinationConfig>,
    pub display_name: Option<String>,
    pub errors: Option<Vec<Error>>,
    pub labels: Option<HashMap<String, String>>,
    pub last_recovery_time: Option<DateTime<Utc>>,
    pub name: Option<String>,
    pub source_config: Option<SourceConfig>,
    pub state: Option<String>,
    pub update_time: Option<DateTime<Utc>>,
}

A resource representing streaming data from a source to a destination.

Activities

This type is used in activities, which are methods you may call on this type or where this type is involved in. The list links the activity name, along with information about where it is used (one of request and response).

• locations streams create projects (request)
• locations streams get projects (response)
• locations streams patch projects (request)

Fields

backfill_all: Option<BackfillAllStrategy>

Automatically backfill objects included in the stream source configuration. Specific objects can be excluded.

backfill_none: Option<BackfillNoneStrategy>

Do not automatically backfill any objects.

create_time: Option<DateTime<Utc>>

Output only. The creation time of the stream.

customer_managed_encryption_key: Option<String>

Immutable. A reference to a KMS encryption key. If provided, it will be used to encrypt the data. If left blank, data will be encrypted using an internal Stream-specific encryption key provisioned through KMS.

destination_config: Option<DestinationConfig>

Required. Destination connection profile configuration.

display_name: Option<String>

Required. Display name.

errors: Option<Vec<Error>>

Output only. Errors on the Stream.

labels: Option<HashMap<String, String>>

Labels.

last_recovery_time: Option<DateTime<Utc>>

Output only. If the stream was recovered, the time of the last recovery. Note: This field is currently experimental.

name: Option<String>

Output only. The stream’s name.

source_config: Option<SourceConfig>

Required. Source connection profile configuration.

state: Option<String>

The state of the stream.

update_time: Option<DateTime<Utc>>

Output only. The last update time of the stream.

Trait Implementations

impl Clone for Stream

fn clone(&self) -> Stream

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Stream

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for Stream

fn default() -> Stream

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for Stream

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for Stream

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl RequestValue for Stream

impl ResponseResult for Stream