Home
last modified time | relevance | path

Searched refs:TaskGroups (Results 1 – 25 of 310) sorted by relevance

12345678910>>...13

/dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/nomad/scheduler/
H A Dreconcile_test.go2009 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 Dutil_test.go383 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 Dstack_test.go53 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 Dreconcile_test.go2006 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 Dstack_test.go53 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 Dutil_test.go164 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 Dalloc_runner_test.go60 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 Dalloc_runner_test.go59 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 Djob_endpoint_hook_connect_test.go55 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 Ddeployment_endpoint_test.go295 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 Ddeployments_watcher_test.go546 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 Ddeployments_watcher_test.go398 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 Denvoy_version_hook_test.go230 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 Dtask_runner_test.go67 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 Dparse_test.go101 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 Djob_endpoint_hook_connect_test.go67 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 Ddeployment_endpoint_test.go295 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 Dtask-groups.cc44 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 Dparse_test.go361 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 Dwatch_jobs_test.go117 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 Dwatch_jobs_test.go117 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 Denv_test.go55 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 Dalloc_endpoint_test.go37 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 Dtracker_test.go25 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 Dalloc_endpoint_test.go37 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 …]

12345678910>>...13