✨ feat(identity): Implement GetPluginInfo (#27)

Signed-off-by: Mriyam Tamuli <mbtamuli@gmail.com>

emptyDirClone/Makefile

@@ -101,12 +101,13 @@ kind-load: ## Load docker image with the plugin, into Kind cluster targeted by t
 
 .PHONY: deploy
 deploy: ## Deploy the plugin to the K8s cluster specified in $KUBECONFIG.
-
-	kubectl apply --file deploy
+	@kubectl apply --filename deploy \
+		|| { sleep 1; kubectl apply --filename deploy; }
 
 .PHONY: undeploy
 undeploy: ## Undeploy the plugin from the K8s cluster specified in $KUBECONFIG.
-	kubectl delete --file deploy
+	@kubectl delete --filename deploy \
+		|| sleep 1
 
 ## Helpers
 

emptyDirClone/internal/emptydirclone/emptydirclone.go

@@ -14,7 +14,9 @@ import (
 )
 
 type Config struct {
-	Endpoint string
+	Name          string
+	Endpoint      string
+	VendorVersion string
 }
 
 type emptyDirClone struct {

emptyDirClone/internal/emptydirclone/identityserver.go

@@ -7,7 +7,10 @@ import (
 )
 
 func (e *emptyDirClone) GetPluginInfo(context.Context, *csi.GetPluginInfoRequest) (*csi.GetPluginInfoResponse, error) {
-	return &csi.GetPluginInfoResponse{}, nil
+	return &csi.GetPluginInfoResponse{
+		Name:          e.config.Name,
+		VendorVersion: e.config.VendorVersion,
+	}, nil
 }
 
 func (e *emptyDirClone) GetPluginCapabilities(context.Context, *csi.GetPluginCapabilitiesRequest) (*csi.GetPluginCapabilitiesResponse, error) {

emptyDirClone/main.go

@@ -9,8 +9,10 @@ import (
 var version string
 
 func main() {
+	const (
+		pluginname = "emptydirclone.mriyam.dev"
+	)
 	var endpoint string
-
 	flag.StringVar(&endpoint, "endpoint", "unix:/csi/csi.sock", "Endpoint for the gRPC server to listen on. Default: \"unix:/csi/csi.sock\"")
 	flag.Parse()
 
@@ -19,7 +21,9 @@ func main() {
 	}
 
 	cfg := emptydirclone.Config{
-		Endpoint: endpoint,
+		Name:          pluginname,
+		Endpoint:      endpoint,
+		VendorVersion: version,
 	}
 
 	emptydirclone := emptydirclone.New(cfg)