feature(slimfaas): status-functions (#65)

* update * update * fix * update * update * update * update * update * update * dte * update * update
AxaFrance · Jun 24, 2024 · 8999eb6 · 8999eb6
1 parent f8cc3a7
commit 8999eb6
Show file tree

Hide file tree

Showing 18 changed files with 5,422 additions and 151 deletions.
diff --git a/README.md b/README.md
@@ -11,10 +11,13 @@ Why use SlimFaas?
   - Allows you to limit the number of parallel HTTP requests for each underlying function
 - Synchronous Publish event via HTTP calls (events) to every replicas which deployment subscribe to the event name
 - Retry: 3 times with graduation: 2 seconds, 4 seconds, 8 seconds
+- Private and Public functions
+- Private functions can be accessed only by internal namespace http call from pods
 - Mind Changer: REST API that show the status of your functions and allow to wake up your infrastructure
   - Very useful to inform end users that your infrastructure is starting
 - Plug and Play: just deploy a standard pod
   - No impact on your current kubernetes manifests: just add an annotation to the pod you want to auto-scale
+
 - Very **Slim** and very **Fast**
 
 ![slim-faas-ram-cpu.png](https://github.com/AxaFrance/SlimFaas/blob/main/documentation/slim-faas-ram-cpu.png)
@@ -38,7 +41,7 @@ kubectl apply -f deployment-functions.yml
 # Install MySql
 kubectl apply -f deployment-mysql.yml
 # to run Single Page webapp demo (optional) on http://localhost:8000
-docker run -p 8000:8000 --rm axaguildev/fibonacci-webapp:latest
+docker run -p 8000:8000 --rm axaguildev/fibonacci-webapp:pr-65-592
 ```
 
 
@@ -60,9 +63,14 @@ Just wake up function:
 - http://localhost:30021/wake-function/fibonacci3
 
 Get function status:
-- http://localhost:30021/status-function/fibonacci1 => {"NumberReady":1,"numberRequested":1}
-- http://localhost:30021/status-function/fibonacci2 => {"NumberReady":1,"numberRequested":1}
-- http://localhost:30021/status-function/fibonacci3 => {"NumberReady":1,"numberRequested":1}
+- http://localhost:30021/status-function/fibonacci1 => {"NumberReady":1,"numberRequested":1,PodType":"Deployment","Visibility":"Public","Name":"fibonacci1"}
+- http://localhost:30021/status-function/fibonacci2 => {"NumberReady":1,"numberRequested":1,PodType":"Deployment","Visibility":"Public","Name":"fibonacci2"}
+- http://localhost:30021/status-function/fibonacci3 => {"NumberReady":1,"numberRequested":1,PodType":"Deployment","Visibility":"Public","Name":"fibonacci3"}
+
+List all function status:
+- http://localhost:30021/status-functions => [{"NumberReady":1,"numberRequested":1,PodType":"Deployment","Visibility":"Public","Name":"fibonacci1"},
+                                              {"NumberReady":1,"numberRequested":1,PodType":"Deployment","Visibility":"Public","Name":"fibonacci2"},
+                                              {"NumberReady":1,"numberRequested":1,PodType":"Deployment","Visibility":"Public","Name":"fibonacci3"}]
 
 Send event to every function replicas (which deployment subscribe to the event name) in synchronous way:
 
@@ -205,7 +213,7 @@ spec:
             - name: BASE_FUNCTION_URL
               value: "http://{function_name}.{namespace}.svc.cluster.local:8080"
             - name: BASE_FUNCTION_POD_URL # require for publish route
-              value: "http://{pod_ip}.svc.cluster.local:8080"
+              value: "http://{pod_ip}:5000"
             - name: BASE_SLIMDATA_URL
               value: "http://{pod_name}.slimfaas.{namespace}.svc.cluster.local:3262/"  # Don't expose this port, it can also be like "http://{pod_ip}:3262/" but if you can use DNS it's better
             - name: SLIMFAAS_PORTS
@@ -382,6 +390,9 @@ Instead of creating many pods, SlimFaas use internally many workers in the same
 By default, **SlimData** use a second HTTP port 3262 to expose its API. Don't expose it and keep it internal.
 
 SlimFaas requires at least 3 nodes in production. 2 nodes are required to keep the database in a consistent state.
+
+![slimdata.PNG](https://github.com/AxaFrance/slimfaas/blob/main/documentation/slimdata.png)
+
 If you want to use just one pod for testing purpose, you can use this env variable:
 - SLIMDATA_CONFIGURATION: '{"coldStart":"true"}'
 

diff --git a/demo/deployment-functions.yml b/demo/deployment-functions.yml
@@ -20,6 +20,7 @@ spec:
         SlimFaas/TimeoutSecondBeforeSetReplicasMin: "10"
         SlimFaas/NumberParallelRequest: "10"
         SlimFaas/DependsOn: "fibonacci2"
+        SlimFaas/SubscribeEvents : "Public:fibo-public,Private:fibo-private"
         #SlimFaas/Schedule: |
         #          {"Culture":"fr-FR","Default":{"WakeUp":["07:00"],"ScaleDownTimeout":[{"Time": "21:00","Value":20},{"Time":"07:00","Value": 10}]}}
     spec:
@@ -66,6 +67,7 @@ spec:
         SlimFaas/ReplicasAtStart: "1"
         SlimFaas/TimeoutSecondBeforeSetReplicasMin: "10"
         SlimFaas/NumberParallelRequest : "10"
+        SlimFaas/SubscribeEvents : "Public:fibo-public,Private:fibo-private"
     spec:
       serviceAccountName: default
       containers:
@@ -112,6 +114,7 @@ spec:
         SlimFaas/TimeoutSecondBeforeSetReplicasMin: "10"
         SlimFaas/NumberParallelRequest : "10"
         SlimFaas/DependsOn: "mysql"
+        SlimFaas/SubscribeEvents : "Public:fibo-public,Private:fibo-private"
     spec:
       serviceAccountName: default
       containers:
@@ -157,6 +160,9 @@ spec:
         SlimFaas/ReplicasStartAsSoonAsOneFunctionRetrieveARequest: "false"
         SlimFaas/TimeoutSecondBeforeSetReplicasMin: "10"
         SlimFaas/NumberParallelRequest : "10"
+        SlimFaas/DefaultVisibility : "Private"
+        SlimFaas/SubscribeEvents : "Public:fibo-public,Private:fibo-private"
+
     spec:
       serviceAccountName: default
       containers:

diff --git a/demo/deployment-slimfaas.yml b/demo/deployment-slimfaas.yml
@@ -97,7 +97,7 @@ spec:
             - name: BASE_FUNCTION_URL
               value: "http://{function_name}.{namespace}.svc.cluster.local:5000"
             - name: BASE_FUNCTION_POD_URL # require for publish route
-              value: "http://{pod_name}.{function_name}.{namespace}.svc.cluster.local:8080"
+              value: "http://{pod_ip}:5000"
             - name: BASE_SLIMDATA_URL
               value: "http://{pod_ip}:3262/"
             - name: NAMESPACE

diff --git a/documentation/async_http_call.PNG b/documentation/async_http_call.PNG
diff --git a/documentation/publish_sync_call.png b/documentation/publish_sync_call.png
diff --git a/documentation/slimdata.png b/documentation/slimdata.png
diff --git a/documentation/slimfaas.pptx b/documentation/slimfaas.pptx
diff --git a/documentation/sync_http_call.PNG b/documentation/sync_http_call.PNG
diff --git a/src/Fibonacci/Program.cs b/src/Fibonacci/Program.cs
@@ -35,13 +35,44 @@
 
 app.MapGet("/hello/{name}", ([FromServices] ILogger<Fibonacci> logger, string name) =>
 {
-    logger.LogInformation("Hello Called");
+    logger.LogInformation("Hello Called with name: {Name}", name);
     return $"Hello {name}!";
 });
 
 
 app.MapGet("/health", () => "OK");
 
+
+app.MapPost("/fibonacci4", (
+    [FromServices] ILogger<Fibonacci> logger,
+    [FromServices] Fibonacci fibonacci,
+    FibonacciInput input) =>
+{
+    logger.LogInformation("Fibonacci Internal Called");
+    using HttpClient client = new();
+    var response = client.PostAsJsonAsync("http://slimfaas.slimfaas-demo.svc.cluster.local:5000/function/fibonacci4/fibonacci", input).Result;
+    var output = response.Content.ReadFromJsonAsync<FibonacciOutput>().Result;
+    logger.LogInformation("Fibonacci Internal output: {Output}", output.Result);
+    return output;
+});
+
+
+app.MapPost("/send-private-fibonacci-event", (
+    [FromServices] ILogger<Fibonacci> logger,
+    [FromServices] Fibonacci fibonacci,
+    FibonacciInput input) =>
+{
+    logger.LogInformation("Fibonacci Internal Event Called");
+    using HttpClient client = new();
+    var response = client.PostAsJsonAsync("http://slimfaas.slimfaas-demo.svc.cluster.local:5000/publish-event/fibo-private/fibonacci", input).Result;
+    logger.LogInformation("Response status code: {StatusCode}", response.StatusCode);
+    logger.LogInformation("Fibonacci Internal Event End");
+});
+
+
+
+
+
 app.Run();
 
 internal class Fibonacci

diff --git a/src/FibonacciReact/.npmrc b/src/FibonacciReact/.npmrc
@@ -0,0 +1,3 @@
+legacy-peer-deps=true
+strict-ssl=false
+registry=https://registry.npmjs.org/