Struct ElasticSearchOpenSearchConfig

pub struct ElasticSearchOpenSearchConfig {
    pub url: String,
    pub index: Option<String>,
    pub delimiter: Option<String>,
    pub username: String,
    pub password: String,
    pub index_column: Option<String>,
    pub routing_column: Option<String>,
    pub retry_on_conflict: i32,
    pub batch_num_messages: usize,
    pub batch_size_kb: usize,
    pub concurrent_requests: usize,
}

Fields

url: String

index: Option<String>

The index’s name of elasticsearch or openserach

delimiter: Option<String>

If pk is set, then “pk1+delimiter+pk2+delimiter…” will be used as the key, if pk is not set, we will just use the first column as the key.

username: String

The username of elasticsearch or openserach

password: String

The username of elasticsearch or openserach

index_column: Option<String>

It is used for dynamic index, if it is be set, the value of this column will be used as the index. It and index can only set one

routing_column: Option<String>

It is used for dynamic route, if it is be set, the value of this column will be used as the route

retry_on_conflict: i32

batch_num_messages: usize

batch_size_kb: usize

concurrent_requests: usize

Implementations

impl ElasticSearchOpenSearchConfig

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

pub fn build_client( &self, connector: &str, ) -> Result<ElasticSearchOpenSearchClient>

pub fn validate_config(&self, schema: &Schema) -> Result<()>

pub fn get_index_column_index(&self, schema: &Schema) -> Result<Option<usize>>

pub fn get_routing_column_index(&self, schema: &Schema) -> Result<Option<usize>>

Trait Implementations

impl Clone for ElasticSearchOpenSearchConfig

fn clone(&self) -> ElasticSearchOpenSearchConfig

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ElasticSearchOpenSearchConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ElasticSearchOpenSearchConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl WithOptions for ElasticSearchOpenSearchConfig