Modules§
Structs§
Functions§
- collect_
limited - collect_
n - collect_
n_ limited - collect_
n_ stream - collect_
ready - create_
events_ batch_ with_ fn - generate_
events_ with_ stream - generate_
lines_ with_ stream - lines_
from_ file - lines_
from_ gzip_ file - map_
event_ batch_ stream - next_
addr - next_
addr_ any - next_
addr_ for_ ip - next_
addr_ v6 - open_
fixture - random_
events_ with_ stream - random_
lines - random_
lines_ with_ stream - random_
map - random_
maps - random_
metrics_ with_ stream - random_
metrics_ with_ stream_ timestamp - Generates event metrics with the provided tags and timestamp.
- random_
string - random_
table_ name - random_
updated_ events_ with_ stream - retry_
until - runtime
- send_
encodable - send_
lines - send_
lines_ tls - spawn_
collect_ n - Collect the first
nevents from a stream while a future is spawned in the background. This is used for tests where the collect has to happen concurrent with the sending process (ie the stream is handling finalization, which is required for the future to receive an acknowledgement). - spawn_
collect_ ready - Collect all the ready events from a stream after spawning a future in the background and letting it run for a given interval. This is used for tests where the collect has to happen concurrent with the sending process (ie the stream is handling finalization, which is required for the future to receive an acknowledgement).
- start_
topology - temp_
dir - temp_
file - test_
generate_ config - trace_
init - wait_
for - wait_
for_ atomic_ usize - wait_
for_ duration - wait_
for_ tcp - wait_
for_ tcp_ duration