diff --git a/config/kis_conn_config.go b/config/kis_conn_config.go index 192eed1..fcd473e 100644 --- a/config/kis_conn_config.go +++ b/config/kis_conn_config.go @@ -3,7 +3,7 @@ package config import ( "errors" "fmt" - "kis-flow/common" + "github.com/aceld/kis-flow/common" ) // KisConnConfig KisConnector 策略配置 diff --git a/config/kis_flow_config.go b/config/kis_flow_config.go index 8dd02b6..d05e6d0 100644 --- a/config/kis_flow_config.go +++ b/config/kis_flow_config.go @@ -1,6 +1,6 @@ package config -import "kis-flow/common" +import "github.com/aceld/kis-flow/common" // KisFlowFunctionParam 一个Flow配置中Function的Id及携带固定配置参数 type KisFlowFunctionParam struct { diff --git a/config/kis_func_config.go b/config/kis_func_config.go index 8742cd2..4f7f6b3 100644 --- a/config/kis_func_config.go +++ b/config/kis_func_config.go @@ -2,8 +2,8 @@ package config import ( "errors" - "kis-flow/common" - "kis-flow/log" + "github.com/aceld/kis-flow/common" + "github.com/aceld/kis-flow/log" ) // FParam 在当前Flow中Function定制固定配置参数类型 diff --git a/conn/kis_connector.go b/conn/kis_connector.go index 5e62e06..4b22897 100644 --- a/conn/kis_connector.go +++ b/conn/kis_connector.go @@ -2,10 +2,10 @@ package conn import ( "context" - "kis-flow/common" - "kis-flow/config" - "kis-flow/id" - "kis-flow/kis" + "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" ) diff --git a/file/config_export.go b/file/config_export.go index a7fbc43..2e7bcbe 100644 --- a/file/config_export.go +++ b/file/config_export.go @@ -3,8 +3,8 @@ package file import ( "errors" "fmt" - "kis-flow/common" - "kis-flow/kis" + "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 521fb9d..a552e1a 100644 --- a/file/config_import.go +++ b/file/config_import.go @@ -3,11 +3,11 @@ package file import ( "errors" "fmt" - "kis-flow/common" - "kis-flow/config" - "kis-flow/flow" - "kis-flow/kis" - "kis-flow/metrics" + "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" "os" "path" "path/filepath" diff --git a/flow/kis_flow.go b/flow/kis_flow.go index 6989c0e..0f4320b 100644 --- a/flow/kis_flow.go +++ b/flow/kis_flow.go @@ -3,15 +3,15 @@ package flow import ( "context" "errors" + "github.com/aceld/kis-flow/common" + "github.com/aceld/kis-flow/config" + "github.com/aceld/kis-flow/conn" + "github.com/aceld/kis-flow/function" + "github.com/aceld/kis-flow/id" + "github.com/aceld/kis-flow/kis" + "github.com/aceld/kis-flow/log" + "github.com/aceld/kis-flow/metrics" "github.com/prometheus/client_golang/prometheus" - "kis-flow/common" - "kis-flow/config" - "kis-flow/conn" - "kis-flow/function" - "kis-flow/id" - "kis-flow/kis" - "kis-flow/log" - "kis-flow/metrics" "sync" "time" diff --git a/flow/kis_flow_action.go b/flow/kis_flow_action.go index 3c118c3..0b538fd 100644 --- a/flow/kis_flow_action.go +++ b/flow/kis_flow_action.go @@ -4,7 +4,7 @@ import ( "context" "errors" "fmt" - "kis-flow/kis" + "github.com/aceld/kis-flow/kis" ) // dealAction 处理Action,决定接下来Flow的流程走向 diff --git a/flow/kis_flow_data.go b/flow/kis_flow_data.go index 70d1f0a..73b68d5 100644 --- a/flow/kis_flow_data.go +++ b/flow/kis_flow_data.go @@ -4,11 +4,11 @@ import ( "context" "errors" "fmt" + "github.com/aceld/kis-flow/common" + "github.com/aceld/kis-flow/config" + "github.com/aceld/kis-flow/log" + "github.com/aceld/kis-flow/metrics" "github.com/patrickmn/go-cache" - "kis-flow/common" - "kis-flow/config" - "kis-flow/log" - "kis-flow/metrics" "time" ) diff --git a/function/kis_base_function.go b/function/kis_base_function.go index b18b3bc..514b8b4 100644 --- a/function/kis_base_function.go +++ b/function/kis_base_function.go @@ -3,10 +3,10 @@ package function import ( "context" "errors" - "kis-flow/common" - "kis-flow/config" - "kis-flow/id" - "kis-flow/kis" + "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" ) diff --git a/function/kis_function_c.go b/function/kis_function_c.go index ff64157..7b49103 100644 --- a/function/kis_function_c.go +++ b/function/kis_function_c.go @@ -2,8 +2,8 @@ package function import ( "context" - "kis-flow/kis" - "kis-flow/log" + "github.com/aceld/kis-flow/kis" + "github.com/aceld/kis-flow/log" ) type KisFunctionC struct { diff --git a/function/kis_function_e.go b/function/kis_function_e.go index 3fa7533..19c4465 100644 --- a/function/kis_function_e.go +++ b/function/kis_function_e.go @@ -2,8 +2,8 @@ package function import ( "context" - "kis-flow/kis" - "kis-flow/log" + "github.com/aceld/kis-flow/kis" + "github.com/aceld/kis-flow/log" ) type KisFunctionE struct { diff --git a/function/kis_function_l.go b/function/kis_function_l.go index 68ec19c..5f8284c 100644 --- a/function/kis_function_l.go +++ b/function/kis_function_l.go @@ -2,8 +2,8 @@ package function import ( "context" - "kis-flow/kis" - "kis-flow/log" + "github.com/aceld/kis-flow/kis" + "github.com/aceld/kis-flow/log" ) type KisFunctionL struct { diff --git a/function/kis_function_s.go b/function/kis_function_s.go index 8e467eb..2311e2f 100644 --- a/function/kis_function_s.go +++ b/function/kis_function_s.go @@ -2,8 +2,8 @@ package function import ( "context" - "kis-flow/kis" - "kis-flow/log" + "github.com/aceld/kis-flow/kis" + "github.com/aceld/kis-flow/log" ) type KisFunctionS struct { diff --git a/function/kis_function_v.go b/function/kis_function_v.go index 14d5cf7..31cc738 100644 --- a/function/kis_function_v.go +++ b/function/kis_function_v.go @@ -2,8 +2,8 @@ package function import ( "context" - "kis-flow/kis" - "kis-flow/log" + "github.com/aceld/kis-flow/kis" + "github.com/aceld/kis-flow/log" ) type KisFunctionV struct { diff --git a/go.mod b/go.mod index 8d94937..835f182 100644 --- a/go.mod +++ b/go.mod @@ -1,4 +1,4 @@ -module kis-flow +module github.com/aceld/kis-flow go 1.18 diff --git a/id/kis_id.go b/id/kis_id.go index 184c7a0..897d5bf 100644 --- a/id/kis_id.go +++ b/id/kis_id.go @@ -1,8 +1,8 @@ package id import ( + "github.com/aceld/kis-flow/common" "github.com/google/uuid" - "kis-flow/common" "strings" ) diff --git a/kis/connector.go b/kis/connector.go index ea9031f..f0829e9 100644 --- a/kis/connector.go +++ b/kis/connector.go @@ -2,7 +2,7 @@ package kis import ( "context" - "kis-flow/config" + "github.com/aceld/kis-flow/config" ) type Connector interface { diff --git a/kis/flow.go b/kis/flow.go index 6c631f1..34d856e 100644 --- a/kis/flow.go +++ b/kis/flow.go @@ -2,8 +2,8 @@ package kis import ( "context" - "kis-flow/common" - "kis-flow/config" + "github.com/aceld/kis-flow/common" + "github.com/aceld/kis-flow/config" "time" ) diff --git a/kis/function.go b/kis/function.go index 7dcc8b4..2aec4b3 100644 --- a/kis/function.go +++ b/kis/function.go @@ -2,7 +2,7 @@ package kis import ( "context" - "kis-flow/config" + "github.com/aceld/kis-flow/config" ) // Function 流式计算基础计算模块,KisFunction是一条流式计算的基本计算逻辑单元, diff --git a/kis/pool.go b/kis/pool.go index 585d73b..a86217e 100644 --- a/kis/pool.go +++ b/kis/pool.go @@ -4,8 +4,8 @@ import ( "context" "errors" "fmt" - "kis-flow/common" - "kis-flow/log" + "github.com/aceld/kis-flow/common" + "github.com/aceld/kis-flow/log" "reflect" "sync" ) diff --git a/kis/router.go b/kis/router.go index 9324e52..8d12896 100644 --- a/kis/router.go +++ b/kis/router.go @@ -2,7 +2,7 @@ package kis import ( "context" - "kis-flow/common" + "github.com/aceld/kis-flow/common" ) // FaaS 定义移植到 faas.go 中 diff --git a/kis/serialize.go b/kis/serialize.go index 93c3c7a..3e82617 100644 --- a/kis/serialize.go +++ b/kis/serialize.go @@ -1,8 +1,8 @@ package kis import ( - "kis-flow/common" - "kis-flow/serialize" + "github.com/aceld/kis-flow/common" + "github.com/aceld/kis-flow/serialize" "reflect" ) diff --git a/metrics/kis_metrics.go b/metrics/kis_metrics.go index 50faa18..de8a525 100644 --- a/metrics/kis_metrics.go +++ b/metrics/kis_metrics.go @@ -1,11 +1,11 @@ package metrics import ( + "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" - "kis-flow/common" - "kis-flow/config" - "kis-flow/log" "net/http" ) diff --git a/serialize/serialize_default.go b/serialize/serialize_default.go index 9152ebf..8e79b2d 100644 --- a/serialize/serialize_default.go +++ b/serialize/serialize_default.go @@ -7,7 +7,7 @@ package serialize import ( "encoding/json" "fmt" - "kis-flow/common" + "github.com/aceld/kis-flow/common" "reflect" ) diff --git a/test/caas/caas_demo1.go b/test/caas/caas_demo1.go index 23b5958..006e827 100644 --- a/test/caas/caas_demo1.go +++ b/test/caas/caas_demo1.go @@ -3,7 +3,7 @@ package caas import ( "context" "fmt" - "kis-flow/kis" + "github.com/aceld/kis-flow/kis" ) // type CaaS func(context.Context, Connector, Function, Flow, interface{}) error diff --git a/test/caas/caas_init1.go b/test/caas/caas_init1.go index cdb016e..0ba141e 100644 --- a/test/caas/caas_init1.go +++ b/test/caas/caas_init1.go @@ -2,7 +2,7 @@ package caas import ( "fmt" - "kis-flow/kis" + "github.com/aceld/kis-flow/kis" ) // type ConnInit func(conn Connector) error diff --git a/test/faas/faas_abort.go b/test/faas/faas_abort.go index 948eead..c9b7846 100644 --- a/test/faas/faas_abort.go +++ b/test/faas/faas_abort.go @@ -3,7 +3,7 @@ package faas import ( "context" "fmt" - "kis-flow/kis" + "github.com/aceld/kis-flow/kis" ) // type FaaS func(context.Context, Flow) error diff --git a/test/faas/faas_data_reuse.go b/test/faas/faas_data_reuse.go index a102998..f0bc9a3 100644 --- a/test/faas/faas_data_reuse.go +++ b/test/faas/faas_data_reuse.go @@ -3,7 +3,7 @@ package faas import ( "context" "fmt" - "kis-flow/kis" + "github.com/aceld/kis-flow/kis" ) // type FaaS func(context.Context, Flow) error diff --git a/test/faas/faas_demo1.go b/test/faas/faas_demo1.go index 5935a08..6bf9a62 100644 --- a/test/faas/faas_demo1.go +++ b/test/faas/faas_demo1.go @@ -3,7 +3,7 @@ package faas import ( "context" "fmt" - "kis-flow/kis" + "github.com/aceld/kis-flow/kis" ) // type FaaS func(context.Context, Flow) error diff --git a/test/faas/faas_demo2.go b/test/faas/faas_demo2.go index 2e648ef..305a026 100644 --- a/test/faas/faas_demo2.go +++ b/test/faas/faas_demo2.go @@ -3,8 +3,8 @@ package faas import ( "context" "fmt" - "kis-flow/kis" - "kis-flow/log" + "github.com/aceld/kis-flow/kis" + "github.com/aceld/kis-flow/log" ) // type FaaS func(context.Context, Flow) error diff --git a/test/faas/faas_demo3.go b/test/faas/faas_demo3.go index 635580b..49f0306 100644 --- a/test/faas/faas_demo3.go +++ b/test/faas/faas_demo3.go @@ -3,7 +3,7 @@ package faas import ( "context" "fmt" - "kis-flow/kis" + "github.com/aceld/kis-flow/kis" ) // type FaaS func(context.Context, Flow) error diff --git a/test/faas/faas_demo4.go b/test/faas/faas_demo4.go index 79233f3..59fad1d 100644 --- a/test/faas/faas_demo4.go +++ b/test/faas/faas_demo4.go @@ -3,7 +3,7 @@ package faas import ( "context" "fmt" - "kis-flow/kis" + "github.com/aceld/kis-flow/kis" ) // type FaaS func(context.Context, Flow) error diff --git a/test/faas/faas_jump.go b/test/faas/faas_jump.go index 72b852a..23f5e1d 100644 --- a/test/faas/faas_jump.go +++ b/test/faas/faas_jump.go @@ -3,7 +3,7 @@ package faas import ( "context" "fmt" - "kis-flow/kis" + "github.com/aceld/kis-flow/kis" ) // type FaaS func(context.Context, Flow) error diff --git a/test/faas/faas_no_result.go b/test/faas/faas_no_result.go index b32e174..5a8f98f 100644 --- a/test/faas/faas_no_result.go +++ b/test/faas/faas_no_result.go @@ -3,7 +3,7 @@ package faas import ( "context" "fmt" - "kis-flow/kis" + "github.com/aceld/kis-flow/kis" ) // type FaaS func(context.Context, Flow) error diff --git a/test/faas/faas_stu_score_avg.go b/test/faas/faas_stu_score_avg.go index 7c20b3a..0b92da1 100644 --- a/test/faas/faas_stu_score_avg.go +++ b/test/faas/faas_stu_score_avg.go @@ -2,9 +2,9 @@ package faas import ( "context" - "kis-flow/kis" - "kis-flow/serialize" - "kis-flow/test/proto" + "github.com/aceld/kis-flow/kis" + "github.com/aceld/kis-flow/serialize" + "github.com/aceld/kis-flow/test/proto" ) type AvgStuScoreIn struct { diff --git a/test/faas/faas_stu_score_avg_print.go b/test/faas/faas_stu_score_avg_print.go index 7f3e55a..8685441 100644 --- a/test/faas/faas_stu_score_avg_print.go +++ b/test/faas/faas_stu_score_avg_print.go @@ -3,9 +3,9 @@ package faas import ( "context" "fmt" - "kis-flow/kis" - "kis-flow/serialize" - "kis-flow/test/proto" + "github.com/aceld/kis-flow/kis" + "github.com/aceld/kis-flow/serialize" + "github.com/aceld/kis-flow/test/proto" ) type PrintStuAvgScoreIn struct { diff --git a/test/init.go b/test/init.go index fb72805..77a744b 100644 --- a/test/init.go +++ b/test/init.go @@ -1,10 +1,10 @@ package test import ( - "kis-flow/common" - "kis-flow/kis" - "kis-flow/test/caas" - "kis-flow/test/faas" + "github.com/aceld/kis-flow/common" + "github.com/aceld/kis-flow/kis" + "github.com/aceld/kis-flow/test/caas" + "github.com/aceld/kis-flow/test/faas" ) func init() { diff --git a/test/kis_action_test.go b/test/kis_action_test.go index c91cd51..d41e9be 100644 --- a/test/kis_action_test.go +++ b/test/kis_action_test.go @@ -3,8 +3,8 @@ package test import ( "context" "fmt" - "kis-flow/file" - "kis-flow/kis" + "github.com/aceld/kis-flow/file" + "github.com/aceld/kis-flow/kis" "testing" ) diff --git a/test/kis_auto_inject_param_test.go b/test/kis_auto_inject_param_test.go index be5f0ee..6fdeaab 100644 --- a/test/kis_auto_inject_param_test.go +++ b/test/kis_auto_inject_param_test.go @@ -2,13 +2,13 @@ package test import ( "context" - "kis-flow/common" - "kis-flow/config" - "kis-flow/file" - "kis-flow/flow" - "kis-flow/kis" - "kis-flow/test/faas" - "kis-flow/test/proto" + "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" + "github.com/aceld/kis-flow/test/faas" + "github.com/aceld/kis-flow/test/proto" "testing" ) diff --git a/test/kis_config_export_test.go b/test/kis_config_export_test.go index 7a842ab..2348d7d 100644 --- a/test/kis_config_export_test.go +++ b/test/kis_config_export_test.go @@ -2,8 +2,8 @@ package test import ( "fmt" - "kis-flow/file" - "kis-flow/kis" + "github.com/aceld/kis-flow/file" + "github.com/aceld/kis-flow/kis" "testing" ) diff --git a/test/kis_config_import_test.go b/test/kis_config_import_test.go index 62909e4..2083346 100644 --- a/test/kis_config_import_test.go +++ b/test/kis_config_import_test.go @@ -2,8 +2,8 @@ package test import ( "context" - "kis-flow/file" - "kis-flow/kis" + "github.com/aceld/kis-flow/file" + "github.com/aceld/kis-flow/kis" "testing" ) diff --git a/test/kis_config_test.go b/test/kis_config_test.go index 36d4450..d737968 100644 --- a/test/kis_config_test.go +++ b/test/kis_config_test.go @@ -1,9 +1,9 @@ package test import ( - "kis-flow/common" - "kis-flow/config" - "kis-flow/log" + "github.com/aceld/kis-flow/common" + "github.com/aceld/kis-flow/config" + "github.com/aceld/kis-flow/log" "testing" ) diff --git a/test/kis_connector_test.go b/test/kis_connector_test.go index 764a6c1..aaca105 100644 --- a/test/kis_connector_test.go +++ b/test/kis_connector_test.go @@ -2,9 +2,9 @@ package test import ( "context" - "kis-flow/common" - "kis-flow/config" - "kis-flow/flow" + "github.com/aceld/kis-flow/common" + "github.com/aceld/kis-flow/config" + "github.com/aceld/kis-flow/flow" "testing" ) diff --git a/test/kis_flow_test.go b/test/kis_flow_test.go index b4d3d74..2b2cbbf 100644 --- a/test/kis_flow_test.go +++ b/test/kis_flow_test.go @@ -2,9 +2,9 @@ package test import ( "context" - "kis-flow/common" - "kis-flow/config" - "kis-flow/flow" + "github.com/aceld/kis-flow/common" + "github.com/aceld/kis-flow/config" + "github.com/aceld/kis-flow/flow" "testing" ) diff --git a/test/kis_fork_test.go b/test/kis_fork_test.go index 05d6b9c..a139b5e 100644 --- a/test/kis_fork_test.go +++ b/test/kis_fork_test.go @@ -2,8 +2,8 @@ package test import ( "context" - "kis-flow/file" - "kis-flow/kis" + "github.com/aceld/kis-flow/file" + "github.com/aceld/kis-flow/kis" "testing" ) diff --git a/test/kis_function_test.go b/test/kis_function_test.go index 1bf82d4..a3f6924 100644 --- a/test/kis_function_test.go +++ b/test/kis_function_test.go @@ -2,10 +2,10 @@ package test import ( "context" - "kis-flow/common" - "kis-flow/config" - "kis-flow/flow" - "kis-flow/function" + "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" ) diff --git a/test/kis_log_test.go b/test/kis_log_test.go index 3ae6ec3..37736cb 100644 --- a/test/kis_log_test.go +++ b/test/kis_log_test.go @@ -2,7 +2,7 @@ package test import ( "context" - "kis-flow/log" + "github.com/aceld/kis-flow/log" "testing" ) diff --git a/test/kis_metrics_test.go b/test/kis_metrics_test.go index 9d03e06..e381524 100644 --- a/test/kis_metrics_test.go +++ b/test/kis_metrics_test.go @@ -3,8 +3,8 @@ package test import ( "context" "fmt" - "kis-flow/file" - "kis-flow/kis" + "github.com/aceld/kis-flow/file" + "github.com/aceld/kis-flow/kis" "testing" "time" ) diff --git a/test/kis_params_test.go b/test/kis_params_test.go index bfd73e0..b6f754c 100644 --- a/test/kis_params_test.go +++ b/test/kis_params_test.go @@ -2,8 +2,8 @@ package test import ( "context" - "kis-flow/file" - "kis-flow/kis" + "github.com/aceld/kis-flow/file" + "github.com/aceld/kis-flow/kis" "testing" ) diff --git a/test/kis_pool_test.go b/test/kis_pool_test.go index 5f49483..a1d74ba 100644 --- a/test/kis_pool_test.go +++ b/test/kis_pool_test.go @@ -2,9 +2,9 @@ package test import ( "context" - "kis-flow/common" - "kis-flow/config" - "kis-flow/flow" + "github.com/aceld/kis-flow/common" + "github.com/aceld/kis-flow/config" + "github.com/aceld/kis-flow/flow" "testing" ) diff --git a/test/prometheus_server_test.go b/test/prometheus_server_test.go index 223119e..dc3b897 100644 --- a/test/prometheus_server_test.go +++ b/test/prometheus_server_test.go @@ -1,7 +1,7 @@ package test import ( - "kis-flow/metrics" + "github.com/aceld/kis-flow/metrics" "testing" )