Function WaitingTaskKey

pkg/redis/redis.go:428–430

WaitingTaskKey returns the subkey of k, where waiting tasks are stored.

(k string)

// WaitingTaskKey returns the subkey of k, where waiting tasks are stored.
func WaitingTaskKey(k string) string {
	return Key(k, "waiting")
}

// IsConsumerGroupExistsErr returns true if error represents the redis BUSYGROUP error.
func IsConsumerGroupExistsErr(err error) bool {