Searched defs:Acker (Results 1 – 10 of 10) sorted by relevance
| /dports/sysutils/vector/vector-0.10.0/src/buffers/ |
| H A D | mod.rs | 100 Acker, in build() argument
136 pub enum Acker { enum
141 impl Acker { impl
|
| /dports/sysutils/vector/vector-0.10.0/src/buffers/disk/ |
| H A D | mod.rs | 36 ) -> Result<(Self::Writer, Self::Reader, super::Acker), Error>; in build()
68 super::Acker, in open()
|
| H A D | leveldb_buffer.rs | 260 fn build(path: PathBuf, max_size: usize) -> Result<(Self::Writer, Self::Reader, Acker), Error> { in build() argument
|
| /dports/net/jgroups/jgroups-2.12.0/tests/junit-functional/org/jgroups/tests/ |
| H A D | AckMcastSenderWindowTest.java | 149 private class Acker extends Thread { class in AckMcastSenderWindowTest
|
| /dports/sysutils/vector/vector-0.10.0/src/sinks/util/ |
| H A D | http.rs | 88 acker: Acker, in new()
116 acker: Acker, in with_retry_logic()
|
| H A D | service2.rs | 128 acker: Acker, in batch_sink()
|
| H A D | sink.rs | 169 pub fn with_executor(service: S, batch: B, timeout: Duration, acker: Acker, exec: E) -> Self { in with_executor()
369 pub fn with_executor(service: S, batch: B, timeout: Duration, acker: Acker, exec: E) -> Self { in with_executor()
|
| H A D | service.rs | 128 acker: Acker, in batch_sink()
|
| /dports/sysutils/vector/vector-0.10.0/src/sinks/ |
| H A D | pulsar.rs | 117 acker: Acker, in new_sink()
|
| /dports/sysutils/vector/vector-0.10.0/src/topology/config/ |
| H A D | mod.rs | 187 pub fn acker(&self) -> Acker { in acker()
|