csiclient: Add grpc.CallOption support to NodeUnpublishVolume

plugins/csi/client.go

@@ -394,7 +394,7 @@ func (c *client) NodePublishVolume(ctx context.Context, req *NodePublishVolumeRe
 	return err
 }
 
-func (c *client) NodeUnpublishVolume(ctx context.Context, volumeID, targetPath string) error {
+func (c *client) NodeUnpublishVolume(ctx context.Context, volumeID, targetPath string, opts ...grpc.CallOption) error {
 	if c == nil {
 		return fmt.Errorf("Client not initialized")
 	}
@@ -417,6 +417,6 @@ func (c *client) NodeUnpublishVolume(ctx context.Context, volumeID, targetPath s
 
 	// NodeUnpublishVolume's response contains no extra data. If err == nil, we were
 	// successful.
-	_, err := c.nodeClient.NodeUnpublishVolume(ctx, req)
+	_, err := c.nodeClient.NodeUnpublishVolume(ctx, req, opts...)
 	return err
 }

plugins/csi/fake/client.go

@@ -208,7 +208,7 @@ func (c *Client) NodePublishVolume(ctx context.Context, req *csi.NodePublishVolu
 	return c.NextNodePublishVolumeErr
 }
 
-func (c *Client) NodeUnpublishVolume(ctx context.Context, volumeID, targetPath string) error {
+func (c *Client) NodeUnpublishVolume(ctx context.Context, volumeID, targetPath string, opts ...grpc.CallOption) error {
 	c.Mu.Lock()
 	defer c.Mu.Unlock()
 

plugins/csi/plugin.go

@@ -66,7 +66,7 @@ type CSIPlugin interface {
 	// NodeUnpublishVolume is used to cleanup usage of a volume for an alloc. This
 	// MUST be called before calling NodeUnstageVolume or ControllerUnpublishVolume
 	// for the given volume.
-	NodeUnpublishVolume(ctx context.Context, volumeID, targetPath string) error
+	NodeUnpublishVolume(ctx context.Context, volumeID, targetPath string, opts ...grpc.CallOption) error
 
 	// Shutdown the client and ensure any connections are cleaned up.
 	Close() error