feat(kubernetes): version (#52)

chaitin · Nov 29, 2022 · 5c1145d · 5c1145d
1 parent 14c9da7
commit 5c1145d
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 0 deletions.
diff --git a/go/kubernetes/kubernetes.go b/go/kubernetes/kubernetes.go
@@ -35,6 +35,9 @@ type Kubernetes struct {
 
 	// inCluster dedicate whether kubernetes client in cluster
 	inCluster bool
+
+	// clientset reference kubernetes.Clientset
+	clientset *kubernetes.Clientset
 }
 
 type NewOption func(kubernetes *Kubernetes) error
@@ -111,6 +114,7 @@ func New(options ...NewOption) (*Kubernetes, error) {
 	if err != nil {
 		return nil, err
 	}
+	k.clientset = clientset
 
 	grs, err := restmapper.GetAPIGroupResources(clientset.Discovery())
 	if err != nil {
@@ -129,6 +133,15 @@ func New(options ...NewOption) (*Kubernetes, error) {
 	return k, nil
 }
 
+func (k *Kubernetes) Version() string {
+	version, err := k.clientset.Discovery().ServerVersion()
+	if err != nil {
+		return ""
+	}
+
+	return version.String()
+}
+
 func (k *Kubernetes) ListNamespaces() ([]string, error) {
 	namespaceResource, err := k.Resource("", Namespaces.String())
 	if err != nil {

diff --git a/go/package.go b/go/package.go
@@ -121,6 +121,9 @@ type ClusterResource interface {
 type Cluster interface {
 	Close() error
 
+	// Version return version of cluster
+	Version() string
+
 	// ConfigPath return config path of cluster
 	ConfigPath() string