Struct MongodbConfig 

pub struct MongodbConfig {
    pub common: MongodbCommon,
    pub type: String,
    pub collection_name_field: Option<String>,
    pub drop_collection_name_field: bool,
    pub bulk_write_max_entries: usize,
}

Fields

common: MongodbCommon

type: String

collection_name_field: Option<String>

The dynamic collection name where data should be sunk to. If specified, the field value will be used as the collection name. The collection name format is same as collection.name. If the field value is null or an empty string, then the collection.name will be used as a fallback destination.

drop_collection_name_field: bool

Controls whether the field value of collection.name.field should be dropped when sinking. Set this option to true to avoid the duplicate values of collection.name.field being written to the result collection.

bulk_write_max_entries: usize

👎Deprecated

The maximum entries will accumulate before performing the bulk write, defaults to 1024.

Implementations

impl MongodbConfig

pub fn from_btreemap(properties: BTreeMap<String, String>) -> Result<Self>

Trait Implementations

impl Clone for MongodbConfig

fn clone(&self) -> MongodbConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MongodbConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for MongodbConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl EnforceSecret for MongodbConfig

fn enforce_one(prop: &str) -> ConnectorResult<()>

const ENFORCE_SECRET_PROPERTIES: Set<&'static str> = _

fn enforce_secret<'a>(prop_iter: impl Iterator<Item = &'a str>) -> Result<()>

impl WithOptions for MongodbConfig