Struct Connector 

#[non_exhaustive]
pub struct Connector {
    pub name: String,
    pub configs: HashMap<String, String>,
    pub state: State,
    pub restart_policy: Option<RestartPolicy>,
    /* private fields */
}

A Kafka Connect connector in a given ConnectCluster.

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

name: String

Identifier. The name of the connector. Structured like: projects/{project}/locations/{location}/connectClusters/{connect_cluster}/connectors/{connector}

configs: HashMap<String, String>

Optional. Connector config as keys/values. The keys of the map are connector property names, for example: connector.class, tasks.max, key.converter.

state: State

Output only. The current state of the connector.

restart_policy: Option<RestartPolicy>

A policy that specifies how to restart the failed connectors/tasks in a Cluster resource. If not set, the failed connectors/tasks won’t be restarted.

Implementations

impl Connector

pub fn new() -> Self

pub fn set_name<T: Into<String>>(self, v: T) -> Self

Sets the value of name.

pub fn set_configs<T, K, V>(self, v: T) -> Self

where T: IntoIterator<Item = (K, V)>, K: Into<String>, V: Into<String>,

Sets the value of configs.

pub fn set_state<T: Into<State>>(self, v: T) -> Self

Sets the value of state.

pub fn set_restart_policy<T: Into<Option<RestartPolicy>>>(self, v: T) -> Self

Sets the value of restart_policy.

Note that all the setters affecting restart_policy are mutually exclusive.

pub fn task_restart_policy(&self) -> Option<&Box<TaskRetryPolicy>>

The value of restart_policy if it holds a TaskRestartPolicy, None if the field is not set or holds a different branch.

pub fn set_task_restart_policy<T: Into<Box<TaskRetryPolicy>>>( self, v: T, ) -> Self

Sets the value of restart_policy to hold a TaskRestartPolicy.

Note that all the setters affecting restart_policy are mutually exclusive.

Trait Implementations

impl Clone for Connector

fn clone(&self) -> Connector

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Connector

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

Formats the value using the given formatter.

impl Default for Connector

fn default() -> Connector

Returns the “default value” for a type.

impl Message for Connector

fn typename() -> &'static str

The typename of this message.

impl PartialEq for Connector

fn eq(&self, other: &Connector) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for Connector