path	# lines of code
metrics/metrics.go	194
metrics/service.go	162
api/v1/alertrule_types.go	78
api/v1/conditions.go	8
api/v1/adxcluster_types.go	48
api/v1/managementcommand_types.go	43
api/v1/function_types.go	40
api/v1/summaryrule_types.go	123
api/v1/groupversion_info.go	10
api/v1/collector_types.go	26
api/v1/alerter_types.go	26
api/v1/zz_generated.deepcopy.go	686
api/v1/ingestor_types.go	29
kustomize/bases/collectors_crd.yaml	83
kustomize/bases/alerters_crd.yaml	166
kustomize/bases/ingestors_crd.yaml	177
kustomize/bases/alertrules_crd.yaml	82
kustomize/bases/functions_crd.yaml	96
kustomize/bases/managementcommands_crd.yaml	85
kustomize/bases/summaryrules_crd.yaml	97
kustomize/bases/adxclusters_crd.yaml	152
ingestor/service.go	405
ingestor/cluster/fake.go	62
ingestor/cluster/batcher.go	363
ingestor/cluster/replicator.go	162
ingestor/cluster/partition.go	28
ingestor/cluster/coordinator.go	270
ingestor/cluster/health.go	117
ingestor/cluster/rendezvous.go	69
ingestor/cluster/client.go	146
ingestor/adx/fake.go	96
ingestor/adx/dispatcher.go	72
ingestor/adx/tasks.go	360
ingestor/adx/syncer.go	382
ingestor/adx/uploader.go	325
ingestor/runner/shutdown/shutdown.go	61
ingestor/storage/crds.go	117
ingestor/storage/kql_functions.go	111
tools/data/metric.go	179
tools/data/file.go	70
tools/crdgen/main.go	18
tools/cmd/write-load/main.go	206
tools/cmd/data-gen/main.go	58
tools/cmd/walreader/main.go	89
tools/cmd/log-load/main.go	340
tools/docgen/config/config.go	435
transform/fields.go	7
transform/transformer.go	171
transform/native_logs_csv.go	200
transform/metrics_csv.go	160
transform/otlp_logs_csv.go	153
collector/metrics/fake.go	12
collector/metrics/handler.go	125
collector/scraper.go	476
collector/service.go	397
collector/log_collection.go	15
collector/otlp/logs_transfer.go	265
collector/otlp/metrics.go	335
collector/otlp/metrics_transfer.go	161
collector/logs/service.go	48
collector/logs/types/fields.go	15
collector/logs/types/logs.go	198
collector/logs/types/pool.go	14
collector/logs/types/processors.go	19
collector/logs/transforms/transform.go	27
collector/logs/transforms/parser/space.go	22
collector/logs/transforms/parser/klog.go	57
collector/logs/transforms/parser/parser.go	68
collector/logs/transforms/parser/keyvalue.go	123
collector/logs/transforms/parser/json.go	32
collector/logs/transforms/plugin/test-plugin/src/github.com/Azure/testplugin/pkg/transforms/addemoji.go	34
collector/logs/transforms/plugin/test-plugin/src/github.com/Azure/testplugin/pkg/mapping/emoji_mapping.go	10
collector/logs/transforms/plugin/symbols.go	3
collector/logs/transforms/plugin/addattributes/add_attributes.go	43
collector/logs/transforms/plugin/yaegi.go	48
collector/logs/transforms/plugin/github_com-Azure-adx-mon-collector-logs-types.go	81
collector/logs/sources/kernel/kernel.go	209
collector/logs/sources/tail/pod_target.go	174
collector/logs/sources/tail/tailer.go	151
collector/logs/sources/tail/tail.go	197
collector/logs/sources/tail/pod_discovery.go	197
collector/logs/sources/tail/sourceparse/cri.go	55
collector/logs/sources/tail/sourceparse/plaintext.go	12
collector/logs/sources/tail/sourceparse/logtype.go	26
collector/logs/sources/tail/sourceparse/docker.go	60
collector/logs/sources/tail/sourceparse/kubernetes.go	21
collector/logs/sources/tail/sourceparse/docker_ffjson.go	342
collector/logs/sources/journal/tailer_linux.go	203
collector/logs/sources/journal/journal.go	19
collector/logs/sources/journal/cursor.go	56
collector/logs/sources/journal/journal_linux.go	107
collector/logs/sources/journal/types.go	17
collector/logs/sources/const.go	81
collector/logs/engine/worker.go	75
collector/logs/engine/batch.go	48
collector/logs/sinks/stdout.go	27
collector/logs/sinks/counting.go	65
collector/logs/sinks/store.go	34
collector/series.go	27
collector/client.go	255
collector/export/metric_otlp.go	233
collector/export/log_fluent.go	208
pkg/csv/csv.go	30
pkg/logger/logger.go	151
pkg/prompb/protobuf.go	289
pkg/prompb/sort.go	66
pkg/prompb/util.go	9
pkg/prompb/types.proto	28
pkg/prompb/pool.go	22
pkg/prompb/iterator.go	218
pkg/prompb/remote.proto	19
pkg/sync/rwmutex.go	38
pkg/promremote/client.go	122
pkg/pool/generic.go	26
pkg/pool/bytebuffer.go	7
pkg/otlp/logs.go	47
pkg/scheduler/periodic.go	69
pkg/k8s/identity.go	46
pkg/k8s/informer.go	57
pkg/testutils/ingestor/ingestor.go	375
pkg/testutils/skip.go	11
pkg/testutils/kql_verify.go	178
pkg/testutils/fs.go	99
pkg/testutils/collector/collector.go	312
pkg/testutils/k8s.go	94
pkg/testutils/alerter/alerter.go	103
pkg/testutils/alerter/k8s.yaml	116
pkg/testutils/uploader.go	39
pkg/testutils/kustainer/k8s.yaml	38
pkg/testutils/kustainer/kustainer.go	297
pkg/service/service.go	6
pkg/limiter/fixed.go	34
pkg/limiter/listener.go	45
pkg/debug/writer.go	5
pkg/tls/cert.go	70
pkg/flake/flake.go	16
pkg/gzip/reader.go	26
pkg/partmap/partmap.go	137
pkg/reader/counter.go	22
pkg/wal/segment_merger.go	54
pkg/wal/repository.go	220
pkg/wal/wal.go	320
pkg/wal/segment.go	450
pkg/wal/reader.go	62
pkg/wal/index.go	201
pkg/wal/iterator.go	115
pkg/wal/filename.go	58
pkg/http/server.go	102
pkg/http/client.go	76
pkg/http/randomizer.go	13
pkg/version/version.go	10
pkg/remote/types.go	44
build/k8s/collector.yaml	361
build/k8s/ksm.yaml	311
build/k8s/ingestor.yaml	275
schema/schema.go	315
alerter/fake.go	99
alerter/rules/localStore.go	97
alerter/rules/store.go	128
alerter/service.go	183
alerter/multikustoclient/auth.go	51
alerter/multikustoclient/client.go	75
alerter/alert/alert.go	11
alerter/alert/client.go	62
alerter/queue/queue.go	3
alerter/engine/fake.go	37
alerter/engine/executor.go	225
alerter/engine/formatter.go	40
alerter/engine/errors.go	8
alerter/engine/worker.go	170
alerter/engine/types.go	28
alerter/engine/client.go	9
alerter/engine/context.go	85
storage/store.go	312
cmd/ingestor/thread_affinity.go	2
cmd/ingestor/main.go	417
cmd/ingestor/thread_affinity_linux.go	9
cmd/collector/config/export.go	233
cmd/collector/config/config.go	572
cmd/collector/main.go	763
cmd/alerter/lint.go	72
cmd/alerter/main.go	141