Searched refs:HttpBatchService (Results 1 – 2 of 2) sorted by relevance
| /dports/sysutils/vector/vector-0.10.0/src/sinks/util/ |
| H A D | http.rs | 65 HttpBatchService<BoxFuture<'static, crate::Result<hyper::Request<Vec<u8>>>>, B::Output>,
127 let svc = HttpBatchService::new(client, request_builder); in with_retry_logic()
287 pub struct HttpBatchService<F, B = Vec<u8>> { struct
292 impl<F, B> HttpBatchService<F, B> { argument
297 HttpBatchService { in new()
304 impl<F, B> Service<B> for HttpBatchService<F, B> implementation
331 impl<F, B> Clone for HttpBatchService<F, B> { implementation
441 let mut service = HttpBatchService::new(client, move |body: Vec<u8>| { in util_http_it_makes_http_requests()
|
| /dports/sysutils/vector/vector-0.10.0/src/sinks/influxdb/ |
| H A D | metrics.rs | 8 http::{HttpBatchService, HttpClient, HttpRetryLogic},
27 inner: HttpBatchService<BoxFuture<'static, crate::Result<hyper::Request<Vec<u8>>>>>,
109 let http_service = HttpBatchService::new(client, create_build_request(uri, token)); in new()
|