service

package
v0.0.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 28, 2025 License: MIT Imports: 28 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	TaskPending   = "Pending"
	TaskFailed    = "Failed"
	TaskSucceeded = "Succeeded"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type ClusterRoleBindingService 

type ClusterRoleBindingService interface {
	// 基础 CRUD 操作
	GetClusterRoleBindingList(ctx context.Context, req *model.GetClusterRoleBindingListReq) (model.ListResp[*model.K8sClusterRoleBinding], error)
	GetClusterRoleBindingDetails(ctx context.Context, req *model.GetClusterRoleBindingDetailsReq) (*model.K8sClusterRoleBinding, error)
	CreateClusterRoleBinding(ctx context.Context, req *model.CreateClusterRoleBindingReq) error
	UpdateClusterRoleBinding(ctx context.Context, req *model.UpdateClusterRoleBindingReq) error
	DeleteClusterRoleBinding(ctx context.Context, req *model.DeleteClusterRoleBindingReq) error

	// YAML 操作
	GetClusterRoleBindingYaml(ctx context.Context, req *model.GetClusterRoleBindingYamlReq) (*model.K8sYaml, error)
	CreateClusterRoleBindingByYaml(ctx context.Context, req *model.CreateClusterRoleBindingByYamlReq) error
	UpdateClusterRoleBindingYaml(ctx context.Context, req *model.UpdateClusterRoleBindingByYamlReq) error
}

func NewClusterRoleBindingService 

func NewClusterRoleBindingService(clusterRoleBindingManager manager.ClusterRoleBindingManager, logger *zap.Logger) ClusterRoleBindingService

type ClusterRoleService 

type ClusterRoleService interface {
	// 基础 CRUD 操作
	GetClusterRoleList(ctx context.Context, req *model.GetClusterRoleListReq) (model.ListResp[*model.K8sClusterRole], error)
	GetClusterRoleDetails(ctx context.Context, req *model.GetClusterRoleDetailsReq) (*model.K8sClusterRole, error)
	CreateClusterRole(ctx context.Context, req *model.CreateClusterRoleReq) error
	UpdateClusterRole(ctx context.Context, req *model.UpdateClusterRoleReq) error
	DeleteClusterRole(ctx context.Context, req *model.DeleteClusterRoleReq) error
	CreateClusterRoleByYaml(ctx context.Context, req *model.CreateClusterRoleByYamlReq) error
	// YAML 操作
	GetClusterRoleYaml(ctx context.Context, req *model.GetClusterRoleYamlReq) (*model.K8sYaml, error)
	UpdateClusterRoleYaml(ctx context.Context, req *model.UpdateClusterRoleByYamlReq) error
}

func NewClusterRoleService 

func NewClusterRoleService(clusterRoleManager manager.ClusterRoleManager, logger *zap.Logger) ClusterRoleService

type ClusterService 

type ClusterService interface {
	ListClusters(ctx context.Context, req *model.ListClustersReq) (model.ListResp[*model.K8sCluster], error)
	CreateCluster(ctx context.Context, req *model.CreateClusterReq) error
	UpdateCluster(ctx context.Context, req *model.UpdateClusterReq) error
	DeleteCluster(ctx context.Context, req *model.DeleteClusterReq) error
	GetClusterByID(ctx context.Context, req *model.GetClusterReq) (*model.K8sCluster, error)
	RefreshClusterStatus(ctx context.Context, req *model.RefreshClusterReq) error
}

func NewClusterService 

func NewClusterService(dao dao.ClusterDAO, client client.K8sClient, clusterMgr manager.ClusterManager, logger *zap.Logger) ClusterService

type ConfigMapService 

type ConfigMapService interface {
	GetConfigMapList(ctx context.Context, req *model.GetConfigMapListReq) (model.ListResp[*model.K8sConfigMap], error)
	GetConfigMap(ctx context.Context, req *model.GetConfigMapDetailsReq) (*model.K8sConfigMap, error)
	CreateConfigMap(ctx context.Context, req *model.CreateConfigMapReq) error
	UpdateConfigMap(ctx context.Context, req *model.UpdateConfigMapReq) error
	CreateConfigMapByYaml(ctx context.Context, req *model.CreateConfigMapByYamlReq) error
	UpdateConfigMapByYaml(ctx context.Context, req *model.UpdateConfigMapByYamlReq) error
	DeleteConfigMap(ctx context.Context, req *model.DeleteConfigMapReq) error
	GetConfigMapYAML(ctx context.Context, req *model.GetConfigMapYamlReq) (string, error)
}

ConfigMapService ConfigMap服务接口

func NewConfigMapService 

func NewConfigMapService(k8sClient client.K8sClient, configMapManager manager.ConfigMapManager, logger *zap.Logger) ConfigMapService

NewConfigMapService 创建新的ConfigMap服务实例

type DaemonSetService 

type DaemonSetService interface {
	GetDaemonSetList(ctx context.Context, req *model.GetDaemonSetListReq) (model.ListResp[*model.K8sDaemonSet], error)
	GetDaemonSetDetails(ctx context.Context, req *model.GetDaemonSetDetailsReq) (*model.K8sDaemonSet, error)
	GetDaemonSetYaml(ctx context.Context, req *model.GetDaemonSetYamlReq) (*model.K8sYaml, error)
	CreateDaemonSet(ctx context.Context, req *model.CreateDaemonSetReq) error
	CreateDaemonSetByYaml(ctx context.Context, req *model.CreateDaemonSetByYamlReq) error
	UpdateDaemonSet(ctx context.Context, req *model.UpdateDaemonSetReq) error
	UpdateDaemonSetByYaml(ctx context.Context, req *model.UpdateDaemonSetByYamlReq) error
	DeleteDaemonSet(ctx context.Context, req *model.DeleteDaemonSetReq) error
	RestartDaemonSet(ctx context.Context, req *model.RestartDaemonSetReq) error
	GetDaemonSetPods(ctx context.Context, req *model.GetDaemonSetPodsReq) (model.ListResp[*model.K8sPod], error)
	GetDaemonSetHistory(ctx context.Context, req *model.GetDaemonSetHistoryReq) (model.ListResp[*model.K8sDaemonSetHistory], error)
	RollbackDaemonSet(ctx context.Context, req *model.RollbackDaemonSetReq) error
}

func NewDaemonSetService 

func NewDaemonSetService(daemonSetManager manager.DaemonSetManager, logger *zap.Logger) DaemonSetService

type DeploymentService 

type DeploymentService interface {
	CreateDeployment(ctx context.Context, req *model.CreateDeploymentReq) error
	GetDeploymentList(ctx context.Context, req *model.GetDeploymentListReq) (model.ListResp[*model.K8sDeployment], error)
	GetDeploymentDetails(ctx context.Context, req *model.GetDeploymentDetailsReq) (*model.K8sDeployment, error)
	GetDeploymentYaml(ctx context.Context, req *model.GetDeploymentYamlReq) (*model.K8sYaml, error)
	UpdateDeployment(ctx context.Context, req *model.UpdateDeploymentReq) error
	DeleteDeployment(ctx context.Context, req *model.DeleteDeploymentReq) error
	CreateDeploymentByYaml(ctx context.Context, req *model.CreateDeploymentByYamlReq) error
	UpdateDeploymentByYaml(ctx context.Context, req *model.UpdateDeploymentByYamlReq) error
	RestartDeployment(ctx context.Context, req *model.RestartDeploymentReq) error
	ScaleDeployment(ctx context.Context, req *model.ScaleDeploymentReq) error
	RollbackDeployment(ctx context.Context, req *model.RollbackDeploymentReq) error
	PauseDeployment(ctx context.Context, req *model.PauseDeploymentReq) error
	ResumeDeployment(ctx context.Context, req *model.ResumeDeploymentReq) error
	GetDeploymentPods(ctx context.Context, req *model.GetDeploymentPodsReq) (model.ListResp[*model.K8sPod], error)
	GetDeploymentHistory(ctx context.Context, req *model.GetDeploymentHistoryReq) (model.ListResp[*model.K8sDeploymentHistory], error)
}

DeploymentService Deployment业务服务接口

func NewDeploymentService 

func NewDeploymentService(deploymentManager manager.DeploymentManager, logger *zap.Logger) DeploymentService

NewDeploymentService 创建新的Deployment业务服务实例

type EventService 

type EventService interface {
	GetEventList(ctx context.Context, req *model.GetEventListReq) (model.ListResp[*model.K8sEvent], error)
	GetEvent(ctx context.Context, req *model.GetEventDetailReq) (*model.K8sEvent, error)
	GetEventsByPod(ctx context.Context, req *model.GetEventsByPodReq) (model.ListResp[*model.K8sEvent], error)
	GetEventsByDeployment(ctx context.Context, req *model.GetEventsByDeploymentReq) (model.ListResp[*model.K8sEvent], error)
	GetEventsByService(ctx context.Context, req *model.GetEventsByServiceReq) (model.ListResp[*model.K8sEvent], error)
	GetEventsByNode(ctx context.Context, req *model.GetEventsByNodeReq) (model.ListResp[*model.K8sEvent], error)
	GetEventStatistics(ctx context.Context, req *model.GetEventStatisticsReq) (*model.EventStatistics, error)
	GetEventSummary(ctx context.Context, req *model.GetEventSummaryReq) (*model.EventSummary, error)
	GetEventTimeline(ctx context.Context, req *model.GetEventTimelineReq) (model.ListResp[*model.EventTimelineItem], error)
	GetEventTrends(ctx context.Context, req *model.GetEventTrendsReq) (model.ListResp[*model.EventTrend], error)
	GetEventGroupData(ctx context.Context, req *model.GetEventGroupDataReq) (model.ListResp[*model.EventGroupData], error)
	DeleteEvent(ctx context.Context, req *model.DeleteEventReq) error
	CleanupOldEvents(ctx context.Context, req *model.CleanupOldEventsReq) error
}

func NewEventService 

func NewEventService(eventManager manager.EventManager, logger *zap.Logger) EventService

NewEventService 创建新的 EventService 实例

type IngressService 

type IngressService interface {
	CreateIngress(ctx context.Context, req *model.CreateIngressReq) error
	GetIngressList(ctx context.Context, req *model.GetIngressListReq) (model.ListResp[*model.K8sIngress], error)
	GetIngressDetails(ctx context.Context, req *model.GetIngressDetailsReq) (*model.K8sIngress, error)
	GetIngressYaml(ctx context.Context, req *model.GetIngressYamlReq) (*model.K8sYaml, error)
	UpdateIngress(ctx context.Context, req *model.UpdateIngressReq) error
	DeleteIngress(ctx context.Context, req *model.DeleteIngressReq) error
	CreateIngressByYaml(ctx context.Context, req *model.CreateIngressByYamlReq) error
	UpdateIngressByYaml(ctx context.Context, req *model.UpdateIngressByYamlReq) error
}

IngressService Ingress业务服务接口

func NewIngressService 

func NewIngressService(ingressManager manager.IngressManager, logger *zap.Logger) IngressService

type NamespaceService 

type NamespaceService interface {
	CreateNamespace(ctx context.Context, req *model.K8sNamespaceCreateReq) error
	DeleteNamespace(ctx context.Context, req *model.K8sNamespaceDeleteReq) error
	GetNamespaceDetails(ctx context.Context, req *model.K8sNamespaceGetDetailsReq) (*model.K8sNamespace, error)
	UpdateNamespace(ctx context.Context, req *model.K8sNamespaceUpdateReq) error
	ListNamespaces(ctx context.Context, req *model.K8sNamespaceListReq) (model.ListResp[*model.K8sNamespace], error)
}

func NewNamespaceService 

func NewNamespaceService(client client.K8sClient, namespaceManager manager.NamespaceManager, logger *zap.Logger) NamespaceService

type NodeService 

type NodeService interface {
	GetNodeList(ctx context.Context, req *model.GetNodeListReq) (model.ListResp[*model.K8sNode], error)
	GetNodeDetail(ctx context.Context, req *model.GetNodeDetailReq) (*model.K8sNode, error)
	AddOrUpdateNodeLabel(ctx context.Context, req *model.AddLabelNodesReq) error
	GetNodeTaints(ctx context.Context, req *model.GetNodeTaintsReq) (model.ListResp[*model.NodeTaint], error)
	DrainNode(ctx context.Context, req *model.DrainNodeReq) error
	CordonNode(ctx context.Context, req *model.NodeCordonReq) error
	UncordonNode(ctx context.Context, req *model.NodeUncordonReq) error
	DeleteNodeLabel(ctx context.Context, req *model.DeleteLabelNodesReq) error
}

func NewNodeService 

func NewNodeService(clusterDao dao.ClusterDAO, client client.K8sClient, nodeManager manager.NodeManager, logger *zap.Logger) NodeService

type PVCService 

type PVCService interface {
	// 获取PVC列表
	GetPVCList(ctx context.Context, req *model.GetPVCListReq) (model.ListResp[*model.K8sPVC], error)
	GetPVCsByNamespace(ctx context.Context, clusterID int, namespace string) ([]*model.K8sPVC, error)

	// 获取PVC详情
	GetPVC(ctx context.Context, req *model.GetPVCDetailsReq) (*model.K8sPVC, error)
	GetPVCYaml(ctx context.Context, req *model.GetPVCYamlReq) (*model.K8sYaml, error)

	// PVC操作
	CreatePVC(ctx context.Context, req *model.CreatePVCReq) error
	UpdatePVC(ctx context.Context, req *model.UpdatePVCReq) error
	// YAML相关方法
	CreatePVCByYaml(ctx context.Context, req *model.CreatePVCByYamlReq) error
	UpdatePVCByYaml(ctx context.Context, req *model.UpdatePVCByYamlReq) error
	DeletePVC(ctx context.Context, req *model.DeletePVCReq) error
	ExpandPVC(ctx context.Context, req *model.ExpandPVCReq) error
	GetPVCPods(ctx context.Context, req *model.GetPVCPodsReq) (model.ListResp[*model.K8sPod], error)
}

func NewPVCService 

func NewPVCService(dao dao.ClusterDAO, client client.K8sClient, pvcManager manager.PVCManager, logger *zap.Logger) PVCService

NewPVCService 创建新的 PVCService 实例

type PVService 

type PVService interface {
	// 获取PV列表
	GetPVList(ctx context.Context, req *model.GetPVListReq) (model.ListResp[*model.K8sPV], error)
	GetPVsByCluster(ctx context.Context, clusterID int) ([]*model.K8sPV, error)

	// 获取PV详情
	GetPV(ctx context.Context, clusterID int, name string) (*model.K8sPV, error)
	GetPVYaml(ctx context.Context, clusterID int, name string) (string, error)

	// PV操作
	CreatePV(ctx context.Context, req *model.CreatePVReq) error
	UpdatePV(ctx context.Context, req *model.UpdatePVReq) error
	// YAML相关方法
	CreatePVByYaml(ctx context.Context, req *model.CreatePVByYamlReq) error
	UpdatePVByYaml(ctx context.Context, req *model.UpdatePVByYamlReq) error
	DeletePV(ctx context.Context, req *model.DeletePVReq) error

	// 高级功能
	ReclaimPV(ctx context.Context, req *model.ReclaimPVReq) error
}

func NewPVService 

func NewPVService(dao dao.ClusterDAO, client client.K8sClient, pvManager manager.PVManager, logger *zap.Logger) PVService

NewPVService 创建新的 PVService 实例

type PodService 

type PodService interface {
	CreatePod(ctx context.Context, req *model.CreatePodReq) error
	GetPodList(ctx context.Context, req *model.GetPodListReq) (model.ListResp[*model.K8sPod], error)
	GetPodDetails(ctx context.Context, req *model.GetPodDetailsReq) (*model.K8sPod, error)
	GetPodYaml(ctx context.Context, req *model.GetPodYamlReq) (*model.K8sYaml, error)
	UpdatePod(ctx context.Context, req *model.UpdatePodReq) error
	DeletePod(ctx context.Context, req *model.DeletePodReq) error
	CreatePodByYaml(ctx context.Context, req *model.CreatePodByYamlReq) error
	UpdatePodByYaml(ctx context.Context, req *model.UpdatePodByYamlReq) error
	GetPodsByNodeName(ctx context.Context, req *model.GetPodsByNodeReq) (model.ListResp[*model.K8sPod], error)
	GetPodContainers(ctx context.Context, req *model.GetPodContainersReq) (model.ListResp[*model.PodContainer], error)
	GetPodLogs(ctx *gin.Context, req *model.GetPodLogsReq) error
	PodExec(ctx *gin.Context, req *model.PodExecReq) error
	PodPortForward(ctx context.Context, req *model.PodPortForwardReq) error
	PodFileDownload(ctx *gin.Context, req *model.PodFileDownloadReq) error
	PodFileUpload(ctx *gin.Context, req *model.PodFileUploadReq) error
}

func NewPodService 

func NewPodService(podManager manager.PodManager, sseHandler sse.Handler, logger *zap.Logger) PodService

type RBACService 

type RBACService interface {
	// 权限分析和检查
	AnalyzeRBACPermissions(ctx context.Context, req *model.AnalyzeRBACPermissionsReq) (*model.EffectivePermissions, error)
	CheckRBACPermission(ctx context.Context, req *model.CheckRBACPermissionReq) (*model.PermissionCheckResult, error)
}

RBACService RBAC权限管理服务接口

func NewRBACService 

func NewRBACService(
	roleService RoleService,
	clusterRoleService ClusterRoleService,
	roleBindingService RoleBindingService,
	clusterRoleBindingService ClusterRoleBindingService,
	logger *zap.Logger,
) RBACService

NewRBACService 创建新的RBAC服务实例

type RoleBindingService 

type RoleBindingService interface {
	// 基础 CRUD 操作
	GetRoleBindingList(ctx context.Context, req *model.GetRoleBindingListReq) (model.ListResp[*model.K8sRoleBinding], error)
	GetRoleBindingDetails(ctx context.Context, req *model.GetRoleBindingDetailsReq) (*model.K8sRoleBinding, error)
	CreateRoleBinding(ctx context.Context, req *model.CreateRoleBindingReq) error
	UpdateRoleBinding(ctx context.Context, req *model.UpdateRoleBindingReq) error
	DeleteRoleBinding(ctx context.Context, req *model.DeleteRoleBindingReq) error

	// YAML 操作
	GetRoleBindingYaml(ctx context.Context, req *model.GetRoleBindingYamlReq) (*model.K8sYaml, error)
	CreateRoleBindingByYaml(ctx context.Context, req *model.CreateRoleBindingByYamlReq) error
	UpdateRoleBindingYaml(ctx context.Context, req *model.UpdateRoleBindingByYamlReq) error
}

func NewRoleBindingService 

func NewRoleBindingService(roleBindingManager manager.RoleBindingManager, logger *zap.Logger) RoleBindingService

type RoleService 

type RoleService interface {
	// 基础 CRUD 操作
	GetRoleList(ctx context.Context, req *model.GetRoleListReq) (model.ListResp[*model.K8sRole], error)
	GetRoleDetails(ctx context.Context, req *model.GetRoleDetailsReq) (*model.K8sRole, error)
	CreateRole(ctx context.Context, req *model.CreateRoleReq) error
	UpdateRole(ctx context.Context, req *model.UpdateRoleReq) error
	DeleteRole(ctx context.Context, req *model.DeleteRoleReq) error
	CreateRoleByYaml(ctx context.Context, req *model.CreateRoleByYamlReq) error

	// YAML 操作
	GetRoleYaml(ctx context.Context, req *model.GetRoleYamlReq) (*model.K8sYaml, error)
	UpdateRoleYaml(ctx context.Context, req *model.UpdateRoleByYamlReq) error
}

func NewRoleService 

func NewRoleService(roleManager manager.RoleManager, logger *zap.Logger) RoleService

type SecretService 

type SecretService interface {
	GetSecretList(ctx context.Context, req *model.GetSecretListReq) (model.ListResp[*model.K8sSecret], error)
	GetSecret(ctx context.Context, req *model.GetSecretDetailsReq) (*model.K8sSecret, error)
	CreateSecret(ctx context.Context, req *model.CreateSecretReq) error
	UpdateSecret(ctx context.Context, req *model.UpdateSecretReq) error
	// YAML相关方法
	CreateSecretByYaml(ctx context.Context, req *model.CreateSecretByYamlReq) error
	UpdateSecretByYaml(ctx context.Context, req *model.UpdateSecretByYamlReq) error
	DeleteSecret(ctx context.Context, req *model.DeleteSecretReq) error
	GetSecretYAML(ctx context.Context, req *model.GetSecretYamlReq) (string, error)
}

SecretService Secret服务接口

func NewSecretService 

func NewSecretService(secretManager manager.SecretManager, logger *zap.Logger) SecretService

NewSecretService 创建新的Secret服务实例

type ServiceAccountService 

type ServiceAccountService interface {
	// 基础 CRUD 操作
	GetServiceAccountList(ctx context.Context, req *model.GetServiceAccountListReq) (model.ListResp[*model.K8sServiceAccount], error)
	GetServiceAccountDetails(ctx context.Context, req *model.GetServiceAccountDetailsReq) (*model.K8sServiceAccount, error)
	CreateServiceAccount(ctx context.Context, req *model.CreateServiceAccountReq) error
	UpdateServiceAccount(ctx context.Context, req *model.UpdateServiceAccountReq) error
	DeleteServiceAccount(ctx context.Context, req *model.DeleteServiceAccountReq) error
	CreateServiceAccountByYaml(ctx context.Context, req *model.CreateServiceAccountByYamlReq) error

	// YAML 操作
	GetServiceAccountYaml(ctx context.Context, req *model.GetServiceAccountYamlReq) (*model.K8sYaml, error)
	UpdateServiceAccountYaml(ctx context.Context, req *model.UpdateServiceAccountByYamlReq) error

	// Token管理
	GetServiceAccountToken(ctx context.Context, req *model.GetServiceAccountTokenReq) (*model.ServiceAccountTokenInfo, error)
	CreateServiceAccountToken(ctx context.Context, req *model.CreateServiceAccountTokenReq) (*model.ServiceAccountTokenInfo, error)
}

func NewServiceAccountService 

func NewServiceAccountService(serviceAccountManager manager.ServiceAccountManager, logger *zap.Logger) ServiceAccountService

type StatefulSetService 

type StatefulSetService interface {
	GetStatefulSetList(ctx context.Context, req *model.GetStatefulSetListReq) (model.ListResp[*model.K8sStatefulSet], error)
	GetStatefulSetDetails(ctx context.Context, req *model.GetStatefulSetDetailsReq) (*model.K8sStatefulSet, error)
	GetStatefulSetYaml(ctx context.Context, req *model.GetStatefulSetYamlReq) (*model.K8sYaml, error)
	CreateStatefulSet(ctx context.Context, req *model.CreateStatefulSetReq) error
	CreateStatefulSetByYaml(ctx context.Context, req *model.CreateStatefulSetByYamlReq) error
	UpdateStatefulSet(ctx context.Context, req *model.UpdateStatefulSetReq) error
	UpdateStatefulSetByYaml(ctx context.Context, req *model.UpdateStatefulSetByYamlReq) error
	DeleteStatefulSet(ctx context.Context, req *model.DeleteStatefulSetReq) error
	RestartStatefulSet(ctx context.Context, req *model.RestartStatefulSetReq) error
	ScaleStatefulSet(ctx context.Context, req *model.ScaleStatefulSetReq) error
	GetStatefulSetPods(ctx context.Context, req *model.GetStatefulSetPodsReq) (model.ListResp[*model.K8sPod], error)
	GetStatefulSetHistory(ctx context.Context, req *model.GetStatefulSetHistoryReq) (model.ListResp[*model.K8sStatefulSetHistory], error)
	RollbackStatefulSet(ctx context.Context, req *model.RollbackStatefulSetReq) error
}

func NewStatefulSetService 

func NewStatefulSetService(statefulSetManager manager.StatefulSetManager, logger *zap.Logger) StatefulSetService

type SvcService 

type SvcService interface {
	GetServiceList(ctx context.Context, req *model.GetServiceListReq) (model.ListResp[*model.K8sService], error)
	GetServiceDetails(ctx context.Context, req *model.GetServiceDetailsReq) (*model.K8sService, error)
	GetServiceYaml(ctx context.Context, req *model.GetServiceYamlReq) (*model.K8sYaml, error)
	CreateService(ctx context.Context, req *model.CreateServiceReq) error
	UpdateService(ctx context.Context, req *model.UpdateServiceReq) error
	CreateServiceByYaml(ctx context.Context, req *model.CreateServiceByYamlReq) error
	UpdateServiceByYaml(ctx context.Context, req *model.UpdateServiceByYamlReq) error
	DeleteService(ctx context.Context, req *model.DeleteServiceReq) error
	GetServiceEndpoints(ctx context.Context, req *model.GetServiceEndpointsReq) ([]*model.K8sServiceEndpoint, error)
}

func NewSvcService 

func NewSvcService(serviceManager manager.ServiceManager, client client.K8sClient, logger *zap.Logger) SvcService

type TaintService 

type TaintService interface {
	CheckTaintYaml(ctx context.Context, taint *model.CheckTaintYamlReq) error
	EnableSwitchNode(ctx context.Context, req *model.NodeCordonReq) error
	AddOrUpdateNodeTaint(ctx context.Context, taint *model.AddNodeTaintsReq) error
	DrainPods(ctx context.Context, req *model.DrainNodeReq) error
	DeleteNodeTaint(ctx context.Context, taint *model.DeleteNodeTaintsReq) error
	SwitchNodeSchedule(ctx context.Context, req *model.SwitchNodeScheduleReq) error
	AddNodeTaint(ctx context.Context, taint *model.AddNodeTaintsReq) error
}

func NewTaintService 

func NewTaintService(manager manager.TaintManager, logger *zap.Logger) TaintService

type YamlTaskService 

type YamlTaskService interface {
	GetYamlTaskList(ctx context.Context, req *model.YamlTaskListReq) (model.ListResp[*model.K8sYamlTask], error)
	CreateYamlTask(ctx context.Context, req *model.YamlTaskCreateReq) error
	UpdateYamlTask(ctx context.Context, req *model.YamlTaskUpdateReq) error
	DeleteYamlTask(ctx context.Context, req *model.YamlTaskDeleteReq) error
	ApplyYamlTask(ctx context.Context, req *model.YamlTaskExecuteReq) error
}

func NewYamlTaskService 

func NewYamlTaskService(manager manager.YamlManager, logger *zap.Logger) YamlTaskService

type YamlTemplateService 

type YamlTemplateService interface {
	GetYamlTemplateList(ctx context.Context, req *model.YamlTemplateListReq) (model.ListResp[*model.K8sYamlTemplate], error)
	CreateYamlTemplate(ctx context.Context, req *model.YamlTemplateCreateReq) error
	CheckYamlTemplate(ctx context.Context, req *model.YamlTemplateCheckReq) error
	UpdateYamlTemplate(ctx context.Context, req *model.YamlTemplateUpdateReq) error
	DeleteYamlTemplate(ctx context.Context, req *model.YamlTemplateDeleteReq) error
	GetYamlTemplateDetail(ctx context.Context, req *model.YamlTemplateDetailReq) (*model.K8sYamlTemplate, error)
}

func NewYamlTemplateService 

func NewYamlTemplateService(manager manager.YamlManager, logger *zap.Logger) YamlTemplateService

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.