code: func NewByteQueue(pool *redis.Pool, name string) *ByteQueue {
  	return &ByteQueue{BaseQueue{
  		source: name,
  		pool:   pool,
  	}}
  }
docs: // NewByteQueue allocates and returns a pointer to a new instance of a
  // ByteQueue. It initializes itself using the given *redis.Pool, and the name,
  // which refers to the keyspace wherein these values will be stored.
  //
  // Internal channels are also initialized here.