From 88d511af912af93eb4f3c899fe30af7436601844 Mon Sep 17 00:00:00 2001
From: jonatan <jonatan5524@gmail.com>
Date: Sat, 28 Dec 2024 17:13:24 +0200
Subject: [PATCH] remove old directory

---
 pkg/service/clusterIP.go | 70 ----------------------------------------
 pkg/service/nodePort.go  | 45 --------------------------
 2 files changed, 115 deletions(-)
 delete mode 100644 pkg/service/clusterIP.go
 delete mode 100644 pkg/service/nodePort.go

diff --git a/pkg/service/clusterIP.go b/pkg/service/clusterIP.go
deleted file mode 100644
index 34dc519..0000000
--- a/pkg/service/clusterIP.go
+++ /dev/null
@@ -1,70 +0,0 @@
-package service
-
-import (
-	"fmt"
-
-	"github.com/jonatan5524/own-kubernetes/pkg"
-	"github.com/jonatan5524/own-kubernetes/pkg/net"
-)
-
-const (
-	CLUSTER_IP_SERVICE_PREFIX = "KUBE-SVC"
-)
-
-func NewClusterIPService(port string, podsCidr string) (*Service, error) {
-	const MAX_CHAIN_NAME = 29
-	serviceName := pkg.GenerateNewID(CLUSTER_IP_SERVICE_PREFIX)[:MAX_CHAIN_NAME-len(CLUSTER_IP_SERVICE_PREFIX)-1]
-
-	if err := net.NewIPTablesChain(serviceName); err != nil {
-		return nil, err
-	}
-
-	ipAddr := "172.17.10.10"
-
-	// iptables -t nat -I KUBE-SERVICES 1 ! -s podsCidr -d 1ipAddr -p tcp -m tcp --dport port -j KUBE-MARK-MASQ
-	if err := net.InsertNewIPTablesRule(
-		fmt.Sprintf("! -s %s -d %s -p tcp -m tcp --dport %s -j %s", podsCidr, ipAddr, port, KUBE_SERVICE_MARK),
-		KUBE_SERVICES_CHAIN, 1); err != nil {
-		return nil, err
-	}
-
-	// iptables -t nat -A KUBE-SERVICES -d clusterIP -p tcp -m tcp --dport port -j ServicerName
-	if err := net.AppendNewIPTablesRule(
-		fmt.Sprintf("-d %s -p tcp -m tcp --dport %s -j %s", ipAddr, port, serviceName),
-		KUBE_SERVICES_CHAIN); err != nil {
-		return nil, err
-	}
-
-	return &Service{
-		Type:   CluserIP,
-		Id:     serviceName,
-		IpAddr: ipAddr,
-		Port:   port,
-	}, nil
-}
-
-func AddRouteToClusterIPService(ip string, port string, service string, index int) error {
-	podService := fmt.Sprintf(service[:len(service)-3]+"-%d", index)
-
-	if err := net.NewIPTablesChain(podService); err != nil {
-		return err
-	}
-
-	// iptables -t nat -A podService -s podIp -j KUBE-MARK-MASQ
-	if err := net.AppendNewIPTablesRule(fmt.Sprintf("-s %s -j %s", ip, KUBE_SERVICE_MARK), podService); err != nil {
-		return err
-	}
-
-	// iptables -t nat -A podService -p tcp -m tcp -j DNAT --to-destination route
-	if err := net.AppendNewIPTablesRule(fmt.Sprintf("-p tcp -m tcp -j DNAT --to-destination %s", fmt.Sprintf("%s:%s", ip, port)), podService); err != nil {
-		return err
-	}
-
-	if index == 0 {
-		// iptables -t nat -A serviceName -j podService
-		return net.AppendNewIPTablesRule(fmt.Sprintf("-j %s", podService), service)
-	}
-
-	// iptables -t nat -A service -m statistic --mode nth --every index --packet 0 -j podService
-	return net.InsertNewIPTablesRule(fmt.Sprintf("-m statistic --mode nth --every %d --packet 0 -j %s", index+1, podService), service, 1)
-}
diff --git a/pkg/service/nodePort.go b/pkg/service/nodePort.go
deleted file mode 100644
index 29c9178..0000000
--- a/pkg/service/nodePort.go
+++ /dev/null
@@ -1,45 +0,0 @@
-package service
-
-import (
-	"fmt"
-
-	"github.com/jonatan5524/own-kubernetes/pkg/net"
-)
-
-const (
-	NODE_PORT_SERVICE_CHAIN = "KUBE-NODEPORT"
-)
-
-func NewNodePortService(port string, podsCidr string, nodeIP string) (*Service, *Service, error) {
-	clusterIPService, err := NewClusterIPService("3001", podsCidr)
-	if err != nil {
-		return nil, nil, err
-	}
-
-	// iptables -t nat -N KUBE-NODEPORTS
-	if err := net.NewIPTablesChain(NODE_PORT_SERVICE_CHAIN); err != nil {
-		return nil, nil, err
-	}
-
-	// iptables -t nat -A KUBE-SERVICES -j KUBE-NODEPORTS
-	if err := net.AppendNewIPTablesRule(fmt.Sprintf("-j %s", NODE_PORT_SERVICE_CHAIN), KUBE_SERVICES_CHAIN); err != nil {
-		return nil, nil, err
-	}
-
-	// iptables -t nat -I KUBE-NODEPORTS 1 -p tcp -m tcp --dport port -j KUBE-MARK-MASQ
-	if err := net.InsertNewIPTablesRule(fmt.Sprintf("-p tcp -m tcp --dport %s -j %s", port, KUBE_SERVICE_MARK), NODE_PORT_SERVICE_CHAIN, 1); err != nil {
-		return nil, nil, err
-	}
-
-	// iptables -t nat -A KUBE-NODEPORTS -p tcp -m tcp --dport port -j clusterIPService
-	if err := net.AppendNewIPTablesRule(fmt.Sprintf("-p tcp -m tcp --dport %s -j %s", port, clusterIPService.Id), NODE_PORT_SERVICE_CHAIN); err != nil {
-		return nil, nil, err
-	}
-
-	return clusterIPService, &Service{
-		Type:   NodePort,
-		Id:     NODE_PORT_SERVICE_CHAIN,
-		IpAddr: nodeIP,
-		Port:   port,
-	}, nil
-}