Method resolveSecrets

src/csi/v0_volume_manager.cpp:1282–1319

Future<Map<string, string>> VolumeManagerProcess::resolveSecrets(
    const Map<string, Secret>& secrets)
{
  if (!secretResolver) {
    return Failure(
        "CSI volume included secrets but the agent was not initialized with "
        "a secret resolver");
  }

  // This `futures` is used below with `process::collect()` to synchronize the
  // continuation. Within the continuation itself, we need to have the
  // key:value mapping of the secrets, so we use `resolvedSecrets` instead.
  vector<Future<Secret::Value>> futures;
  hashmap<string, Future<Secret::Value>> resolvedSecrets;

  for (auto it = secrets.begin(); it != secrets.end(); ++it) {
    Future<Secret::Value> pendingSecret = secretResolver->resolve(it->second);

    futures.push_back(pendingSecret);
    resolvedSecrets.insert({it->first, pendingSecret});
  }

  return process::collect(futures)
    .then([=]() {
      Map<string, string> result;

      foreachpair (
          const string& key,
          const Future<Secret::Value>& secret,
          resolvedSecrets) {
        CHECK(secret.isReady());

        result.insert({key, secret->data()});
      }

      return result;
    });
}


VolumeManager::VolumeManager(