k8s

package

v0.0.0-...-e6d3209 Latest Latest Go to latest Published: Jul 24, 2021 License: MIT Imports: 19 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/xiliangMa/diss-backend

Documentation ¶

Index ¶

func ClearCluster(clusterList []*models.Cluster)
type ClusterService
- func (this *ClusterService) ListCluster(from, limit int) *models.Result
- func (this *ClusterService) UpdateCluster() *models.Result
type ContainerService
- func (this *ContainerService) AddContainer()
- func (this *ContainerService) DeleteContainer()
- func (this *ContainerService) InitContainer(EventType watch.EventType)
type DeploymentService
- func (this *DeploymentService) List() (*v1.DeploymentList, error)
- func (this *DeploymentService) Wtach()
type K8sClearService
- func (this *K8sClearService) Check(cluster *models.Cluster) *models.Cluster
- func (this *K8sClearService) ClearAll()
- func (this *K8sClearService) ClearCluster()
- func (this *K8sClearService) ClearContainer()
- func (this *K8sClearService) ClearDeployment()
- func (this *K8sClearService) ClearNetworkPolicy()
- func (this *K8sClearService) ClearNode()
- func (this *K8sClearService) ClearNs()
- func (this *K8sClearService) ClearPod()
- func (this *K8sClearService) ClearService()
- func (this *K8sClearService) ClearTask(cluster *models.Cluster)
type K8sWatchService
- func (this *K8sWatchService) WatchAll()
- func (this *K8sWatchService) WatchCluster() models.Result
type NameSpaceService
- func (this *NameSpaceService) List() (*v1.NamespaceList, error)
- func (this *NameSpaceService) Wtach()
type NetworkPolicyService
- func (this *NetworkPolicyService) Create() (*v1.NetworkPolicy, error)
- func (this *NetworkPolicyService) Delete() error
- func (this *NetworkPolicyService) List() (*v1.NetworkPolicyList, error)
- func (this *NetworkPolicyService) Update() (*v1.NetworkPolicy, error)
- func (this *NetworkPolicyService) Wtach()
type NodeService
- func (this *NodeService) List() (*v1.NodeList, error)
- func (this *NodeService) Wtach()
type PodService
- func (this *PodService) List() (*v1.PodList, error)
- func (this *PodService) Wtach()
type SVCService
- func (this *SVCService) List() (*v1.ServiceList, error)
- func (this *SVCService) Wtach()

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func ClearCluster ¶

func ClearCluster(clusterList []*models.Cluster)

Types ¶

type ClusterService ¶

type ClusterService struct {
	Cluster *models.Cluster
}

func (*ClusterService) ListCluster ¶

func (this *ClusterService) ListCluster(from, limit int) *models.Result

func (*ClusterService) UpdateCluster ¶

func (this *ClusterService) UpdateCluster() *models.Result

type ContainerService ¶

type ContainerService struct {
	Cluster *models.Cluster
	Pod     *v1.Pod
}

func (*ContainerService) AddContainer ¶

func (this *ContainerService) AddContainer()

func (*ContainerService) DeleteContainer ¶

func (this *ContainerService) DeleteContainer()

func (*ContainerService) InitContainer ¶

func (this *ContainerService) InitContainer(EventType watch.EventType)

type DeploymentService ¶

type DeploymentService struct {
	ClientGo models.ClientGo
	Cluster  *models.Cluster
	Close    chan bool
}

func (*DeploymentService) List ¶

func (this *DeploymentService) List() (*v1.DeploymentList, error)

func (*DeploymentService) Wtach ¶

func (this *DeploymentService) Wtach()

type K8sClearService ¶

type K8sClearService struct {
	ClusterList    []*models.Cluster
	DropCluster    bool
	CurrentCluster *models.Cluster
}

func (*K8sClearService) Check ¶

func (this *K8sClearService) Check(cluster *models.Cluster) *models.Cluster

func (*K8sClearService) ClearAll ¶

func (this *K8sClearService) ClearAll()

todo 删除任务

func (*K8sClearService) ClearCluster ¶

func (this *K8sClearService) ClearCluster()

func (*K8sClearService) ClearContainer ¶

func (this *K8sClearService) ClearContainer()

func (*K8sClearService) ClearDeployment ¶

func (this *K8sClearService) ClearDeployment()

func (*K8sClearService) ClearNetworkPolicy ¶

func (this *K8sClearService) ClearNetworkPolicy()

func (*K8sClearService) ClearNode ¶

func (this *K8sClearService) ClearNode()

func (*K8sClearService) ClearNs ¶

func (this *K8sClearService) ClearNs()

func (*K8sClearService) ClearPod ¶

func (this *K8sClearService) ClearPod()

func (*K8sClearService) ClearService ¶

func (this *K8sClearService) ClearService()

func (*K8sClearService) ClearTask ¶

func (this *K8sClearService) ClearTask(cluster *models.Cluster)

todo clear container and host task

type K8sWatchService ¶

type K8sWatchService struct {
	Cluster *models.Cluster
}

func (*K8sWatchService) WatchAll ¶

func (this *K8sWatchService) WatchAll()

*

watch 集群下所有的资源
namespace、pod、node

func (*K8sWatchService) WatchCluster ¶

func (this *K8sWatchService) WatchCluster() models.Result

type NameSpaceService ¶

type NameSpaceService struct {
	ClientGo models.ClientGo
	Cluster  *models.Cluster
	Close    chan bool
}

func (*NameSpaceService) List ¶

func (this *NameSpaceService) List() (*v1.NamespaceList, error)

func (*NameSpaceService) Wtach ¶

func (this *NameSpaceService) Wtach()

type NetworkPolicyService ¶

type NetworkPolicyService struct {
	ClientGo      models.ClientGo
	Cluster       *models.Cluster
	Close         chan bool
	NetworkPolicy *models.NetworkPolicy
}

func (*NetworkPolicyService) Create ¶

func (this *NetworkPolicyService) Create() (*v1.NetworkPolicy, error)

func (*NetworkPolicyService) Delete ¶

func (this *NetworkPolicyService) Delete() error

func (*NetworkPolicyService) List ¶

func (this *NetworkPolicyService) List() (*v1.NetworkPolicyList, error)

func (*NetworkPolicyService) Update ¶

func (this *NetworkPolicyService) Update() (*v1.NetworkPolicy, error)

func (*NetworkPolicyService) Wtach ¶

func (this *NetworkPolicyService) Wtach()

type NodeService ¶

type NodeService struct {
	ClientGo models.ClientGo
	Cluster  *models.Cluster
	Close    chan bool
}

func (*NodeService) List ¶

func (this *NodeService) List() (*v1.NodeList, error)

func (*NodeService) Wtach ¶

func (this *NodeService) Wtach()

type PodService ¶

type PodService struct {
	ClientGo models.ClientGo
	Cluster  *models.Cluster
	Close    chan bool
}

func (*PodService) List ¶

func (this *PodService) List() (*v1.PodList, error)

func (*PodService) Wtach ¶

func (this *PodService) Wtach()

type SVCService ¶

type SVCService struct {
	ClientGo models.ClientGo
	Cluster  *models.Cluster
	Close    chan bool
}

func (*SVCService) List ¶

func (this *SVCService) List() (*v1.ServiceList, error)

func (*SVCService) Wtach ¶

func (this *SVCService) Wtach()

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL