Struct rlink_connector_elasticsearch::elasticsearch_sink::ElasticsearchWriteThread [−][src]
pub struct ElasticsearchWriteThread { /* fields omitted */ }
Implementations
impl ElasticsearchWriteThread
[src]
impl ElasticsearchWriteThread
[src]pub fn new(
address: &str,
headers: HashMap<String, String>,
handover: Handover,
batch_size: usize
) -> Result<Self, Box<dyn Error>>
[src]
address: &str,
headers: HashMap<String, String>,
handover: Handover,
batch_size: usize
) -> Result<Self, Box<dyn Error>>
pub async fn run(
&mut self,
converters: Arc<Box<dyn ElasticsearchConverter>>,
parallelism: usize
)
[src]
&mut self,
converters: Arc<Box<dyn ElasticsearchConverter>>,
parallelism: usize
)
pub async fn run0(&mut self, converter: Arc<Box<dyn ElasticsearchConverter>>)
[src]
Trait Implementations
impl Clone for ElasticsearchWriteThread
[src]
impl Clone for ElasticsearchWriteThread
[src]fn clone(&self) -> ElasticsearchWriteThread
[src]
pub fn clone_from(&mut self, source: &Self)
1.0.0[src]
Auto Trait Implementations
impl !RefUnwindSafe for ElasticsearchWriteThread
impl !RefUnwindSafe for ElasticsearchWriteThread
impl Send for ElasticsearchWriteThread
impl Send for ElasticsearchWriteThread
impl Sync for ElasticsearchWriteThread
impl Sync for ElasticsearchWriteThread
impl Unpin for ElasticsearchWriteThread
impl Unpin for ElasticsearchWriteThread
impl !UnwindSafe for ElasticsearchWriteThread
impl !UnwindSafe for ElasticsearchWriteThread
Blanket Implementations
impl<T> CloneAny for T where
T: Any + Clone,
impl<T> CloneAny for T where
T: Any + Clone,
pub fn clone_any(&self) -> Box<dyn CloneAny + 'static, Global>
pub fn clone_any_send(&self) -> Box<dyn CloneAny + 'static + Send, Global> where
T: Send,
T: Send,
pub fn clone_any_sync(&self) -> Box<dyn CloneAny + 'static + Sync, Global> where
T: Sync,
T: Sync,
pub fn clone_any_send_sync(
&self
) -> Box<dyn CloneAny + 'static + Sync + Send, Global> where
T: Send + Sync,
&self
) -> Box<dyn CloneAny + 'static + Sync + Send, Global> where
T: Send + Sync,
impl<T> Instrument for T
[src]
impl<T> Instrument for T
[src]pub fn instrument(self, span: Span) -> Instrumented<Self>
[src]
pub fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T> Same<T> for T
impl<T> Same<T> for T
type Output = T
Should always be Self
impl<T> UnsafeAny for T where
T: Any,
impl<T> UnsafeAny for T where
T: Any,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,