chore: fix import lint

Signed-off-by: Jiyong Huang <[email protected]>

.github/workflows/lint.yaml

@@ -67,4 +67,4 @@ jobs:
  with:
  version: latest
  working-directory: sdk/go
- args: "--out-${NO_FUTURE}format line-number"
+ args: "--out-${NO_FUTURE}format line-number --config=.gosdkci.yaml"

.golangci.yaml

@@ -19,6 +19,6 @@ linters-settings:
  sections:
  - standard
  - default
- - prefix(github.com/lf-edge/ekuiper)
+ - prefix(github.com/lf-edge/ekuiper/v2)
  staticcheck:
  go: '1.22'

extensions/functions/accumulateWordCount/accumulateWordCount.go

@@ -19,6 +19,7 @@ import (
  "strings"
 
  "github.com/lf-edge/ekuiper/contract/v2/api"
+
  "github.com/lf-edge/ekuiper/v2/pkg/ast"
 )
 

extensions/functions/geohash/geohash.go

@@ -17,9 +17,8 @@ package main
 import (
  "fmt"
 
- "github.com/mmcloughlin/geohash"
-
  "github.com/lf-edge/ekuiper/contract/v2/api"
+ "github.com/mmcloughlin/geohash"
 )
 
 type (

extensions/functions/image/resize.go

@@ -22,9 +22,8 @@ import (
  "image/jpeg"
  "image/png"
 
- "github.com/nfnt/resize"
-
  "github.com/lf-edge/ekuiper/contract/v2/api"
+ "github.com/nfnt/resize"
 )
 
 type imageResize struct{}

extensions/functions/image/thumbnail.go

@@ -21,9 +21,8 @@ import (
  "image/jpeg"
  "image/png"
 
- "github.com/nfnt/resize"
-
  "github.com/lf-edge/ekuiper/contract/v2/api"
+ "github.com/nfnt/resize"
 )
 
 type thumbnail struct{}

extensions/functions/labelImage/labelImage.go

@@ -28,10 +28,9 @@ import (
  "sort"
  "sync"
 
- tflite "github.com/mattn/go-tflite" //nolint:typecheck
- "github.com/nfnt/resize"
-
  "github.com/lf-edge/ekuiper/contract/v2/api"
+ "github.com/mattn/go-tflite" //nolint:typecheck
+ "github.com/nfnt/resize"
 )
 
 type labelImage struct {

extensions/functions/tfLite/tfLite.go

@@ -19,9 +19,9 @@ package main
 import (
  "fmt"
 
+ "github.com/lf-edge/ekuiper/contract/v2/api"
  "github.com/mattn/go-tflite"
 
- "github.com/lf-edge/ekuiper/contract/v2/api"
  "github.com/lf-edge/ekuiper/v2/pkg/cast"
 )
 

extensions/functions/tfLite/tfLite_test.go

@@ -21,6 +21,7 @@ import (
  "testing"
 
  "github.com/lf-edge/ekuiper/contract/v2/api"
+
  "github.com/lf-edge/ekuiper/v2/internal/conf"
  "github.com/lf-edge/ekuiper/v2/internal/pkg/def"
  kctx "github.com/lf-edge/ekuiper/v2/internal/topo/context"

extensions/impl/image/image.go

@@ -27,6 +27,7 @@ import (
  "time"
 
  "github.com/lf-edge/ekuiper/contract/v2/api"
+
  "github.com/lf-edge/ekuiper/v2/pkg/cast"
  "github.com/lf-edge/ekuiper/v2/pkg/timex"
 )

extensions/impl/influx/influx.go

@@ -20,8 +20,8 @@ import (
  "time"
 
  client "github.com/influxdata/influxdb1-client/v2"
-
  "github.com/lf-edge/ekuiper/contract/v2/api"
+
  "github.com/lf-edge/ekuiper/v2/extensions/impl/tspoint"
  "github.com/lf-edge/ekuiper/v2/pkg/cast"
  "github.com/lf-edge/ekuiper/v2/pkg/cert"

extensions/impl/influx2/influx2.go

@@ -23,8 +23,8 @@ import (
 
  client "github.com/influxdata/influxdb-client-go/v2"
  "github.com/influxdata/influxdb-client-go/v2/api/write"
-
  "github.com/lf-edge/ekuiper/contract/v2/api"
+
  "github.com/lf-edge/ekuiper/v2/extensions/impl/tspoint"
  "github.com/lf-edge/ekuiper/v2/pkg/cast"
  "github.com/lf-edge/ekuiper/v2/pkg/cert"

extensions/impl/kafka/sink.go

@@ -20,11 +20,11 @@ import (
  "fmt"
  "strings"
 
+ "github.com/lf-edge/ekuiper/contract/v2/api"
  "github.com/pingcap/failpoint"
  kafkago "github.com/segmentio/kafka-go"
  "github.com/segmentio/kafka-go/sasl"
 
- "github.com/lf-edge/ekuiper/contract/v2/api"
  "github.com/lf-edge/ekuiper/v2/pkg/cast"
  "github.com/lf-edge/ekuiper/v2/pkg/cert"
 )

extensions/impl/kafka/source.go

@@ -21,13 +21,13 @@ import (
  "strings"
  "time"
 
+ "github.com/lf-edge/ekuiper/contract/v2/api"
  "github.com/pingcap/failpoint"
  kafkago "github.com/segmentio/kafka-go"
  "github.com/segmentio/kafka-go/sasl"
  "github.com/segmentio/kafka-go/sasl/plain"
  "github.com/segmentio/kafka-go/sasl/scram"
 
- "github.com/lf-edge/ekuiper/contract/v2/api"
  "github.com/lf-edge/ekuiper/v2/internal/conf"
  "github.com/lf-edge/ekuiper/v2/pkg/cast"
  "github.com/lf-edge/ekuiper/v2/pkg/cert"

extensions/impl/random/random.go

@@ -23,6 +23,7 @@ import (
  "time"
 
  "github.com/lf-edge/ekuiper/contract/v2/api"
+
  "github.com/lf-edge/ekuiper/v2/pkg/cast"
  "github.com/lf-edge/ekuiper/v2/pkg/message"
 )

extensions/impl/sql/client/client.go

@@ -20,6 +20,7 @@ import (
  "sync"
 
  "github.com/lf-edge/ekuiper/contract/v2/api"
+
  "github.com/lf-edge/ekuiper/v2/pkg/modules"
  "github.com/lf-edge/ekuiper/v2/pkg/sqldatabase/driver"
 )

extensions/impl/sql/lookupSource.go

@@ -19,9 +19,9 @@ import (
  "fmt"
  "strings"
 
+ "github.com/lf-edge/ekuiper/contract/v2/api"
  "github.com/pingcap/failpoint"
 
- "github.com/lf-edge/ekuiper/contract/v2/api"
  client2 "github.com/lf-edge/ekuiper/v2/extensions/impl/sql/client"
  "github.com/lf-edge/ekuiper/v2/internal/conf"
  "github.com/lf-edge/ekuiper/v2/internal/topo/context"

extensions/impl/sql/sink.go

@@ -20,6 +20,7 @@ import (
  "strings"
 
  "github.com/lf-edge/ekuiper/contract/v2/api"
+
  "github.com/lf-edge/ekuiper/v2/extensions/impl/sql/client"
  "github.com/lf-edge/ekuiper/v2/pkg/ast"
  "github.com/lf-edge/ekuiper/v2/pkg/cast"

extensions/impl/sql/source.go

@@ -22,9 +22,9 @@ import (
  "reflect"
  "time"
 
+ "github.com/lf-edge/ekuiper/contract/v2/api"
  "github.com/pingcap/failpoint"
 
- "github.com/lf-edge/ekuiper/contract/v2/api"
  client2 "github.com/lf-edge/ekuiper/v2/extensions/impl/sql/client"
  "github.com/lf-edge/ekuiper/v2/pkg/cast"
  "github.com/lf-edge/ekuiper/v2/pkg/connection"

extensions/impl/sql/source_test.go

@@ -20,10 +20,10 @@ import (
  "testing"
  "time"
 
+ "github.com/lf-edge/ekuiper/contract/v2/api"
  "github.com/pingcap/failpoint"
  "github.com/stretchr/testify/require"
 
- "github.com/lf-edge/ekuiper/contract/v2/api"
  "github.com/lf-edge/ekuiper/v2/extensions/impl/sql/client"
  "github.com/lf-edge/ekuiper/v2/extensions/impl/sql/testx"
  "github.com/lf-edge/ekuiper/v2/internal/topo/context"

extensions/impl/tspoint/transform.go

@@ -20,6 +20,7 @@ import (
  "time"
 
  "github.com/lf-edge/ekuiper/contract/v2/api"
+
  "github.com/lf-edge/ekuiper/v2/pkg/cast"
  "github.com/lf-edge/ekuiper/v2/pkg/timex"
 )

extensions/impl/video/source.go

@@ -24,9 +24,9 @@ import (
  "strings"
  "time"
 
+ "github.com/lf-edge/ekuiper/contract/v2/api"
  ffmpeg "github.com/u2takey/ffmpeg-go"
 
- "github.com/lf-edge/ekuiper/contract/v2/api"
  "github.com/lf-edge/ekuiper/v2/pkg/cast"
 )
 

extensions/impl/video/source_test.go

@@ -18,9 +18,9 @@ import (
  "errors"
  "testing"
 
+ "github.com/lf-edge/ekuiper/contract/v2/api"
  "github.com/stretchr/testify/assert"
 
- "github.com/lf-edge/ekuiper/contract/v2/api"
  "github.com/lf-edge/ekuiper/v2/pkg/mock"
  mockContext "github.com/lf-edge/ekuiper/v2/pkg/mock/context"
  "github.com/lf-edge/ekuiper/v2/pkg/model"

extensions/impl/zmq/conf.go

@@ -18,6 +18,7 @@ import (
  "errors"
 
  "github.com/lf-edge/ekuiper/contract/v2/api"
+
  "github.com/lf-edge/ekuiper/v2/pkg/cast"
 )
 

extensions/impl/zmq/sink.go

@@ -19,9 +19,9 @@ package zmq
 import (
  "fmt"
 
+ "github.com/lf-edge/ekuiper/contract/v2/api"
  zmq "github.com/pebbe/zmq4"
 
- "github.com/lf-edge/ekuiper/contract/v2/api"
  "github.com/lf-edge/ekuiper/v2/pkg/errorx"
 )
 

extensions/impl/zmq/source.go

@@ -20,9 +20,9 @@ import (
  "context"
  "fmt"
 
+ "github.com/lf-edge/ekuiper/contract/v2/api"
  zmq "github.com/pebbe/zmq4"
 
- "github.com/lf-edge/ekuiper/contract/v2/api"
  "github.com/lf-edge/ekuiper/v2/pkg/timex"
 )
 

extensions/sinks/image/image.go

@@ -16,6 +16,7 @@ package main
 
 import (
  "github.com/lf-edge/ekuiper/contract/v2/api"
+
  "github.com/lf-edge/ekuiper/v2/extensions/impl/image"
 )
 

extensions/sinks/influx/influx.go

@@ -16,8 +16,8 @@ package main
 
 import (
  _ "github.com/influxdata/influxdb1-client/v2"
-
  "github.com/lf-edge/ekuiper/contract/v2/api"
+
  "github.com/lf-edge/ekuiper/v2/extensions/impl/influx"
 )
 

extensions/sinks/influx2/influx2.go

@@ -16,8 +16,8 @@ package main
 
 import (
  _ "github.com/influxdata/influxdb-client-go/v2"
-
  "github.com/lf-edge/ekuiper/contract/v2/api"
+
  "github.com/lf-edge/ekuiper/v2/extensions/impl/influx2"
 )
 

extensions/sinks/kafka/kafka.go

@@ -16,6 +16,7 @@ package kafka
 
 import (
  "github.com/lf-edge/ekuiper/contract/v2/api"
+
  "github.com/lf-edge/ekuiper/v2/extensions/impl/kafka"
 )
 

extensions/sinks/sql/sql.go

@@ -16,6 +16,7 @@ package main
 
 import (
  "github.com/lf-edge/ekuiper/contract/v2/api"
+
  "github.com/lf-edge/ekuiper/v2/extensions/impl/sql"
 )
 

extensions/sinks/zmq/zmq.go

@@ -16,6 +16,7 @@ package main
 
 import (
  "github.com/lf-edge/ekuiper/contract/v2/api"
+
  "github.com/lf-edge/ekuiper/v2/extensions/impl/zmq"
 )
 

extensions/sources/kafka/kafka.go

@@ -16,6 +16,7 @@ package kafka
 
 import (
  "github.com/lf-edge/ekuiper/contract/v2/api"
+
  "github.com/lf-edge/ekuiper/v2/extensions/impl/sql"
 )
 

extensions/sources/random/random.go

@@ -16,6 +16,7 @@ package main
 
 import (
  "github.com/lf-edge/ekuiper/contract/v2/api"
+
  "github.com/lf-edge/ekuiper/v2/extensions/impl/random"
 )
 

extensions/sources/sql/sql.go

@@ -16,6 +16,7 @@ package main
 
 import (
  "github.com/lf-edge/ekuiper/contract/v2/api"
+
  "github.com/lf-edge/ekuiper/v2/extensions/impl/sql"
 )
 

extensions/sources/video/video.go

@@ -16,6 +16,7 @@ package main
 
 import (
  "github.com/lf-edge/ekuiper/contract/v2/api"
+
  "github.com/lf-edge/ekuiper/v2/extensions/impl/video"
 )
 

extensions/sources/zmq/zmq.go

@@ -16,6 +16,7 @@ package main
 
 import (
  "github.com/lf-edge/ekuiper/contract/v2/api"
+
  "github.com/lf-edge/ekuiper/v2/extensions/impl/zmq"
 )
 

internal/binder/function/binder.go

@@ -1,4 +1,4 @@
-// Copyright 2022-2023 EMQ Technologies Co., Ltd.
+// Copyright 2022-2024 EMQ Technologies Co., Ltd.
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -19,6 +19,7 @@ import (
  "fmt"
 
  "github.com/lf-edge/ekuiper/contract/v2/api"
+
  "github.com/lf-edge/ekuiper/v2/internal/binder"
  "github.com/lf-edge/ekuiper/v2/pkg/ast"
 )

internal/binder/function/funcs_agg.go

@@ -17,9 +17,9 @@ package function
 import (
  "fmt"
 
+ "github.com/lf-edge/ekuiper/contract/v2/api"
  "github.com/montanaflynn/stats"
 
- "github.com/lf-edge/ekuiper/contract/v2/api"
  "github.com/lf-edge/ekuiper/v2/pkg/ast"
  "github.com/lf-edge/ekuiper/v2/pkg/cast"
 )

internal/binder/function/funcs_analytic.go

@@ -1,4 +1,4 @@
-// Copyright 2022-2023 EMQ Technologies Co., Ltd.
+// Copyright 2022-2024 EMQ Technologies Co., Ltd.
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
@@ -21,6 +21,7 @@ import (
  "strconv"
 
  "github.com/lf-edge/ekuiper/contract/v2/api"
+
  "github.com/lf-edge/ekuiper/v2/pkg/ast"
  "github.com/lf-edge/ekuiper/v2/pkg/cast"
 )