ok8s/types.go at master · chulinx/ok8s · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
package ok8s

import (
	appsv1 "k8s.io/api/apps/v1"
	apicorev1 "k8s.io/api/core/v1"
	"k8s.io/api/networking/v1beta1"
	"k8s.io/client-go/kubernetes"
	"k8s.io/client-go/tools/cache"
	"k8s.io/metrics/pkg/client/clientset/versioned"
)

// K8sApi define resource operate method
type K8sApi interface {
	// The resource api interface
	Prefix(namespace string) interface{}
	// Create resource from namespace and resource struct
	/* For DeploymentType k8s.io/api/apps/v1 v1.deployment
	 * For Configmap k8s.io/api/core/v1  v1.configmap
	 */
	Create(namespace string, resource interface{}) (bool, error)
	// Get a resource from namespace and resource name
	Get(namespace, name string) (bool, KResource)
	// IsExits judge resource exits
	IsExits(namespace, name string) bool
	// Delete a resource from namespace and resource name
	Delete(namespace, name string) (bool, error)
	// List multiple resource from one namespace
	List(namespace string) (KResource, error)
	// Update a resource
	Update(namespace string, resource interface{}) bool
	//Labels(DeploymentType, namespace string) map[string]map[string]string
	// Watch a resource
	/* Example:
	*  eventFuncs := new(cache.ResourceEventHandlerFuncs)
	*  eventFuncs.DeleteFunc= func(obj interface{}) {
	*  		DeploymentType := obj.(*appsv1.DeploymentType)
	*  		log.Printf("delete DeploymentType %s",DeploymentType.Name)
	*  		fmt.Println(Deployment.Labels,DeploymentType.Spec.Template.Labels)
	*  }
	*  eventFuncs.AddFunc= func(obj interface{}) {
	*  		DeploymentType := obj.(*appsv1.DeploymentType)
	*  		log.Printf("add DeploymentType %s",DeploymentType.Name)
	*  		fmt.Println(DeploymentType.Labels,DeploymentType.Spec.Template.Labels)
	*  }
	*  Watch("default",eventFuncs)
	 */
	Watch(namespace string, eventFuncs cache.ResourceEventHandlerFuncs)
}

// ClientSet kubernetes.Clientset
type ClientSets struct {
	ClientSet *kubernetes.Clientset
}

type MetricsClientSets struct {
	MClientSets *versioned.Clientset
}

// Kubernetes Resource struct
//
// Unified all resource
type KResource struct {
	Deployment     appsv1.Deployment
	DeploymentList appsv1.DeploymentList
	Configmap      apicorev1.ConfigMap
	ConfigmapList  apicorev1.ConfigMapList
	Service        apicorev1.Service
	ServiceList    apicorev1.ServiceList
	Secret         apicorev1.Secret
	SecretList     apicorev1.SecretList
	Ingress        v1beta1.Ingress
	IngressList    v1beta1.IngressList
	Pod 		   apicorev1.Pod
	PodList        apicorev1.PodList
}

func NewK8(inter K8sApi) K8sApi {
	return inter
}