Renamed the API for function worker liveliness probe

Author: mukesh-ctds

pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/FunctionsImpl.java

@@ -69,7 +69,7 @@
 @Slf4j
 public class FunctionsImpl extends ComponentImpl implements Functions<PulsarWorkerService> {
 
-    private boolean isIllegalStateException = false;
+    private boolean isFunctionWorkerAlive = true;
 
     public FunctionsImpl(Supplier<PulsarWorkerService> workerServiceSupplier) {
         super(workerServiceSupplier, Function.FunctionDetails.ComponentType.FUNCTION);
@@ -695,7 +695,7 @@ public void updateFunctionOnWorkerLeader(final String tenant,
         try {
             functionMetaDataManager.updateFunctionOnLeader(functionMetaData, delete);
         } catch (IllegalStateException e) {
-            this.isIllegalStateException = true;
+            this.isFunctionWorkerAlive = false;
             throw new RestException(Response.Status.INTERNAL_SERVER_ERROR, e.getMessage());
         } catch (IllegalArgumentException e) {
             throw new RestException(Response.Status.BAD_REQUEST, e.getMessage());
@@ -792,7 +792,7 @@ private Function.FunctionDetails validateUpdateRequestParams(final String tenant
         }
     }
 
-    public boolean checkForIllegalStateException() {
-        return this.isIllegalStateException;
+    public boolean checkLiveliness() {
+        return this.isFunctionWorkerAlive;
     }
 }

pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/rest/api/v3/FunctionsApiV3Resource.java

@@ -432,10 +432,10 @@ public void updateFunctionOnWorkerLeader(final @PathParam("tenant") String tenan
     }
 
     @GET
-    @Path("/restart")
-    public Response checkForIllegalStateException() {
-        boolean isIllegalStateException = functions().checkForIllegalStateException();
-        if (isIllegalStateException) {
+    @Path("/live")
+    public Response checkLiveliness() {
+        boolean isAlive = functions().checkLiveliness();
+        if (!isAlive) {
             return Response.status(Response.Status.SERVICE_UNAVAILABLE)
                     .entity("There is IllegalStateException, Service is not running. Need to restart.")
                     .build();

pulsar-functions/worker/src/main/java/org/apache/pulsar/functions/worker/service/api/Functions.java

@@ -103,5 +103,5 @@ FunctionInstanceStatusData getFunctionInstanceStatus(String tenant,
 
     List<FunctionDefinition> getBuiltinFunctions(AuthenticationParameters authParams);
 
-    boolean checkForIllegalStateException();
+    boolean checkLiveliness();
 }