Merge pull request #17 from davidz627/feature/csiv0.3.0

Bump CSI Spec version to 0.3.0 and make necessary code update

Author: davidz627

Gopkg.lock

@@ -31,7 +31,12 @@
 
 [[constraint]]
   name = "github.com/container-storage-interface/spec"
-  version = "0.2.0"
+  version = "0.3.0"
+
+# Transitive dependency of CSI Spec
+[[override]]
+  name = "github.com/golang/protobuf"
+  version = "1.1.0"
 
 [[constraint]]
   branch = "master"

Gopkg.toml

@@ -37,6 +37,8 @@ type GCEControllerServer struct {
 	CloudProvider gce.GCECompute
 }
 
+var _ csi.ControllerServer = &GCEControllerServer{}
+
 const (
 	// MaxVolumeSizeInBytes is the maximum standard and ssd size of 64TB
 	MaxVolumeSizeInBytes     int64 = 64 * 1024 * 1024 * 1024 * 1024
@@ -425,3 +427,15 @@ func (gceCS *GCEControllerServer) ControllerGetCapabilities(ctx context.Context,
 		Capabilities: gceCS.Driver.cscap,
 	}, nil
 }
+
+func (gceCS *GCEControllerServer) CreateSnapshot(ctx context.Context, req *csi.CreateSnapshotRequest) (*csi.CreateSnapshotResponse, error) {
+	return nil, status.Error(codes.Unimplemented, "")
+}
+
+func (gceCS *GCEControllerServer) DeleteSnapshot(ctx context.Context, req *csi.DeleteSnapshotRequest) (*csi.DeleteSnapshotResponse, error) {
+	return nil, status.Error(codes.Unimplemented, "")
+}
+
+func (gceCS *GCEControllerServer) ListSnapshots(ctx context.Context, req *csi.ListSnapshotsRequest) (*csi.ListSnapshotsResponse, error) {
+	return nil, status.Error(codes.Unimplemented, "")
+}

pkg/gce-csi-driver/controller.go

@@ -35,6 +35,8 @@ type GCENodeServer struct {
 	mux sync.Mutex
 }
 
+var _ csi.NodeServer = &GCENodeServer{}
+
 func (ns *GCENodeServer) NodePublishVolume(ctx context.Context, req *csi.NodePublishVolumeRequest) (*csi.NodePublishVolumeResponse, error) {
 	ns.mux.Lock()
 	defer ns.mux.Unlock()
@@ -262,3 +264,16 @@ func (ns *GCENodeServer) NodeGetCapabilities(ctx context.Context, req *csi.NodeG
 		Capabilities: ns.Driver.nscap,
 	}, nil
 }
+
+func (ns *GCENodeServer) NodeGetInfo(ctx context.Context, req *csi.NodeGetInfoRequest) (*csi.NodeGetInfoResponse, error) {
+	glog.Infof("NodeGetInfo called with req: %#v", req)
+
+	resp := &csi.NodeGetInfoResponse{
+		NodeId: ns.Driver.nodeID,
+		// TODO: Set MaxVolumesPerNode based on Node Type
+		// Default of 0 means that CO Decides how many nodes can be published
+		MaxVolumesPerNode:  0,
+		AccessibleTopology: nil,
+	}
+	return resp, nil
+}