Remove unused function

banzaicloud · Apr 16, 2019 · 4428075 · 4428075
1 parent cac8ef1
commit 4428075
Showing 1 changed file with 0 additions and 25 deletions.
diff --git a/cmd/pke/app/phases/kubeadm/node/node.go b/cmd/pke/app/phases/kubeadm/node/node.go
@@ -15,14 +15,12 @@
 package node
 
 import (
-	"context"
 	"fmt"
 	"io"
 	"os"
 	"path/filepath"
 	"text/template"
 
-	"github.com/banzaicloud/pke/.gen/pipeline"
 	"github.com/banzaicloud/pke/cmd/pke/app/constants"
 	"github.com/banzaicloud/pke/cmd/pke/app/phases"
 	"github.com/banzaicloud/pke/cmd/pke/app/phases/kubeadm"
@@ -234,29 +232,6 @@ func (n *Node) workerBootstrapParameters(cmd *cobra.Command) (err error) {
 	return
 }
 
-func pipelineJoinArgs(cmd *cobra.Command) (apiServerHostPort, kubeadmToken, caCertHash string, err error) {
-	if !pipelineutil.Enabled(cmd) {
-		return
-	}
-	endpoint, token, orgID, clusterID, err := pipelineutil.CommandArgs(cmd)
-	if err != nil {
-		return
-	}
-
-	// Pipeline client.
-	c := pipelineutil.Client(os.Stdout, endpoint, token)
-
-	var b pipeline.GetClusterBootstrapResponse
-	b, _, err = c.ClustersApi.GetClusterBootstrap(context.Background(), orgID, clusterID)
-	if err != nil {
-		return
-	}
-	apiServerHostPort = b.MasterAddress
-	kubeadmToken = b.Token
-	caCertHash = b.DiscoveryTokenCaCertHash
-	return
-}
-
 func (n *Node) install(out io.Writer) error {
 	// write kubeadm config
 	if err := n.writeKubeadmConfig(out, kubeadmConfig); err != nil {