Getting metrics from SignalFX

signalflow_metrics.go

package main

import (
	"fmt"
	"log"

	. "github.com/signalfx/signalfx-go/signalflow"
)

const (
	signalFxRealm = "PUT_YOUR_REALM_HERE"
	signalFxToken = "PUT_YOUR_TOKEN_HERE"

	kubernetesCluster = "PUT_YOUR_CLUSTER_NAME_HERE"
	kubernetesNamespace = "signalfx"
	meanTime = "5m"
)

func main() {
	c, err := NewClient(
		StreamURLForRealm(signalFxRealm),
		AccessToken(signalFxToken))
	if err != nil {
		log.Printf("Error creating client: %v", err)
		return
	}

	script := fmt.Sprintf(
		"data('container_cpu_utilization', filter=filter('k8s.cluster.name', '%s') and filter('k8s.namespace.name', '%s')).mean(over='%s').publish()",
		kubernetesCluster,
		kubernetesNamespace,
		meanTime,
	)

	comp, err := c.Execute(&ExecuteRequest{
		Program: script,
	})
	if err != nil {
		log.Printf("Could not send execute request: %v", err)
		return
	}

	fmt.Printf("Resolution: %v\n", comp.Resolution())
	fmt.Printf("Max Delay: %v\n", comp.MaxDelay())
	fmt.Printf("Detected Lag: %v\n", comp.Lag())

	for msg := range comp.Data() {
		// This will run as long as there is data, or until the websocket gets
		// disconnected.  If a websocket error occurs, the job will NOT be
		// automatically restarted.
		if len(msg.Payloads) == 0 {
			fmt.Printf("\rNo data available")
			continue
		}
		for _, pl := range msg.Payloads {
			meta := comp.TSIDMetadata(pl.TSID)
			fmt.Printf("%s %v: %v\n", meta.OriginatingMetric, meta.CustomProperties["k8s.pod.name"], pl.Value())
		}
		fmt.Println("")
	}

	err = comp.Err()
	if err != nil {
		log.Printf("Error: %v", comp.Err())
	} else {
		log.Printf("Job completed")
	}
}