diff options
Diffstat (limited to 'weed/command/filer_replication.go')
| -rw-r--r-- | weed/command/filer_replication.go | 24 |
1 files changed, 14 insertions, 10 deletions
diff --git a/weed/command/filer_replication.go b/weed/command/filer_replication.go index 087a12059..3384e4023 100644 --- a/weed/command/filer_replication.go +++ b/weed/command/filer_replication.go @@ -41,16 +41,7 @@ func runFilerReplicate(cmd *Command, args []string) bool { var notificationInput sub.NotificationInput - enabledInput := "" - for _, input := range sub.NotificationInputs { - if config.GetBool("notification." + input.GetName() + ".enabled") { - if enabledInput == "" { - enabledInput = input.GetName() - } else { - glog.Fatalf("Notification input is enabled for both %s and %s", enabledInput, input.GetName()) - } - } - } + validateOneEnabledInput(config) for _, input := range sub.NotificationInputs { if config.GetBool("notification." + input.GetName() + ".enabled") { @@ -133,3 +124,16 @@ func runFilerReplicate(cmd *Command, args []string) bool { return true } + +func validateOneEnabledInput(config *viper.Viper) { + enabledInput := "" + for _, input := range sub.NotificationInputs { + if config.GetBool("notification." + input.GetName() + ".enabled") { + if enabledInput == "" { + enabledInput = input.GetName() + } else { + glog.Fatalf("Notification input is enabled for both %s and %s", enabledInput, input.GetName()) + } + } + } +} |