code: func (db *BytesConnectionRedis) NewBrokerWatcher(prefix string) *BytesBrokerWatcherRedis {
  	return &BytesBrokerWatcherRedis{db.Logger, prefix, db, db.closeCh}
  }
docs: // NewBrokerWatcher creates a new CRUD + KeyValProtoWatcher proxy instance to redis using BytesConnectionRedis.
  // The given prefix will be prepended to key argument in all calls.
  // Specify empty string ("") if not wanting to use prefix.