Merge pull request #11 from aceld/feature/aceld

change module export

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 策略配置

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 {

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定制固定配置参数类型

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"
 )
 

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"

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"

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"
 

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的流程走向

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"
 )
 

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"
 )
 

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 {

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 {

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 {

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 {

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 {

go.mod

@@ -1,4 +1,4 @@
-module kis-flow
+module github.com/aceld/kis-flow
 
 go 1.18
 

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"
 )
 

kis/connector.go

@@ -2,7 +2,7 @@ package kis
 
 import (
 	"context"
-	"kis-flow/config"
+	"github.com/aceld/kis-flow/config"
 )
 
 type Connector interface {

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"
 )
 

kis/function.go

@@ -2,7 +2,7 @@ package kis
 
 import (
 	"context"
-	"kis-flow/config"
+	"github.com/aceld/kis-flow/config"
 )
 
 // Function 流式计算基础计算模块，KisFunction是一条流式计算的基本计算逻辑单元，

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"
 )

kis/router.go

@@ -2,7 +2,7 @@ package kis
 
 import (
 	"context"
-	"kis-flow/common"
+	"github.com/aceld/kis-flow/common"
 )
 
 // FaaS 定义移植到 faas.go 中

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"
 )
 

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"
 )
 

serialize/serialize_default.go

@@ -7,7 +7,7 @@ package serialize
 import (
 	"encoding/json"
 	"fmt"
-	"kis-flow/common"
+	"github.com/aceld/kis-flow/common"
 	"reflect"
 )
 

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

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

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

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

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

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

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

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

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

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

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 {

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 {

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() {

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"
 )
 

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"
 )
 

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"
 )
 

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"
 )
 

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"
 )
 

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"
 )
 

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"
 )
 

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"
 )
 

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"
 )
 

test/kis_log_test.go

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

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"
 )

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"
 )
 

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"
 )
 

test/prometheus_server_test.go

@@ -1,7 +1,7 @@
 package test
 
 import (
-	"kis-flow/metrics"
+	"github.com/aceld/kis-flow/metrics"
 	"testing"
 )