add resources "delete all" method in each service

node/node.go

@@ -90,3 +90,26 @@ func (s *Service) Delete(ctx context.Context, name string) error {
 	}
 	return nil
 }
+
+// Deletes deletes all nodes.
+func (s *Service) Deletes(ctx context.Context) error {
+	pl, err := s.podService.List(ctx)
+	if err != nil {
+		return xerrors.Errorf("list pods: %w", err)
+	}
+
+	// delete all pods
+	for i := range pl.Items {
+		pod := pl.Items[i]
+		if err := s.podService.Delete(ctx, pod.Name); err != nil {
+			return xerrors.Errorf("delete pod: %w", err)
+		}
+	}
+
+	// delete all nodes
+	if err := s.client.CoreV1().Nodes().DeleteCollection(ctx, metav1.DeleteOptions{}, metav1.ListOptions{}); err != nil {
+		return xerrors.Errorf("delete nodes: %w", err)
+	}
+
+	return nil
+}

persistentvolume/persistentvolume.go

@@ -62,3 +62,12 @@ func (s *Service) Delete(ctx context.Context, name string) error {
 
 	return nil
 }
+
+// Deletes deletes all persistentVolumes.
+func (s *Service) Deletes(ctx context.Context) error {
+	if err := s.client.CoreV1().PersistentVolumes().DeleteCollection(ctx, metav1.DeleteOptions{}, metav1.ListOptions{}); err != nil {
+		return xerrors.Errorf("delete persistentVolumes: %w", err)
+	}
+
+	return nil
+}

persistentvolumeclaim/persistentvolumeclaim.go

@@ -66,3 +66,12 @@ func (s *Service) Delete(ctx context.Context, name string) error {
 
 	return nil
 }
+
+// Deletes deletes all persistentVolumeClaims.
+func (s *Service) Deletes(ctx context.Context) error {
+	if err := s.client.CoreV1().PersistentVolumeClaims(defaultNamespaceName).DeleteCollection(ctx, metav1.DeleteOptions{}, metav1.ListOptions{}); err != nil {
+		return xerrors.Errorf("delete persistentVolumeClaims: %w", err)
+	}
+
+	return nil
+}

pod/pod.go

@@ -74,3 +74,12 @@ func (s *Service) Delete(ctx context.Context, name string) error {
 
 	return nil
 }
+
+// Deltes deletes all pods.
+func (s *Service) Deletes(ctx context.Context) error {
+	if err := s.client.CoreV1().Pods(defaultNamespaceName).DeleteCollection(ctx, metav1.DeleteOptions{}, metav1.ListOptions{}); err != nil {
+		return fmt.Errorf("delete pods: %w", err)
+	}
+
+	return nil
+}

priorityclass/priorityclass.go

@@ -58,3 +58,12 @@ func (s *Service) Delete(ctx context.Context, name string) error {
 
 	return nil
 }
+
+// Deletes deletes all priority classes.
+func (s *Service) Deletes(ctx context.Context) error {
+	if err := s.client.SchedulingV1().PriorityClasses().DeleteCollection(ctx, metav1.DeleteOptions{}, metav1.ListOptions{}); err != nil {
+		return xerrors.Errorf("delete priorityClasses: %w", err)
+	}
+
+	return nil
+}

server/di/interface.go

@@ -18,6 +18,7 @@ type PodService interface {
 	List(ctx context.Context) (*corev1.PodList, error)
 	Apply(ctx context.Context, pod *configv1.PodApplyConfiguration) (*corev1.Pod, error)
 	Delete(ctx context.Context, name string) error
+	Deletes(ctx context.Context) error
 }
 
 // NodeService represents service for manage Nodes.
@@ -26,6 +27,7 @@ type NodeService interface {
 	List(ctx context.Context) (*corev1.NodeList, error)
 	Apply(ctx context.Context, node *configv1.NodeApplyConfiguration) (*corev1.Node, error)
 	Delete(ctx context.Context, name string) error
+	Deletes(ctx context.Context) error
 }
 
 // PersistentVolumeService represents service for manage Pods.
@@ -34,6 +36,7 @@ type PersistentVolumeService interface {
 	List(ctx context.Context) (*corev1.PersistentVolumeList, error)
 	Apply(ctx context.Context, pv *configv1.PersistentVolumeApplyConfiguration) (*corev1.PersistentVolume, error)
 	Delete(ctx context.Context, name string) error
+	Deletes(ctx context.Context) error
 }
 
 // PersistentVolumeClaimService represents service for manage Nodes.
@@ -42,6 +45,7 @@ type PersistentVolumeClaimService interface {
 	List(ctx context.Context) (*corev1.PersistentVolumeClaimList, error)
 	Apply(ctx context.Context, pvc *configv1.PersistentVolumeClaimApplyConfiguration) (*corev1.PersistentVolumeClaim, error)
 	Delete(ctx context.Context, name string) error
+	Deletes(ctx context.Context) error
 }
 
 // StorageClassService represents service for manage Pods.
@@ -50,6 +54,7 @@ type StorageClassService interface {
 	List(ctx context.Context) (*storagev1.StorageClassList, error)
 	Apply(ctx context.Context, sc *storageconfigv1.StorageClassApplyConfiguration) (*storagev1.StorageClass, error)
 	Delete(ctx context.Context, name string) error
+	Deletes(ctx context.Context) error
 }
 
 // SchedulerService represents service for manage scheduler.
@@ -67,4 +72,5 @@ type PriorityClassService interface {
 	List(ctx context.Context) (*v1.PriorityClassList, error)
 	Apply(ctx context.Context, priorityClass *schedulingv1.PriorityClassApplyConfiguration) (*v1.PriorityClass, error)
 	Delete(ctx context.Context, name string) error
+	Deletes(ctx context.Context) error
 }

storageclass/storageclass.go

@@ -62,3 +62,12 @@ func (s *Service) Delete(ctx context.Context, name string) error {
 
 	return nil
 }
+
+// Deletes deletes all storageClasss.
+func (s *Service) Deletes(ctx context.Context) error {
+	if err := s.client.StorageV1().StorageClasses().DeleteCollection(ctx, metav1.DeleteOptions{}, metav1.ListOptions{}); err != nil {
+		return xerrors.Errorf("delete storageClasss: %w", err)
+	}
+
+	return nil
+}