elektron/pcp/pcp.go

package main

import (
	"bufio"
	"fmt"
	"log"
	"os/exec"
	"strings"
)

func main() {
	const pcpCommand string = "pmdumptext -m -l -f '' -t 1.0 -d , -c config" // We always want the most granular
	cmd := exec.Command("sh", "-c", pcpCommand)
	//	time := time.Now().Format("200601021504")

	//	stdout, err := os.Create("./"+time+".txt")
	pipe, err := cmd.StdoutPipe()

	//cmd.Stdout = stdout

	scanner := bufio.NewScanner(pipe)

	go func() {
		// Get names of the columns
		scanner.Scan()

		headers := strings.Split(scanner.Text(), ",")

		for _, hostMetric := range headers {
			split := strings.Split(hostMetric, ":")
			fmt.Printf("Host %s: Metric: %s\n", split[0], split[1])
		}

		// Throw away first set of results
		scanner.Scan()

		seconds := 0
		for scanner.Scan() {
			fmt.Printf("Second: %d\n", seconds)
			for i, val := range strings.Split(scanner.Text(), ",") {
				fmt.Printf("host metric: %s val: %s\n", headers[i], val)
			}

			seconds++

			fmt.Println("--------------------------------")
		}
	}()

	fmt.Println("PCP started: ")

	if err != nil {
		log.Fatal(err)
	}
	if err := cmd.Start(); err != nil {
		log.Fatal(err)
	}
	if err := cmd.Wait(); err != nil {
		log.Fatal(err)
	}
}