Lines Matching +defs:source +defs:dir

490         let dir = tempdir().unwrap();  in file_happy_path()  localVariable
496 let source = file::file_source(&config, config.data_dir.clone().unwrap(), shutdown, tx); in file_happy_path() localVariable
552 let dir = tempdir().unwrap(); in file_truncate() localVariable
557 let source = file::file_source(&config, config.data_dir.clone().unwrap(), shutdown, tx); in file_truncate() localVariable
621 let dir = tempdir().unwrap(); in file_rotate() localVariable
626 let source = file::file_source(&config, config.data_dir.clone().unwrap(), shutdown, tx); in file_rotate() localVariable
691 let dir = tempdir().unwrap(); in file_multiple_paths() localVariable
698 let source = file::file_source(&config, config.data_dir.clone().unwrap(), shutdown, tx); in file_multiple_paths() localVariable
754 let dir = tempdir().unwrap(); in file_file_key() localVariable
760 let source = file::file_source(&config, config.data_dir.clone().unwrap(), shutdown, tx); in file_file_key() localVariable
788 let dir = tempdir().unwrap(); in file_file_key() localVariable
795 let source = file::file_source(&config, config.data_dir.clone().unwrap(), shutdown, tx); in file_file_key() localVariable
823 let dir = tempdir().unwrap(); in file_file_key() localVariable
830 let source = file::file_source(&config, config.data_dir.clone().unwrap(), shutdown, tx); in file_file_key() localVariable
865 let dir = tempdir().unwrap(); in file_start_position_server_restart() localVariable
881 let source = file::file_source(&config, config.data_dir.clone().unwrap(), shutdown, tx); in file_start_position_server_restart() localVariable
904 let source = file::file_source(&config, config.data_dir.clone().unwrap(), shutdown, tx); in file_start_position_server_restart() localVariable
932 let source = file::file_source(&config, config.data_dir.clone().unwrap(), shutdown, tx); in file_start_position_server_restart() localVariable
956 let dir = tempdir().unwrap(); in file_start_position_server_restart_with_file_rotation() localVariable
969 let source = file::file_source(&config, config.data_dir.clone().unwrap(), shutdown, tx); in file_start_position_server_restart_with_file_rotation() localVariable
996 let source = file::file_source(&config, config.data_dir.clone().unwrap(), shutdown, tx); in file_start_position_server_restart_with_file_rotation() localVariable
1026 let dir = tempdir().unwrap(); in file_start_position_ignore_old_files() localVariable
1034 let source = file::file_source(&config, config.data_dir.clone().unwrap(), shutdown, tx); in file_start_position_ignore_old_files() localVariable
1112 let dir = tempdir().unwrap(); in file_max_line_bytes() localVariable
1119 let source = file::file_source(&config, config.data_dir.clone().unwrap(), shutdown, tx); in file_max_line_bytes() localVariable
1172 let dir = tempdir().unwrap(); in test_multi_line_aggregation_legacy() localVariable
1180 let source = file::file_source(&config, config.data_dir.clone().unwrap(), shutdown, tx); in test_multi_line_aggregation_legacy() localVariable
1245 let dir = tempdir().unwrap(); in test_multi_line_aggregation() localVariable
1257 let source = file::file_source(&config, config.data_dir.clone().unwrap(), shutdown, tx); in test_multi_line_aggregation() localVariable
1322 let dir = tempdir().unwrap(); in test_fair_reads() localVariable
1349 let source = file::file_source(&config, config.data_dir.clone().unwrap(), shutdown, tx); in test_fair_reads() localVariable
1387 let dir = tempdir().unwrap(); in test_oldest_first() localVariable
1414 let source = file::file_source(&config, config.data_dir.clone().unwrap(), shutdown, tx); in test_oldest_first() localVariable
1452 let dir = tempdir().unwrap(); in test_gzipped_file() localVariable
1458 let source = file::file_source(&config, config.data_dir.clone().unwrap(), shutdown, tx); in test_gzipped_file() localVariable
1499 let dir = tempdir().unwrap(); in remove_file() localVariable
1506 let source = file::file_source(&config, config.data_dir.clone().unwrap(), shutdown, tx); in remove_file() localVariable