204 lines
8.4 KiB
Go
204 lines
8.4 KiB
Go
package consul
|
|
|
|
import (
|
|
"bytes"
|
|
"context"
|
|
"fmt"
|
|
"os"
|
|
"strings"
|
|
"time"
|
|
|
|
capi "github.com/hashicorp/consul/api"
|
|
"github.com/hashicorp/nomad/api"
|
|
"github.com/hashicorp/nomad/e2e/e2eutil"
|
|
"github.com/hashicorp/nomad/e2e/framework"
|
|
"github.com/hashicorp/nomad/helper/uuid"
|
|
"github.com/stretchr/testify/require"
|
|
)
|
|
|
|
type ScriptChecksE2ETest struct {
|
|
framework.TC
|
|
jobIds []string
|
|
}
|
|
|
|
func (tc *ScriptChecksE2ETest) BeforeAll(f *framework.F) {
|
|
// Ensure cluster has leader before running tests
|
|
e2eutil.WaitForLeader(f.T(), tc.Nomad())
|
|
// Ensure that we have at least 1 client node in ready state
|
|
e2eutil.WaitForNodesReady(f.T(), tc.Nomad(), 1)
|
|
}
|
|
|
|
// TestGroupScriptCheck runs a job with a single task group with several services
|
|
// and associated script checks. It updates, stops, etc. the job to verify
|
|
// that script checks are re-registered as expected.
|
|
func (tc *ScriptChecksE2ETest) TestGroupScriptCheck(f *framework.F) {
|
|
nomadClient := tc.Nomad()
|
|
uuid := uuid.Generate()
|
|
require := require.New(f.T())
|
|
consulClient := tc.Consul()
|
|
|
|
jobId := "checks_group" + uuid[0:8]
|
|
tc.jobIds = append(tc.jobIds, jobId)
|
|
|
|
// Job run: verify that checks were registered in Consul
|
|
allocs := e2eutil.RegisterAndWaitForAllocs(f.T(),
|
|
nomadClient, "consul/input/checks_group.nomad", jobId, "")
|
|
require.Equal(1, len(allocs))
|
|
e2eutil.RequireConsulStatus(require, consulClient, "group-service-1", capi.HealthPassing)
|
|
e2eutil.RequireConsulStatus(require, consulClient, "group-service-2", capi.HealthWarning)
|
|
e2eutil.RequireConsulStatus(require, consulClient, "group-service-3", capi.HealthCritical)
|
|
|
|
// Check in warning state becomes healthy after check passes
|
|
_, _, err := exec(nomadClient, allocs,
|
|
[]string{"/bin/sh", "-c", "touch /tmp/${NOMAD_ALLOC_ID}-alive-2b"})
|
|
require.NoError(err)
|
|
e2eutil.RequireConsulStatus(require, consulClient, "group-service-2", capi.HealthPassing)
|
|
|
|
// Job update: verify checks are re-registered in Consul
|
|
allocs = e2eutil.RegisterAndWaitForAllocs(f.T(),
|
|
nomadClient, "consul/input/checks_group_update.nomad", jobId, "")
|
|
require.Equal(1, len(allocs))
|
|
e2eutil.RequireConsulStatus(require, consulClient, "group-service-1", capi.HealthPassing)
|
|
e2eutil.RequireConsulStatus(require, consulClient, "group-service-2", capi.HealthPassing)
|
|
e2eutil.RequireConsulStatus(require, consulClient, "group-service-3", capi.HealthCritical)
|
|
|
|
// Verify we don't have any linger script checks running on the client
|
|
out, _, err := exec(nomadClient, allocs, []string{"pgrep", "sleep"})
|
|
require.NoError(err)
|
|
running := strings.Split(strings.TrimSpace(out.String()), "\n")
|
|
require.LessOrEqual(len(running), 2) // task itself + 1 check == 2
|
|
|
|
// Clean job stop: verify that checks were deregistered in Consul
|
|
nomadClient.Jobs().Deregister(jobId, false, nil) // nomad job stop
|
|
e2eutil.RequireConsulDeregistered(require, consulClient, "group-service-1")
|
|
e2eutil.RequireConsulDeregistered(require, consulClient, "group-service-2")
|
|
e2eutil.RequireConsulDeregistered(require, consulClient, "group-service-3")
|
|
|
|
// Restore for next test
|
|
allocs = e2eutil.RegisterAndWaitForAllocs(f.T(),
|
|
nomadClient, "consul/input/checks_group.nomad", jobId, "")
|
|
require.Equal(2, len(allocs))
|
|
e2eutil.RequireConsulStatus(require, consulClient, "group-service-1", capi.HealthPassing)
|
|
e2eutil.RequireConsulStatus(require, consulClient, "group-service-2", capi.HealthWarning)
|
|
e2eutil.RequireConsulStatus(require, consulClient, "group-service-3", capi.HealthCritical)
|
|
|
|
// Crash a task: verify that checks become healthy again
|
|
_, _, err = exec(nomadClient, allocs, []string{"pkill", "sleep"})
|
|
if err != nil && err.Error() != "plugin is shut down" {
|
|
require.FailNow("unexpected error: %v", err)
|
|
}
|
|
e2eutil.RequireConsulStatus(require, consulClient, "group-service-1", capi.HealthPassing)
|
|
e2eutil.RequireConsulStatus(require, consulClient, "group-service-2", capi.HealthWarning)
|
|
e2eutil.RequireConsulStatus(require, consulClient, "group-service-3", capi.HealthCritical)
|
|
|
|
// TODO(tgross) ...
|
|
// Restart client: verify that checks are re-registered
|
|
}
|
|
|
|
// TestTaskScriptCheck runs a job with a single task with several services
|
|
// and associated script checks. It updates, stops, etc. the job to verify
|
|
// that script checks are re-registered as expected.
|
|
func (tc *ScriptChecksE2ETest) TestTaskScriptCheck(f *framework.F) {
|
|
nomadClient := tc.Nomad()
|
|
uuid := uuid.Generate()
|
|
require := require.New(f.T())
|
|
consulClient := tc.Consul()
|
|
|
|
jobId := "checks_task" + uuid[0:8]
|
|
tc.jobIds = append(tc.jobIds, jobId)
|
|
|
|
// Job run: verify that checks were registered in Consul
|
|
allocs := e2eutil.RegisterAndWaitForAllocs(f.T(),
|
|
nomadClient, "consul/input/checks_task.nomad", jobId, "")
|
|
require.Equal(1, len(allocs))
|
|
e2eutil.RequireConsulStatus(require, consulClient, "task-service-1", capi.HealthPassing)
|
|
e2eutil.RequireConsulStatus(require, consulClient, "task-service-2", capi.HealthWarning)
|
|
e2eutil.RequireConsulStatus(require, consulClient, "task-service-3", capi.HealthCritical)
|
|
|
|
// Check in warning state becomes healthy after check passes
|
|
_, _, err := exec(nomadClient, allocs,
|
|
[]string{"/bin/sh", "-c", "touch ${NOMAD_TASK_DIR}/alive-2b"})
|
|
require.NoError(err)
|
|
e2eutil.RequireConsulStatus(require, consulClient, "task-service-2", capi.HealthPassing)
|
|
|
|
// Job update: verify checks are re-registered in Consul
|
|
allocs = e2eutil.RegisterAndWaitForAllocs(f.T(),
|
|
nomadClient, "consul/input/checks_task_update.nomad", jobId, "")
|
|
require.Equal(1, len(allocs))
|
|
e2eutil.RequireConsulStatus(require, consulClient, "task-service-1", capi.HealthPassing)
|
|
e2eutil.RequireConsulStatus(require, consulClient, "task-service-2", capi.HealthPassing)
|
|
e2eutil.RequireConsulStatus(require, consulClient, "task-service-3", capi.HealthCritical)
|
|
|
|
// Verify we don't have any linger script checks running on the client
|
|
out, _, err := exec(nomadClient, allocs, []string{"pgrep", "sleep"})
|
|
require.NoError(err)
|
|
running := strings.Split(strings.TrimSpace(out.String()), "\n")
|
|
require.LessOrEqual(len(running), 2) // task itself + 1 check == 2
|
|
|
|
// Clean job stop: verify that checks were deregistered in Consul
|
|
nomadClient.Jobs().Deregister(jobId, false, nil) // nomad job stop
|
|
e2eutil.RequireConsulDeregistered(require, consulClient, "task-service-1")
|
|
e2eutil.RequireConsulDeregistered(require, consulClient, "task-service-2")
|
|
e2eutil.RequireConsulDeregistered(require, consulClient, "task-service-3")
|
|
|
|
// Restore for next test
|
|
allocs = e2eutil.RegisterAndWaitForAllocs(f.T(),
|
|
nomadClient, "consul/input/checks_task.nomad", jobId, "")
|
|
require.Equal(2, len(allocs))
|
|
e2eutil.RequireConsulStatus(require, consulClient, "task-service-1", capi.HealthPassing)
|
|
e2eutil.RequireConsulStatus(require, consulClient, "task-service-2", capi.HealthWarning)
|
|
e2eutil.RequireConsulStatus(require, consulClient, "task-service-3", capi.HealthCritical)
|
|
|
|
// Crash a task: verify that checks become healthy again
|
|
_, _, err = exec(nomadClient, allocs, []string{"pkill", "sleep"})
|
|
if err != nil && err.Error() != "plugin is shut down" {
|
|
require.FailNow("unexpected error: %v", err)
|
|
}
|
|
e2eutil.RequireConsulStatus(require, consulClient, "task-service-1", capi.HealthPassing)
|
|
e2eutil.RequireConsulStatus(require, consulClient, "task-service-2", capi.HealthWarning)
|
|
e2eutil.RequireConsulStatus(require, consulClient, "task-service-3", capi.HealthCritical)
|
|
|
|
// TODO(tgross) ...
|
|
// Restart client: verify that checks are re-registered
|
|
}
|
|
|
|
func (tc *ScriptChecksE2ETest) AfterEach(f *framework.F) {
|
|
nomadClient := tc.Nomad()
|
|
jobs := nomadClient.Jobs()
|
|
// Stop all jobs in test
|
|
for _, id := range tc.jobIds {
|
|
jobs.Deregister(id, true, nil)
|
|
}
|
|
// Garbage collect
|
|
nomadClient.System().GarbageCollect()
|
|
}
|
|
|
|
func exec(client *api.Client, allocs []*api.AllocationListStub, command []string) (bytes.Buffer, bytes.Buffer, error) {
|
|
ctx, cancelFn := context.WithTimeout(context.Background(), 5*time.Second)
|
|
defer cancelFn()
|
|
|
|
// we're getting a list of from the registration call here but
|
|
// one of them might be stopped or stopping, which will return
|
|
// an error if we try to exec into it.
|
|
var alloc *api.Allocation
|
|
for _, stub := range allocs {
|
|
if stub.DesiredStatus == "run" {
|
|
alloc = &api.Allocation{
|
|
ID: stub.ID,
|
|
Namespace: stub.Namespace,
|
|
NodeID: stub.NodeID,
|
|
}
|
|
}
|
|
}
|
|
var stdout, stderr bytes.Buffer
|
|
if alloc == nil {
|
|
return stdout, stderr, fmt.Errorf("no allocation ready for exec")
|
|
}
|
|
_, err := client.Allocations().Exec(ctx,
|
|
alloc, "test", false,
|
|
command,
|
|
os.Stdin, &stdout, &stderr,
|
|
make(chan api.TerminalSize), nil)
|
|
return stdout, stderr, err
|
|
}
|