Exit on CSI gRPC conn loss
@@ -137,7 +137,7 @@ func main() {
snapshotscheme.AddToScheme(scheme.Scheme)
// Connect to CSI.
- csiConn, err := connection.Connect(*csiAddress)
+ csiConn, err := connection.Connect(*csiAddress, connection.OnConnectionLoss(connection.ExitOnConnectionLoss()))
if err != nil {
klog.Errorf("error connecting to CSI driver: %v", err)
os.Exit(1)
