before watch pause

br/pkg/streamhelper/models.go

@@ -94,6 +94,12 @@ func Pause(task string) string {
 	return path.Join(streamKeyPrefix, taskPausePath, task)
 }
 
+// PrefixOfPause returns the prefix for pausing the task.
+// Normally it would be <prefix>/pause/
+func PrefixOfPause() string {
+	return path.Join(streamKeyPrefix, taskPausePath) + "/"
+}
+
 // LastErrorPrefixOf make the prefix for searching last error by some task.
 func LastErrorPrefixOf(task string) string {
 	return strings.TrimSuffix(path.Join(streamKeyPrefix, taskLastErrorPath, task), "/") + "/"