added base code for node server

Author: Krish Chowdhary

Makefile

@@ -0,0 +1,3 @@
+
+build:
+	go build -o bin/main main.go

bin/.gitignore

@@ -0,0 +1,2 @@
+*
+!.gitignore

cmd/cmd.go

@@ -33,6 +33,8 @@ var (
 	identity = "cosi.storage.k8s.io"
 	nodeID   = ""
 	endpoint = "unix://csi/csi.sock"
+	protocol = ""
+	listen   = ""
 )
 
 var driverCmd = &cobra.Command{
@@ -60,6 +62,8 @@ func init() {
 	driverCmd.PersistentFlags().StringVarP(&identity, "identity", "i", identity, "identity of this COSI CSI driver")
 	driverCmd.PersistentFlags().StringVarP(&endpoint, "endpoint", "e", endpoint, "endpoint at which COSI CSI driver is listening")
 	driverCmd.PersistentFlags().StringVarP(&nodeID, "node-id", "n", nodeID, "identity of the node in which COSI CSI driver is running")
+	driverCmd.PersistentFlags().StringVarP(&listen, "listen", "l", nodeID, "address of the listening socket for the node server")
+	driverCmd.PersistentFlags().StringVarP(&protocol, "protocol", "p", nodeID, "must be one of tcp, tcp4, tcp6, unix, unixpacket")
 
 	driverCmd.PersistentFlags().MarkHidden("alsologtostderr")
 	driverCmd.PersistentFlags().MarkHidden("log_backtrace_at")

cmd/driver.go

@@ -16,32 +16,54 @@ limitations under the License.
 
 package cmd
 
-
 import (
-	csicommon "github.com/kubernetes-csi/drivers/pkg/csi-common"
-
-	"github.com/container-object-storage-interface/ephemeral-csi-driver/pkg/controller"
-	id "github.com/container-object-storage-interface/ephemeral-csi-driver/pkg/identity"
+	"net"
+	"os"
 
+	cs "github.com/container-object-storage-interface/api/clientset/typed/storage.k8s.io/v1alpha1"
+	"github.com/container-storage-interface/spec/lib/go/csi"
 	"github.com/golang/glog"
+	"google.golang.org/grpc"
+	rest "k8s.io/client-go/rest"
+	"k8s.io/klog"
+
+	id "github.com/container-object-storage-interface/ephemeral-csi-driver/pkg/identity"
+	"github.com/container-object-storage-interface/ephemeral-csi-driver/pkg/node"
 )
 
 func driver(args []string) error {
+
+	if protocol == "unix" {
+		if err := os.RemoveAll(listen); err != nil {
+			klog.Fatalf("could not prepare socket: %v", err)
+		}
+	}
+
 	idServer, err := id.NewIdentityServer(identity, Version, map[string]string{})
 	if err != nil {
 		return err
 	}
 	glog.V(5).Infof("identity server started")
 
-	ctrlServer, err := controller.NewControllerServer(identity, nodeID)
+	config := &rest.Config{}
+
+	client := cs.NewForConfigOrDie(config)
+
+	node := node.NewNodeServer(identity, nodeID, *client)
 	if err != nil {
 		return err
 	}
-	glog.V(5).Infof("controller manager started")
 
-	s := csicommon.NewNonBlockingGRPCServer()
-	s.Start(endpoint, idServer, ctrlServer, nil)
-	s.Wait()
+	srv := grpc.NewServer()
+	csi.RegisterNodeServer(srv, node)
+	csi.RegisterIdentityServer(srv, idServer)
+	l, err := net.Listen(protocol, listen)
+	if err != nil {
+		klog.Fatalf("could not create listener: %v", err)
+	}
+	if err = srv.Serve(l); err != nil {
+		klog.Fatalf("%v", err)
+	}
 
 	return nil
 }

go.mod

@@ -1,3 +1,16 @@
 module github.com/container-object-storage-interface/ephemeral-csi-driver
 
 go 1.15
+
+require (
+	github.com/container-object-storage-interface/api v0.0.0-20200919075357-9eea1b2d66da
+	github.com/container-object-storage-interface/spec v0.0.0-20200908192509-18912d8bf2a5
+	github.com/container-storage-interface/spec v1.3.0
+	github.com/golang/glog v0.0.0-20160126235308-23def4e6c14b
+	github.com/spf13/cobra v0.0.5
+	github.com/spf13/viper v1.3.2
+	google.golang.org/grpc v1.30.0
+	k8s.io/apimachinery v0.18.4
+	k8s.io/client-go v0.18.4
+	k8s.io/klog v1.0.0
+)