// Copyright 2016 The go-qemu Authors. // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. // You may obtain a copy of the License at // // http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. package main import ( "embed" "flag" "net" "time" hypervisor "github.com/digitalocean/go-qemu/hypervisor" ) var Version string //go:embed resources/* var resources embed.FS var hv *hypervisor.Hypervisor func main() { flag.Parse() // fmt.Printf("\nConnecting to %s://%s\n", *network, *address) newConn := func() (net.Conn, error) { // return net.DialTimeout(*network, *address, *timeout) return net.DialTimeout("unix", "/var/run/libvirt/libvirt-sock", 2*time.Second) // return net.DialTimeout("tcp", "farm02:16514", *timeout) } driver := hypervisor.NewRPCDriver(newConn) hv = hypervisor.New(driver) poolHypervisor(hv) startHTTP() }