weed/replication/sink/localsink/local_incremental_sink.go


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

package localsink

import (
	"github.com/seaweedfs/seaweedfs/weed/replication/sink"
)

type LocalIncSink struct {
	LocalSink
}

func (localincsink *LocalIncSink) GetName() string {
	return "local_incremental"
}

func init() {
	sink.Sinks = append(sink.Sinks, &LocalIncSink{})
}