Path	Lines of Code
cmd/cli/main.go	1019
cmd/hostmgr/main.go	679
cmd/jobmgr/main.go	635
cmd/placement/main.go	409
config/hostmgr/base.yaml	61
config/jobmgr/base.yaml	89
config/migratedb/base.yaml	20
pkg/archiver/engine/engine.go	357
pkg/aurorabridge/event_publisher.go	348
pkg/aurorabridge/handler.go	1912
pkg/cli/job_actions.go	772
pkg/common/async/job.go	9
pkg/common/async/pool.go	70
pkg/common/async/queue.go	58
pkg/common/background/work.go	122
pkg/common/backoff/policy.go	44
pkg/common/constraints/label_values.go	73
pkg/common/deadline_queue/priority_queue.go	32
pkg/common/eventstream/client.go	236
pkg/common/eventstream/handler.go	257
pkg/common/leader/id.go	110
pkg/common/metrics/config.go	162
pkg/common/util/util.go	471
pkg/common/v1alpha/eventstream/client.go	194
pkg/hostmgr/factory/task/task_builder.go	480
pkg/hostmgr/goalstate/host.go	152
pkg/hostmgr/goalstate/host_actions.go	208
pkg/hostmgr/handler.go	1259
pkg/hostmgr/host/drainer/drainer.go	207
pkg/hostmgr/hostpool/manager/manager.go	415
pkg/hostmgr/hostpool/resizer/resizer.go	179
pkg/hostmgr/mesos/detector.go	59
pkg/hostmgr/mesos/driver.go	258
pkg/hostmgr/mesos/yarpc/encoding/mpb/inbound.go	60
pkg/hostmgr/mesos/yarpc/transport/mhttp/handler.go	50
pkg/hostmgr/mesos/yarpc/transport/mhttp/inbound.go	210
pkg/hostmgr/mesos/yarpc/transport/mhttp/outbound.go	173
pkg/hostmgr/offer/handler.go	405
pkg/hostmgr/offer/offerpool/pool.go	624
pkg/hostmgr/p2k/hostcache/hostcache.go	513
pkg/hostmgr/p2k/hostcache/hostsummary/basehostsummary.go	398
pkg/hostmgr/p2k/hostcache/hostsummary/kubelethostsummary.go	263
pkg/hostmgr/p2k/hostcache/hostsummary/mesoshostsummary.go	42
pkg/hostmgr/p2k/hostmgrsvc/handler.go	324
pkg/hostmgr/p2k/plugins/k8s/k8s.go	235
pkg/hostmgr/p2k/plugins/k8s/util.go	115
pkg/hostmgr/p2k/plugins/mesos/mesos.go	382
pkg/hostmgr/p2k/plugins/mesos/offer.go	122
pkg/hostmgr/p2k/podeventmanager/podeventmanager.go	74
pkg/hostmgr/p2k/scalar/host.go	105
pkg/hostmgr/p2k/scalar/pod.go	150
pkg/hostmgr/server.go	282
pkg/jobmgr/cached/job.go	2505
pkg/jobmgr/cached/job_factory.go	292
pkg/jobmgr/cached/listener.go	21
pkg/jobmgr/cached/task.go	540
pkg/jobmgr/cached/update.go	908
pkg/jobmgr/cached/workflow_strategy.go	166
pkg/jobmgr/goalstate/config.go	80
pkg/jobmgr/goalstate/driver.go	380
pkg/jobmgr/goalstate/job.go	190
pkg/jobmgr/goalstate/task.go	217
pkg/jobmgr/goalstate/task_start.go	92
pkg/jobmgr/goalstate/task_stop.go	149
pkg/jobmgr/goalstate/task_terminated_retry.go	37
pkg/jobmgr/goalstate/update.go	117
pkg/jobmgr/goalstate/update_actions.go	176
pkg/jobmgr/goalstate/update_run.go	730
pkg/jobmgr/job/config/validate.go	255
pkg/jobmgr/jobsvc/handler.go	1022
pkg/jobmgr/jobsvc/metrics.go	82
pkg/jobmgr/jobsvc/private/handler.go	369
pkg/jobmgr/jobsvc/stateless/handler.go	1727
pkg/jobmgr/logmanager/logmanager.go	86
pkg/jobmgr/task/activermtask/active_rm_tasks.go	72
pkg/jobmgr/task/event/update.go	529
pkg/jobmgr/task/evictor/evictor.go	372
pkg/jobmgr/task/lifecyclemgr/v0_lifecyclemgr.go	412
pkg/jobmgr/task/lifecyclemgr/v1_lifecyclemgr.go	190
pkg/jobmgr/task/placement/placement.go	584
pkg/jobmgr/tasksvc/handler.go	1267
pkg/jobmgr/updatesvc/handler.go	379
pkg/jobmgr/util/handler/thermos.go	612
pkg/jobmgr/util/task/runtime.go	107
pkg/placement/engine.go	417
pkg/placement/offers/v0/service.go	200
pkg/placement/plugins/batch/strategy.go	108
pkg/placement/plugins/helpers.go	96
pkg/placement/plugins/mimir/strategy.go	138
pkg/placement/plugins/strategy.go	39
pkg/placement/plugins/v0/needs.go	42
pkg/resmgr/common/config.go	7
pkg/resmgr/handler.go	927
pkg/resmgr/queue/multi_level_list.go	232
pkg/resmgr/queue/priority.go	110
pkg/resmgr/respool/admission.go	301
pkg/resmgr/respool/respoolsvc/handler.go	472
pkg/resmgr/respool/restree.go	268
pkg/resmgr/server.go	164
pkg/resmgr/task/reconciler.go	149
pkg/resmgr/task/rmtask.go	527
pkg/resmgr/task/scheduler.go	323
pkg/resmgr/task/tracker.go	437
pkg/storage/cassandra/impl/decorator.go	69
pkg/storage/cassandra/impl/resultset.go	131
pkg/storage/cassandra/impl/store.go	144
pkg/storage/cassandra/models.go	238
pkg/storage/cassandra/store.go	2402
pkg/storage/interfaces.go	111
pkg/storage/objects/host_infos.go	432
pkg/storage/objects/pod_events.go	230
pkg/storage/objects/store.go	77
protobuf/peloton/api/v0/respool/respool.proto	310
protobuf/peloton/api/v0/respool/svc/respool_svc.proto	147
protobuf/peloton/api/v0/task/svc/task_svc.proto	312
protobuf/peloton/api/v0/task/task.proto	771
protobuf/peloton/api/v1alpha/job/stateless/svc/stateless_svc.proto	466
protobuf/peloton/api/v1alpha/pod/apachemesos/apachemesos.proto	122
protobuf/peloton/api/v1alpha/pod/pod.proto	613
protobuf/peloton/api/v1alpha/pod/svc/pod_svc.proto	167
protobuf/peloton/api/v1alpha/respool/respool.proto	155
protobuf/peloton/api/v1alpha/respool/svc/respool_svc.proto	107
protobuf/peloton/private/hostmgr/hostsvc/hostsvc.proto	876
protobuf/peloton/private/resmgr/taskqueue/taskqueue.proto	28
tools/deploy/app.py	705
tools/deploy/aurora/client.py	74
tools/deploy/cluster.py	94
tools/minicluster/config.yaml	89
tools/minicluster/minicluster.py	645