local_incremental_sink.go 278 B

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