code: func (queue *BufferedQueue) Start() error {
  	queue.redisClient.SAdd(masterQueueKey(), queue.Name)
  	val := queue.redisClient.Get(queueHeartbeatKey(queue.Name)).Val()
  	if val == "ping" {
  		return fmt.Errorf("buffered queue with this name is already started")
  	}
  	queue.startHeartbeat()
  	queue.startWritingBufferToRedis()
  	queue.startPacemaker()
  	return nil
  }
docs: // Start dispatches the background writer that flushes the buffer.
  // If there is already a BufferedQueue running it will return an error.