Develop

backend/endpoint/workload.go

@@ -6,9 +6,10 @@ import (
 )
 
 type WorkloadEndpoint struct {
-	podUseCase        usecase.PodUseCase
-	deploymentUseCase usecase.DeploymentUseCase
-	resourceUseCase   usecase.ResourceUseCase
+	podUseCase          usecase.PodUseCase
+	deploymentUseCase   usecase.DeploymentUseCase
+	resourceUseCase     usecase.ResourceUseCase
+	troubleshootUseCase usecase.TroubleshootUseCase
 }
 
 func NewWorkloadEndpoint(podUseCase usecase.PodUseCase, deploymentUseCase usecase.DeploymentUseCase) *WorkloadEndpoint {
@@ -51,12 +52,8 @@ func (we *WorkloadEndpoint) ResourceTuning(namespace string, clusterCtx string)
 	we.resourceUseCase.Invoke(namespace, clusterCtx)
 }
 
-func (we *WorkloadEndpoint) TroubleshootPod(name string, namespace string, clusterCtx string) {
-	we.podUseCase.TroubleshootPod(name, namespace, clusterCtx)
-}
-
-func (we *WorkloadEndpoint) TroubleshootDeployment(name string, namespace string, clusterCtx string) {
-	we.deploymentUseCase.TroubleshootDeployment(name, namespace, clusterCtx)
+func (we *WorkloadEndpoint) AutoTroubleshoot(name string, namespace string, clusterCtx string, resource string) {
+	we.troubleshootUseCase.Invoke(name, namespace, clusterCtx, resource)
 }
 
 func (we *WorkloadEndpoint) ExportManifest(name string, namespace string, clusterCtx string) ([]byte, error) {

backend/kubeclient/deployment.go

@@ -4,6 +4,7 @@ import (
 	"Kubexplorer/backend/model"
 	"context"
 	"fmt"
+	v1_apps "k8s.io/api/apps/v1"
 	v1 "k8s.io/api/core/v1"
 	"k8s.io/apimachinery/pkg/api/resource"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@@ -111,6 +112,17 @@ func (d deploymentClient) GetDeployment(name string, namespace string, clusterCt
 	}, nil
 }
 
+func (d deploymentClient) GetDeploymentV2(name string, namespace string, clusterCtx string) (*v1_apps.Deployment, error) {
+	client, err := d.manager.ResolveClusterContext(clusterCtx)
+	if err != nil {
+		return &v1_apps.Deployment{}, fmt.Errorf("cluster %s is not registered", clusterCtx)
+	}
+
+	deployment, _ := client.AppsV1().Deployments(namespace).Get(context.TODO(), name, metav1.GetOptions{})
+
+	return deployment, nil
+}
+
 func (d deploymentClient) UpdateDeployment(name string, namespace string, dto model.DeploymentUpdate, clusterCtx string) error {
 	client, err := d.manager.ResolveClusterContext(clusterCtx)
 	if err != nil {

backend/kubeclient/interfaces.go

@@ -2,6 +2,9 @@ package kubeclient
 
 import (
 	"Kubexplorer/backend/model"
+	v1_apps "k8s.io/api/apps/v1"
+	v1_batch "k8s.io/api/batch/v1"
+	v1_core "k8s.io/api/core/v1"
 	"k8s.io/metrics/pkg/apis/metrics/v1beta1"
 )
 
@@ -23,13 +26,20 @@ type MetricClient interface {
 type PodClient interface {
 	GetPods(clusterCtx string) ([]model.PodDto, error)
 	GetPod(name string, namespace string, clusterCtx string) (model.PodDto, error)
+	GetPodV2(name string, namespace string, clusterCtx string) (*v1_core.Pod, error)
+
 	UpdatePod(name string, namespace string, dto model.PodUpdate, clusterCtx string) error
 	DeletePod(name string, namespace string, clusterCtx string) error
 }
 
+type JobClient interface {
+	GetJob(name string, namespace string, clusterCtx string) (*v1_batch.Job, error)
+}
+
 type DeploymentClient interface {
 	GetDeployments(clusterCtx string) ([]model.DeploymentDto, error)
 	GetDeployment(name string, namespace string, clusterCtx string) (model.DeploymentDto, error)
+	GetDeploymentV2(name string, namespace string, clusterCtx string) (*v1_apps.Deployment, error)
 	UpdateDeployment(name string, namespace string, dto model.DeploymentUpdate, clusterCtx string) error
 	DeleteDeployment(name string, namespace string, clusterCtx string) error
 	ExportManifest(name string, namespace string, clusterCtx string) ([]byte, error)

backend/kubeclient/job.go

@@ -0,0 +1,29 @@
+package kubeclient
+
+import (
+	"context"
+	"fmt"
+	v1 "k8s.io/api/batch/v1"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+)
+
+type jobClient struct {
+	manager ClusterResolver
+}
+
+func NewJob(manager ClusterResolver) JobClient {
+	return &jobClient{
+		manager: manager,
+	}
+}
+
+func (j *jobClient) GetJob(name string, namespace string, clusterCtx string) (*v1.Job, error) {
+	client, err := j.manager.ResolveClusterContext(clusterCtx)
+	if err != nil {
+		return &v1.Job{}, fmt.Errorf("cluster %s is not registered", clusterCtx)
+	}
+
+	job, _ := client.BatchV1().Jobs(namespace).Get(context.TODO(), name, metav1.GetOptions{})
+
+	return job, nil
+}

backend/kubeclient/pod.go

@@ -4,6 +4,7 @@ import (
 	"Kubexplorer/backend/model"
 	"context"
 	"fmt"
+	v1 "k8s.io/api/core/v1"
 	"k8s.io/apimachinery/pkg/api/resource"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 )
@@ -69,6 +70,17 @@ func (p *podClient) GetPods(clusterCtx string) ([]model.PodDto, error) {
 	return podArray, nil
 }
 
+func (p *podClient) GetPodV2(clusterCtx string, name string, namespace string) (*v1.Pod, error) {
+	client, err := p.manager.ResolveClusterContext(clusterCtx)
+	if err != nil {
+		return &v1.Pod{}, fmt.Errorf("cluster %s is not registered", clusterCtx)
+	}
+
+	pod, _ := client.CoreV1().Pods(namespace).Get(context.TODO(), name, metav1.GetOptions{})
+
+	return pod, nil
+}
+
 func (p *podClient) GetPod(name string, namespace string, clusterCtx string) (model.PodDto, error) {
 	client, err := p.manager.ResolveClusterContext(clusterCtx)
 	if err != nil {

backend/model/job.go

@@ -0,0 +1,12 @@
+package model
+
+type JobDto struct {
+	Name      string
+	Namespace string
+	Container Container
+	Node      string
+	Age       string
+	Status    string
+	Editable  []string
+	Labels    map[string]string
+}

backend/model/troubleshoot.go

@@ -0,0 +1,6 @@
+package model
+
+type Troubleshoot struct {
+	Meaning        string
+	Recommendation string
+}