Skip libvirt connection on startup

Author: notandy

internal/controller/hypervisor_controller.go

@@ -290,12 +290,6 @@ func (r *HypervisorReconciler) Reconcile(ctx context.Context, req ctrl.Request)
 // SetupWithManager sets up the controller with the Manager.
 func (r *HypervisorReconciler) SetupWithManager(mgr ctrl.Manager) error {
 	ctx := context.Background()
-	log := logger.Log.WithName("HypervisorReconciler")
-
-	// Initialize Libvirt connection
-	if err := r.Libvirt.Connect(); err != nil {
-		log.Error(err, "unable to connect to Libvirt system bus, reconnecting on reconciliation")
-	}
 
 	var err error
 	if r.osDescriptor, err = r.Systemd.Describe(ctx); err != nil {

internal/libvirt/libvirt.go

@@ -22,6 +22,7 @@ import (
 	"fmt"
 	"os"
 	"sync"
+	"time"
 
 	v1 "github.com/cobaltcore-dev/openstack-hypervisor-operator/api/v1"
 	"github.com/digitalocean/go-libvirt"
@@ -51,7 +52,12 @@ func NewLibVirt(k client.Client) *LibVirt {
 	}
 	log.Log.Info("Using libvirt unix domain socket", "socket", socketPath)
 	return &LibVirt{
-		libvirt.NewWithDialer(dialers.NewLocal(dialers.WithSocket(socketPath))),
+		libvirt.NewWithDialer(
+			dialers.NewLocal(
+				dialers.WithSocket(socketPath),
+				dialers.WithLocalTimeout(15*time.Second),
+			),
+		),
 		k,
 		make(map[string]context.CancelFunc),
 		sync.Mutex{},