feat(io): merge dirwatch into file source (#3480)

Signed-off-by: Jiyong Huang <[email protected]>
lf-edge · Dec 27, 2024 · f5534b6 · f5534b6
1 parent db950cf
commit f5534b6
Show file tree

Hide file tree

Showing 8 changed files with 101 additions and 449 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