chore: remove dirwatch

merge into file source Signed-off-by: Jiyong Huang <huangjy@emqx.io>
ngjaying · Dec 26, 2024 · acc7ebc · acc7ebc
1 parent 2e70f7a
commit acc7ebc
Show file tree

Hide file tree

Showing 5 changed files with 0 additions and 416 deletions.
diff --git a/etc/sources/dirwatch.yaml b/etc/sources/dirwatch.yaml
diff --git a/internal/binder/io/builtin.go b/internal/binder/io/builtin.go
@@ -18,7 +18,6 @@ import (
 	"github.com/lf-edge/ekuiper/contract/v2/api"
 
 	"github.com/lf-edge/ekuiper/v2/internal/binder"
-	"github.com/lf-edge/ekuiper/v2/internal/io/dirwatch"
 	"github.com/lf-edge/ekuiper/v2/internal/io/file"
 	"github.com/lf-edge/ekuiper/v2/internal/io/http"
 	"github.com/lf-edge/ekuiper/v2/internal/io/http/httpserver"
@@ -38,7 +37,6 @@ func init() {
 	modules.RegisterSource("httppull", func() api.Source { return &http.HttpPullSource{} })
 	modules.RegisterSource("httppush", func() api.Source { return &http.HttpPushSource{} })
 	modules.RegisterSource("file", file.GetSource)
-	modules.RegisterSource("dirwatch", dirwatch.GetSource)
 	modules.RegisterSource("memory", func() api.Source { return memory.GetSource() })
 	modules.RegisterSource("neuron", neuron.GetSource)
 	modules.RegisterSource("websocket", func() api.Source { return websocket.GetSource() })

diff --git a/internal/io/dirwatch/source.go b/internal/io/dirwatch/source.go
diff --git a/internal/io/dirwatch/source_test.go b/internal/io/dirwatch/source_test.go