Issue 30

examples/README.md

@@ -121,4 +121,49 @@ You should have an output similar to this:
 ```{r, engine='bash', count_lines}
 Connecting to unix:///var/run/libvirt/libvirt-sock
 Domain should be shut off now
+```
+
+#### libvirtgo_run_command
+
+[libvirtgo_run_command](./libvirtgo_run_command) demonstrates how to use 
+ the [libvirtGoMonitorLinux](https://godoc.org/github.com/digitalocean/go-qemu/libvirtGoMonitorLinux) 
+ package to send a QMP command to the specified domain.
+
+To run:
+```{r, engine='bash', count_lines}
+   $ go get github.com/digitalocean/go-qemu
+   $ go run examples/libvirtgo_run_command/main.go -uri="qemu:///system" -domainName="centos7"
+```
+
+
+You should see an output similar to this:
+```{r, engine='bash', count_lines}
+query-cpus: {"return":[{"current":true,"CPU":0,"qom_path":"/machine/unattached/device[0]","pc":-2130342250,"halted":true,"thread_id":2462}],"id":"libvirt-36"}
+```
+
+#### libvirtgo_events
+
+[libvirtgo_events](./libvirtgo_events) demonstrates how to use 
+ the [libvirtGoMonitorLinux](https://godoc.org/github.com/digitalocean/go-qemu/libvirtGoMonitorLinux) 
+ package to wait for lifecycle events from the specified domain.
+
+To run:
+```{r, engine='bash', count_lines}
+   $ go get github.com/digitalocean/go-qemu
+
+   Terminal 1:
+   $ go run examples/libvirtgo_events/main.go -uri="qemu:///system" -domainName="ubuntu14.04"
+
+   Terminal 2:
+   virsh -c qemu:///system
+   virsh # start ubuntu14.04
+```
+
+
+You should see an output similar to this on Terminal 1:
+```{r, engine='bash', count_lines}
+Waiting for Domain events...
+Press the Enter key to stop
+Event: qmp.Event{Event:"Domain event=\"resumed\" detail=\"unpaused\"", Data:map[string]interface {}{"details":libvirt.DomainLifecycleEvent{Event:4, Detail:0}}, Timestamp:struct { Seconds int64 "json:\"seconds\""; Microseconds int64 "json:\"microseconds\"" }{Seconds:11, Microseconds:0}}
+Event: qmp.Event{Event:"Domain event=\"started\" detail=\"booted\"", Data:map[string]interface {}{"details":libvirt.DomainLifecycleEvent{Event:2, Detail:0}}, Timestamp:struct { Seconds int64 "json:\"seconds\""; Microseconds int64 "json:\"microseconds\"" }{Seconds:12, Microseconds:0}}
 ```

examples/libvirtgo_events/main.go

@@ -0,0 +1,55 @@
+// 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 (
+	"flag"
+	"fmt"
+	"log"
+
+	"github.com/digitalocean/go-qemu/qmp"
+)
+
+var (
+	uri        = flag.String("uri", "qemu:///system", "URI to connect to the libvirtd host.")
+	domainName = flag.String("domainName", "mydomain", "The domain to run commands against.")
+)
+
+func main() {
+	flag.Parse()
+
+	mon := qmp.NewLibvirtGoMonitor(*uri, *domainName)
+
+	err := mon.Connect()
+	if err != nil {
+		log.Fatalf("Unable to connect: %v\n", err)
+	}
+
+	events, err := mon.Events()
+	if err != nil {
+		log.Fatalf("Unable to register for events: %v\n", err)
+	}
+
+	fmt.Println("Waiting for Domain events...")
+	go func() {
+		for event := range events {
+			fmt.Printf("Event: %#v\n", event)
+		}
+	}()
+
+	fmt.Println("Press the Enter key to stop")
+	fmt.Scanln()
+	mon.Disconnect()
+}

examples/libvirtgo_run_command/main.go

@@ -0,0 +1,57 @@
+// 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 (
+	"flag"
+	"fmt"
+	"log"
+
+	qemu "github.com/digitalocean/go-qemu"
+	"github.com/digitalocean/go-qemu/qmp"
+)
+
+var (
+	uri        = flag.String("uri", "qemu:///system", "URI to connect to the libvirtd host.")
+	domainName = flag.String("domainName", "mydomain", "The domain to run commands against.")
+)
+
+func main() {
+	flag.Parse()
+
+	mon := qmp.NewLibvirtGoMonitor(*uri, *domainName)
+
+	if err := mon.Connect(); err != nil {
+		log.Fatalf("failed to connect: %v", err)
+	}
+
+	domain, err := qemu.NewDomain(mon, *domainName)
+	if err != nil {
+		log.Fatalf("failed to create domain object: %v", err)
+	}
+	defer domain.Close()
+
+	// domain.CPUs will forward QMP commands to the monitor
+	cpus, err := domain.CPUs()
+	if err != nil {
+		log.Fatalf("failed to get cpus: %v", err)
+	}
+
+	fmt.Printf("CPUs: %v\n", cpus)
+
+	if err = mon.Disconnect(); err != nil {
+		log.Fatalf("Unable to disconnect: %v\n", err)
+	}
+}

qmp/README.md

@@ -7,7 +7,7 @@ Package `qmp` enables interaction with QEMU instances via the QEMU Machine Proto
 
 ### Libvirt
 
-If your environment is managed by Libvirt, QMP interaction must be proxied through the Libvirt daemon. This can be be done through two available drivers:
+If your environment is managed by Libvirt, QMP interaction must be proxied through the Libvirt daemon. This can be done through three available drivers:
 
 #### RPC
 
@@ -19,6 +19,15 @@ conn, err := net.DialTimeout("tcp", "192.168.1.1:16509", 2*time.Second)
 monitor := libvirtrpc.New("stage-lb-1", conn)
 ```
 
+### Libvirt-go
+
+This monitor provides communication with the Libvirt daemon using the [libvirt-go](https://github.com/rgbkrk/libvirt-go) package as its internal implementation.
+At the moment, libvirt-go only supports `Linux`.
+
+```go
+monitor, err := qmp.NewLibvirtGoMonitor("qemu:///system", "centos7")
+```
+
 #### virsh
 
 A connection to the monitor socket is provided by proxing requests through the `virsh` executable.

qmp/libvirtgo.go

@@ -0,0 +1,23 @@
+// 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 qmp
+
+// LibvirtGoMonitor is a Monitor that wraps the libvirt-go package to
+// communicate with a QEMU Machine Protocol (QMP) socket.
+// Communication is proxied via the libvirtd daemon. Multiple
+// connections to the same hypervisor and domain are permitted.
+type LibvirtGoMonitor struct {
+	Monitor
+}