goimports -l -w .

config/kis_conn_config.go

@@ -2,6 +2,7 @@ package config
 
 import (
 	"fmt"
+
 	"github.com/aceld/kis-flow/common"
 )
 

conn/kis_connector.go

@@ -2,11 +2,12 @@ package conn
 
 import (
 	"context"
+	"sync"
+
 	"github.com/aceld/kis-flow/common"
 	"github.com/aceld/kis-flow/config"
 	"github.com/aceld/kis-flow/id"
 	"github.com/aceld/kis-flow/kis"
-	"sync"
 )
 
 // KisConnector represents a KisConnector instance

file/config_export.go

@@ -2,9 +2,10 @@ package file
 
 import (
 	"fmt"
+	"os"
+
 	"github.com/aceld/kis-flow/common"
 	"github.com/aceld/kis-flow/kis"
-	"os"
 
 	"gopkg.in/yaml.v3"
 )

file/config_import.go

@@ -2,15 +2,16 @@ package file
 
 import (
 	"fmt"
+	"os"
+	"path"
+	"path/filepath"
+
 	"github.com/aceld/kis-flow/common"
 	"github.com/aceld/kis-flow/config"
 	"github.com/aceld/kis-flow/flow"
 	"github.com/aceld/kis-flow/kis"
 	"github.com/aceld/kis-flow/metrics"
 	"gopkg.in/yaml.v3"
-	"os"
-	"path"
-	"path/filepath"
 )
 
 type allConfig struct {

flow/kis_flow.go

@@ -3,6 +3,9 @@ package flow
 import (
 	"context"
 	"errors"
+	"sync"
+	"time"
+
 	"github.com/aceld/kis-flow/common"
 	"github.com/aceld/kis-flow/config"
 	"github.com/aceld/kis-flow/conn"
@@ -12,8 +15,6 @@ import (
 	"github.com/aceld/kis-flow/log"
 	"github.com/aceld/kis-flow/metrics"
 	"github.com/prometheus/client_golang/prometheus"
-	"sync"
-	"time"
 
 	"github.com/patrickmn/go-cache"
 )

function/kis_base_function.go

@@ -3,11 +3,12 @@ package function
 import (
 	"context"
 	"errors"
+	"sync"
+
 	"github.com/aceld/kis-flow/common"
 	"github.com/aceld/kis-flow/config"
 	"github.com/aceld/kis-flow/id"
 	"github.com/aceld/kis-flow/kis"
-	"sync"
 )
 
 type BaseFunction struct {

function/kis_function_c.go

@@ -2,6 +2,7 @@ package function
 
 import (
 	"context"
+
 	"github.com/aceld/kis-flow/kis"
 	"github.com/aceld/kis-flow/log"
 )

function/kis_function_e.go

@@ -2,6 +2,7 @@ package function
 
 import (
 	"context"
+
 	"github.com/aceld/kis-flow/kis"
 	"github.com/aceld/kis-flow/log"
 )

function/kis_function_l.go

@@ -2,6 +2,7 @@ package function
 
 import (
 	"context"
+
 	"github.com/aceld/kis-flow/kis"
 	"github.com/aceld/kis-flow/log"
 )

function/kis_function_s.go

@@ -2,6 +2,7 @@ package function
 
 import (
 	"context"
+
 	"github.com/aceld/kis-flow/kis"
 	"github.com/aceld/kis-flow/log"
 )

function/kis_function_v.go

@@ -2,6 +2,7 @@ package function
 
 import (
 	"context"
+
 	"github.com/aceld/kis-flow/kis"
 	"github.com/aceld/kis-flow/log"
 )

id/kis_id.go

@@ -1,9 +1,10 @@
 package id
 
 import (
+	"strings"
+
 	"github.com/aceld/kis-flow/common"
 	"github.com/google/uuid"
-	"strings"
 )
 
 // KisID generates a random instance ID.

metrics/kis_metrics.go

@@ -1,12 +1,13 @@
 package metrics
 
 import (
+	"net/http"
+
 	"github.com/aceld/kis-flow/common"
 	"github.com/aceld/kis-flow/config"
 	"github.com/aceld/kis-flow/log"
 	"github.com/prometheus/client_golang/prometheus"
 	"github.com/prometheus/client_golang/prometheus/promhttp"
-	"net/http"
 )
 
 // KisMetrics kisFlow's Prometheus monitoring metrics

test/caas/caas_demo1.go

@@ -3,6 +3,7 @@ package caas
 import (
 	"context"
 	"fmt"
+
 	"github.com/aceld/kis-flow/kis"
 )
 

test/caas/caas_init1.go

@@ -2,6 +2,7 @@ package caas
 
 import (
 	"fmt"
+
 	"github.com/aceld/kis-flow/kis"
 )
 

test/faas/faas_abort.go

@@ -3,6 +3,7 @@ package faas
 import (
 	"context"
 	"fmt"
+
 	"github.com/aceld/kis-flow/kis"
 )
 

test/faas/faas_data_reuse.go

@@ -3,6 +3,7 @@ package faas
 import (
 	"context"
 	"fmt"
+
 	"github.com/aceld/kis-flow/kis"
 )
 

test/faas/faas_demo1.go

@@ -3,6 +3,7 @@ package faas
 import (
 	"context"
 	"fmt"
+
 	"github.com/aceld/kis-flow/kis"
 )
 

test/faas/faas_demo2.go

@@ -3,6 +3,7 @@ package faas
 import (
 	"context"
 	"fmt"
+
 	"github.com/aceld/kis-flow/kis"
 	"github.com/aceld/kis-flow/log"
 )

test/faas/faas_demo3.go

@@ -3,6 +3,7 @@ package faas
 import (
 	"context"
 	"fmt"
+
 	"github.com/aceld/kis-flow/kis"
 )
 

test/faas/faas_demo4.go

@@ -3,6 +3,7 @@ package faas
 import (
 	"context"
 	"fmt"
+
 	"github.com/aceld/kis-flow/kis"
 )
 

test/faas/faas_jump.go

@@ -3,6 +3,7 @@ package faas
 import (
 	"context"
 	"fmt"
+
 	"github.com/aceld/kis-flow/kis"
 )
 

test/faas/faas_no_result.go

@@ -3,6 +3,7 @@ package faas
 import (
 	"context"
 	"fmt"
+
 	"github.com/aceld/kis-flow/kis"
 )
 

test/faas/faas_stu_score_avg.go

@@ -2,6 +2,7 @@ package faas
 
 import (
 	"context"
+
 	"github.com/aceld/kis-flow/kis"
 	"github.com/aceld/kis-flow/serialize"
 	"github.com/aceld/kis-flow/test/proto"

test/faas/faas_stu_score_avg_print.go

@@ -3,6 +3,7 @@ package faas
 import (
 	"context"
 	"fmt"
+
 	"github.com/aceld/kis-flow/kis"
 	"github.com/aceld/kis-flow/serialize"
 	"github.com/aceld/kis-flow/test/proto"

test/kis_action_test.go

@@ -3,9 +3,10 @@ package test
 import (
 	"context"
 	"fmt"
+	"testing"
+
 	"github.com/aceld/kis-flow/file"
 	"github.com/aceld/kis-flow/kis"
-	"testing"
 )
 
 func TestActionAbort(t *testing.T) {

test/kis_auto_inject_param_test.go

@@ -2,6 +2,8 @@ package test
 
 import (
 	"context"
+	"testing"
+
 	"github.com/aceld/kis-flow/common"
 	"github.com/aceld/kis-flow/config"
 	"github.com/aceld/kis-flow/file"
@@ -9,7 +11,6 @@ import (
 	"github.com/aceld/kis-flow/kis"
 	"github.com/aceld/kis-flow/test/faas"
 	"github.com/aceld/kis-flow/test/proto"
-	"testing"
 )
 
 func TestAutoInjectParamWithConfig(t *testing.T) {

test/kis_config_export_test.go

@@ -2,9 +2,10 @@ package test
 
 import (
 	"fmt"
+	"testing"
+
 	"github.com/aceld/kis-flow/file"
 	"github.com/aceld/kis-flow/kis"
-	"testing"
 )
 
 func TestConfigExportYaml(t *testing.T) {

test/kis_config_import_test.go

@@ -2,9 +2,10 @@ package test
 
 import (
 	"context"
+	"testing"
+
 	"github.com/aceld/kis-flow/file"
 	"github.com/aceld/kis-flow/kis"
-	"testing"
 )
 
 func TestConfigImportYaml(t *testing.T) {

test/kis_config_test.go

@@ -1,10 +1,11 @@
 package test
 
 import (
+	"testing"
+
 	"github.com/aceld/kis-flow/common"
 	"github.com/aceld/kis-flow/config"
 	"github.com/aceld/kis-flow/log"
-	"testing"
 )
 
 func TestNewFuncConfig(t *testing.T) {

test/kis_connector_test.go

@@ -2,10 +2,11 @@ package test
 
 import (
 	"context"
+	"testing"
+
 	"github.com/aceld/kis-flow/common"
 	"github.com/aceld/kis-flow/config"
 	"github.com/aceld/kis-flow/flow"
-	"testing"
 )
 
 func TestNewKisConnector(t *testing.T) {

test/kis_flow_commit_batch_test.go

@@ -2,10 +2,11 @@ package test
 
 import (
 	"context"
+	"testing"
+
 	"github.com/aceld/kis-flow/file"
 	"github.com/aceld/kis-flow/kis"
 	"github.com/aceld/kis-flow/log"
-	"testing"
 )
 
 func TestForkFlowCommitBatch(t *testing.T) {

test/kis_flow_test.go

@@ -2,10 +2,11 @@ package test
 
 import (
 	"context"
+	"testing"
+
 	"github.com/aceld/kis-flow/common"
 	"github.com/aceld/kis-flow/config"
 	"github.com/aceld/kis-flow/flow"
-	"testing"
 )
 
 func TestNewKisFlow(t *testing.T) {

test/kis_fork_test.go

@@ -3,12 +3,13 @@ package test
 import (
 	"context"
 	"fmt"
+	"testing"
+
 	"github.com/aceld/kis-flow/common"
 	"github.com/aceld/kis-flow/config"
 	"github.com/aceld/kis-flow/file"
 	"github.com/aceld/kis-flow/flow"
 	"github.com/aceld/kis-flow/kis"
-	"testing"
 )
 
 func TestForkFlow(t *testing.T) {

test/kis_function_test.go

@@ -2,11 +2,12 @@ package test
 
 import (
 	"context"
+	"testing"
+
 	"github.com/aceld/kis-flow/common"
 	"github.com/aceld/kis-flow/config"
 	"github.com/aceld/kis-flow/flow"
 	"github.com/aceld/kis-flow/function"
-	"testing"
 )
 
 func TestNewKisFunction(t *testing.T) {

test/kis_log_test.go

@@ -2,8 +2,9 @@ package test
 
 import (
 	"context"
-	"github.com/aceld/kis-flow/log"
 	"testing"
+
+	"github.com/aceld/kis-flow/log"
 )
 
 func TestKisLogger(t *testing.T) {

test/kis_metrics_test.go

@@ -3,10 +3,11 @@ package test
 import (
 	"context"
 	"fmt"
-	"github.com/aceld/kis-flow/file"
-	"github.com/aceld/kis-flow/kis"
 	"testing"
 	"time"
+
+	"github.com/aceld/kis-flow/file"
+	"github.com/aceld/kis-flow/kis"
 )
 
 func TestMetricsDataTotal(t *testing.T) {

test/kis_params_test.go

@@ -2,9 +2,10 @@ package test
 
 import (
 	"context"
+	"testing"
+
 	"github.com/aceld/kis-flow/file"
 	"github.com/aceld/kis-flow/kis"
-	"testing"
 )
 
 func TestParams(t *testing.T) {

test/kis_pool_test.go

@@ -2,10 +2,11 @@ package test
 
 import (
 	"context"
+	"testing"
+
 	"github.com/aceld/kis-flow/common"
 	"github.com/aceld/kis-flow/config"
 	"github.com/aceld/kis-flow/flow"
-	"testing"
 )
 
 func TestNewKisPool(t *testing.T) {

test/prometheus_server_test.go

@@ -1,8 +1,9 @@
 package test
 
 import (
-	"github.com/aceld/kis-flow/metrics"
 	"testing"
+
+	"github.com/aceld/kis-flow/metrics"
 )
 
 func TestPrometheusServer(t *testing.T) {