feat: redis에 pod 정보 업데이트

Author: jin20fd

DBManager/src/K8SApi/K8SApi.module.ts

@@ -1,7 +1,9 @@
 import { Module } from '@nestjs/common';
 import { K8SApiService } from './K8SApi.service';
+import { RedisModule } from 'src/config/redis/redis.module';
 
 @Module({
+  imports: [RedisModule],
   exports: [K8SApiService],
   providers: [K8SApiService],
 })

DBManager/src/K8SApi/K8SApi.service.ts

@@ -1,5 +1,6 @@
-import { Injectable } from '@nestjs/common';
+import { Injectable, OnModuleInit } from '@nestjs/common';
 import * as k8s from '@kubernetes/client-node';
+import { RedisService } from 'src/config/redis/redis.service';
 
 @Injectable()
 export class K8SApiService {
@@ -8,6 +9,8 @@ export class K8SApiService {
   private k8sWatch : k8s.Watch;
   private namespace = 'default';
 
+  constructor(private readonly redisService: RedisService) {}
+
   async onModuleInit() {
     const kc = new k8s.KubeConfig();
     kc.loadFromDefault();
@@ -21,18 +24,15 @@ export class K8SApiService {
     const queryParams = { allowWatchBookmarks: true };
     const handlePodEvent = (type : String, apiObj: any, watchObj: any) => {
       if (type === 'ADDED') {
-          console.log('Watch Created Pod');
-          console.log(watchObj.object.metadata.name);
+          const createdPod = watchObj.object.metadata.name;
+          this.redisService.hsetPod(createdPod, 'activeUser', 0);
       } else if (type === 'DELETED') {
-          console.log('Watch Deleted Pod');
-          console.log(watchObj.object.metadata.name);
+          const deletedPod = watchObj.object.metadata.name;
+          this.redisService.delPod(deletedPod);
       }
     };
-    const handleError = (err: any) => {
-      console.log(err);
-    };
 
-    const req = this.k8sWatch.watch(path, queryParams, handlePodEvent, handleError);
+    this.k8sWatch.watch(path, queryParams, handlePodEvent, err => {});
   }
 
   async createPod() {
@@ -51,13 +51,11 @@ export class K8SApiService {
     };
 
     const createdPod = await this.k8sApi.createNamespacedPod(this.namespace, mysqlPod);
-    // console.log('Created pod:', createdPod.body.metadata.name);
     return createdPod;
   }
 
   async deletePod(podName: string) {
     const deletePod = await this.k8sApi.deleteNamespacedPod(podName, this.namespace);
-    // console.log('Deleted pod:', deletePod.body.metadata.name);
     return deletePod;
   }
 

DBManager/src/config/redis/redis.service.ts

@@ -40,6 +40,10 @@ export class RedisService {
     await this.podConnection.hset(key, field, value);
   }
 
+  async delPod(key: string): Promise<void> {
+    await this.podConnection.del(key);
+  }
+
   async subscribeActiveUser(
     channel: string,
     onMessage: (message: string) => void,