feat(v1): expose filer grpc client

Author: kyya

README.md

@@ -19,7 +19,8 @@ import (
 
 func main() {
 	listener := &example.LogFileEventHandler{}
-	if err := seawolf.Run("localhost:18888", seawolf.WithListener(listener)); err != nil {
+	wolf := seawolf.New("localhost:18888", seawolf.WithListener(listener))
+	if err := wolf.Run(); err != nil {
 		panic(err)
 	}
 }

v1/seawolf.go

@@ -11,6 +11,7 @@ import (
 )
 
 type SeaWolf struct {
+	client    filer_pb.SeaweedFilerClient
 	Listeners []internal.FileListener
 }
 
@@ -22,26 +23,30 @@ func WithListener(listener internal.FileListener) Option {
 	}
 }
 
-func Run(address string, opts ...Option) error {
+func New(address string, opts ...Option) *SeaWolf {
 	conn, err := grpc.Dial(address, grpc.WithInsecure())
 	if err != nil {
-		return err
+		panic(err)
 	}
 	defer conn.Close()
+	client := filer_pb.NewSeaweedFilerClient(conn)
 
 	wolf := &SeaWolf{
+		client:    client,
 		Listeners: make([]internal.FileListener, 0),
 	}
 
 	for _, opt := range opts {
 		opt(wolf)
 	}
 
-	client := filer_pb.NewSeaweedFilerClient(conn)
+	return wolf
+}
 
+func (wolf *SeaWolf) Run() error {
 	fmt.Println("Listening file metadata...")
 	for {
-		req, err := client.SubscribeMetadata(context.TODO(), &filer_pb.SubscribeMetadataRequest{
+		req, err := wolf.client.SubscribeMetadata(context.TODO(), &filer_pb.SubscribeMetadataRequest{
 			SinceNs: time.Now().UnixNano(),
 		})
 		if err != nil {
@@ -78,3 +83,7 @@ func Run(address string, opts ...Option) error {
 		}
 	}
 }
+
+func (wolf *SeaWolf) Client() filer_pb.SeaweedFilerClient {
+	return wolf.client
+}