restore gci modify

Signed-off-by: siwuxie <cwl990110@163.com>
lf-edge · Sep 19, 2024 · f7f3315 · f7f3315
1 parent a0100d8
commit f7f3315
Show file tree

Hide file tree

Showing 7 changed files with 17 additions and 15 deletions.
diff --git a/contract/api/source.go b/contract/api/source.go
@@ -82,14 +82,10 @@ type LookupBytesSource interface {
 
 /// helper function definition
 
-type (
-	ErrorIngest func(ctx StreamContext, err error)
-	BytesIngest func(ctx StreamContext, payload []byte, meta map[string]any, ts time.Time)
-)
+type ErrorIngest func(ctx StreamContext, err error)
+type BytesIngest func(ctx StreamContext, payload []byte, meta map[string]any, ts time.Time)
 
 // TupleIngest reads in a structural data or its list.
 // It supports map and []map for now
-type (
-	TupleIngest func(ctx StreamContext, data any, meta map[string]any, ts time.Time)
-	EOFIngest   func(ctx StreamContext)
-)
+type TupleIngest func(ctx StreamContext, data any, meta map[string]any, ts time.Time)
+type EOFIngest func(ctx StreamContext)
diff --git a/sdk/go/connection/connection.go b/sdk/go/connection/connection.go
@@ -18,14 +18,15 @@ import (
 	"fmt"
 	"time"
 
-	"github.com/lf-edge/ekuiper/sdk/go/api"
-	"github.com/lf-edge/ekuiper/sdk/go/context"
 	"go.nanomsg.org/mangos/v3"
 	"go.nanomsg.org/mangos/v3/protocol/pull"
 	"go.nanomsg.org/mangos/v3/protocol/push"
 	"go.nanomsg.org/mangos/v3/protocol/req"
 	// introduce ipc
 	_ "go.nanomsg.org/mangos/v3/transport/ipc"
+
+	"github.com/lf-edge/ekuiper/sdk/go/api"
+	"github.com/lf-edge/ekuiper/sdk/go/context"
 )
 
 // Options Initialized in plugin.go Start according to the config

diff --git a/sdk/go/context/default.go b/sdk/go/context/default.go
@@ -18,8 +18,9 @@ import (
 	"context"
 	"time"
 
-	"github.com/lf-edge/ekuiper/sdk/go/api"
 	"github.com/sirupsen/logrus"
+
+	"github.com/lf-edge/ekuiper/sdk/go/api"
 )
 
 const LoggerKey = "$$logger"

diff --git a/sdk/go/context/logger.go b/sdk/go/context/logger.go
@@ -16,8 +16,9 @@ package context
 
 import (
 	filename "github.com/keepeye/logrus-filename"
-	"github.com/lf-edge/ekuiper/sdk/go/api"
 	"github.com/sirupsen/logrus"
+
+	"github.com/lf-edge/ekuiper/sdk/go/api"
 )
 
 var Log *logrus.Logger

diff --git a/sdk/go/example/mirror/random_source.go b/sdk/go/example/mirror/random_source.go
@@ -22,8 +22,9 @@ import (
 	"strings"
 	"time"
 
-	"github.com/lf-edge/ekuiper/sdk/go/api"
 	"github.com/mitchellh/mapstructure"
+
+	"github.com/lf-edge/ekuiper/sdk/go/api"
 )
 
 const dedupStateKey = "input"

diff --git a/sdk/go/mock/mock.go b/sdk/go/mock/mock.go
@@ -19,8 +19,9 @@ import (
 	"time"
 
 	filename "github.com/keepeye/logrus-filename"
-	"github.com/lf-edge/ekuiper/sdk/go/api"
 	"github.com/sirupsen/logrus"
+
+	"github.com/lf-edge/ekuiper/sdk/go/api"
 )
 
 type mockContext struct {

diff --git a/sdk/go/runtime/sink.go b/sdk/go/runtime/sink.go
@@ -19,9 +19,10 @@ import (
 	"encoding/json"
 	"fmt"
 
+	"go.nanomsg.org/mangos/v3"
+
 	"github.com/lf-edge/ekuiper/sdk/go/api"
 	"github.com/lf-edge/ekuiper/sdk/go/connection"
-	"go.nanomsg.org/mangos/v3"
 )
 
 type sinkRuntime struct {