Path	Lines of Code
cmd/apiserver/config.go	15
cmd/apiserver/main.go	238
cmd/archiver/main.go	225
cmd/aurorabridge/config.go	24
cmd/aurorabridge/main.go	284
cmd/cli/main.go	1019
cmd/hostmgr/config.go	23
cmd/hostmgr/main.go	679
cmd/jobmgr/config.go	22
cmd/jobmgr/main.go	635
cmd/migratedb/config.go	7
cmd/migratedb/main.go	92
cmd/mock-cqos/config.go	7
cmd/mock-cqos/main.go	149
cmd/placement/main.go	409
cmd/resmgr/config.go	19
cmd/resmgr/main.go	434
config/apiserver/base.yaml	11
config/apiserver/development.yaml	6
config/archiver/base.yaml	16
config/archiver/development.yaml	20
config/aurorabridge/base.yaml	18
config/aurorabridge/development.yaml	38
config/executor/base.yaml	3
config/executor/development.yaml	3
config/hostmgr/base.yaml	61
config/hostmgr/development.yaml	26
config/jobmgr/base.yaml	89
config/jobmgr/development.yaml	24
config/migratedb/base.yaml	20
config/migratedb/development.yaml	8
config/mock-cqos/base.yaml	3
config/mock-cqos/development.yaml	2
config/placement/base.yaml	50
config/placement/development.yaml	15
config/placement_stateful/base.yaml	49
config/placement_stateful/development.yaml	15
config/placement_stateless/base.yaml	49
config/placement_stateless/development.yaml	15
config/resmgr/base.yaml	45
config/resmgr/development.yaml	25
example/auth/basic/security_example.yaml	31
example/default_respool.yaml	30
example/helloworld_job.yaml	28
example/helloworld_pool.yaml	26
example/performance/generate_instance_config.py	47
example/performance/testjob_base.yaml	30
example/performance/testjob_base_100k.yaml	12
example/performance/testjob_base_50k.yaml	12
example/performance/testjob_large_long.yaml	33
example/performance/testjob_large_short.yaml	33
example/performance/testjob_xlarge_short.yaml	33
example/stateless/testspec.yaml	29
example/stateless/testspec_sla.yaml	35
example/testjob.yaml	52
example/testjob_docker.yaml	48
example/testjob_gpu_mesos_containerizer.yaml	41
example/testjob_host_affinity_constraint.yaml	30
example/testjob_persistent_volume_docker.yaml	66
example/testjob_revocable.yaml	36
example/testjob_stateless_preemptible.yaml	32
example/testjob_stateless_revocable.yaml	34
example/testjob_stateless_service.yaml	32
example/testjob_stateless_service_host_limit.yaml	44
example/testjob_unified.yaml	46
example/testjob_with_health_check.yaml	81
mkdocs.yml	13
pkg/apiserver/config.go	5
pkg/apiserver/constants.go	1
pkg/apiserver/forward/helpers.go	22
pkg/apiserver/forward/stream.go	98
pkg/apiserver/forward/unary.go	42
pkg/apiserver/procedures.go	156
pkg/archiver/config/config.go	70
pkg/archiver/doc.go	1
pkg/archiver/engine/engine.go	357
pkg/archiver/engine/metrics.go	34
pkg/aurorabridge/atop/constraint.go	92
pkg/aurorabridge/atop/create_spec.go	14
pkg/aurorabridge/atop/job_name.go	8
pkg/aurorabridge/atop/job_spec.go	69
pkg/aurorabridge/atop/pod_spec.go	221
pkg/aurorabridge/atop/pod_state.go	44
pkg/aurorabridge/atop/update_spec.go	19
pkg/aurorabridge/atop/workflow_state.go	36
pkg/aurorabridge/common/constants.go	20
pkg/aurorabridge/common/job_update_status_set.go	28
pkg/aurorabridge/common/util.go	61
pkg/aurorabridge/config.go	112
pkg/aurorabridge/event_publisher.go	348
pkg/aurorabridge/fixture/aurora.go	64
pkg/aurorabridge/fixture/doc.go	1
pkg/aurorabridge/fixture/peloton.go	91
pkg/aurorabridge/handler.go	1912
pkg/aurorabridge/handler_startjobupdate.go	425
pkg/aurorabridge/handler_unused.go	66
pkg/aurorabridge/label/aurora_job_key.go	52
pkg/aurorabridge/label/aurora_metadata.go	59
pkg/aurorabridge/metrics.go	93
pkg/aurorabridge/mockutil/mockutil.go	35
pkg/aurorabridge/opaquedata/data.go	66
pkg/aurorabridge/ptoa/config_group.go	32
pkg/aurorabridge/ptoa/config_summary.go	100
pkg/aurorabridge/ptoa/constraint.go	82
pkg/aurorabridge/ptoa/identity.go	13
pkg/aurorabridge/ptoa/job_instance_update_event.go	28
pkg/aurorabridge/ptoa/job_key.go	23
pkg/aurorabridge/ptoa/job_summary.go	100
pkg/aurorabridge/ptoa/job_update_action.go	39
pkg/aurorabridge/ptoa/job_update_details.go	115
pkg/aurorabridge/ptoa/job_update_event.go	34
pkg/aurorabridge/ptoa/job_update_instructions.go	34
pkg/aurorabridge/ptoa/job_update_settings.go	14
pkg/aurorabridge/ptoa/job_update_status.go	49
pkg/aurorabridge/ptoa/job_update_summary.go	52
pkg/aurorabridge/ptoa/range.go	16
pkg/aurorabridge/ptoa/schedule_status.go	56
pkg/aurorabridge/ptoa/scheduled_task.go	109
pkg/aurorabridge/ptoa/task_config.go	198
pkg/aurorabridge/ptoa/task_event.go	24
pkg/aurorabridge/ptoa/task_tier.go	15
pkg/aurorabridge/ptoa/util.go	36
pkg/aurorabridge/response.go	40
pkg/aurorabridge/respool_loader.go	145
pkg/aurorabridge/server.go	89
pkg/aurorabridge/thrift/api.thrift	561
pkg/auth/config.go	5
pkg/auth/impl/auth.go	29
pkg/auth/impl/basic/client.go	56
pkg/auth/impl/basic/config.go	16
pkg/auth/impl/basic/manager.go	317
pkg/auth/impl/noop/noop.go	34
pkg/auth/interfaces.go	22
pkg/cli/admin_actions.go	44
pkg/cli/client.go	143
pkg/cli/common.go	60
pkg/cli/config/config.go	61
pkg/cli/example/basic_auth_example.yaml	2
pkg/cli/host_actions.go	210
pkg/cli/host_pool_actions.go	118
pkg/cli/job_actions.go	772
pkg/cli/jobmgr_actions.go	99
pkg/cli/middleware/auth.go	51
pkg/cli/offers.go	24
pkg/cli/output.go	89
pkg/cli/pod_actions.go	224
pkg/cli/resmgr_actions.go	138
pkg/cli/respool_actions.go	258
pkg/cli/stateless_actions.go	970
pkg/cli/task_actions.go	533
pkg/cli/update_actions.go	279
pkg/cli/volume_actions.go	66
pkg/cli/watch_actions.go	168
pkg/common/api/api_converter.go	1268
pkg/common/api/version.go	27
pkg/common/async/daemon.go	111
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/backoff/retry.go	31
pkg/common/buildversion/handler.go	14
pkg/common/cirbuf/circular_buffer.go	119
pkg/common/concurrency/map.go	81
pkg/common/config/parse.go	47
pkg/common/config/thermos.go	81
pkg/common/constants.go	66
pkg/common/constraints/evaluate.go	139
pkg/common/constraints/label_values.go	73
pkg/common/deadline_queue/doc.go	1
pkg/common/deadline_queue/item.go	58
pkg/common/deadline_queue/metrics.go	15
pkg/common/deadline_queue/priority_queue.go	32
pkg/common/deadline_queue/queue.go	98
pkg/common/errors.go	19
pkg/common/eventstream/client.go	236
pkg/common/eventstream/handler.go	257
pkg/common/eventstream/metrics.go	72
pkg/common/goalstate/doc.go	1
pkg/common/goalstate/engine.go	235
pkg/common/goalstate/metrics.go	16
pkg/common/goalstate/types.go	16
pkg/common/health/config.go	7
pkg/common/health/heartbeat.go	85
pkg/common/health/metrics.go	16
pkg/common/leader/discovery.go	79
pkg/common/leader/election.go	211
pkg/common/leader/id.go	110
pkg/common/leader/interfaces.go	14
pkg/common/leader/metrics.go	44
pkg/common/leader/observer.go	122
pkg/common/lifecycle/lifecycle.go	63
pkg/common/logging/level.go	79
pkg/common/logging/log_field_formatter.go	14
pkg/common/logging/secrets_formatter.go	55
pkg/common/logging/sentry.go	40
pkg/common/metrics/config.go	162
pkg/common/metrics/runtime.go	119
pkg/common/procedure/label.go	109
pkg/common/queue/queue.go	67
pkg/common/recovery/metrics.go	18
pkg/common/recovery/recovery.go	272
pkg/common/reservation/label.go	46
pkg/common/rpc/rpc.go	58
pkg/common/scalar/counter_maps.go	17
pkg/common/scalar/gauge_maps.go	24
pkg/common/scalar/resources.go	7
pkg/common/sorter/multikeysorter.go	36
pkg/common/statemachine/builder.go	53
pkg/common/statemachine/statemachine.go	350
pkg/common/statemachine/statetimer.go	96
pkg/common/statemachine/transition.go	8
pkg/common/statusupdate/event.go	188
pkg/common/stringset/stringset.go	52
pkg/common/taskconfig/compare.go	333
pkg/common/taskconfig/merge.go	84
pkg/common/thermos/thermos.go	106
pkg/common/util/entityversion/entity_version.go	62
pkg/common/util/mesos_util.go	33
pkg/common/util/parallel_run.go	74
pkg/common/util/port_util.go	72
pkg/common/util/randutil/randutil.go	23
pkg/common/util/strings/strings.go	7
pkg/common/util/task/convert.go	102
pkg/common/util/util.go	471
pkg/common/util/yarpc/yarpc_util.go	25
pkg/common/v1alpha/constraints/evaluate.go	141
pkg/common/v1alpha/constraints/label_values.go	32
pkg/common/v1alpha/eventstream/client.go	194
pkg/common/v1alpha/eventstream/handler.go	252
pkg/common/v1alpha/eventstream/metrics.go	72
pkg/hostmgr/binpacking/binpacking.go	60
pkg/hostmgr/binpacking/defragranker.go	72
pkg/hostmgr/binpacking/firstfitranker.go	28
pkg/hostmgr/binpacking/loadawareranker.go	140
pkg/hostmgr/binpacking/ranker.go	16
pkg/hostmgr/common/constants.go	7
pkg/hostmgr/common/types.go	2
pkg/hostmgr/config/config.go	34
pkg/hostmgr/config/cqos.go	4
pkg/hostmgr/factory/task/task_builder.go	480
pkg/hostmgr/goalstate/config.go	23
pkg/hostmgr/goalstate/driver.go	151
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/host/map.go	216
pkg/hostmgr/host/mesoshelper/mesos.go	114
pkg/hostmgr/host/metrics.go	16
pkg/hostmgr/hostpool/constants.go	5
pkg/hostmgr/hostpool/hostmover/hostmover.go	142
pkg/hostmgr/hostpool/hostmover/metrics.go	16
pkg/hostmgr/hostpool/hostpool.go	99
pkg/hostmgr/hostpool/manager/manager.go	415
pkg/hostmgr/hostpool/manager/metrics.go	34
pkg/hostmgr/hostpool/metrics.go	20
pkg/hostmgr/hostpool/resizer/config.go	41
pkg/hostmgr/hostpool/resizer/metrics.go	29
pkg/hostmgr/hostpool/resizer/resizer.go	179
pkg/hostmgr/hostsvc/handler.go	295
pkg/hostmgr/hostsvc/metrics.go	29
pkg/hostmgr/matcher.go	132
pkg/hostmgr/mesos/config.go	18
pkg/hostmgr/mesos/detector.go	59
pkg/hostmgr/mesos/driver.go	258
pkg/hostmgr/mesos/manager.go	79
pkg/hostmgr/mesos/mesos-go/detector/doc.go	1
pkg/hostmgr/mesos/mesos-go/detector/factory.go	111
pkg/hostmgr/mesos/mesos-go/detector/interface.go	20
pkg/hostmgr/mesos/mesos-go/detector/standalone.go	215
pkg/hostmgr/mesos/mesos-go/detector/zoo/client2.go	76
pkg/hostmgr/mesos/mesos-go/detector/zoo/detect.go	308
pkg/hostmgr/mesos/mesos-go/detector/zoo/doc.go	1
pkg/hostmgr/mesos/mesos-go/detector/zoo/mock/conn.go	44
pkg/hostmgr/mesos/mesos-go/detector/zoo/mock/mock.go	65
pkg/hostmgr/mesos/mesos-go/detector/zoo/plugin.go	9
pkg/hostmgr/mesos/mesos-go/detector/zoo/types.go	17
pkg/hostmgr/mesos/mesos-go/doc.go	1
pkg/hostmgr/mesos/mesos-go/mesosutil/mesosprotoutil.go	12
pkg/hostmgr/mesos/mesos-go/upid/doc.go	1
pkg/hostmgr/mesos/mesos-go/upid/upid.go	34
pkg/hostmgr/mesos/yarpc/encoding/mpb/constants.go	7
pkg/hostmgr/mesos/yarpc/encoding/mpb/inbound.go	60
pkg/hostmgr/mesos/yarpc/encoding/mpb/moperator.go	292
pkg/hostmgr/mesos/yarpc/encoding/mpb/register.go	73
pkg/hostmgr/mesos/yarpc/encoding/mpb/scheduler.go	47
pkg/hostmgr/mesos/yarpc/encoding/mpb/util.go	45
pkg/hostmgr/mesos/yarpc/peer/interfaces.go	13
pkg/hostmgr/mesos/yarpc/peer/peer_chooser.go	112
pkg/hostmgr/mesos/yarpc/peer/simple_chooser.go	53
pkg/hostmgr/mesos/yarpc/peer/smart_chooser.go	93
pkg/hostmgr/mesos/yarpc/transport/mhttp/constants.go	10
pkg/hostmgr/mesos/yarpc/transport/mhttp/driver.go	15
pkg/hostmgr/mesos/yarpc/transport/mhttp/handler.go	50
pkg/hostmgr/mesos/yarpc/transport/mhttp/inbound.go	210
pkg/hostmgr/mesos/yarpc/transport/mhttp/metrics.go	30
pkg/hostmgr/mesos/yarpc/transport/mhttp/outbound.go	173
pkg/hostmgr/mesos/yarpc/transport/mhttp/outbound_client.go	20
pkg/hostmgr/metrics/metrics.go	122
pkg/hostmgr/models/models.go	42
pkg/hostmgr/offer/handler.go	405
pkg/hostmgr/offer/metrics.go	22
pkg/hostmgr/offer/offerpool/matcher.go	89
pkg/hostmgr/offer/offerpool/metrics.go	50
pkg/hostmgr/offer/offerpool/pool.go	624
pkg/hostmgr/offer/offerpool/refresher.go	26
pkg/hostmgr/offer/pruner.go	83
pkg/hostmgr/p2k/config/config.go	5
pkg/hostmgr/p2k/hostcache/hostcache.go	513
pkg/hostmgr/p2k/hostcache/hostsummary/basehostsummary.go	398
pkg/hostmgr/p2k/hostcache/hostsummary/interface.go	35
pkg/hostmgr/p2k/hostcache/hostsummary/kubelethostsummary.go	263
pkg/hostmgr/p2k/hostcache/hostsummary/matcher.go	65
pkg/hostmgr/p2k/hostcache/hostsummary/mesoshostsummary.go	42
pkg/hostmgr/p2k/hostcache/hostsummary/podinfo.go	81
pkg/hostmgr/p2k/hostcache/hostsummary/testutils.go	92
pkg/hostmgr/p2k/hostcache/metrics.go	26
pkg/hostmgr/p2k/hostmgrsvc/handler.go	324
pkg/hostmgr/p2k/plugins/common.go	37
pkg/hostmgr/p2k/plugins/interface.go	14
pkg/hostmgr/p2k/plugins/k8s/k8s.go	235
pkg/hostmgr/p2k/plugins/k8s/util.go	115
pkg/hostmgr/p2k/plugins/mesos/agent_syncer.go	65
pkg/hostmgr/p2k/plugins/mesos/mesos.go	382
pkg/hostmgr/p2k/plugins/mesos/metrics.go	32
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/prune/held_host_pruner.go	28
pkg/hostmgr/prune/interface.go	5
pkg/hostmgr/prune/placing_host_pruner.go	28
pkg/hostmgr/queue/queue.go	86
pkg/hostmgr/reconcile/config.go	7
pkg/hostmgr/reconcile/metrics.go	26
pkg/hostmgr/reconcile/task_reconciler.go	181
pkg/hostmgr/recovery.go	113
pkg/hostmgr/reserver/reserver.go	329
pkg/hostmgr/scalar/resources.go	262
pkg/hostmgr/server.go	282
pkg/hostmgr/summary/summary.go	660
pkg/hostmgr/util/constraint.go	53
pkg/hostmgr/util/util.go	56
pkg/hostmgr/watchevent/config.go	17
pkg/hostmgr/watchevent/processor.go	174
pkg/jobmgr/adminsvc/api_lock_component.go	33
pkg/jobmgr/adminsvc/goalstate_component.go	19
pkg/jobmgr/adminsvc/handler.go	131
pkg/jobmgr/adminsvc/lockable_component_interface.go	9
pkg/jobmgr/adminsvc/task_life_cycle_lock_component.go	33
pkg/jobmgr/cached/constants.go	39
pkg/jobmgr/cached/job.go	2505
pkg/jobmgr/cached/job_factory.go	292
pkg/jobmgr/cached/listener.go	21
pkg/jobmgr/cached/metrics.go	28
pkg/jobmgr/cached/patch.go	31
pkg/jobmgr/cached/task.go	540
pkg/jobmgr/cached/update.go	908
pkg/jobmgr/cached/workflow_strategy.go	166
pkg/jobmgr/common/constants.go	31
pkg/jobmgr/common/doc.go	1
pkg/jobmgr/common/errors.go	4
pkg/jobmgr/common/types.go	31
pkg/jobmgr/config.go	28
pkg/jobmgr/goalstate/config.go	80
pkg/jobmgr/goalstate/driver.go	380
pkg/jobmgr/goalstate/job.go	190
pkg/jobmgr/goalstate/job_actions.go	325
pkg/jobmgr/goalstate/job_create.go	313
pkg/jobmgr/goalstate/job_kill.go	167
pkg/jobmgr/goalstate/job_runtime_updater.go	524
pkg/jobmgr/goalstate/metrics.go	96
pkg/jobmgr/goalstate/task.go	217
pkg/jobmgr/goalstate/task_actions.go	78
pkg/jobmgr/goalstate/task_fail_restart.go	143
pkg/jobmgr/goalstate/task_initialize.go	54
pkg/jobmgr/goalstate/task_launch_retry.go	115
pkg/jobmgr/goalstate/task_start.go	92
pkg/jobmgr/goalstate/task_stop.go	149
pkg/jobmgr/goalstate/task_stop_retry.go	31
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/goalstate/update_start.go	173
pkg/jobmgr/job/config/validate.go	255
pkg/jobmgr/jobsvc/config.go	40
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/podsvc/handler.go	805
pkg/jobmgr/server.go	107
pkg/jobmgr/task/activermtask/active_rm_tasks.go	72
pkg/jobmgr/task/activermtask/metrics.go	18
pkg/jobmgr/task/deadline/config.go	16
pkg/jobmgr/task/deadline/tracker.go	169
pkg/jobmgr/task/enqueue.go	32
pkg/jobmgr/task/event/asyncprocessor.go	183
pkg/jobmgr/task/event/metrics.go	46
pkg/jobmgr/task/event/update.go	529
pkg/jobmgr/task/evictor/evictor.go	372
pkg/jobmgr/task/evictor/metrics.go	26
pkg/jobmgr/task/lifecyclemgr/lifecyclemgr.go	71
pkg/jobmgr/task/lifecyclemgr/locker.go	42
pkg/jobmgr/task/lifecyclemgr/metrics.go	42
pkg/jobmgr/task/lifecyclemgr/v0_lifecyclemgr.go	412
pkg/jobmgr/task/lifecyclemgr/v1_lifecyclemgr.go	190
pkg/jobmgr/task/placement/metrics.go	23
pkg/jobmgr/task/placement/placement.go	584
pkg/jobmgr/task/util.go	162
pkg/jobmgr/tasksvc/handler.go	1267
pkg/jobmgr/tasksvc/metrics.go	73
pkg/jobmgr/updatesvc/handler.go	379
pkg/jobmgr/updatesvc/metrics.go	55
pkg/jobmgr/util/expansion/expand.go	56
pkg/jobmgr/util/goalstate/job.go	10
pkg/jobmgr/util/handler/api_converter.go	1189
pkg/jobmgr/util/handler/cache.go	32
pkg/jobmgr/util/handler/thermos.go	612
pkg/jobmgr/util/handler/thermos_types.go	108
pkg/jobmgr/util/job/config.go	48
pkg/jobmgr/util/task/runtime.go	107
pkg/jobmgr/util/update/job.go	17
pkg/jobmgr/volumesvc/handler.go	38
pkg/jobmgr/watchsvc/config.go	17
pkg/jobmgr/watchsvc/handler.go	213
pkg/jobmgr/watchsvc/listener.go	58
pkg/jobmgr/watchsvc/metrics.go	23
pkg/jobmgr/watchsvc/processor.go	329
pkg/jobmgr/workflow/progress/check.go	112
pkg/jobmgr/workflow/progress/config.go	18
pkg/jobmgr/workflow/progress/metrics.go	26
pkg/middleware/inbound/api_lock.go	106
pkg/middleware/inbound/auth.go	76
pkg/middleware/inbound/leader_check.go	43
pkg/middleware/inbound/rate_limit.go	127
pkg/middleware/inbound/yarpc_metrics.go	67
pkg/middleware/outbound/auth.go	44
pkg/mock-cqos/config.go	5
pkg/mock-cqos/handler.go	40
pkg/placement/config/config.go	94
pkg/placement/engine.go	417
pkg/placement/hosts/service.go	159
pkg/placement/metrics/metrics.go	59
pkg/placement/models/ports.go	53
pkg/placement/models/types.go	31
pkg/placement/models/v0/assignment.go	123
pkg/placement/models/v0/doc.go	1
pkg/placement/models/v0/hostoffers.go	82
pkg/placement/models/v0/hosts.go	27
pkg/placement/models/v0/mimir.go	32
pkg/placement/models/v0/task.go	83
pkg/placement/models/v0/util.go	26
pkg/placement/models/v1/lease.go	69
pkg/placement/offers/doc.go	1
pkg/placement/offers/types.go	15
pkg/placement/offers/v0/service.go	200
pkg/placement/offers/v1/service.go	157
pkg/placement/plugins/batch/strategy.go	108
pkg/placement/plugins/helpers.go	96
pkg/placement/plugins/mimir/common/labels.go	4
pkg/placement/plugins/mimir/common/metrics.go	106
pkg/placement/plugins/mimir/common/utils.go	53
pkg/placement/plugins/mimir/lib/algorithms/doc.go	1
pkg/placement/plugins/mimir/lib/algorithms/placement.go	91
pkg/placement/plugins/mimir/lib/algorithms/relocation.go	80
pkg/placement/plugins/mimir/lib/doc.go	1
pkg/placement/plugins/mimir/lib/generation/distribution.go	131
pkg/placement/plugins/mimir/lib/generation/doc.go	1
pkg/placement/plugins/mimir/lib/generation/orderings/expression.go	147
pkg/placement/plugins/mimir/lib/generation/orderings/ordering_builder.go	21
pkg/placement/plugins/mimir/lib/generation/placement/entity.go	64
pkg/placement/plugins/mimir/lib/generation/placement/group.go	48
pkg/placement/plugins/mimir/lib/generation/placement/ordering.go	20
pkg/placement/plugins/mimir/lib/generation/placement/requirement.go	24
pkg/placement/plugins/mimir/lib/generation/requirements/and_requirement.go	24
pkg/placement/plugins/mimir/lib/generation/requirements/label_requirement.go	36
pkg/placement/plugins/mimir/lib/generation/requirements/metric_requirement.go	25
pkg/placement/plugins/mimir/lib/generation/requirements/or_requirement.go	24
pkg/placement/plugins/mimir/lib/generation/requirements/relation_requirement.go	36
pkg/placement/plugins/mimir/lib/internal/fixtures.go	51
pkg/placement/plugins/mimir/lib/model/doc.go	1
pkg/placement/plugins/mimir/lib/model/labels/bag.go	156
pkg/placement/plugins/mimir/lib/model/labels/label.go	51
pkg/placement/plugins/mimir/lib/model/labels/set.go	60
pkg/placement/plugins/mimir/lib/model/labels/template.go	60
pkg/placement/plugins/mimir/lib/model/metrics/derivation.go	5
pkg/placement/plugins/mimir/lib/model/metrics/set.go	119
pkg/placement/plugins/mimir/lib/model/metrics/template.go	29
pkg/placement/plugins/mimir/lib/model/metrics/template_set.go	61
pkg/placement/plugins/mimir/lib/model/metrics/topsort.go	49
pkg/placement/plugins/mimir/lib/model/metrics/type.go	162
pkg/placement/plugins/mimir/lib/model/orderings/bucket.go	56
pkg/placement/plugins/mimir/lib/model/orderings/concatenate.go	19
pkg/placement/plugins/mimir/lib/model/orderings/constant.go	15
pkg/placement/plugins/mimir/lib/model/orderings/endpoint.go	17
pkg/placement/plugins/mimir/lib/model/orderings/inverse.go	24
pkg/placement/plugins/mimir/lib/model/orderings/label.go	19
pkg/placement/plugins/mimir/lib/model/orderings/map.go	21
pkg/placement/plugins/mimir/lib/model/orderings/mapping.go	90
pkg/placement/plugins/mimir/lib/model/orderings/metric.go	24
pkg/placement/plugins/mimir/lib/model/orderings/multiply.go	37
pkg/placement/plugins/mimir/lib/model/orderings/negate.go	19
pkg/placement/plugins/mimir/lib/model/orderings/relation.go	19
pkg/placement/plugins/mimir/lib/model/orderings/source.go	6
pkg/placement/plugins/mimir/lib/model/orderings/sum.go	37
pkg/placement/plugins/mimir/lib/model/placement/assignment.go	17
pkg/placement/plugins/mimir/lib/model/placement/entities.go	8
pkg/placement/plugins/mimir/lib/model/placement/entity.go	22
pkg/placement/plugins/mimir/lib/model/placement/group.go	33
pkg/placement/plugins/mimir/lib/model/placement/ordering.go	38
pkg/placement/plugins/mimir/lib/model/placement/relocation_rank.go	15
pkg/placement/plugins/mimir/lib/model/placement/requirement.go	14
pkg/placement/plugins/mimir/lib/model/placement/reservation.go	5
pkg/placement/plugins/mimir/lib/model/placement/reserved.go	6
pkg/placement/plugins/mimir/lib/model/placement/scope.go	93
pkg/placement/plugins/mimir/lib/model/placement/transcript.go	84
pkg/placement/plugins/mimir/lib/model/placement/transcriptable.go	15
pkg/placement/plugins/mimir/lib/model/requirements/and.go	40
pkg/placement/plugins/mimir/lib/model/requirements/comparison.go	25
pkg/placement/plugins/mimir/lib/model/requirements/label.go	38
pkg/placement/plugins/mimir/lib/model/requirements/metric.go	36
pkg/placement/plugins/mimir/lib/model/requirements/or.go	40
pkg/placement/plugins/mimir/lib/model/requirements/relation.go	38
pkg/placement/plugins/mimir/strategy.go	138
pkg/placement/plugins/mimir/v0/entities.go	127
pkg/placement/plugins/mimir/v0/groups.go	73
pkg/placement/plugins/mimir/v1/group.go	42
pkg/placement/plugins/strategy.go	39
pkg/placement/plugins/v0/needs.go	42
pkg/placement/plugins/v1/needs.go	37
pkg/placement/reserver/reserver.go	322
pkg/placement/tasks/doc.go	1
pkg/placement/tasks/service.go	247
pkg/placement/testutil/assignment.go	18
pkg/placement/testutil/host.go	11
pkg/placement/testutil/v0/host_offer.go	97
pkg/placement/testutil/v0/rmtask.go	77
pkg/resmgr/common/config.go	7
pkg/resmgr/common/constants.go	5
pkg/resmgr/config.go	20
pkg/resmgr/constants.go	5
pkg/resmgr/entitlement/calculator.go	229
pkg/resmgr/entitlement/capacity_manager.go	152
pkg/resmgr/entitlement/metrics.go	18
pkg/resmgr/entitlement/non_revocable.go	231
pkg/resmgr/entitlement/revocable.go	164
pkg/resmgr/handler.go	927
pkg/resmgr/host/drainer.go	164
pkg/resmgr/host/metrics.go	14
pkg/resmgr/hostmover/batch_scorer.go	244
pkg/resmgr/metrics.go	67
pkg/resmgr/preemption/metrics.go	39
pkg/resmgr/preemption/preemptor.go	336
pkg/resmgr/preemption/ranker.go	153
pkg/resmgr/queue/multi_level_list.go	232
pkg/resmgr/queue/priority.go	110
pkg/resmgr/queue/queue.go	21
pkg/resmgr/recovery.go	318
pkg/resmgr/respool/admission.go	301
pkg/resmgr/respool/constants.go	8
pkg/resmgr/respool/doc.go	1
pkg/resmgr/respool/metrics.go	114
pkg/resmgr/respool/respool.go	808
pkg/resmgr/respool/respoolconfig_validator.go	281
pkg/resmgr/respool/respoolsvc/handler.go	472
pkg/resmgr/respool/restree.go	268
pkg/resmgr/scalar/resources.go	257
pkg/resmgr/server.go	164
pkg/resmgr/task/backoffpolicy.go	40
pkg/resmgr/task/backoffpolicyfactory.go	57
pkg/resmgr/task/config.go	15
pkg/resmgr/task/constants.go	6
pkg/resmgr/task/metrics.go	88
pkg/resmgr/task/reconciler.go	149
pkg/resmgr/task/rmtask.go	527
pkg/resmgr/task/scheduler.go	323
pkg/resmgr/task/sla.go	130
pkg/resmgr/task/tracker.go	437
pkg/resmgr/tasktestutil/util.go	53
pkg/storage/cassandra/api/entity.go	27
pkg/storage/cassandra/api/stapi.go	71
pkg/storage/cassandra/config.go	18
pkg/storage/cassandra/impl/config.go	24
pkg/storage/cassandra/impl/decorator.go	69
pkg/storage/cassandra/impl/executor.go	145
pkg/storage/cassandra/impl/querybuilder.go	22
pkg/storage/cassandra/impl/resultset.go	131
pkg/storage/cassandra/impl/storage.go	131
pkg/storage/cassandra/impl/store.go	144
pkg/storage/cassandra/migrations/0000_bootstrap.down.cql	14
pkg/storage/cassandra/migrations/0000_bootstrap.up.cql	119
pkg/storage/cassandra/migrations/0001_task_add_version.down.cql	1
pkg/storage/cassandra/migrations/0001_task_add_version.up.cql	1
pkg/storage/cassandra/migrations/0002_volume_add_mv.down.cql	2
pkg/storage/cassandra/migrations/0002_volume_add_mv.up.cql	8
pkg/storage/cassandra/migrations/0003_upgrade_info_add.down.cql	2
pkg/storage/cassandra/migrations/0003_upgrade_info_add.up.cql	18
pkg/storage/cassandra/migrations/0004_lucene_index_v2.down.cql	4
pkg/storage/cassandra/migrations/0004_lucene_index_v2.up.cql	25
pkg/storage/cassandra/migrations/0005_drop_old_table_index.down.cql	28
pkg/storage/cassandra/migrations/0005_drop_old_table_index.up.cql	2
pkg/storage/cassandra/migrations/0006_alter_gc_compaction_strategy.down.cql	6
pkg/storage/cassandra/migrations/0006_alter_gc_compaction_strategy.up.cql	6
pkg/storage/cassandra/migrations/0007_secret_info.down.cql	1
pkg/storage/cassandra/migrations/0007_secret_info.up.cql	10
pkg/storage/cassandra/migrations/0008_alter_compaction_strategy_sstablesize_gc.down.cql	14
pkg/storage/cassandra/migrations/0008_alter_compaction_strategy_sstablesize_gc.up.cql	14
pkg/storage/cassandra/migrations/0009_add_pod_events.down.cql	1
pkg/storage/cassandra/migrations/0009_add_pod_events.up.cql	31
pkg/storage/cassandra/migrations/0010_update_add.down.cql	13
pkg/storage/cassandra/migrations/0010_update_add.up.cql	13
pkg/storage/cassandra/migrations/0011_pod_events_add_healthy.down.cql	1
pkg/storage/cassandra/migrations/0011_pod_events_add_healthy.up.cql	1
pkg/storage/cassandra/migrations/0012_pod_events_add_desired_run_id.down.cql	1
pkg/storage/cassandra/migrations/0012_pod_events_add_desired_run_id.up.cql	1
pkg/storage/cassandra/migrations/0013_update_add_instances_updated_added.down.cql	4
pkg/storage/cassandra/migrations/0013_update_add_instances_updated_added.up.cql	4
pkg/storage/cassandra/migrations/0014_add_system_labels_to_config_tables.down.cql	2
pkg/storage/cassandra/migrations/0014_add_system_labels_to_config_tables.up.cql	2
pkg/storage/cassandra/migrations/0015_update_add_instances_failed.down.cql	1
pkg/storage/cassandra/migrations/0015_update_add_instances_failed.up.cql	1
pkg/storage/cassandra/migrations/0016_update_add_prev_state.down.cql	1
pkg/storage/cassandra/migrations/0016_update_add_prev_state.up.cql	1
pkg/storage/cassandra/migrations/0017_active_jobs.down.cql	1
pkg/storage/cassandra/migrations/0017_active_jobs.up.cql	16
pkg/storage/cassandra/migrations/0018_add_job_name_id_mapping.down.cql	1
pkg/storage/cassandra/migrations/0018_add_job_name_id_mapping.up.cql	18
pkg/storage/cassandra/migrations/0019_task_config_v2.down.cql	1
pkg/storage/cassandra/migrations/0019_task_config_v2.up.cql	20
pkg/storage/cassandra/migrations/0020_update_opaque_data.down.cql	1
pkg/storage/cassandra/migrations/0020_update_opaque_data.up.cql	1
pkg/storage/cassandra/migrations/0021_add_pod_workflow_events.down.cql	1
pkg/storage/cassandra/migrations/0021_add_pod_workflow_events.up.cql	20
pkg/storage/cassandra/migrations/0022_add_job_update_events.down.cql	1
pkg/storage/cassandra/migrations/0022_add_job_update_events.up.cql	19
pkg/storage/cassandra/migrations/0023_drop_respool_by_owner_mv.down.cql	4
pkg/storage/cassandra/migrations/0023_drop_respool_by_owner_mv.up.cql	1
pkg/storage/cassandra/migrations/0024_add_sla_job_index.down.cql	1
pkg/storage/cassandra/migrations/0024_add_sla_job_index.up.cql	1
pkg/storage/cassandra/migrations/0025_add_update_completion_time.down.cql	1
pkg/storage/cassandra/migrations/0025_add_update_completion_time.up.cql	1
pkg/storage/cassandra/migrations/0026_drop_mv_volumes.down.cql	8
pkg/storage/cassandra/migrations/0026_drop_mv_volumes.up.cql	2
pkg/storage/cassandra/migrations/0027_add_job_spec_apiversion.down.cql	2
pkg/storage/cassandra/migrations/0027_add_job_spec_apiversion.up.cql	2
pkg/storage/cassandra/migrations/0028_alter_compaction_strategy_secret_info.down.cql	2
pkg/storage/cassandra/migrations/0028_alter_compaction_strategy_secret_info.up.cql	2
pkg/storage/cassandra/migrations/0029_add_pod_spec_apiversion.down.cql	2
pkg/storage/cassandra/migrations/0029_add_pod_spec_apiversion.up.cql	2
pkg/storage/cassandra/migrations/0030_add_host_infos.down.cql	1
pkg/storage/cassandra/migrations/0030_add_host_infos.up.cql	19
pkg/storage/cassandra/migrations/0031_drop_mv_job.down.cql	4
pkg/storage/cassandra/migrations/0031_drop_mv_job.up.cql	1
pkg/storage/cassandra/migrations/0032_add_host_labels.down.cql	1
pkg/storage/cassandra/migrations/0032_add_host_labels.up.cql	1
pkg/storage/cassandra/migrations/0033_add_host_pools.down.cql	2
pkg/storage/cassandra/migrations/0033_add_host_pools.up.cql	2
pkg/storage/cassandra/migrations/0034_add_update_timestamp_events.down.cql	2
pkg/storage/cassandra/migrations/0034_add_update_timestamp_events.up.cql	2
pkg/storage/cassandra/migrator.go	86
pkg/storage/cassandra/models.go	238
pkg/storage/cassandra/store.go	2402
pkg/storage/config/config.go	10
pkg/storage/connectors/cassandra/cassandra.go	476
pkg/storage/connectors/cassandra/config.go	30
pkg/storage/connectors/cassandra/conn.go	105
pkg/storage/connectors/cassandra/cql.go	155
pkg/storage/interfaces.go	111
pkg/storage/metrics.go	600
pkg/storage/objects/active_jobs.go	97
pkg/storage/objects/base/object.go	31
pkg/storage/objects/base/optional_types.go	68
pkg/storage/objects/host_infos.go	432
pkg/storage/objects/job_config.go	310
pkg/storage/objects/job_index.go	328
pkg/storage/objects/job_name_id.go	79
pkg/storage/objects/job_runtime.go	111
pkg/storage/objects/job_update_events.go	115
pkg/storage/objects/pod_events.go	230
pkg/storage/objects/respools.go	219
pkg/storage/objects/secret.go	152
pkg/storage/objects/store.go	77
pkg/storage/objects/task_config_v2.go	311
pkg/storage/objects/task_runtime.go	1
pkg/storage/objects/volumes.go	1
pkg/storage/orm/client.go	120
pkg/storage/orm/connector.go	40
pkg/storage/orm/doc.go	1
pkg/storage/orm/object_parser.go	108
pkg/storage/orm/table.go	179
pkg/storage/querybuilder/accessor.go	6
pkg/storage/querybuilder/delete.go	79
pkg/storage/querybuilder/expr.go	202
pkg/storage/querybuilder/insert.go	139
pkg/storage/querybuilder/part.go	47
pkg/storage/querybuilder/placeholder.go	49
pkg/storage/querybuilder/querybuilder.go	41
pkg/storage/querybuilder/select.go	198
pkg/storage/querybuilder/update.go	179
pkg/storage/querybuilder/where.go	23
pkg/storage/stores/stores.go	25
protobuf/mesos/v1/agent/agent.proto	571
protobuf/mesos/v1/allocator/allocator.proto	47
protobuf/mesos/v1/executor/executor.proto	186
protobuf/mesos/v1/maintenance/maintenance.proto	72
protobuf/mesos/v1/master/master.proto	535
protobuf/mesos/v1/mesos.proto	3055
protobuf/mesos/v1/quota/quota.proto	62
protobuf/mesos/v1/resource_provider/resource_provider.proto	164
protobuf/mesos/v1/scheduler/scheduler.proto	470
protobuf/peloton/api/v0/changelog/changelog.proto	18
protobuf/peloton/api/v0/errors/errors.proto	24
protobuf/peloton/api/v0/host/host.proto	69
protobuf/peloton/api/v0/host/svc/host_svc.proto	137
protobuf/peloton/api/v0/job/job.proto	546
protobuf/peloton/api/v0/job/svc/job_svc.proto	308
protobuf/peloton/api/v0/peloton.proto	106
protobuf/peloton/api/v0/query/query.proto	51
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/v0/update/svc/update_svc.proto	189
protobuf/peloton/api/v0/update/update.proto	100
protobuf/peloton/api/v0/volume/svc/volume_svc.proto	70
protobuf/peloton/api/v0/volume/volume.proto	46
protobuf/peloton/api/v1alpha/admin/svc/admin_svc.proto	48
protobuf/peloton/api/v1alpha/host/host.proto	60
protobuf/peloton/api/v1alpha/host/svc/host_svc.proto	113
protobuf/peloton/api/v1alpha/job/stateless/stateless.proto	366
protobuf/peloton/api/v1alpha/job/stateless/svc/stateless_svc.proto	466
protobuf/peloton/api/v1alpha/peloton.proto	101
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/query/query.proto	40
protobuf/peloton/api/v1alpha/respool/respool.proto	155
protobuf/peloton/api/v1alpha/respool/svc/respool_svc.proto	107
protobuf/peloton/api/v1alpha/volume/svc/volume_svc.proto	51
protobuf/peloton/api/v1alpha/volume/volume.proto	81
protobuf/peloton/api/v1alpha/watch/svc/watch_svc.proto	84
protobuf/peloton/api/v1alpha/watch/watch.proto	28
protobuf/peloton/private/eventstream/eventstream.proto	97
protobuf/peloton/private/eventstream/v1alpha/event/event.proto	14
protobuf/peloton/private/eventstream/v1alpha/eventstreamsvc/eventstreamsvc.proto	47
protobuf/peloton/private/hostmgr/hostsvc/hostsvc.proto	876
protobuf/peloton/private/hostmgr/v1alpha/hostmgr.proto	93
protobuf/peloton/private/hostmgr/v1alpha/svc/hostmgr_svc.proto	130
protobuf/peloton/private/jobmgrsvc/jobmgrsvc.proto	95
protobuf/peloton/private/models/models.proto	66
protobuf/peloton/private/resmgr/resmgr.proto	145
protobuf/peloton/private/resmgr/taskqueue/taskqueue.proto	28
protobuf/peloton/private/resmgrsvc/resmgrsvc.proto	404
protobuf/qos/v1alpha1/qos.proto	66
scripts/generate-protobuf.py	154
scripts/logformat.py	16
tools/__init__.py	1
tools/deploy/__init__.py	1
tools/deploy/app.py	705
tools/deploy/aurora/__init__.py	1
tools/deploy/aurora/api.thrift	578
tools/deploy/aurora/api/AuroraAdmin.py	2944
tools/deploy/aurora/api/AuroraSchedulerManager.py	2516
tools/deploy/aurora/api/ReadOnlyScheduler.py	2171
tools/deploy/aurora/api/__init__.py	1
tools/deploy/aurora/api/constants.py	53
tools/deploy/aurora/api/ttypes.py	7316
tools/deploy/aurora/client.py	74
tools/deploy/aurora/schema/__init__.py	1
tools/deploy/aurora/schema/aurora/__init__.py	1
tools/deploy/aurora/schema/aurora/base.py	99
tools/deploy/aurora/schema/thermos/__init__.py	1
tools/deploy/aurora/schema/thermos/schema.py	1
tools/deploy/aurora/schema/thermos/schema_base.py	57
tools/deploy/cluster.py	94
tools/deploy/main.py	38
tools/minicluster/__init__.py	1
tools/minicluster/client.py	38
tools/minicluster/config.yaml	89
tools/minicluster/docker_client.py	65
tools/minicluster/kind.py	61
tools/minicluster/kind_config.yaml	23
tools/minicluster/main.py	163
tools/minicluster/minicluster.py	645
tools/minicluster/print_utils.py	14
tools/minicluster/utils.py	58
tools/vcluster/__init__.py	1
tools/vcluster/color_print.py	14
tools/vcluster/config/default-small.yaml	154
tools/vcluster/config/default.yaml	160
tools/vcluster/config_generator.py	84
tools/vcluster/main.py	230
tools/vcluster/modules.py	191
tools/vcluster/peloton_helper.py	300
tools/vcluster/vcluster.py	293