with

SlimPlanet · Jan 26, 2025 · 80eabce · 80eabce
1 parent 5fdd09b
commit 80eabce
Show file tree

Hide file tree

Showing 3 changed files with 17 additions and 7 deletions.
diff --git a/README.md b/README.md
@@ -305,6 +305,16 @@ spec:
             #      "requestJournal:expiration":"00:01:00",
             #      "heartbeatThreshold":"0.5",
             #   }
+            # name : SLIMFAAS_JOB_CONFIGURATION
+            # value : | # represent SlimFaas internal configuration, more documentation here:
+            #    {
+            #          "DefaultNumberParallelRequest": 1, # Timeout in seconds
+            #          "DefaultVisibility": "Private", # Retry pattern in seconds
+            #          "AllowDynamicJob": false,
+            #          "Jobs": {
+            #              "daisy" : { "NumberParallelRequest": 1, "Visibility": "Public" }
+            #          }
+            #    }
           volumeMounts:
             - name: slimfaas-volume
               mountPath: /database

diff --git a/src/SlimFaas/SlimProxyMiddleware.cs b/src/SlimFaas/SlimProxyMiddleware.cs
@@ -14,7 +14,7 @@ public enum FunctionType
     Wake,
     Status,
     Publish,
-    AsyncJob,
+    Job,
     NotAFunction
 }
 
@@ -47,7 +47,7 @@ public class SlimProxyMiddleware(RequestDelegate next, ISlimFaasQueue slimFaasQu
     private const string WakeFunction = "/wake-function";
     private const string Function = "/function";
     private const string PublishEvent = "/publish-event";
-    private const string AsyncJob = "/async-job";
+    private const string Job = "/job";
 
     private readonly int[] _slimFaasPorts = EnvironmentVariables.ReadIntegers(EnvironmentVariables.SlimFaasPorts,
         EnvironmentVariables.SlimFaasPortsDefault);
@@ -91,7 +91,7 @@ await contextResponse.WriteAsJsonAsync(functionStatuses,
             case FunctionType.NotAFunction:
                 await next(context);
                 return;
-            case  FunctionType.AsyncJob:
+            case  FunctionType.Job:
 
                 if (jobService == null)
                 {
@@ -568,7 +568,7 @@ private static FunctionInfo GetFunctionInfo(ILogger<SlimProxyMiddleware> faasLog
             StatusFunction => FunctionType.Status,
             WakeFunction => FunctionType.Wake,
             PublishEvent => FunctionType.Publish,
-            AsyncJob => FunctionType.AsyncJob,
+            Job => FunctionType.Job,
             _ => FunctionType.NotAFunction
         };
         return new FunctionInfo(functionPath, functionName, functionType);
@@ -597,9 +597,9 @@ private static string FunctionBeginPath(PathString path)
         {
             functionBeginPath = $"{PublishEvent}";
         }
-        else if (path.StartsWithSegments(AsyncJob))
+        else if (path.StartsWithSegments(Job))
         {
-            functionBeginPath = $"{AsyncJob}";
+            functionBeginPath = $"{Job}";
         }
 
         return functionBeginPath;

diff --git a/tests/SlimFaas.Tests/SlimProxyMiddlewareTests.cs b/tests/SlimFaas.Tests/SlimProxyMiddlewareTests.cs
@@ -305,7 +305,7 @@ public async Task GetStatusFunctionAndReturnOk(string path, HttpStatusCode expec
     }
 
     [Theory]
-    [InlineData("/async-job/daisy", HttpStatusCode.NoContent, 1)]
+    [InlineData("/job/daisy", HttpStatusCode.NoContent, 1)]
     public async Task RunJobAndReturnOk(string path, HttpStatusCode expectedHttpStatusCode,
         int numberFireJob)
     {