.editorconfig
.gitignore
.golangci.yml
.mockery.yaml
README.md
debian.txt
docker-compose.yaml
go.mod
go.sum
license.md
pipeline-mirror.yaml
pipeline.yaml
pyproject.toml
requirements.txt
requirements_tests.txt
setup.py
test_integration.sh
tox.ini
.github/CODEOWNERS
azul_bedrock/__init__.py
azul_bedrock/dispatcher.py
azul_bedrock/dispatcher_params.py
azul_bedrock/exceptions.py
azul_bedrock/identify.py
azul_bedrock/identify.yaml
azul_bedrock/models_api.py
azul_bedrock/models_auth.py
azul_bedrock/models_network.py
azul_bedrock/models_settings.py
azul_bedrock/trusted_mime.yaml
azul_bedrock/yara_rules.yar
azul_bedrock.egg-info/PKG-INFO
azul_bedrock.egg-info/SOURCES.txt
azul_bedrock.egg-info/dependency_links.txt
azul_bedrock.egg-info/requires.txt
azul_bedrock.egg-info/top_level.txt
azul_bedrock/mock/__init__.py
azul_bedrock/mock/dp.py
azul_bedrock/mock/events.py
azul_bedrock/mock/helper.py
azul_bedrock/mock/state.py
azul_bedrock/mock/streams.py
azul_bedrock/models_restapi/__init__.py
azul_bedrock/models_restapi/basic.py
azul_bedrock/models_restapi/binaries.py
azul_bedrock/models_restapi/binaries_auto_complete.py
azul_bedrock/models_restapi/binaries_data.py
azul_bedrock/models_restapi/features.py
azul_bedrock/models_restapi/plugins.py
azul_bedrock/models_restapi/purge.py
azul_bedrock/models_restapi/sources.py
azul_bedrock/models_restapi/statistics.py
azul_bedrock/test_utils/bucket_storage.py
azul_bedrock/test_utils/errors.py
azul_bedrock/test_utils/file_manager.py
azul_bedrock/test_utils/file_manager_settings.py
docs/go-runner.md
gosrc/embeded_files.go
gosrc/identify.yaml
gosrc/cart/cart.go
gosrc/cart/cart_test.go
gosrc/client/client.go
gosrc/client/client_test.go
gosrc/client/events.go
gosrc/client/interface.go
gosrc/client/mock_ClientInterface.go
gosrc/client/streams.go
gosrc/client/getevents/parameters.go
gosrc/client/postevents/parameters.go
gosrc/client/poststreams/parameters.go
gosrc/events/avro.go
gosrc/events/avro_generate_test.go
gosrc/events/avro_test.go
gosrc/events/benchmark_test.go
gosrc/events/event.go
gosrc/events/event_binary.go
gosrc/events/event_binary_actions.go
gosrc/events/event_binary_datastream_labels.go
gosrc/events/event_binary_feature_types.go
gosrc/events/event_binary_test.go
gosrc/events/event_delete.go
gosrc/events/event_delete_test.go
gosrc/events/event_download.go
gosrc/events/event_download_test.go
gosrc/events/event_insert.go
gosrc/events/event_insert_test.go
gosrc/events/event_models.go
gosrc/events/event_plugin.go
gosrc/events/event_plugin_test.go
gosrc/events/event_retrohunt.go
gosrc/events/event_status.go
gosrc/events/event_status_test.go
gosrc/events/event_status_types.go
gosrc/events/event_status_types_test.go
gosrc/events/event_test.go
gosrc/events/schemas/readme.md
gosrc/events/schemas/v4/0_support.json
gosrc/events/schemas/v4/1_binary.json
gosrc/events/schemas/v4/2_delete.json
gosrc/events/schemas/v4/2_download.json
gosrc/events/schemas/v4/2_insert.json
gosrc/events/schemas/v4/2_plugin.json
gosrc/events/schemas/v4/2_retrohunt.json
gosrc/events/schemas/v4/2_status.json
gosrc/events/schemas/v4/3_collections.json
gosrc/events/schemas/v4/readme.md
gosrc/events/schemas/v5/0_support.json
gosrc/events/schemas/v5/1_binary.json
gosrc/events/schemas/v5/2_delete.json
gosrc/events/schemas/v5/2_download.json
gosrc/events/schemas/v5/2_insert.json
gosrc/events/schemas/v5/2_plugin.json
gosrc/events/schemas/v5/2_retrohunt.json
gosrc/events/schemas/v5/2_status.json
gosrc/events/schemas/v5/3_collections.json
gosrc/events/schemas/v5/readme.md
gosrc/identify/identify.go
gosrc/identify/identify_test.go
gosrc/identify/identify_test.yaml
gosrc/identify/magic.go
gosrc/identify/main_test.go
gosrc/identify/trusted_mime.yaml
gosrc/identify/yara_rules.yar
gosrc/legacy_identify/legacy_mapper.go
gosrc/legacy_identify/legacy_mapper_test.go
gosrc/models/deployed_plugin.go
gosrc/models/restapi.go
gosrc/models/restapi_test.go
gosrc/models/sources.go
gosrc/models/sources_test.go
gosrc/msginflight/conversion_avro.go
gosrc/msginflight/conversion_avro_bulk.go
gosrc/msginflight/conversion_json.go
gosrc/msginflight/msg_in_flight.go
gosrc/msginflight/msg_in_flight_test.go
gosrc/msginflight/test_data_generator.go
gosrc/plugin/error_types.go
gosrc/plugin/job.go
gosrc/plugin/job_event.go
gosrc/plugin/job_event_test.go
gosrc/plugin/job_test.go
gosrc/plugin/logger.go
gosrc/plugin/runner.go
gosrc/plugin/runner_test.go
gosrc/plugin/runner_test_run_test.go
gosrc/plugin/settings.go
gosrc/plugin/settings_test.go
gosrc/plugin/test_generators.go
gosrc/plugin/test_template.go
gosrc/settings/bytes_hook.go
gosrc/settings/bytes_hook_test.go
gosrc/settings/init.go
gosrc/settings/parser.go
gosrc/settings/parser_test.go
gosrc/store/parent_stream_closer.go
gosrc/store/store.go
gosrc/store/store_azure.go
gosrc/store/store_azure_test.go
gosrc/store/store_cache.go
gosrc/store/store_cache_test.go
gosrc/store/store_filesystem.go
gosrc/store/store_filesystem_test.go
gosrc/store/store_interface_tests.go
gosrc/store/store_mem.go
gosrc/store/store_mem_test.go
gosrc/store/store_mock.go
gosrc/store/store_s3.go
gosrc/store/store_s3_auto_ageoff.go
gosrc/store/store_s3_test.go
gosrc/store/store_xor.go
gosrc/store/store_xor_test.go
gosrc/testdata/testdata.go
gosrc/testutils/file_manager.go
gosrc/testutils/file_manager_settings.go
gosrc/testutils/file_manager_test.go
gosrc/testutils/storage_client.go
testdata/cart/README.md
testdata/cart/text-long.txt
testdata/cart/text-long.txt.cart
testdata/cart/text.txt
testdata/cart/text.txt.cart
testdata/events/entityLarge.json
testdata/events/entitySmall.json
testdata/events/sanity.json
testdata/events/api/get_events/valid.events.json
testdata/events/api/get_events/valid.info.json
testdata/events/binary/augmented.json
testdata/events/binary/augmented.json.avro
testdata/events/binary/augmented_no_extra.json
testdata/events/binary/augmented_no_extra.json.avro
testdata/events/binary/bulk.json
testdata/events/binary/bulk.json.avro
testdata/events/binary/enriched.json
testdata/events/binary/enriched.json.avro
testdata/events/binary/enriched_w_data.json
testdata/events/binary/enriched_w_data.json.avro
testdata/events/binary/enriched_w_info_dict.json
testdata/events/binary/enriched_w_info_dict.json.avro
testdata/events/binary/enriched_w_info_list.json
testdata/events/binary/enriched_w_info_list.json.avro
testdata/events/binary/extracted.json
testdata/events/binary/extracted.json.avro
testdata/events/binary/invalid_path.json
testdata/events/binary/invalid_path.json.avro
testdata/events/binary/mapped_w_non_content_data.json
testdata/events/binary/v4/augmented.json
testdata/events/binary/v4/augmented.json.avro
testdata/events/binary/v4/augmented_no_extra.json
testdata/events/binary/v4/augmented_no_extra.json.avro
testdata/events/binary/v4/bulk.json
testdata/events/binary/v4/bulk.json.avro
testdata/events/binary/v4/enriched.json
testdata/events/binary/v4/enriched.json.avro
testdata/events/binary/v4/enriched_w_data.json
testdata/events/binary/v4/enriched_w_data.json.avro
testdata/events/binary/v4/enriched_w_info_dict.json
testdata/events/binary/v4/enriched_w_info_dict.json.avro
testdata/events/binary/v4/enriched_w_info_list.json
testdata/events/binary/v4/enriched_w_info_list.json.avro
testdata/events/binary/v4/extracted.json
testdata/events/binary/v4/extracted.json.avro
testdata/events/binary/v4/invalid_path.json
testdata/events/binary/v4/invalid_path.json.avro
testdata/events/binary/v4/mapped_w_non_content_data.json
testdata/events/delete/author.json
testdata/events/delete/author.json.avro
testdata/events/delete/bulk.json
testdata/events/delete/bulk.json.avro
testdata/events/delete/link.json
testdata/events/delete/link.json.avro
testdata/events/delete/submission-complex.json
testdata/events/delete/submission-complex.json.avro
testdata/events/delete/submission-simple.json
testdata/events/delete/submission-simple.json.avro
testdata/events/delete/v4/author.json
testdata/events/delete/v4/author.json.avro
testdata/events/delete/v4/bulk.json
testdata/events/delete/v4/bulk.json.avro
testdata/events/delete/v4/link.json
testdata/events/delete/v4/link.json.avro
testdata/events/delete/v4/submission-complex.json
testdata/events/delete/v4/submission-complex.json.avro
testdata/events/delete/v4/submission-simple.json
testdata/events/delete/v4/submission-simple.json.avro
testdata/events/download/bulk.json
testdata/events/download/bulk.json.avro
testdata/events/download/example1.json
testdata/events/download/example1.json.avro
testdata/events/download/v4/bulk.json
testdata/events/download/v4/bulk.json.avro
testdata/events/download/v4/example1.json
testdata/events/download/v4/example1.json.avro
testdata/events/insert/bulk.json
testdata/events/insert/bulk.json.avro
testdata/events/insert/example1.json
testdata/events/insert/example1.json.avro
testdata/events/insert/v4/bulk.json
testdata/events/insert/v4/bulk.json.avro
testdata/events/insert/v4/example1.json
testdata/events/insert/v4/example1.json.avro
testdata/events/plugin/bulk.json
testdata/events/plugin/bulk.json.avro
testdata/events/plugin/example1.json
testdata/events/plugin/example1.json.avro
testdata/events/plugin/v4/bulk.json
testdata/events/plugin/v4/bulk.json.avro
testdata/events/plugin/v4/example1.json
testdata/events/plugin/v4/example1.json.avro
testdata/events/retrohunt/bulk.json
testdata/events/retrohunt/bulk.json.avro
testdata/events/retrohunt/example1.json
testdata/events/retrohunt/example1.json.avro
testdata/events/retrohunt/v4/bulk.json
testdata/events/retrohunt/v4/bulk.json.avro
testdata/events/retrohunt/v4/example1.json
testdata/events/retrohunt/v4/example1.json.avro
testdata/events/speed/status.json
testdata/events/speed/status.json.avro
testdata/events/speed/v4/status.json
testdata/events/speed/v4/status.json.avro
testdata/events/status/bulk.json
testdata/events/status/bulk.json.avro
testdata/events/status/example1.json
testdata/events/status/example1.json.avro
testdata/events/status/v4/bulk.json
testdata/events/status/v4/bulk.json.avro
testdata/events/status/v4/example1.json
testdata/events/status/v4/example1.json.avro
testdata/sources/sources1.yaml
testdata/sources/sources_bad_expiry_inner_spaces.yaml
testdata/sources/sources_bad_expiry_no_number.yaml
testdata/sources/sources_bad_expiry_outer_spaces_lead.yaml
testdata/sources/sources_bad_expiry_outer_spaces_trail.yaml
testdata/store/random-long-text-file.txt
tests/__init__.py
tests/integration/__init__.py
tests/integration/test_file_manager.py
tests/unit/__init__.py
tests/unit/identify_test.yaml
tests/unit/test_dispatcher.py
tests/unit/test_exceptions.py
tests/unit/test_identify.py
tests/unit/test_models_api.py
tests/unit/test_models_auth.py
tests/unit/test_models_network.py
tests/unit/test_models_network_comms.py
tests/unit/test_models_settings.py