Struct EsSyncManager 

pub struct EsSyncManager { /* private fields */ }

Implementations

impl EsSyncManager

pub fn new() -> Self

创建默认 Manager（使用 Mock 后端，仅供测试）。

⚠️ 生产环境请使用 EsSyncManager::with_backend 注入真实 ES 客户端实现。

pub fn with_backend(backend: Box<dyn EsSync>) -> Self

使用指定后端创建 Manager（用于注入真实 ES 客户端）。

示例

use sz_orm_es::{EsSyncManager, EsSync};

struct RealEsClient { /* elasticsearch::http::transport::Transport */ }
impl EsSync for RealEsClient { /* ... */ }

let manager = EsSyncManager::with_backend(Box::new(RealEsClient { /* ... */ }));

pub fn create_index( &mut self, index: impl Into<String>, mapping: HashMap<String, EsFieldType>, )

pub fn get_mapping(&self, index: &str) -> Option<&HashMap<String, EsFieldType>>

pub fn sync_to_es( &self, documents: Vec<EsDocument>, ) -> Result<EsSyncResult, EsError>

pub fn delete_from_es( &self, index: &str, ids: Vec<String>, ) -> Result<EsSyncResult, EsError>

pub fn search( &self, request: EsSearchRequest, ) -> Result<EsSearchResult, EsError>

pub fn count(&self, index: &str) -> Result<usize, EsError>

Returns the total number of documents stored in index.

⚠️ 仅在默认 new() 构造（Mock 后端）时可用；使用 with_backend 注入自定义后端时返回 EsError::BackendNotSupported。

Trait Implementations

impl Default for EsSyncManager

fn default() -> Self

Returns the “default value” for a type.