Sea Wolf

This is made for listening seaweedfs's file metadata changes.

Install

go get github.com/tuxmart/seawolf

Usage

package main

import (
	"github.com/tuxmart/seawolf/example"
	"github.com/tuxmart/seawolf/v1"
)

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

You could implement your own file listeners by implementing FileListener interface.

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