Support to get kyuubi server event with RESTful api

kyuubi-common/src/main/scala/org/apache/kyuubi/config/KyuubiConf.scala

@@ -3940,4 +3940,24 @@ object KyuubiConf {
       .version("1.9.1")
       .serverOnly
       .fallbackConf(HIVE_SERVER2_THRIFT_RESULTSET_DEFAULT_FETCH_SIZE)
+
+  object ServerEventConfMode extends Enumeration {
+    type ServerEventConfMode = Value
+    val ORIGINAL, REDACTED, NONE = Value
+  }
+
+  val SERVER_EVENT_CONF_MODE: ConfigEntry[String] =
+    buildConf("kyuubi.server.event.conf.mode")
+      .doc("Specifies how server configuration is exposed in server events. " +
+        "Available options are: <ul>" +
+        " <li>ORIGINAL: Return the original server configuration.</li>" +
+        " <li>REDACTED: Redact sensitive information based on" +
+        s" ${SERVER_SECRET_REDACTION_PATTERN.key}.</li>" +
+        " <li>NONE: Do not return any server configuration.</li></ul>")
+      .version("1.11.0")
+      .serverOnly
+      .stringConf
+      .transformToUpperCase
+      .checkValues(ServerEventConfMode)
+      .createWithDefault(ServerEventConfMode.REDACTED.toString)
 }

kyuubi-rest-client/src/main/java/org/apache/kyuubi/client/AdminRestApi.java

@@ -20,6 +20,7 @@
 import java.util.*;
 import org.apache.commons.lang3.StringUtils;
 import org.apache.kyuubi.client.api.v1.dto.Engine;
+import org.apache.kyuubi.client.api.v1.dto.KyuubiServerEvent;
 import org.apache.kyuubi.client.api.v1.dto.OperationData;
 import org.apache.kyuubi.client.api.v1.dto.ServerData;
 import org.apache.kyuubi.client.api.v1.dto.SessionData;
@@ -165,6 +166,12 @@ public List<ServerData> listServers() {
     return Arrays.asList(result);
   }
 
+  public KyuubiServerEvent getServerEvent() {
+    return this.getClient()
+        .get(
+            API_BASE_PATH + "/server/event", null, KyuubiServerEvent.class, client.getAuthHeader());
+  }
+
   private IRestClient getClient() {
     return this.client.getHttpClient();
   }

kyuubi-rest-client/src/main/java/org/apache/kyuubi/client/api/v1/dto/KyuubiServerEvent.java

@@ -0,0 +1,162 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.kyuubi.client.api.v1.dto;
+
+import java.util.Collections;
+import java.util.Map;
+import java.util.Objects;
+import org.apache.commons.lang3.builder.ReflectionToStringBuilder;
+import org.apache.commons.lang3.builder.ToStringStyle;
+
+public class KyuubiServerEvent {
+  private String serverName;
+  private Long startTime;
+  private Long eventTime;
+  private String state;
+  private String serverIP;
+  private Map<String, String> serverConf;
+  private Map<String, String> serverEnv;
+  private Map<String, String> buildInfo;
+
+  public KyuubiServerEvent() {}
+
+  public KyuubiServerEvent(
+      String serverName,
+      Long startTime,
+      Long eventTime,
+      String state,
+      String serverIP,
+      Map<String, String> serverConf,
+      Map<String, String> serverEnv,
+      Map<String, String> buildInfo) {
+    this.serverName = serverName;
+    this.startTime = startTime;
+    this.eventTime = eventTime;
+    this.state = state;
+    this.serverIP = serverIP;
+    this.serverConf = serverConf;
+    this.serverEnv = serverEnv;
+    this.buildInfo = buildInfo;
+  }
+
+  public String getServerName() {
+    return serverName;
+  }
+
+  public void setServerName(String serverName) {
+    this.serverName = serverName;
+  }
+
+  public Long getStartTime() {
+    return startTime;
+  }
+
+  public void setStartTime(Long startTime) {
+    this.startTime = startTime;
+  }
+
+  public Long getEventTime() {
+    return eventTime;
+  }
+
+  public void setEventTime(Long eventTime) {
+    this.eventTime = eventTime;
+  }
+
+  public String getState() {
+    return state;
+  }
+
+  public void setState(String state) {
+    this.state = state;
+  }
+
+  public String getServerIP() {
+    return serverIP;
+  }
+
+  public void setServerIP(String serverIP) {
+    this.serverIP = serverIP;
+  }
+
+  public Map<String, String> getServerConf() {
+    if (null == serverConf) {
+      return Collections.emptyMap();
+    }
+    return serverConf;
+  }
+
+  public void setServerConf(Map<String, String> serverConf) {
+    this.serverConf = serverConf;
+  }
+
+  public Map<String, String> getServerEnv() {
+    if (null == serverEnv) {
+      return Collections.emptyMap();
+    }
+    return serverEnv;
+  }
+
+  public void setServerEnv(Map<String, String> serverEnv) {
+    this.serverEnv = serverEnv;
+  }
+
+  public Map<String, String> getBuildInfo() {
+    if (null == buildInfo) {
+      return Collections.emptyMap();
+    }
+    return buildInfo;
+  }
+
+  public void setBuildInfo(Map<String, String> buildInfo) {
+    this.buildInfo = buildInfo;
+  }
+
+  @Override
+  public boolean equals(Object o) {
+    if (this == o) return true;
+    if (o == null || getClass() != o.getClass()) return false;
+    KyuubiServerEvent that = (KyuubiServerEvent) o;
+    return Objects.equals(getServerName(), that.getServerName())
+        && Objects.equals(getStartTime(), that.getStartTime())
+        && Objects.equals(getEventTime(), that.getEventTime())
+        && Objects.equals(getState(), that.getState())
+        && Objects.equals(getServerIP(), that.getServerIP())
+        && Objects.equals(getServerConf(), that.getServerConf())
+        && Objects.equals(getServerEnv(), that.getServerEnv())
+        && Objects.equals(getBuildInfo(), that.getBuildInfo());
+  }
+
+  @Override
+  public int hashCode() {
+    return Objects.hash(
+        getServerName(),
+        getStartTime(),
+        getEventTime(),
+        getState(),
+        getServerIP(),
+        getServerConf(),
+        getServerEnv(),
+        getBuildInfo());
+  }
+
+  @Override
+  public String toString() {
+    return ReflectionToStringBuilder.toString(this, ToStringStyle.JSON_STYLE);
+  }
+}

kyuubi-server/src/main/scala/org/apache/kyuubi/server/KyuubiServer.scala

@@ -231,6 +231,10 @@ class KyuubiServer(name: String) extends Serverable(name) {
     super.stop()
   }
 
+  def getServerEvent(): Option[KyuubiServerInfoEvent] = {
+    KyuubiServerInfoEvent(this, state)
+  }
+
   private def initLoggerEventHandler(conf: KyuubiConf): Unit = {
     ServerEventHandlerRegister.registerEventLoggers(conf)
   }

kyuubi-server/src/main/scala/org/apache/kyuubi/server/api/ApiUtils.scala

@@ -21,9 +21,12 @@ import scala.collection.JavaConverters._
 
 import org.apache.kyuubi.{Logging, Utils}
 import org.apache.kyuubi.client.api.v1.dto
-import org.apache.kyuubi.client.api.v1.dto.{OperationData, OperationProgress, ServerData, SessionData}
+import org.apache.kyuubi.client.api.v1.dto.{KyuubiServerEvent, OperationData, OperationProgress, ServerData, SessionData}
+import org.apache.kyuubi.config.KyuubiConf
+import org.apache.kyuubi.events.KyuubiServerInfoEvent
 import org.apache.kyuubi.ha.client.ServiceNodeInfo
 import org.apache.kyuubi.operation.KyuubiOperation
+import org.apache.kyuubi.server.KyuubiServer
 import org.apache.kyuubi.session.KyuubiSession
 
 object ApiUtils extends Logging {
@@ -136,6 +139,34 @@ object ApiUtils extends Logging {
       "Running")
   }
 
+  def serverEvent(serverEvent: KyuubiServerInfoEvent): KyuubiServerEvent = {
+    if (serverEvent == null) return new KyuubiServerEvent()
+    new KyuubiServerEvent(
+      serverEvent.serverName,
+      serverEvent.startTime,
+      serverEvent.eventTime,
+      serverEvent.state,
+      serverEvent.serverIP,
+      processServerConf(serverEvent.serverConf).asJava,
+      serverEvent.serverEnv.asJava,
+      (Map(
+        "BUILD_USER" -> serverEvent.BUILD_USER,
+        "BUILD_DATE" -> serverEvent.BUILD_DATE,
+        "REPO_URL" -> serverEvent.REPO_URL) ++ serverEvent.VERSION_INFO).asJava)
+  }
+
+  private def processServerConf(serverConf: Map[String, String]): Map[String, String] = {
+    val kyuubiConf = Option(KyuubiServer.kyuubiServer).map(_.getConf).getOrElse(new KyuubiConf())
+    val confMode = kyuubiConf.get(KyuubiConf.SERVER_EVENT_CONF_MODE)
+    KyuubiConf.ServerEventConfMode.withName(confMode) match {
+      case KyuubiConf.ServerEventConfMode.ORIGINAL => serverConf
+      case KyuubiConf.ServerEventConfMode.REDACTED =>
+        val redactionPattern = kyuubiConf.get(KyuubiConf.SERVER_SECRET_REDACTION_PATTERN)
+        Utils.redact(redactionPattern, serverConf.toSeq).toMap
+      case KyuubiConf.ServerEventConfMode.NONE => Map.empty[String, String]
+    }
+  }
+
   def logAndRefineErrorMsg(errorMsg: String, throwable: Throwable): String = {
     error(errorMsg, throwable)
     s"$errorMsg: ${Utils.prettyPrint(throwable)}"

kyuubi-server/src/main/scala/org/apache/kyuubi/server/api/v1/AdminResource.scala

@@ -378,7 +378,7 @@ private[v1] class AdminResource extends ApiRequestContext with Logging {
       new Content(
         mediaType = MediaType.APPLICATION_JSON,
         array = new ArraySchema(schema = new Schema(implementation =
-          classOf[OperationData])))),
+          classOf[ServerData])))),
     description = "list all live kyuubi servers")
   @GET
   @Path("server")
@@ -401,6 +401,19 @@ private[v1] class AdminResource extends ApiRequestContext with Logging {
     servers.toSeq
   }
 
+  @ApiResponse(
+    responseCode = "200",
+    content = Array(
+      new Content(
+        mediaType = MediaType.APPLICATION_JSON,
+        schema = new Schema(implementation = classOf[KyuubiServerEvent]))),
+    description = "Get the server event")
+  @GET
+  @Path("server/event")
+  def getServerEvent(): KyuubiServerEvent = {
+    ApiUtils.serverEvent(KyuubiServer.kyuubiServer.getServerEvent().orNull)
+  }
+
   private def normalizeEngineInfo(
       userName: String,
       engineType: String,

kyuubi-server/src/test/scala/org/apache/kyuubi/server/api/v1/AdminResourceSuite.scala

@@ -841,4 +841,15 @@ class AdminResourceSuite extends KyuubiFunSuite with RestFrontendTestHelper {
       assert("Running".equals(testServer.getStatus))
     }
   }
+
+  test("get server event") {
+    val response = webTarget.path("api/v1/admin/server/event")
+      .request()
+      .header(AUTHORIZATION_HEADER, HttpAuthUtils.basicAuthorizationHeader(Utils.currentUser))
+      .get
+
+    assert(response.getStatus === 200)
+    val serverEvent = response.readEntity(classOf[KyuubiServerEvent])
+    assert(serverEvent.getStartTime > 0)
+  }
 }

kyuubi-server/src/test/scala/org/apache/kyuubi/server/rest/client/AdminRestApiSuite.scala

@@ -173,4 +173,14 @@ class AdminRestApiSuite extends RestClientTestHelper {
       assert(servers.map(s => s.getInstance()).contains(server.frontendServices.last.connectionUrl))
     }
   }
+
+  test("get server event") {
+    val spnegoKyuubiRestClient: KyuubiRestClient =
+      KyuubiRestClient.builder(baseUri.toString)
+        .authHeaderMethod(KyuubiRestClient.AuthHeaderMethod.SPNEGO)
+        .spnegoHost("localhost")
+        .build()
+    val adminRestApi = new AdminRestApi(spnegoKyuubiRestClient)
+    assert(adminRestApi.getServerEvent.getStartTime > 0)
+  }
 }