Path	Lines of Code
ingestion-beam/src/test/java/com/mozilla/telemetry/AmplitudePublisherTest.java	12
ingestion-beam/src/test/java/com/mozilla/telemetry/DecoderMainTest.java	137
ingestion-beam/src/test/java/com/mozilla/telemetry/FileWindowingTest.java	95
ingestion-beam/src/test/java/com/mozilla/telemetry/RepublisherMainTest.java	113
ingestion-beam/src/test/java/com/mozilla/telemetry/SinkAvroTest.java	152
ingestion-beam/src/test/java/com/mozilla/telemetry/SinkMainTest.java	118
ingestion-beam/src/test/java/com/mozilla/telemetry/amplitude/AmplitudeEventTest.java	41
ingestion-beam/src/test/java/com/mozilla/telemetry/amplitude/FilterByDocTypeTest.java	48
ingestion-beam/src/test/java/com/mozilla/telemetry/amplitude/ParseAmplitudeEventsTest.java	255
ingestion-beam/src/test/java/com/mozilla/telemetry/amplitude/SendRequestTest.java	121
ingestion-beam/src/test/java/com/mozilla/telemetry/avro/PubsubMessageRecordFormatterTest.java	281
ingestion-beam/src/test/java/com/mozilla/telemetry/contextualservices/AggregateImpressionsTest.java	102
ingestion-beam/src/test/java/com/mozilla/telemetry/contextualservices/BuildReportingUrlTest.java	10
ingestion-beam/src/test/java/com/mozilla/telemetry/contextualservices/FilterByDocTypeTest.java	88
ingestion-beam/src/test/java/com/mozilla/telemetry/contextualservices/LabelSpikesTest.java	166
ingestion-beam/src/test/java/com/mozilla/telemetry/contextualservices/ParseReportingUrlTest.java	854
ingestion-beam/src/test/java/com/mozilla/telemetry/contextualservices/SendRequestTest.java	105
ingestion-beam/src/test/java/com/mozilla/telemetry/contextualservices/VerifyMetadataTest.java	145
ingestion-beam/src/test/java/com/mozilla/telemetry/decoder/AddMetadataTest.java	59
ingestion-beam/src/test/java/com/mozilla/telemetry/decoder/GeoCityLookupTest.java	138
ingestion-beam/src/test/java/com/mozilla/telemetry/decoder/GeoIspLookupTest.java	73
ingestion-beam/src/test/java/com/mozilla/telemetry/decoder/MessageScrubberTest.java	657
ingestion-beam/src/test/java/com/mozilla/telemetry/decoder/ParseLogEntryTest.java	72
ingestion-beam/src/test/java/com/mozilla/telemetry/decoder/ParsePayloadTest.java	294
ingestion-beam/src/test/java/com/mozilla/telemetry/decoder/ParseProxyTest.java	95
ingestion-beam/src/test/java/com/mozilla/telemetry/decoder/ParseUriTest.java	383
ingestion-beam/src/test/java/com/mozilla/telemetry/decoder/ParseUserAgentTest.java	147
ingestion-beam/src/test/java/com/mozilla/telemetry/decoder/SanitizeAttributesTest.java	83
ingestion-beam/src/test/java/com/mozilla/telemetry/decoder/ipprivacy/HashClientInfoTest.java	51
ingestion-beam/src/test/java/com/mozilla/telemetry/decoder/ipprivacy/ParseIpTest.java	30
ingestion-beam/src/test/java/com/mozilla/telemetry/decoder/ipprivacy/TestRemoveAttributes.java	33
ingestion-beam/src/test/java/com/mozilla/telemetry/integration/BeamDependenciesIntegrationTest.java	59
ingestion-beam/src/test/java/com/mozilla/telemetry/integration/BigQueryIntegrationTest.java	408
ingestion-beam/src/test/java/com/mozilla/telemetry/integration/PubsubIntegrationTest.java	170
ingestion-beam/src/test/java/com/mozilla/telemetry/integration/PubsubLiteIntegrationTest.java	164
ingestion-beam/src/test/java/com/mozilla/telemetry/integration/StorageIntegrationTest.java	85
ingestion-beam/src/test/java/com/mozilla/telemetry/matchers/Lines.java	43
ingestion-beam/src/test/java/com/mozilla/telemetry/metrics/KeyedCounterTest.java	11
ingestion-beam/src/test/java/com/mozilla/telemetry/metrics/PerDocTypeCounterTest.java	29
ingestion-beam/src/test/java/com/mozilla/telemetry/options/ErrorOutputTypeTest.java	27
ingestion-beam/src/test/java/com/mozilla/telemetry/options/OutputFileFormatTest.java	28
ingestion-beam/src/test/java/com/mozilla/telemetry/republisher/RandomSamplerTest.java	24
ingestion-beam/src/test/java/com/mozilla/telemetry/transforms/CompressPayloadTest.java	29
ingestion-beam/src/test/java/com/mozilla/telemetry/transforms/DecodePubsubMessagesTest.java	49
ingestion-beam/src/test/java/com/mozilla/telemetry/transforms/DecompressPayloadTest.java	48
ingestion-beam/src/test/java/com/mozilla/telemetry/transforms/LimitPayloadSizeTest.java	39
ingestion-beam/src/test/java/com/mozilla/telemetry/transforms/PubsubConstraintsTest.java	78
ingestion-beam/src/test/java/com/mozilla/telemetry/transforms/PubsubLiteCompatTest.java	94
ingestion-beam/src/test/java/com/mozilla/telemetry/transforms/WithCurrentTimestampTest.java	15
ingestion-beam/src/test/java/com/mozilla/telemetry/util/DynamicPathTemplateTest.java	86
ingestion-beam/src/test/java/com/mozilla/telemetry/util/JsonTest.java	45
ingestion-beam/src/test/java/com/mozilla/telemetry/util/NormalizeAttributesTest.java	76
ingestion-beam/src/test/java/com/mozilla/telemetry/util/TestWithDeterministicJson.java	24
ingestion-beam/src/test/java/com/mozilla/telemetry/util/TimeTest.java	52
ingestion-beam/src/test/resources/jwe.py	38
ingestion-core/src/test/java/com/mozilla/telemetry/ingestion/core/schema/AvroSchemaStoreTest.java	42
ingestion-core/src/test/java/com/mozilla/telemetry/ingestion/core/schema/JSONSchemaStoreTest.java	52
ingestion-core/src/test/java/com/mozilla/telemetry/ingestion/core/schema/PipelineMetadataStoreTest.java	43
ingestion-core/src/test/java/com/mozilla/telemetry/ingestion/core/schema/TestConstant.java	6
ingestion-core/src/test/java/com/mozilla/telemetry/ingestion/core/transform/NestedMetadataTest.java	189
ingestion-core/src/test/java/com/mozilla/telemetry/ingestion/core/transform/PubsubMessageToObjectNodeBeamTest.java	643
ingestion-core/src/test/java/com/mozilla/telemetry/ingestion/core/transform/PubsubMessageToObjectNodeSinkTest.java	220
ingestion-core/src/test/java/com/mozilla/telemetry/ingestion/core/util/DerivedAttributesMapTest.java	67
ingestion-core/src/test/java/com/mozilla/telemetry/ingestion/core/util/IOFunctionTest.java	24
ingestion-core/src/test/java/com/mozilla/telemetry/ingestion/core/util/JsonTest.java	85
ingestion-core/src/test/java/com/mozilla/telemetry/ingestion/core/util/SnakeCaseTest.java	44
ingestion-core/src/test/resources/schema/test-schemas/assembly.xml	16
ingestion-edge/tests/__init__.py	1
ingestion-edge/tests/flush_manager/__init__.py	1
ingestion-edge/tests/flush_manager/conftest.py	234
ingestion-edge/tests/flush_manager/test_flush_manager.py	147
ingestion-edge/tests/integration/__init__.py	1
ingestion-edge/tests/integration/conftest.py	109
ingestion-edge/tests/integration/publish/__init__.py	1
ingestion-edge/tests/integration/publish/conftest.py	62
ingestion-edge/tests/integration/publish/helpers.py	108
ingestion-edge/tests/integration/publish/test_flush.py	46
ingestion-edge/tests/integration/publish/test_healthy.py	107
ingestion-edge/tests/integration/publish/test_misconfigured.py	36
ingestion-edge/tests/integration/publish/test_pubsub_failure.py	31
ingestion-edge/tests/integration/test_dockerflow.py	17
ingestion-edge/tests/integration/test_pubsub_emulator.py	43
ingestion-edge/tests/load/conftest.py	272
ingestion-edge/tests/load/test_throughput.py	59
ingestion-edge/tests/load/wrk/telemetry.lua	6
ingestion-edge/tests/unit/__init__.py	1
ingestion-edge/tests/unit/conftest.py	32
ingestion-edge/tests/unit/dockerflow/__init__.py	1
ingestion-edge/tests/unit/dockerflow/test_check_disk_bytes_free.py	73
ingestion-edge/tests/unit/dockerflow/test_check_queue_size.py	33
ingestion-edge/tests/unit/dockerflow/test_init_app.py	30
ingestion-edge/tests/unit/flush/__init__.py	1
ingestion-edge/tests/unit/flush/test_flush.py	90
ingestion-edge/tests/unit/flush/test_init_app.py	27
ingestion-edge/tests/unit/flush_manager/__init__.py	1
ingestion-edge/tests/unit/flush_manager/conftest.py	9
ingestion-edge/tests/unit/flush_manager/test_create_job.py	197
ingestion-edge/tests/unit/flush_manager/test_delete_complete.py	110
ingestion-edge/tests/unit/flush_manager/test_delete_detached.py	149
ingestion-edge/tests/unit/flush_manager/test_delete_unschedulable.py	87
ingestion-edge/tests/unit/flush_manager/test_main.py	33
ingestion-edge/tests/unit/publish/__init__.py	1
ingestion-edge/tests/unit/publish/test_init_app.py	24
ingestion-edge/tests/unit/publish/test_submit.py	92
ingestion-edge/tests/unit/test_util.py	8
ingestion-edge/tests/unit/test_wsgi.py	12
ingestion-sink/src/test/java/com/mozilla/telemetry/ingestion/sink/LoggingTest.java	34
ingestion-sink/src/test/java/com/mozilla/telemetry/ingestion/sink/SinkBigQueryIntegrationTest.java	201
ingestion-sink/src/test/java/com/mozilla/telemetry/ingestion/sink/SinkGcsIntegrationTest.java	81
ingestion-sink/src/test/java/com/mozilla/telemetry/ingestion/sink/SinkPipeTest.java	110
ingestion-sink/src/test/java/com/mozilla/telemetry/ingestion/sink/SinkPubsubIntegrationTest.java	63
ingestion-sink/src/test/java/com/mozilla/telemetry/ingestion/sink/SinkPubsubLiteIntegrationTest.java	96
ingestion-sink/src/test/java/com/mozilla/telemetry/ingestion/sink/SinkTest.java	53
ingestion-sink/src/test/java/com/mozilla/telemetry/ingestion/sink/config/SinkConfigTest.java	20
ingestion-sink/src/test/java/com/mozilla/telemetry/ingestion/sink/io/BigQueryLoadTest.java	77
ingestion-sink/src/test/java/com/mozilla/telemetry/ingestion/sink/io/BigQueryWriteTest.java	168
ingestion-sink/src/test/java/com/mozilla/telemetry/ingestion/sink/io/GcsWriteTest.java	94
ingestion-sink/src/test/java/com/mozilla/telemetry/ingestion/sink/io/PipeTest.java	14
ingestion-sink/src/test/java/com/mozilla/telemetry/ingestion/sink/io/PubsubLiteReadTest.java	72
ingestion-sink/src/test/java/com/mozilla/telemetry/ingestion/sink/io/PubsubReadIntegrationTest.java	120
ingestion-sink/src/test/java/com/mozilla/telemetry/ingestion/sink/io/PubsubWriteIntegrationTest.java	36
ingestion-sink/src/test/java/com/mozilla/telemetry/ingestion/sink/io/WriteWithErrorsTest.java	28
ingestion-sink/src/test/java/com/mozilla/telemetry/ingestion/sink/transform/CompressPayloadTest.java	41
ingestion-sink/src/test/java/com/mozilla/telemetry/ingestion/sink/transform/DecompressPayloadTest.java	43
ingestion-sink/src/test/java/com/mozilla/telemetry/ingestion/sink/transform/PubsubMessageToTemplatedStringTest.java	26
ingestion-sink/src/test/java/com/mozilla/telemetry/ingestion/sink/util/BatchWriteTest.java	59
ingestion-sink/src/test/java/com/mozilla/telemetry/ingestion/sink/util/BigQueryDataset.java	23
ingestion-sink/src/test/java/com/mozilla/telemetry/ingestion/sink/util/BoundedSink.java	35
ingestion-sink/src/test/java/com/mozilla/telemetry/ingestion/sink/util/EnvTest.java	38
ingestion-sink/src/test/java/com/mozilla/telemetry/ingestion/sink/util/GcsBucket.java	21
ingestion-sink/src/test/java/com/mozilla/telemetry/ingestion/sink/util/PubsubTopics.java	147
ingestion-sink/src/test/java/com/mozilla/telemetry/ingestion/sink/util/SinglePubsubTopic.java	20
ingestion-sink/src/test/resources/log4j2-list.yaml	13