chore: remove zmq from full (#2330)

Signed-off-by: Jiyong Huang <huangjy@emqx.io>
lf-edge · Oct 17, 2023 · d97e279 · d97e279
1 parent 334ac18
commit d97e279
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 9 deletions.
diff --git a/Makefile b/Makefile
@@ -79,12 +79,10 @@ build_core: build_prepare
 PLUGINS_IN_FULL := \
 	extensions/sinks/influx \
 	extensions/sinks/influx2 \
-	extensions/sinks/zmq \
 	extensions/sinks/kafka \
 	extensions/sinks/image \
 	extensions/sinks/sql   \
 	extensions/sources/random \
-	extensions/sources/zmq \
 	extensions/sources/sql \
 	extensions/sources/video
 

diff --git a/internal/binder/io/ext_full.go b/internal/binder/io/ext_full.go
@@ -22,26 +22,24 @@ import (
 	influx2 "github.com/lf-edge/ekuiper/extensions/sinks/influx2/ext"
 	kafka "github.com/lf-edge/ekuiper/extensions/sinks/kafka/ext"
 	sqlSink "github.com/lf-edge/ekuiper/extensions/sinks/sql/ext"
-	zmqSink "github.com/lf-edge/ekuiper/extensions/sinks/zmq/ext"
 	random "github.com/lf-edge/ekuiper/extensions/sources/random/ext"
 	sql "github.com/lf-edge/ekuiper/extensions/sources/sql/ext"
 	video "github.com/lf-edge/ekuiper/extensions/sources/video/ext"
-	zmq "github.com/lf-edge/ekuiper/extensions/sources/zmq/ext"
 	"github.com/lf-edge/ekuiper/pkg/api"
 )
 
 func init() {
 	sources["random"] = func() api.Source { return random.GetSource() }
 	sources["video"] = func() api.Source { return video.GetSource() }
 	sources["sql"] = func() api.Source { return sql.GetSource() }
-	sources["zmq"] = func() api.Source { return zmq.GetSource() }
 	lookupSources["sql"] = func() api.LookupSource { return sql.GetLookup() }
 	sinks["image"] = func() api.Sink { return image.GetSink() }
 	sinks["influx"] = func() api.Sink { return influx.GetSink() }
 	sinks["influx2"] = func() api.Sink { return influx2.GetSink() }
 	sinks["kafka"] = func() api.Sink { return kafka.GetSink() }
 	sinks["sql"] = func() api.Sink { return sqlSink.GetSink() }
-	// Do not include tdengine because it is not supported for all versions
+	// Do not include zmq/tdengine because it is not supported for all versions
 	// sinks["tdengine"] = func() api.Sink { return tdengine.GetSink() }
-	sinks["zmq"] = func() api.Sink { return zmqSink.GetSink() }
+	// sinks["zmq"] = func() api.Sink { return zmqSink.GetSink() }
+	// sources["zmq"] = func() api.Source { return zmq.GetSource() }
 }
diff --git a/internal/server/prebuild_plugins_full.go b/internal/server/prebuild_plugins_full.go
@@ -17,7 +17,7 @@
 package server
 
 var (
-	NativeSourcePlugin   = []string{}
-	NativeSinkPlugin     = []string{"tdengine"}
+	NativeSourcePlugin   = []string{"zmq"}
+	NativeSinkPlugin     = []string{"tdengine", "zmq"}
 	NativeFunctionPlugin = []string{"accumulateWordCount", "countPlusOne", "echo", "geohash", "image", "labelImage", "tfLite"}
 )