Method state

src/slave/http.cpp:1331–1553

Future<Response> Http::state(
    const Request& request,
    const Option<Principal>& principal) const
{
  if (slave->state == Slave::RECOVERING) {
    return ServiceUnavailable("Agent has not finished recovery");
  }

  return ObjectApprovers::create(
             slave->authorizer,
             principal,
             {VIEW_FRAMEWORK,
              VIEW_TASK,
              VIEW_EXECUTOR,
              VIEW_FLAGS,
              VIEW_ROLE,
              VIEW_RESOURCE_PROVIDER})
    .then(defer(
        slave->self(),
        [this, request](const Owned<ObjectApprovers>& approvers) -> Response {
          // This lambda is consumed before the outer lambda
          // returns, hence capture by reference is fine here.
          auto state = [this, &approvers](JSON::ObjectWriter* writer) {
            writer->field("version", MESOS_VERSION);

            if (build::GIT_SHA.isSome()) {
              writer->field("git_sha", build::GIT_SHA.get());
            }

            if (build::GIT_BRANCH.isSome()) {
              writer->field("git_branch", build::GIT_BRANCH.get());
            }

            if (build::GIT_TAG.isSome()) {
              writer->field("git_tag", build::GIT_TAG.get());
            }

            writer->field("build_date", build::DATE);
            writer->field("build_time", build::TIME);
            writer->field("build_user", build::USER);
            writer->field("start_time", slave->startTime.secs());

            writer->field("id", slave->info.id().value());
            writer->field("pid", string(slave->self()));
            writer->field("hostname", slave->info.hostname());
            writer->field(
                "capabilities",
                slave->capabilities.toRepeatedPtrField());

            if (slave->info.has_domain()) {
              writer->field("domain", slave->info.domain());
            }

            if (slave->drainConfig.isSome()) {
              writer->field(
                  "drain_config",
                  JSON::Protobuf(slave->drainConfig.get()));