| /dports/sysutils/vector/vector-0.10.0/src/buffers/ |
| H A D | mod.rs | 100 Acker, in build() argument
112 Ok((tx, rx, Acker::Null)) in build()
136 pub enum Acker { enum
141 impl Acker { impl
152 Acker::Null => {} in ack()
153 Acker::Disk(counter, notifier) => { in ack()
164 let acker = Acker::Disk(Arc::clone(&ack_counter), Arc::clone(¬ifier)); in new_for_testing()
198 use super::{Acker, BufferConfig, DropWhenFull, WhenFull};
230 let acker = Acker::Disk(counter, task.clone()); in ack_with_none()
|
| /dports/sysutils/vector/vector-0.10.0/src/sinks/ |
| H A D | blackhole.rs | 2 buffers::Acker,
15 acker: Acker,
50 pub fn new(config: BlackholeConfig, acker: Acker) -> Self { in new()
100 use crate::buffers::Acker;
106 let sink = BlackholeSink::new(config, Acker::Null); in blackhole()
|
| H A D | pulsar.rs | 2 buffers::Acker,
58 acker: Acker,
117 acker: Acker, in new_sink() argument
264 let (acker, ack_counter) = Acker::new_for_testing(); in pulsar_happy()
|
| H A D | kafka.rs | 2 buffers::Acker,
76 acker: Acker,
125 fn new(config: KafkaSinkConfig, acker: Acker) -> crate::Result<Self> { in new()
326 buffers::Acker,
460 let (acker, ack_counter) = Acker::new_for_testing(); in kafka_happy_path()
|
| H A D | statsd.rs | 2 buffers::Acker,
85 pub fn new(config: StatsdSinkConfig, acker: Acker) -> crate::Result<super::RouterSink> { in new()
225 buffers::Acker,
343 let sink = StatsdSvc::new(config, Acker::Null).unwrap(); in test_send_to_statsd()
|
| H A D | prometheus.rs | 2 buffers::Acker,
96 acker: Acker,
316 fn new(config: PrometheusSinkConfig, acker: Acker) -> Self { in new()
|
| /dports/sysutils/vector/vector-0.10.0/src/sinks/util/ |
| H A D | sink.rs | 37 use crate::buffers::Acker;
71 acker: Acker,
76 pub fn new(inner: T, acker: Acker) -> Self { in new()
635 acker: Acker,
650 fn new(service: S, acker: Acker) -> Self { in new()
769 use crate::buffers::Acker;
911 let (acker, _) = Acker::new_for_testing(); in batch_sink_buffers_messages_until_limit()
953 let (acker, _) = Acker::new_for_testing(); in batch_sink_flushes_below_min_on_close()
987 let (acker, _) = Acker::new_for_testing(); in batch_sink_expired_linger()
1022 let (acker, _) = Acker::new_for_testing(); in partition_batch_sink_buffers_messages_until_limit()
[all …]
|
| H A D | http.rs | 7 buffers::Acker,
88 acker: Acker, in new() argument
116 acker: Acker, in with_retry_logic() argument
|
| H A D | service2.rs | 4 use crate::buffers::Acker;
128 acker: Acker, in batch_sink() argument
|
| H A D | service.rs | 6 use crate::buffers::Acker;
128 acker: Acker, in batch_sink() argument
|
| /dports/sysutils/vector/vector-0.10.0/benches/ |
| H A D | batch.rs | 6 use vector::buffers::Acker;
30 let (acker, _) = Acker::new_for_testing(); in batching()
75 let (acker, _) = Acker::new_for_testing(); in partitioned_batching()
|
| /dports/net/jgroups/jgroups-2.12.0/tests/junit-functional/org/jgroups/tests/ |
| H A D | AckMcastSenderWindowTest.java | 84 Acker acker=new Acker(); in test1()
149 private class Acker extends Thread { class in AckMcastSenderWindowTest
|
| /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() argument
68 super::Acker, in open() argument
|
| H A D | leveldb_buffer.rs | 28 use crate::buffers::Acker;
260 fn build(path: PathBuf, max_size: usize) -> Result<(Self::Writer, Self::Reader, Acker), Error> { in build() argument
287 let acker = Acker::Disk(Arc::clone(&ack_counter), Arc::clone(&write_notifier)); in build()
|
| /dports/sysutils/vector/vector-0.10.0/src/topology/config/ |
| H A D | mod.rs | 2 buffers::Acker,
174 pub(super) acker: Acker,
182 acker: Acker::Null, in new_test()
187 pub fn acker(&self) -> Acker { in acker() argument
|
| /dports/sysutils/vector/vector-0.10.0/src/sinks/util/buffer/ |
| H A D | mod.rs | 163 use crate::buffers::Acker;
179 let (acker, _) = Acker::new_for_testing(); in gzip()
|
| H A D | metrics.rs | 275 buffers::Acker,
309 let (acker, _) = Acker::new_for_testing(); in sink()
|
| /dports/net/socat/socat-1.7.4.2/ |
| H A D | README.FIPS | 2 David Acker has patched socat to add OpenSSL FIPS.
|
| /dports/databases/cayley/cayley-0.7.5-2-gcf576ba/vendor/github.com/jackc/fake/data/en/ |
| H A D | streets | 10 Acker
|
| /dports/security/makepasswd/makepasswd-1.10/debian/ |
| H A D | changelog | 34 (thanks, Steven Van Acker; LP: #894739).
|
| /dports/multimedia/libv4l/linux-5.13-rc2/Documentation/translations/zh_CN/process/ |
| H A D | submitting-patches.rst | 419 因此，补丁合并有时会手动将Acker的“Yep，looks good to me”转换为 Acked-By：（但
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/Documentation/translations/zh_CN/process/ |
| H A D | submitting-patches.rst | 419 因此，补丁合并有时会手动将Acker的“Yep，looks good to me”转换为 Acked-By：（但
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/Documentation/translations/zh_CN/process/ |
| H A D | submitting-patches.rst | 419 因此，补丁合并有时会手动将Acker的“Yep，looks good to me”转换为 Acked-By：（但
|
| /dports/irc/inspircd/inspircd-3.11.0/make/template/ |
| H A D | inspircd | 6 # Copyright (C) 2015 Steven Van Acker <steven@singularity.be>
|
| /dports/security/webfwlog/webfwlog-1.1.1/ |
| H A D | ChangeLog | 201 - Allow override of data source at runtime (suggested by Steven Van Acker).
|