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", "This is the domain to run commands against.")
+)
+
+func main() {
+	flag.Parse()
+
+	libvirtGoMonitor := qmp.NewLibvirtGoMonitor(*uri, *domainName)
+
+	err := libvirtGoMonitor.Connect()
+	if err != nil {
+		log.Fatalf("Unable to connect: %v\n", err)
+	}
+
+	eventsChans, err := libvirtGoMonitor.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 eventsChans {
+			fmt.Printf("Event: %#v\n", event)
+		}
+	}()
+
+	fmt.Println("Press the Enter key to stop")
+	fmt.Scanln()
+	libvirtGoMonitor.Disconnect()
+}

examples/libvirtgo_run_command/main.go

@@ -0,0 +1,50 @@
+// 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", "This is the domain to run commands against.")
+)
+
+func main() {
+	flag.Parse()
+
+	libvirtGoMonitor := qmp.NewLibvirtGoMonitor(*uri, *domainName)
+
+	err := libvirtGoMonitor.Connect()
+	if err != nil {
+		log.Fatalf("Unable to connect: %v\n", err)
+	}
+
+	command := []byte("{\"execute\" : \"query-cpus\"}")
+	cpus, err := libvirtGoMonitor.Run(command)
+	if err != nil {
+		log.Fatalf("Unable to run command: %v\n", err)
+	}
+	fmt.Printf("query-cpus: %s\n", string(cpus))
+
+	if err = libvirtGoMonitor.Disconnect(); err != nil {
+		log.Fatalf("Unable to disconnect: %v\n", err)
+	}
+}

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 provied via the libvirtd daemon. Multiple
+// connections to the same hypervisor and domain are permitted.
+type LibvirtGoMonitor struct {
+	Monitor
+}