mirror of
https://github.com/kemko/nomad.git
synced 2026-01-06 10:25:42 +03:00
go vet
This commit is contained in:
@@ -136,7 +136,6 @@ func (l *LogRotator) Start(r io.Reader) error {
|
||||
}
|
||||
}
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
// PurgeOldFiles removes older files and keeps only the last N files rotated for
|
||||
|
||||
@@ -320,8 +320,6 @@ func (r *TaskRunner) run() {
|
||||
// Set force start because we are restarting the task.
|
||||
forceStart = true
|
||||
}
|
||||
|
||||
return
|
||||
}
|
||||
|
||||
// handleUpdate takes an updated allocation and updates internal state to
|
||||
|
||||
@@ -259,8 +259,6 @@ SCAN:
|
||||
case <-b.duplicateCh:
|
||||
goto SCAN
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
|
||||
// Flush is used to clear the state of blocked evaluations.
|
||||
|
||||
@@ -580,7 +580,7 @@ func TestServiceSched_JobModify_InPlace(t *testing.T) {
|
||||
h.AssertEvalStatus(t, structs.EvalStatusComplete)
|
||||
|
||||
// Verify the network did not change
|
||||
rp := structs.Port{"main", 5000}
|
||||
rp := structs.Port{Label: "main", Value: 5000}
|
||||
for _, alloc := range out {
|
||||
for _, resources := range alloc.TaskResources {
|
||||
if resources.Networks[0].ReservedPorts[0] != rp {
|
||||
|
||||
@@ -468,7 +468,7 @@ func TestSystemSched_JobModify_InPlace(t *testing.T) {
|
||||
h.AssertEvalStatus(t, structs.EvalStatusComplete)
|
||||
|
||||
// Verify the network did not change
|
||||
rp := structs.Port{"main", 5000}
|
||||
rp := structs.Port{Label: "main", Value: 5000}
|
||||
for _, alloc := range out {
|
||||
for _, resources := range alloc.TaskResources {
|
||||
if resources.Networks[0].ReservedPorts[0] != rp {
|
||||
|
||||
Reference in New Issue
Block a user