/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/scheduler/ |
H A D | reconcile_test.go | 2009 d.TaskGroups[job.TaskGroups[0].Name] = s 2115 d.TaskGroups[job.TaskGroups[0].Name] = s 2242 d.TaskGroups[job.TaskGroups[0].Name] = s 2965 d.TaskGroups[job.TaskGroups[0].Name] = s 3038 d.TaskGroups[job.TaskGroups[0].Name] = s 3111 d.TaskGroups[job.TaskGroups[0].Name] = s 3277 job.TaskGroups = append(job.TaskGroups, job.TaskGroups[0].Copy()) 3444 d.TaskGroups[job.TaskGroups[0].Name] = s 3507 d.TaskGroups[job.TaskGroups[0].Name] = s 3581 d.TaskGroups[job.TaskGroups[0].Name] = s [all …]
|
H A D | util_test.go | 383 name := j1.TaskGroups[0].Name 451 name := j1.TaskGroups[0].Name 516 name := j1.TaskGroups[0].Name 523 j3.TaskGroups[0].Tasks[0].Name = "foo" 531 j5.TaskGroups[0].Tasks = append(j5.TaskGroups[0].Tasks, 532 j5.TaskGroups[0].Tasks[0]) 548 j8.TaskGroups[0].Tasks[0].User = "foo" 743 *tg = *job.TaskGroups[0] 798 *tg = *job.TaskGroups[0] 828 TaskGroup: job.TaskGroups[0].Name, [all …]
|
H A D | stack_test.go | 53 stack.Select(job.TaskGroups[0], selectOptions) 110 node := stack.Select(job.TaskGroups[0], selectOptions) 182 n1 := stack.Select(job.TaskGroups[0], selectOptions) 192 n2 := stack.Select(job.TaskGroups[0], selectOptions) 220 job.TaskGroups[0].Tasks[0].Driver = "foo" 224 node := stack.Select(job.TaskGroups[0], selectOptions) 253 node := stack.Select(job.TaskGroups[0], selectOptions) 391 n1 := stack.Select(job.TaskGroups[0], selectOptions) 401 n2 := stack.Select(job.TaskGroups[0], selectOptions) 425 job.TaskGroups[0].Tasks[0].Driver = "foo" [all …]
|
/dports/sysutils/nomad/nomad-1.1.0/scheduler/ |
H A D | reconcile_test.go | 2006 d.TaskGroups[job.TaskGroups[0].Name] = s 2112 d.TaskGroups[job.TaskGroups[0].Name] = s 2239 d.TaskGroups[job.TaskGroups[0].Name] = s 2962 d.TaskGroups[job.TaskGroups[0].Name] = s 3034 d.TaskGroups[job.TaskGroups[0].Name] = s 3107 d.TaskGroups[job.TaskGroups[0].Name] = s 3273 job.TaskGroups = append(job.TaskGroups, job.TaskGroups[0].Copy()) 3440 d.TaskGroups[job.TaskGroups[0].Name] = s 3503 d.TaskGroups[job.TaskGroups[0].Name] = s 3577 d.TaskGroups[job.TaskGroups[0].Name] = s [all …]
|
H A D | stack_test.go | 53 stack.Select(job.TaskGroups[0], selectOptions) 110 node := stack.Select(job.TaskGroups[0], selectOptions) 157 option = stack.Select(job.TaskGroups[0], selectOptions) 182 n1 := stack.Select(job.TaskGroups[0], selectOptions) 192 n2 := stack.Select(job.TaskGroups[0], selectOptions) 220 job.TaskGroups[0].Tasks[0].Driver = "foo" 224 node := stack.Select(job.TaskGroups[0], selectOptions) 287 job.TaskGroups[0].Count = 2 467 n1 := stack.Select(job.TaskGroups[0], selectOptions) 477 n2 := stack.Select(job.TaskGroups[0], selectOptions) [all …]
|
H A D | util_test.go | 164 job.TaskGroups[0].Count = 1 445 name := j1.TaskGroups[0].Name 513 name := j1.TaskGroups[0].Name 578 name := j1.TaskGroups[0].Name 593 j5.TaskGroups[0].Tasks = append(j5.TaskGroups[0].Tasks, 594 j5.TaskGroups[0].Tasks[0]) 952 *tg = *job.TaskGroups[0] 1005 tg := job.TaskGroups[0] 1064 *tg = *job.TaskGroups[0] 1094 TaskGroup: job.TaskGroups[0].Name, [all …]
|
/dports/sysutils/nomad/nomad-1.1.0/client/allocrunner/ |
H A D | alloc_runner_test.go | 60 task := alloc.Job.TaskGroups[0].Tasks[0] 75 alloc.Job.TaskGroups[0].Tasks = append(alloc.Job.TaskGroups[0].Tasks, task2) 489 tg := alloc.Job.TaskGroups[0] 497 task := alloc.Job.TaskGroups[0].Tasks[0] 512 alloc.Job.TaskGroups[0].Tasks = append(alloc.Job.TaskGroups[0].Tasks, task2) 640 alloc.Job.TaskGroups[0].Tasks = append(alloc.Job.TaskGroups[0].Tasks, task2, task3) 735 alloc.Job.TaskGroups[0].Tasks = append(alloc.Job.TaskGroups[0].Tasks, task2) 887 tg := alloc.Job.TaskGroups[0] 938 alloc.Job.TaskGroups[0].Tasks = append(alloc.Job.TaskGroups[0].Tasks, task.Copy()) 1258 alloc.Job.TaskGroups[0].Tasks = append(alloc.Job.TaskGroups[0].Tasks, badtask) [all …]
|
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/client/allocrunner/ |
H A D | alloc_runner_test.go | 59 task := alloc.Job.TaskGroups[0].Tasks[0] 74 alloc.Job.TaskGroups[0].Tasks = append(alloc.Job.TaskGroups[0].Tasks, task2) 152 tg := alloc.Job.TaskGroups[0] 160 task := alloc.Job.TaskGroups[0].Tasks[0] 175 alloc.Job.TaskGroups[0].Tasks = append(alloc.Job.TaskGroups[0].Tasks, task2) 302 alloc.Job.TaskGroups[0].Tasks = append(alloc.Job.TaskGroups[0].Tasks, task2, task3) 396 alloc.Job.TaskGroups[0].Tasks = append(alloc.Job.TaskGroups[0].Tasks, task2) 509 tg := alloc.Job.TaskGroups[0] 560 alloc.Job.TaskGroups[0].Tasks = append(alloc.Job.TaskGroups[0].Tasks, task.Copy()) 878 alloc.Job.TaskGroups[0].Tasks = append(alloc.Job.TaskGroups[0].Tasks, badtask) [all …]
|
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/nomad/ |
H A D | job_endpoint_hook_connect_test.go | 55 job.TaskGroups[0] = &structs.TaskGroup{ 80 tgOut := job.TaskGroups[0].Copy() 100 require.NoError(t, groupConnectHook(job, job.TaskGroups[0])) 101 require.Exactly(t, tgOut, job.TaskGroups[0]) 104 require.NoError(t, groupConnectHook(job, job.TaskGroups[0])) 105 require.Exactly(t, tgOut, job.TaskGroups[0]) 120 j.TaskGroups[0].Services[0].Name = "${JOB}-api" 125 require.Len(t, j.TaskGroups[0].Tasks, 2) 126 require.Equal(t, "connect-proxy-my-job-api", j.TaskGroups[0].Tasks[1].Name)
|
H A D | deployment_endpoint_test.go | 295 j.TaskGroups[0].Update.MaxParallel = 2 306 d.TaskGroups["web"].AutoRevert = true 483 j.TaskGroups[0].Update.MaxParallel = 2 484 j.TaskGroups[0].Update.Canary = 1 548 j.TaskGroups[0].Update.MaxParallel = 2 549 j.TaskGroups[0].Update.Canary = 1 639 j.TaskGroups[0].Update.MaxParallel = 2 707 j.TaskGroups[0].Update.MaxParallel = 2 803 j.TaskGroups[0].Update.MaxParallel = 2 813 d.TaskGroups["web"].AutoRevert = true [all …]
|
/dports/sysutils/nomad/nomad-1.1.0/nomad/deploymentwatcher/ |
H A D | deployments_watcher_test.go | 546 j.TaskGroups[0].Update = upd 1071 j.TaskGroups[0].Count = 1 1074 j.TaskGroups = append(j.TaskGroups, j.TaskGroups[0].Copy()) 1075 j.TaskGroups[1].Name = "foo" 1082 d.TaskGroups["foo"] = d.TaskGroups["web"].Copy() 1217 state := dout.TaskGroups["web"] 1259 j.TaskGroups[0].Count = 2 1315 state := dout.TaskGroups["web"] 1351 j.TaskGroups[0].Name = "group1" 1356 j.TaskGroups = append(j.TaskGroups, j.TaskGroups[0].Copy()) [all …]
|
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/nomad/deploymentwatcher/ |
H A D | deployments_watcher_test.go | 398 j.TaskGroups[0].Update.Canary = 1 454 j.TaskGroups[0].Update.Canary = 2 510 j.TaskGroups[0].Update = upd 1021 j.TaskGroups[0].Count = 1 1024 j.TaskGroups = append(j.TaskGroups, j.TaskGroups[0].Copy()) 1025 j.TaskGroups[1].Name = "foo" 1032 d.TaskGroups["foo"] = d.TaskGroups["web"].Copy() 1124 j.TaskGroups[0].Update.Canary = 1 1163 state := dout.TaskGroups["web"] 1201 j.TaskGroups[0].Count = 2 [all …]
|
/dports/sysutils/nomad/nomad-1.1.0/client/allocrunner/taskrunner/ |
H A D | envoy_version_hook_test.go | 230 alloc.Job.TaskGroups[0].Tasks[0] = mock.ConnectSidecarTask() 247 Task: alloc.Job.TaskGroups[0].Tasks[0], 273 alloc.Job.TaskGroups[0].Tasks[0] = mock.ConnectSidecarTask() 291 Task: alloc.Job.TaskGroups[0].Tasks[0], 317 alloc.Job.TaskGroups[0].Tasks[0] = mock.ConnectSidecarTask() 318 alloc.Job.TaskGroups[0].Tasks[0].Driver = "exec" 338 Task: alloc.Job.TaskGroups[0].Tasks[0], 364 alloc.Job.TaskGroups[0].Tasks[0] = mock.ConnectSidecarTask() 379 Task: alloc.Job.TaskGroups[0].Tasks[0], 405 alloc.Job.TaskGroups[0].Tasks[0] = mock.ConnectSidecarTask() [all …]
|
H A D | task_runner_test.go | 67 for _, tg := range alloc.Job.TaskGroups { 175 alloc.Job.TaskGroups[0].Count = 1 211 alloc.Job.TaskGroups[0].Count = 1 212 task := alloc.Job.TaskGroups[0].Tasks[0] 261 alloc.Job.TaskGroups[0].Count = 1 262 task := alloc.Job.TaskGroups[0].Tasks[0] 315 task := alloc.Job.TaskGroups[0].Tasks[0] 719 alloc.Job.TaskGroups[0].Count = 1 1130 tg := alloc.Job.TaskGroups[0] 1371 tg := alloc.Job.TaskGroups[0] [all …]
|
/dports/sysutils/nomad/nomad-1.1.0/jobspec/ |
H A D | parse_test.go | 101 TaskGroups: []*api.TaskGroup{ 544 TaskGroups: []*api.TaskGroup{ 578 TaskGroups: []*api.TaskGroup{ 614 TaskGroups: []*api.TaskGroup{ 639 TaskGroups: []*api.TaskGroup{ 751 TaskGroups: []*api.TaskGroup{ 802 TaskGroups: []*api.TaskGroup{ 824 TaskGroups: []*api.TaskGroup{ 848 TaskGroups: []*api.TaskGroup{ 896 TaskGroups: []*api.TaskGroup{ [all …]
|
/dports/sysutils/nomad/nomad-1.1.0/nomad/ |
H A D | job_endpoint_hook_connect_test.go | 67 job.TaskGroups[0] = &structs.TaskGroup{ 87 tgExp := job.TaskGroups[0].Copy() 108 require.Exactly(t, tgExp, job.TaskGroups[0]) 112 require.Exactly(t, tgExp, job.TaskGroups[0]) 129 expTG := job.TaskGroups[0].Copy() 142 require.Exactly(t, expTG, job.TaskGroups[0]) 146 require.Exactly(t, expTG, job.TaskGroups[0]) 176 expTG := job.TaskGroups[0].Copy() 211 require.Exactly(t, expTG, job.TaskGroups[0]) 215 require.Exactly(t, expTG, job.TaskGroups[0]) [all …]
|
H A D | deployment_endpoint_test.go | 295 j.TaskGroups[0].Update.MaxParallel = 2 306 d.TaskGroups["web"].AutoRevert = true 483 j.TaskGroups[0].Update.MaxParallel = 2 484 j.TaskGroups[0].Update.Canary = 1 548 j.TaskGroups[0].Update.MaxParallel = 2 549 j.TaskGroups[0].Update.Canary = 1 639 j.TaskGroups[0].Update.MaxParallel = 2 707 j.TaskGroups[0].Update.MaxParallel = 2 803 j.TaskGroups[0].Update.MaxParallel = 2 813 d.TaskGroups["web"].AutoRevert = true [all …]
|
/dports/news/pan/pan-0.145/pan/tasks/ |
H A D | task-groups.cc | 44 TaskGroups :: TaskGroups (Data& data, const Quark& servername): in TaskGroups() function in TaskGroups 54 TaskGroups :: ~TaskGroups () in ~TaskGroups() 62 TaskGroups :: use_nntp (NNTP * nntp) in use_nntp() 77 TaskGroups :: on_nntp_line (NNTP * nntp, in on_nntp_line() 88 TaskGroups :: on_nntp_line_process (NNTP * nntp UNUSED, in on_nntp_line_process() 140 TaskGroups :: on_nntp_done (NNTP * nntp, in on_nntp_done()
|
/dports/sysutils/nomad/nomad-1.1.0/jobspec2/ |
H A D | parse_test.go | 361 require.Len(t, out.TaskGroups, 3) 362 require.Equal(t, "groupA", *out.TaskGroups[0].Name) 363 require.Equal(t, "groupB", *out.TaskGroups[1].Name) 364 require.Equal(t, "groupC", *out.TaskGroups[2].Name) 365 require.Equal(t, 1, *out.TaskGroups[0].Tasks[0].Resources.CPU) 371 require.Equal(t, "id:1", out.TaskGroups[0].Tasks[0].Env["ID"]) 372 require.Equal(t, "id:2", out.TaskGroups[1].Tasks[0].Env["ID"]) 581 TaskGroups: []*api.TaskGroup{ 607 TaskGroups: []*api.TaskGroup{ 633 TaskGroups: []*api.TaskGroup{ [all …]
|
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/nomad/drainer/ |
H A D | watch_jobs_test.go | 117 a.TaskGroup = job.TaskGroups[0].Name 129 job.TaskGroups[0].Migrate.MaxParallel = 3 130 job.TaskGroups[0].Count = count 558 job.TaskGroups[0].Count = 10 560 job.TaskGroups[0].Count = tc.Count 563 job.TaskGroups[0].Migrate.MaxParallel = tc.MaxParallel 575 a.TaskGroup = job.TaskGroups[0].Name 624 a.TaskGroup = job.TaskGroups[0].Name 650 require.Nil(handleTaskGroup(snap, true, job.TaskGroups[0], allocs, 101, res)) 662 require.Nil(handleTaskGroup(snap, true, job.TaskGroups[0], allocs, 103, res)) [all …]
|
/dports/sysutils/nomad/nomad-1.1.0/nomad/drainer/ |
H A D | watch_jobs_test.go | 117 a.TaskGroup = job.TaskGroups[0].Name 129 job.TaskGroups[0].Migrate.MaxParallel = 3 130 job.TaskGroups[0].Count = count 558 job.TaskGroups[0].Count = 10 560 job.TaskGroups[0].Count = tc.Count 563 job.TaskGroups[0].Migrate.MaxParallel = tc.MaxParallel 575 a.TaskGroup = job.TaskGroups[0].Name 624 a.TaskGroup = job.TaskGroups[0].Name 650 require.Nil(handleTaskGroup(snap, true, job.TaskGroups[0], allocs, 101, res)) 662 require.Nil(handleTaskGroup(snap, true, job.TaskGroups[0], allocs, 103, res)) [all …]
|
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/client/taskenv/ |
H A D | env_test.go | 55 task := mock.Job().TaskGroups[0].Tasks[0] 165 task := a.Job.TaskGroups[0].Tasks[0] 269 task := a.Job.TaskGroups[0].Tasks[0] 374 task := a.Job.TaskGroups[0].Tasks[0] 496 env := NewBuilder(n, a, a.Job.TaskGroups[0].Tasks[0], "global") 557 task := a.Job.TaskGroups[0].Tasks[0] 640 task := a.Job.TaskGroups[0].Tasks[0] 684 task := a.Job.TaskGroups[0].Tasks[0] 704 task := a.Job.TaskGroups[0].Tasks[0] 757 task := a.Job.TaskGroups[0].Tasks[0] [all …]
|
/dports/sysutils/nomad/nomad-1.1.0/client/ |
H A D | alloc_endpoint_test.go | 37 a.Job.TaskGroups[0].Tasks[0].Driver = "mock_driver" 83 job.TaskGroups[0].Count = 1 223 a.Job.TaskGroups[0].RestartPolicy = rp 266 job.TaskGroups[0].Count = 1 365 job.TaskGroups[0].Count = 1 470 job.TaskGroups[0].Count = 1 545 job.TaskGroups[0].Count = 1 766 job.TaskGroups[0].Count = 1 885 job.TaskGroups[0].Count = 1 1034 job.TaskGroups[0].Count = 1 [all …]
|
/dports/sysutils/nomad/nomad-1.1.0/client/allochealth/ |
H A D | tracker_test.go | 25 alloc.Job.TaskGroups[0].Migrate.MinHealthyTime = 1 // let's speed things up 26 task := alloc.Job.TaskGroups[0].Tasks[0] 96 alloc.Job.TaskGroups[0].Migrate.MinHealthyTime = 1 // let's speed things up 136 alloc.Job.TaskGroups[0].Migrate.MinHealthyTime = 1 // let's speed things up 137 task := alloc.Job.TaskGroups[0].Tasks[0] 277 alloc.Job.TaskGroups[0].Migrate.MinHealthyTime = 1 // let's speed things up 278 task := alloc.Job.TaskGroups[0].Tasks[0] 284 alloc.Job.TaskGroups[0].Tasks = append(alloc.Job.TaskGroups[0].Tasks, task2) 425 alloc.Job.TaskGroups[0].Migrate.MinHealthyTime = 1 // let's speed things up 426 task := alloc.Job.TaskGroups[0].Tasks[0]
|
/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/client/ |
H A D | alloc_endpoint_test.go | 37 a.Job.TaskGroups[0].Tasks[0].Driver = "mock_driver" 83 job.TaskGroups[0].Count = 1 264 job.TaskGroups[0].Count = 1 361 job.TaskGroups[0].Count = 1 466 job.TaskGroups[0].Count = 1 541 job.TaskGroups[0].Count = 1 762 job.TaskGroups[0].Count = 1 881 job.TaskGroups[0].Count = 1 936 Task: job.TaskGroups[0].Tasks[0].Name, 1030 job.TaskGroups[0].Count = 1 [all …]
|