Module test_util

Modules

• compression

Structs

• CountReceiver

Functions

• collect_limited
• collect_n
• collect_n_limited
• collect_n_stream
• collect_ready
• generate_events_with_stream
• generate_lines_with_stream
• lines_from_file
• lines_from_gzip_file
• map_event_batch_stream
• next_addr
• 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 n events 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