Method addResourceProviderConfig

src/slave/http.cpp:4028–4069

Future<Response> Http::addResourceProviderConfig(
    const mesos::agent::Call& call,
    const Option<Principal>& principal) const
{
  CHECK_EQ(mesos::agent::Call::ADD_RESOURCE_PROVIDER_CONFIG, call.type());
  CHECK(call.has_add_resource_provider_config());

  const ResourceProviderInfo& info = call.add_resource_provider_config().info();

  LOG(INFO)
    << "Processing ADD_RESOURCE_PROVIDER_CONFIG call with"
    << " type '" << info.type() << "' and name '" << info.name() << "'";

  return ObjectApprovers::create(
             slave->authorizer, principal, {MODIFY_RESOURCE_PROVIDER_CONFIG})
    .then(defer(
        slave->self(),
        [=](const Owned<ObjectApprovers>& approvers) -> Future<Response> {
          if (!approvers->approved<MODIFY_RESOURCE_PROVIDER_CONFIG>()) {
            return Forbidden();
          }

          Option<Error> error = LocalResourceProvider::validate(info);
          if (error.isSome()) {
            return BadRequest(
                "Failed to validate resource provider config with type '" +
                info.type() + "' and name '" + info.name() + "': " +
                error->message);
          }

          return slave->localResourceProviderDaemon->add(info)
            .then([info](bool added) -> Response {
              if (!added) {
                return Conflict(
                    "Resource provider with type '" + info.type() +
                    "' and name '" + info.name() + "' already exists");
              }

              return OK();
            });
        }));
}


Future<Response> Http::updateResourceProviderConfig(