1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17
package localsink import ( "github.com/chrislusf/seaweedfs/weed/replication/sink" ) type LocalIncSink struct { LocalSink } func (localincsink *LocalIncSink) GetName() string { return "local_incremental" } func init() { sink.Sinks = append(sink.Sinks, &LocalIncSink{}) }