118 lines
2.3 KiB
Go
118 lines
2.3 KiB
Go
package api
|
|
|
|
import (
|
|
"reflect"
|
|
"testing"
|
|
)
|
|
|
|
func TestCompose(t *testing.T) {
|
|
// Compose a task
|
|
task := NewTask("task1", "exec").
|
|
SetConfig("foo", "bar").
|
|
SetMeta("foo", "bar").
|
|
Constrain(NewConstraint("kernel.name", "=", "linux")).
|
|
Require(&Resources{
|
|
CPU: 1250,
|
|
MemoryMB: 1024,
|
|
DiskMB: 2048,
|
|
IOPS: 500,
|
|
Networks: []*NetworkResource{
|
|
&NetworkResource{
|
|
CIDR: "0.0.0.0/0",
|
|
MBits: 100,
|
|
ReservedPorts: []Port{{"", 80}, {"", 443}},
|
|
},
|
|
},
|
|
})
|
|
|
|
// Compose a task group
|
|
grp := NewTaskGroup("grp1", 2).
|
|
Constrain(NewConstraint("kernel.name", "=", "linux")).
|
|
SetMeta("foo", "bar").
|
|
AddTask(task)
|
|
|
|
// Compose a job
|
|
job := NewServiceJob("job1", "myjob", "region1", 2).
|
|
SetMeta("foo", "bar").
|
|
AddDatacenter("dc1").
|
|
Constrain(NewConstraint("kernel.name", "=", "linux")).
|
|
AddTaskGroup(grp)
|
|
|
|
// Check that the composed result looks correct
|
|
expect := &Job{
|
|
Region: "region1",
|
|
ID: "job1",
|
|
Name: "myjob",
|
|
Type: JobTypeService,
|
|
Priority: 2,
|
|
Datacenters: []string{
|
|
"dc1",
|
|
},
|
|
Meta: map[string]string{
|
|
"foo": "bar",
|
|
},
|
|
Constraints: []*Constraint{
|
|
&Constraint{
|
|
LTarget: "kernel.name",
|
|
RTarget: "linux",
|
|
Operand: "=",
|
|
},
|
|
},
|
|
TaskGroups: []*TaskGroup{
|
|
&TaskGroup{
|
|
Name: "grp1",
|
|
Count: 2,
|
|
Constraints: []*Constraint{
|
|
&Constraint{
|
|
LTarget: "kernel.name",
|
|
RTarget: "linux",
|
|
Operand: "=",
|
|
},
|
|
},
|
|
RestartPolicy: NewRestartPolicy(),
|
|
Tasks: []*Task{
|
|
&Task{
|
|
Name: "task1",
|
|
Driver: "exec",
|
|
Resources: &Resources{
|
|
CPU: 1250,
|
|
MemoryMB: 1024,
|
|
DiskMB: 2048,
|
|
IOPS: 500,
|
|
Networks: []*NetworkResource{
|
|
&NetworkResource{
|
|
CIDR: "0.0.0.0/0",
|
|
MBits: 100,
|
|
ReservedPorts: []Port{
|
|
{"", 80},
|
|
{"", 443},
|
|
},
|
|
},
|
|
},
|
|
},
|
|
Constraints: []*Constraint{
|
|
&Constraint{
|
|
LTarget: "kernel.name",
|
|
RTarget: "linux",
|
|
Operand: "=",
|
|
},
|
|
},
|
|
Config: map[string]interface{}{
|
|
"foo": "bar",
|
|
},
|
|
Meta: map[string]string{
|
|
"foo": "bar",
|
|
},
|
|
},
|
|
},
|
|
Meta: map[string]string{
|
|
"foo": "bar",
|
|
},
|
|
},
|
|
},
|
|
}
|
|
if !reflect.DeepEqual(job, expect) {
|
|
t.Fatalf("expect: %#v, got: %#v", expect, job)
|
|
}
|
|
}
|