diff --git a/config/kis_conn_config.go b/config/kis_conn_config.go index bf272ca..b766310 100644 --- a/config/kis_conn_config.go +++ b/config/kis_conn_config.go @@ -2,6 +2,7 @@ package config import ( "fmt" + "github.com/aceld/kis-flow/common" ) diff --git a/conn/kis_connector.go b/conn/kis_connector.go index 2624b0e..bf1372b 100644 --- a/conn/kis_connector.go +++ b/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 diff --git a/file/config_export.go b/file/config_export.go index df2fb93..e22415b 100644 --- a/file/config_export.go +++ b/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" ) diff --git a/file/config_import.go b/file/config_import.go index ac8e01c..f79a935 100644 --- a/file/config_import.go +++ b/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 { diff --git a/flow/kis_flow.go b/flow/kis_flow.go index 5920b08..b1fb0a3 100644 --- a/flow/kis_flow.go +++ b/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" ) diff --git a/function/kis_base_function.go b/function/kis_base_function.go index 169f5bf..ee1f821 100644 --- a/function/kis_base_function.go +++ b/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 { diff --git a/function/kis_function_c.go b/function/kis_function_c.go index dc21db6..496d10b 100644 --- a/function/kis_function_c.go +++ b/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" ) diff --git a/function/kis_function_e.go b/function/kis_function_e.go index ca9d05f..ce9bfc5 100644 --- a/function/kis_function_e.go +++ b/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" ) diff --git a/function/kis_function_l.go b/function/kis_function_l.go index cf04a20..20da3f4 100644 --- a/function/kis_function_l.go +++ b/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" ) diff --git a/function/kis_function_s.go b/function/kis_function_s.go index 0cb0abb..93aff35 100644 --- a/function/kis_function_s.go +++ b/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" ) diff --git a/function/kis_function_v.go b/function/kis_function_v.go index 00604dd..5ec2e95 100644 --- a/function/kis_function_v.go +++ b/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" ) diff --git a/id/kis_id.go b/id/kis_id.go index 4dd423f..9cbb3ea 100644 --- a/id/kis_id.go +++ b/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. diff --git a/metrics/kis_metrics.go b/metrics/kis_metrics.go index 4047591..7c73c3d 100644 --- a/metrics/kis_metrics.go +++ b/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 diff --git a/test/caas/caas_demo1.go b/test/caas/caas_demo1.go index d4c978c..3e4f38c 100644 --- a/test/caas/caas_demo1.go +++ b/test/caas/caas_demo1.go @@ -3,6 +3,7 @@ package caas import ( "context" "fmt" + "github.com/aceld/kis-flow/kis" ) diff --git a/test/caas/caas_init1.go b/test/caas/caas_init1.go index c600323..2845fb9 100644 --- a/test/caas/caas_init1.go +++ b/test/caas/caas_init1.go @@ -2,6 +2,7 @@ package caas import ( "fmt" + "github.com/aceld/kis-flow/kis" ) diff --git a/test/faas/faas_abort.go b/test/faas/faas_abort.go index 09b200a..e600e5a 100644 --- a/test/faas/faas_abort.go +++ b/test/faas/faas_abort.go @@ -3,6 +3,7 @@ package faas import ( "context" "fmt" + "github.com/aceld/kis-flow/kis" ) diff --git a/test/faas/faas_data_reuse.go b/test/faas/faas_data_reuse.go index 785ef2b..be0ab3a 100644 --- a/test/faas/faas_data_reuse.go +++ b/test/faas/faas_data_reuse.go @@ -3,6 +3,7 @@ package faas import ( "context" "fmt" + "github.com/aceld/kis-flow/kis" ) diff --git a/test/faas/faas_demo1.go b/test/faas/faas_demo1.go index e49d08d..eb2cff3 100644 --- a/test/faas/faas_demo1.go +++ b/test/faas/faas_demo1.go @@ -3,6 +3,7 @@ package faas import ( "context" "fmt" + "github.com/aceld/kis-flow/kis" ) diff --git a/test/faas/faas_demo2.go b/test/faas/faas_demo2.go index 56b01e2..3cf9119 100644 --- a/test/faas/faas_demo2.go +++ b/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" ) diff --git a/test/faas/faas_demo3.go b/test/faas/faas_demo3.go index afd0c0e..eeb9421 100644 --- a/test/faas/faas_demo3.go +++ b/test/faas/faas_demo3.go @@ -3,6 +3,7 @@ package faas import ( "context" "fmt" + "github.com/aceld/kis-flow/kis" ) diff --git a/test/faas/faas_demo4.go b/test/faas/faas_demo4.go index c2b60ba..fe088d5 100644 --- a/test/faas/faas_demo4.go +++ b/test/faas/faas_demo4.go @@ -3,6 +3,7 @@ package faas import ( "context" "fmt" + "github.com/aceld/kis-flow/kis" ) diff --git a/test/faas/faas_jump.go b/test/faas/faas_jump.go index 9b529d3..af448b6 100644 --- a/test/faas/faas_jump.go +++ b/test/faas/faas_jump.go @@ -3,6 +3,7 @@ package faas import ( "context" "fmt" + "github.com/aceld/kis-flow/kis" ) diff --git a/test/faas/faas_no_result.go b/test/faas/faas_no_result.go index e360054..2a88208 100644 --- a/test/faas/faas_no_result.go +++ b/test/faas/faas_no_result.go @@ -3,6 +3,7 @@ package faas import ( "context" "fmt" + "github.com/aceld/kis-flow/kis" ) diff --git a/test/faas/faas_stu_score_avg.go b/test/faas/faas_stu_score_avg.go index 01b8e9e..665758b 100644 --- a/test/faas/faas_stu_score_avg.go +++ b/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" diff --git a/test/faas/faas_stu_score_avg_print.go b/test/faas/faas_stu_score_avg_print.go index 8685441..78351fb 100644 --- a/test/faas/faas_stu_score_avg_print.go +++ b/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" diff --git a/test/kis_action_test.go b/test/kis_action_test.go index f851d78..04ebc5d 100644 --- a/test/kis_action_test.go +++ b/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) { diff --git a/test/kis_auto_inject_param_test.go b/test/kis_auto_inject_param_test.go index 7a0b4b4..c11c3d3 100644 --- a/test/kis_auto_inject_param_test.go +++ b/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) { diff --git a/test/kis_config_export_test.go b/test/kis_config_export_test.go index 527fdc4..8ae035d 100644 --- a/test/kis_config_export_test.go +++ b/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) { diff --git a/test/kis_config_import_test.go b/test/kis_config_import_test.go index bf94f9a..76cbe92 100644 --- a/test/kis_config_import_test.go +++ b/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) { diff --git a/test/kis_config_test.go b/test/kis_config_test.go index ef7478c..b93a7d7 100644 --- a/test/kis_config_test.go +++ b/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) { diff --git a/test/kis_connector_test.go b/test/kis_connector_test.go index d2dfe87..3fde3b4 100644 --- a/test/kis_connector_test.go +++ b/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) { diff --git a/test/kis_flow_commit_batch_test.go b/test/kis_flow_commit_batch_test.go index a8e2b13..8da835b 100644 --- a/test/kis_flow_commit_batch_test.go +++ b/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) { diff --git a/test/kis_flow_test.go b/test/kis_flow_test.go index 96f08e6..9b05c0d 100644 --- a/test/kis_flow_test.go +++ b/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) { diff --git a/test/kis_fork_test.go b/test/kis_fork_test.go index 8825dcb..acdcfd3 100644 --- a/test/kis_fork_test.go +++ b/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) { diff --git a/test/kis_function_test.go b/test/kis_function_test.go index bd15d6e..51fae3e 100644 --- a/test/kis_function_test.go +++ b/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) { diff --git a/test/kis_log_test.go b/test/kis_log_test.go index 37736cb..781d4e6 100644 --- a/test/kis_log_test.go +++ b/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) { diff --git a/test/kis_metrics_test.go b/test/kis_metrics_test.go index f365f69..a94fbab 100644 --- a/test/kis_metrics_test.go +++ b/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) { diff --git a/test/kis_params_test.go b/test/kis_params_test.go index 0c1e768..14e44ea 100644 --- a/test/kis_params_test.go +++ b/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) { diff --git a/test/kis_pool_test.go b/test/kis_pool_test.go index 1990e2b..a51c965 100644 --- a/test/kis_pool_test.go +++ b/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) { diff --git a/test/prometheus_server_test.go b/test/prometheus_server_test.go index dc3b897..645c507 100644 --- a/test/prometheus_server_test.go +++ b/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) {