diff --git a/api/ifaces/listeners.go b/api/ifaces/listeners.go index 520cfa124..7c2479852 100644 --- a/api/ifaces/listeners.go +++ b/api/ifaces/listeners.go @@ -1,8 +1,9 @@ package ifaces import ( + "context" + "github.com/iron-io/functions/api/models" - "golang.org/x/net/context" ) type AppListener interface { diff --git a/api/models/mq.go b/api/models/mq.go index 30ad389ca..8528f3a98 100644 --- a/api/models/mq.go +++ b/api/models/mq.go @@ -1,8 +1,6 @@ package models -import ( - "golang.org/x/net/context" -) +import "context" // Titan uses a Message Queue to impose a total ordering on jobs that it will // execute in order. Tasks are added to the queue via the Push() interface. The diff --git a/api/mqs/bolt.go b/api/mqs/bolt.go index b252c637a..ff2f46824 100644 --- a/api/mqs/bolt.go +++ b/api/mqs/bolt.go @@ -1,6 +1,7 @@ package mqs import ( + "context" "encoding/binary" "encoding/json" "errors" @@ -14,7 +15,6 @@ import ( "github.com/boltdb/bolt" "github.com/iron-io/functions/api/models" "github.com/iron-io/runner/common" - "golang.org/x/net/context" ) type BoltDbMQ struct { @@ -104,7 +104,7 @@ func NewBoltMQ(url *url.URL) (*BoltDbMQ, error) { func (mq *BoltDbMQ) Start() { go func() { // It would be nice to switch to a tick-less, next-event Timer based model. - for _ = range mq.ticker.C { + for range mq.ticker.C { err := mq.db.Update(func(tx *bolt.Tx) error { now := uint64(time.Now().UnixNano()) for i := 0; i < 3; i++ { diff --git a/api/mqs/memory.go b/api/mqs/memory.go index 7b21870de..bcb8b4da1 100644 --- a/api/mqs/memory.go +++ b/api/mqs/memory.go @@ -1,6 +1,7 @@ package mqs import ( + "context" "errors" "math/rand" "sync" @@ -10,7 +11,6 @@ import ( "github.com/google/btree" "github.com/iron-io/functions/api/models" "github.com/iron-io/runner/common" - "golang.org/x/net/context" ) type MemoryMQ struct { @@ -59,7 +59,7 @@ func NewMemoryMQ() *MemoryMQ { func (mq *MemoryMQ) start() { // start goroutine to check for delayed jobs and put them onto regular queue when ready go func() { - for _ = range mq.Ticker.C { + for range mq.Ticker.C { ji := &TaskItem{ StartAt: time.Now(), } @@ -80,7 +80,7 @@ func (mq *MemoryMQ) start() { // start goroutine to check for messages that have timed out and put them back onto regular queue // TODO: this should be like the delayed messages above. Could even be the same thing as delayed messages, but remove them if job is completed. go func() { - for _ = range mq.Ticker.C { + for range mq.Ticker.C { ji := &TaskItem{ StartAt: time.Now(), } diff --git a/api/mqs/mock.go b/api/mqs/mock.go index 810c26aac..55d5c257c 100644 --- a/api/mqs/mock.go +++ b/api/mqs/mock.go @@ -1,8 +1,9 @@ package mqs import ( + "context" + "github.com/iron-io/functions/api/models" - "golang.org/x/net/context" ) type Mock struct { diff --git a/api/mqs/redis.go b/api/mqs/redis.go index 61cc61891..6a3b42712 100644 --- a/api/mqs/redis.go +++ b/api/mqs/redis.go @@ -1,6 +1,7 @@ package mqs import ( + "context" "encoding/json" "errors" "fmt" @@ -12,7 +13,6 @@ import ( "github.com/garyburd/redigo/redis" "github.com/iron-io/functions/api/models" "github.com/iron-io/runner/common" - "golang.org/x/net/context" ) type RedisMQ struct { @@ -162,7 +162,7 @@ func (mq *RedisMQ) start() { logrus.WithError(err).Fatal("Could not start redis MQ reservation system") } - for _ = range mq.ticker.C { + for range mq.ticker.C { mq.processPendingReservations(conn) mq.processDelayedTasks(conn) } diff --git a/api/runner/async_runner.go b/api/runner/async_runner.go index 20e6600c0..39ce36346 100644 --- a/api/runner/async_runner.go +++ b/api/runner/async_runner.go @@ -2,6 +2,7 @@ package runner import ( "bytes" + "context" "encoding/json" "errors" "io/ioutil" @@ -13,7 +14,6 @@ import ( log "github.com/Sirupsen/logrus" "github.com/iron-io/functions/api/models" - "golang.org/x/net/context" ) func getTask(url string) (*models.Task, error) { diff --git a/api/runner/async_runner_test.go b/api/runner/async_runner_test.go index 292690cd0..196358ae2 100644 --- a/api/runner/async_runner_test.go +++ b/api/runner/async_runner_test.go @@ -1,6 +1,7 @@ package runner import ( + "context" "encoding/json" "fmt" "io/ioutil" @@ -15,7 +16,6 @@ import ( "github.com/gin-gonic/gin" "github.com/iron-io/functions/api/models" "github.com/iron-io/functions/api/mqs" - "golang.org/x/net/context" ) func getMockTask() models.Task { @@ -97,7 +97,7 @@ func TestGetTask(t *testing.T) { func TestGetTaskError(t *testing.T) { tests := []map[string]interface{}{ - map[string]interface{}{ + { "url": "/invalid", "task": getMockTask(), "error": "invalid character 'p' after top-level value", diff --git a/api/runner/metrics.go b/api/runner/metrics.go index ad96576bf..dd9b7949f 100644 --- a/api/runner/metrics.go +++ b/api/runner/metrics.go @@ -1,11 +1,11 @@ package runner import ( + "context" "time" "github.com/Sirupsen/logrus" "github.com/iron-io/runner/common" - "golang.org/x/net/context" ) type Logger interface { diff --git a/api/runner/runner.go b/api/runner/runner.go index dcbf7ca4b..178e119ee 100644 --- a/api/runner/runner.go +++ b/api/runner/runner.go @@ -2,6 +2,7 @@ package runner import ( "bufio" + "context" "errors" "fmt" "io" @@ -12,8 +13,6 @@ import ( "sync" "time" - "golang.org/x/net/context" - "github.com/Sirupsen/logrus" "github.com/iron-io/runner/common" "github.com/iron-io/runner/drivers" diff --git a/api/runner/runner_test.go b/api/runner/runner_test.go index 45b9858e6..6bcb54afb 100644 --- a/api/runner/runner_test.go +++ b/api/runner/runner_test.go @@ -2,12 +2,12 @@ package runner import ( "bytes" + "context" "fmt" "testing" "time" "github.com/iron-io/functions/api/models" - "golang.org/x/net/context" ) func TestRunnerHello(t *testing.T) { diff --git a/api/runner/task.go b/api/runner/task.go index 024ba5856..ad70b184e 100644 --- a/api/runner/task.go +++ b/api/runner/task.go @@ -1,10 +1,9 @@ package runner import ( + "context" "io" - "golang.org/x/net/context" - dockercli "github.com/fsouza/go-dockerclient" "github.com/iron-io/runner/common" "github.com/iron-io/runner/drivers" diff --git a/api/server/apps_create.go b/api/server/apps_create.go index 922f71cb5..804aee564 100644 --- a/api/server/apps_create.go +++ b/api/server/apps_create.go @@ -1,10 +1,9 @@ package server import ( + "context" "net/http" - "golang.org/x/net/context" - "github.com/gin-gonic/gin" "github.com/iron-io/functions/api/models" "github.com/iron-io/runner/common" diff --git a/api/server/apps_delete.go b/api/server/apps_delete.go index 4cff5ea8e..302a38e0a 100644 --- a/api/server/apps_delete.go +++ b/api/server/apps_delete.go @@ -1,10 +1,9 @@ package server import ( + "context" "net/http" - "golang.org/x/net/context" - "github.com/gin-gonic/gin" "github.com/iron-io/functions/api/models" "github.com/iron-io/runner/common" diff --git a/api/server/apps_get.go b/api/server/apps_get.go index 96e46688d..95ff231ed 100644 --- a/api/server/apps_get.go +++ b/api/server/apps_get.go @@ -1,10 +1,9 @@ package server import ( + "context" "net/http" - "golang.org/x/net/context" - "github.com/gin-gonic/gin" "github.com/iron-io/functions/api/models" "github.com/iron-io/runner/common" diff --git a/api/server/apps_list.go b/api/server/apps_list.go index b7e9f31e5..881c25c49 100644 --- a/api/server/apps_list.go +++ b/api/server/apps_list.go @@ -1,10 +1,9 @@ package server import ( + "context" "net/http" - "golang.org/x/net/context" - "github.com/gin-gonic/gin" "github.com/iron-io/functions/api/models" "github.com/iron-io/runner/common" diff --git a/api/server/apps_update.go b/api/server/apps_update.go index a1f4e3e79..4b58775f4 100644 --- a/api/server/apps_update.go +++ b/api/server/apps_update.go @@ -1,10 +1,9 @@ package server import ( + "context" "net/http" - "golang.org/x/net/context" - "github.com/gin-gonic/gin" "github.com/iron-io/functions/api/models" "github.com/iron-io/runner/common" diff --git a/api/server/helpers.go b/api/server/helpers.go index f18c0181c..dc3481cf4 100644 --- a/api/server/helpers.go +++ b/api/server/helpers.go @@ -1,6 +1,7 @@ package server import ( + "context" "encoding/json" "io" "io/ioutil" @@ -8,8 +9,6 @@ import ( "net/http/httptest" "testing" - "golang.org/x/net/context" - "github.com/gin-gonic/gin" "github.com/iron-io/functions/api/models" "github.com/iron-io/functions/api/runner" diff --git a/api/server/routes_create.go b/api/server/routes_create.go index 97ef8af6a..01d1c3036 100644 --- a/api/server/routes_create.go +++ b/api/server/routes_create.go @@ -1,10 +1,9 @@ package server import ( + "context" "net/http" - "golang.org/x/net/context" - "github.com/gin-gonic/gin" "github.com/iron-io/functions/api/models" "github.com/iron-io/functions/api/runner" diff --git a/api/server/routes_delete.go b/api/server/routes_delete.go index 5c8641b65..c82fae7f2 100644 --- a/api/server/routes_delete.go +++ b/api/server/routes_delete.go @@ -1,10 +1,9 @@ package server import ( + "context" "net/http" - "golang.org/x/net/context" - "github.com/gin-gonic/gin" "github.com/iron-io/functions/api/models" "github.com/iron-io/runner/common" diff --git a/api/server/routes_get.go b/api/server/routes_get.go index 3a74c84b4..4ab175dac 100644 --- a/api/server/routes_get.go +++ b/api/server/routes_get.go @@ -1,10 +1,9 @@ package server import ( + "context" "net/http" - "golang.org/x/net/context" - "github.com/Sirupsen/logrus" "github.com/gin-gonic/gin" "github.com/iron-io/functions/api/models" diff --git a/api/server/routes_list.go b/api/server/routes_list.go index 5c63b7825..72baee4f1 100644 --- a/api/server/routes_list.go +++ b/api/server/routes_list.go @@ -1,10 +1,9 @@ package server import ( + "context" "net/http" - "golang.org/x/net/context" - "github.com/Sirupsen/logrus" "github.com/gin-gonic/gin" "github.com/iron-io/functions/api/models" diff --git a/api/server/routes_update.go b/api/server/routes_update.go index 8090d4d8e..93b0e23db 100644 --- a/api/server/routes_update.go +++ b/api/server/routes_update.go @@ -1,10 +1,9 @@ package server import ( + "context" "net/http" - "golang.org/x/net/context" - "github.com/gin-gonic/gin" "github.com/iron-io/functions/api/models" "github.com/iron-io/runner/common" diff --git a/api/server/runner.go b/api/server/runner.go index 1ccf61116..7fe219b23 100644 --- a/api/server/runner.go +++ b/api/server/runner.go @@ -2,16 +2,14 @@ package server import ( "bytes" + "context" + "encoding/json" "fmt" "io/ioutil" "net/http" "strings" "time" - "golang.org/x/net/context" - - "encoding/json" - "github.com/Sirupsen/logrus" "github.com/gin-gonic/gin" "github.com/iron-io/functions/api/models" diff --git a/api/server/runner_test.go b/api/server/runner_test.go index 6f17cac13..5deaacd7f 100644 --- a/api/server/runner_test.go +++ b/api/server/runner_test.go @@ -97,8 +97,8 @@ func TestRouteRunnerExecution(t *testing.T) { {Name: "myapp", Config: models.Config{}}, }, FakeRoutes: []*models.Route{ - {Path: "/myroute", AppName: "myapp", Image: "iron/hello", Headers: map[string][]string{"X-Function": []string{"Test"}}}, - {Path: "/myerror", AppName: "myapp", Image: "iron/error", Headers: map[string][]string{"X-Function": []string{"Test"}}}, + {Path: "/myroute", AppName: "myapp", Image: "iron/hello", Headers: map[string][]string{"X-Function": {"Test"}}}, + {Path: "/myerror", AppName: "myapp", Image: "iron/error", Headers: map[string][]string{"X-Function": {"Test"}}}, }, }, &mqs.Mock{}, testRunner(t)) router := testRouter() @@ -109,12 +109,12 @@ func TestRouteRunnerExecution(t *testing.T) { expectedCode int expectedHeaders map[string][]string }{ - {"/r/myapp/myroute", ``, http.StatusOK, map[string][]string{"X-Function": []string{"Test"}}}, - {"/r/myapp/myerror", ``, http.StatusInternalServerError, map[string][]string{"X-Function": []string{"Test"}}}, + {"/r/myapp/myroute", ``, http.StatusOK, map[string][]string{"X-Function": {"Test"}}}, + {"/r/myapp/myerror", ``, http.StatusInternalServerError, map[string][]string{"X-Function": {"Test"}}}, // Added same tests again to check if time is reduced by the auth cache - {"/r/myapp/myroute", ``, http.StatusOK, map[string][]string{"X-Function": []string{"Test"}}}, - {"/r/myapp/myerror", ``, http.StatusInternalServerError, map[string][]string{"X-Function": []string{"Test"}}}, + {"/r/myapp/myroute", ``, http.StatusOK, map[string][]string{"X-Function": {"Test"}}}, + {"/r/myapp/myerror", ``, http.StatusInternalServerError, map[string][]string{"X-Function": {"Test"}}}, } { body := bytes.NewBuffer([]byte(test.body)) _, rec := routerRequest(t, router, "GET", test.path, body) diff --git a/api/server/server.go b/api/server/server.go index 2406938ec..0adb394a1 100644 --- a/api/server/server.go +++ b/api/server/server.go @@ -1,13 +1,12 @@ package server import ( + "context" "encoding/json" "io/ioutil" "net/http" "path" - "golang.org/x/net/context" - "github.com/Sirupsen/logrus" "github.com/gin-gonic/gin" "github.com/iron-io/functions/api/ifaces" diff --git a/main.go b/main.go index 3c95af292..20a9bc5d8 100644 --- a/main.go +++ b/main.go @@ -1,6 +1,7 @@ package main import ( + "context" "fmt" "os" "os/signal" @@ -13,7 +14,6 @@ import ( "github.com/iron-io/functions/api/runner" "github.com/iron-io/functions/api/server" "github.com/spf13/viper" - "golang.org/x/net/context" ) const (