Merge pull request #27 from Saetch/25-kubernetes-integration

updated necessary name for kubernetes deploy

Cluster/Master/Program.cs

@@ -1,4 +1,4 @@
-using System.Net;
+using System.Net;
 using System.Text.Json.Serialization;
 using System.Globalization;
 using System.Text.Json;
@@ -356,7 +356,7 @@ static async Task<List<WanderingPosition>> FindAbandonedValuesFromNode(String no
     }
 
     static async Task<List<Position>> GetPositions(List<Tuple<int, int>> positions, HttpClient httpClient){
-        String url = "http://hasher_service:8080/hash_multiple?vec=";
+        String url = "http://hasher-service:8080/hash_multiple?vec=";
         foreach(Tuple<int, int> position in positions){
             url += "x:"+position.Item1 + "," + "y:"+position.Item2 + ";";
         }

Cluster/Node_cs/NodeBehavior.cs

@@ -507,7 +507,7 @@ private static async Task<List<HashedPosition>> QueryHasherForPoints(List<Point>
                 TypeInfoResolver = AppJsonSerializerContext.Default
             };
             using (HttpClient httpClient = new HttpClient()){
-                string baseUrl = "http://hasher_service:8080/hash_multiple";
+                string baseUrl = "http://hasher-service:8080/hash_multiple";
                 Console.WriteLine("Making request to: " + baseUrl);
                 var json = JsonSerializer.Serialize(positions, options);
                 var query = "?vec=" + json.Replace("[{","").Replace("}]","").Replace("},{",";").Replace("\"","");

Cluster/coordinator/src/post_requests.rs

@@ -9,7 +9,7 @@ use rand::Rng;
 
 use crate::{communication::{HashedPosition, NodeRegisterResponse, Position}, deal_with_nodes::{self, distribute_value}, state::{InteriorMutableState, NodeOccupation, NodeState}};
 
-pub const HASHER_SERVICE_URL : &str = "http://hasher_service:8080/hash/";
+pub const HASHER_SERVICE_URL : &str = "http://hasher-service:8080/hash/";
 
 pub async fn register(path: web::Path<String>, data: web::Data<InteriorMutableState>) -> impl Responder {
     let client = Client::default();

Cluster/docker-compose.yml

@@ -54,7 +54,7 @@ services:
       depends_on:
         - coordinator
         - hasher_service
-    hasher_service:
+    hasher-service:
       image: ghcr.io/saetch/hasher_service:latest
       ports:
         - "5002:8080"       ## this is for debug purposes, the service does not need to be exposed to the host at all

deploy/deploy-nodes.yaml

@@ -0,0 +1,43 @@
+apiVersion: apps/v1
+kind: Deployment
+metadata:
+  name: d-nodecs
+spec:
+  replicas: 4
+  selector:
+    matchLabels:
+      app: d-nodecs
+  template:
+    metadata:
+      labels:
+        app: d-nodecs
+    spec:
+      containers:
+        - name: app
+          image: ghcr.io/saetch/deightma_nodecs:latest
+          ports:
+            - containerPort: 5552
+              name: d-nodecs-p
+          env:
+            - name: DB_HOST
+              value: test-db
+          resources:
+            requests:
+              memory: "20Mi"
+              cpu: "10m"
+            limits:
+              memory: "100Mi"
+              cpu: "100m"
+---
+apiVersion: v1
+kind: Service
+metadata:
+  name: d-nodecs
+spec:
+  selector:
+    app: d-nodecs
+  ports:
+    - name: d-nodecs-p
+      protocol: TCP
+      port: 5552
+      targetPort: d-nodecs-p