diff --git a/kis/flow.go b/kis/flow.go index a4649b8..dfb2cf2 100644 --- a/kis/flow.go +++ b/kis/flow.go @@ -2,9 +2,10 @@ package kis import ( "context" + "time" + "github.com/aceld/kis-flow/common" "github.com/aceld/kis-flow/config" - "time" ) type Flow interface { diff --git a/kis/function.go b/kis/function.go index 5ebb057..e59dcf6 100644 --- a/kis/function.go +++ b/kis/function.go @@ -2,6 +2,7 @@ package kis import ( "context" + "github.com/aceld/kis-flow/config" ) diff --git a/kis/pool.go b/kis/pool.go index 8951f2c..d0aba57 100644 --- a/kis/pool.go +++ b/kis/pool.go @@ -4,10 +4,11 @@ import ( "context" "errors" "fmt" - "github.com/aceld/kis-flow/common" - "github.com/aceld/kis-flow/log" "reflect" "sync" + + "github.com/aceld/kis-flow/common" + "github.com/aceld/kis-flow/log" ) var _poolOnce sync.Once diff --git a/kis/router.go b/kis/router.go index 2143c8e..a0833e7 100644 --- a/kis/router.go +++ b/kis/router.go @@ -2,6 +2,7 @@ package kis import ( "context" + "github.com/aceld/kis-flow/common" ) diff --git a/kis/serialize.go b/kis/serialize.go index 8e4e30d..e2b65a6 100644 --- a/kis/serialize.go +++ b/kis/serialize.go @@ -1,9 +1,10 @@ package kis import ( + "reflect" + "github.com/aceld/kis-flow/common" "github.com/aceld/kis-flow/serialize" - "reflect" ) // Serialize Data serialization interface