Browse Source

add logging

pull/747/head
Chris Lu 6 years ago
parent
commit
14858f6224
  1. 14
      weed/command/filer_replication.go

14
weed/command/filer_replication.go

@ -1,12 +1,16 @@
package command package command
import ( import (
"strings"
"github.com/chrislusf/seaweedfs/weed/glog" "github.com/chrislusf/seaweedfs/weed/glog"
"github.com/chrislusf/seaweedfs/weed/replication" "github.com/chrislusf/seaweedfs/weed/replication"
"github.com/chrislusf/seaweedfs/weed/server" "github.com/chrislusf/seaweedfs/weed/server"
"github.com/spf13/viper" "github.com/spf13/viper"
"strings"
"github.com/chrislusf/seaweedfs/weed/replication/sink" "github.com/chrislusf/seaweedfs/weed/replication/sink"
_ "github.com/chrislusf/seaweedfs/weed/replication/sink/s3sink"
_ "github.com/chrislusf/seaweedfs/weed/replication/sink/filersink"
_ "github.com/chrislusf/seaweedfs/weed/replication/sink/gcssink"
) )
func init() { func init() {
@ -72,6 +76,14 @@ func runFilerReplicate(cmd *Command, args []string) bool {
} }
} }
if dataSink == nil {
println("no data sink defined:")
for _, sk := range sink.Sinks {
println(" " + sk.GetName())
}
return true
}
replicator := replication.NewReplicator(config.Sub("source.filer"), dataSink) replicator := replication.NewReplicator(config.Sub("source.filer"), dataSink)
for { for {

Loading…
Cancel
Save