Module vector::test_util

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_string
• 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