feat: add basic source code

Author: kyya

README.md

@@ -0,0 +1,40 @@
+## Sea Wolf
+
+This is made for listening seaweedfs's file metadata changes.
+
+## Install
+```bash
+go get github.com/tuxmart/seawolf
+```
+
+## Usage
+
+```golang
+package main
+
+import (
+	"github.com/tuxmart/seawolf/example"
+	"github.com/tuxmart/seawolf/v1"
+)
+
+func main() {
+	listener := &example.LogFileEventHandler{}
+	if err := seawolf.Run("localhost:18888", seawolf.WithListener(listener)); err != nil {
+		panic(err)
+	}
+}
+```
+
+You could implement your own file listeners by implementing `FileListener` interface.
+
+```golang
+type FileListener interface {
+	Create(ev *filer_pb.SubscribeMetadataResponse)
+	Delete(ev *filer_pb.SubscribeMetadataResponse)
+	Update(ev *filer_pb.SubscribeMetadataResponse)
+	Move(ev *filer_pb.SubscribeMetadataResponse)
+}
+```
+
+## Reference
++ [Filer Change Data Capture](https://github.com/seaweedfs/seaweedfs/wiki/Filer-Change-Data-Capture)

example/just_log.go

@@ -0,0 +1,29 @@
+package example
+
+import (
+	"fmt"
+
+	"github.com/seaweedfs/seaweedfs/weed/pb/filer_pb"
+)
+
+type LogFileEventHandler struct {
+}
+
+func (l *LogFileEventHandler) Create(ev *filer_pb.SubscribeMetadataResponse) {
+	// System.out.println("created entry " + event.getDirectory() + "/" + notification.getNewEntry().getName());
+	fmt.Printf("Created entry %s%s\n", ev.GetDirectory(), ev.GetEventNotification().GetNewEntry().GetName())
+}
+
+func (l *LogFileEventHandler) Delete(ev *filer_pb.SubscribeMetadataResponse) {
+	// 		System.out.println("deleted entry " + event.getDirectory() + "/" + notification.getOldEntry().getName())
+	fmt.Printf("Deleted entry %s%s\n", ev.GetDirectory(), ev.GetEventNotification().GetOldEntry().GetName())
+}
+
+func (l *LogFileEventHandler) Update(ev *filer_pb.SubscribeMetadataResponse) {
+	// System.out.println("updated entry " + event.getDirectory() + "/" + notification.getNewEntry().getName())
+	fmt.Printf("Updated entry %s%s\n", ev.GetDirectory(), ev.GetEventNotification().GetNewEntry().GetName())
+}
+
+func (l *LogFileEventHandler) Move(ev *filer_pb.SubscribeMetadataResponse) {
+	fmt.Printf("Moved %s%s to %s%s", ev.GetDirectory(), ev.GetEventNotification().GetOldEntry().GetName(), ev.GetEventNotification().GetNewParentPath(), ev.GetEventNotification().GetNewEntry().GetName())
+}

go.mod

@@ -0,0 +1,45 @@
+module github.com/tuxmart/seawolf
+
+go 1.19
+
+require (
+	github.com/seaweedfs/seaweedfs v0.0.0-20230710161428-6f7008958e60
+	google.golang.org/grpc v1.56.2
+)
+
+require (
+	github.com/beorn7/perks v1.0.1 // indirect
+	github.com/cespare/xxhash/v2 v2.2.0 // indirect
+	github.com/disintegration/imaging v1.6.2 // indirect
+	github.com/fsnotify/fsnotify v1.6.0 // indirect
+	github.com/go-errors/errors v1.1.1 // indirect
+	github.com/golang/protobuf v1.5.3 // indirect
+	github.com/hashicorp/hcl v1.0.0 // indirect
+	github.com/magiconair/properties v1.8.7 // indirect
+	github.com/matttproud/golang_protobuf_extensions v1.0.4 // indirect
+	github.com/mitchellh/mapstructure v1.5.0 // indirect
+	github.com/pelletier/go-toml/v2 v2.0.8 // indirect
+	github.com/pkg/errors v0.9.1 // indirect
+	github.com/prometheus/client_golang v1.16.0 // indirect
+	github.com/prometheus/client_model v0.3.0 // indirect
+	github.com/prometheus/common v0.42.0 // indirect
+	github.com/prometheus/procfs v0.11.0 // indirect
+	github.com/seaweedfs/goexif v1.0.3 // indirect
+	github.com/spf13/afero v1.9.5 // indirect
+	github.com/spf13/cast v1.5.1 // indirect
+	github.com/spf13/jwalterweatherman v1.1.0 // indirect
+	github.com/spf13/pflag v1.0.5 // indirect
+	github.com/spf13/viper v1.16.0 // indirect
+	github.com/subosito/gotenv v1.4.2 // indirect
+	github.com/viant/ptrie v0.3.0 // indirect
+	github.com/viant/toolbox v0.33.2 // indirect
+	golang.org/x/image v0.9.0 // indirect
+	golang.org/x/net v0.12.0 // indirect
+	golang.org/x/sys v0.10.0 // indirect
+	golang.org/x/text v0.11.0 // indirect
+	google.golang.org/genproto/googleapis/rpc v0.0.0-20230629202037-9506855d4529 // indirect
+	google.golang.org/protobuf v1.31.0 // indirect
+	gopkg.in/ini.v1 v1.67.0 // indirect
+	gopkg.in/yaml.v2 v2.4.0 // indirect
+	gopkg.in/yaml.v3 v3.0.1 // indirect
+)