prometheus

ExamplePrometheus_Push demonstrates how to use Prometheus.Push. Open the link to see an example: https://go.dev/play/p/ViGSBJbtGKz

package main

import (
	"context"
	"github.com/mo-silent/go-devops"
	"github.com/mo-silent/go-devops/prometheus"

	log "github.com/sirupsen/logrus"
	"os"
	"time"
)

func main() {
	// prometheus push metrics example
	log.SetLevel(log.DebugLevel)
	log.SetOutput(os.Stdout)
	ctx, cancel := context.WithTimeout(context.Background(), 1*time.Minute)
	defer cancel()
	p := devops.NewDevops().Prometheus()
	pm := prometheus.PushMetrics{
		Name:  "test",
		Label: []string{"sample1", "sample2"},
		Metrics: []prometheus.PromMetrics{
			{
				Values: []string{"s1", "s2"},
				Data:   99.99,
			},
		},
	}
	if err := p.Push(ctx, pm, "localhost:9091"); err != nil {
		log.Errorf("push metrics error, err:  %v", err)
	}
}

Output:

ExamplePrometheus_Query_vector demonstrates how to query scalar data using Prometheus.Query. Open the link to see an example: https://go.dev/play/p/cbqzfN1JDOE

package main

import (
	"context"
	"fmt"

	jsoniter "github.com/json-iterator/go"
	"github.com/mo-silent/go-devops"
	"github.com/mo-silent/go-devops/prometheus"
	"github.com/prometheus/client_golang/api"

	log "github.com/sirupsen/logrus"
	"os"
	"time"
)

func main() {
	// An example of how to query Prometheus metrics by range.
	log.SetLevel(log.DebugLevel)
	log.SetOutput(os.Stdout)
	ctx, cancel := context.WithTimeout(context.Background(), 1*time.Minute)
	defer cancel()

	// new prometheus client
	client, err := api.NewClient(api.Config{
		Address: "http://10.158.215.90:80",
	})
	if err != nil {
		log.Errorf("Error creating client: %v\n", err)
		return
	}

	end := time.Now().UTC().Unix()

	p := devops.NewDevops().Prometheus()
	res, err := p.Query(ctx, client, "dynatrace_api_latency", end)
	if err != nil {
		log.Errorf("Error querying Prometheus: %v\n", err)
	}
	vector, err := res.ConvertByte()
	if err != nil {
		log.Errorf("Convert matrix result to byte error, err: %v", err)
	}
	var result prometheus.Vector
	if err := jsoniter.Unmarshal(vector, &result); err != nil {
		log.Errorf("error jsoniter unmarshal result to prometheus.Matrix, err: %v", err)
	}
	fmt.Println(result)
}

Output:

ExamplePrometheus_Query_vector demonstrates how to query vector data using Prometheus.Query. Open the link to see an example: https://go.dev/play/p/cbqzfN1JDOE

package main

import (
	"context"
	"fmt"

	jsoniter "github.com/json-iterator/go"
	"github.com/mo-silent/go-devops"
	"github.com/mo-silent/go-devops/prometheus"
	"github.com/prometheus/client_golang/api"

	log "github.com/sirupsen/logrus"
	"os"
	"time"
)

func main() {
	// An example of how to query Prometheus metrics by range.
	log.SetLevel(log.DebugLevel)
	log.SetOutput(os.Stdout)
	ctx, cancel := context.WithTimeout(context.Background(), 1*time.Minute)
	defer cancel()

	// new prometheus client
	client, err := api.NewClient(api.Config{
		Address: "http://10.158.215.90:80",
	})
	if err != nil {
		log.Errorf("Error creating client: %v\n", err)
		return
	}

	end := time.Now().UTC().Unix()

	p := devops.NewDevops().Prometheus()
	res, err := p.Query(ctx, client, "dynatrace_api_latency", end)
	if err != nil {
		log.Errorf("Error querying Prometheus: %v\n", err)
	}
	vector, err := res.ConvertByte()
	if err != nil {
		log.Errorf("Convert matrix result to byte error, err: %v", err)
	}
	var result prometheus.Vector
	if err := jsoniter.Unmarshal(vector, &result); err != nil {
		log.Errorf("error jsoniter unmarshal result to prometheus.Matrix, err: %v", err)
	}
	fmt.Println(result)
}

Output:

ExamplePrometheus_QueryRange demonstrates how to use Prometheus.QueryRange. Open the link to see an example: https://go.dev/play/p/32LVSjFs2hU

package main

import (
	"context"
	"fmt"

	jsoniter "github.com/json-iterator/go"
	"github.com/mo-silent/go-devops"
	"github.com/mo-silent/go-devops/prometheus"
	"github.com/prometheus/client_golang/api"

	v1 "github.com/prometheus/client_golang/api/prometheus/v1"

	log "github.com/sirupsen/logrus"
	"os"
	"time"
)

func main() {
	// An example of how to query Prometheus metrics by range.
	log.SetLevel(log.DebugLevel)
	log.SetOutput(os.Stdout)
	ctx, cancel := context.WithTimeout(context.Background(), 1*time.Minute)
	defer cancel()

	// new prometheus client
	client, err := api.NewClient(api.Config{
		Address: "http://10.158.215.90:80",
	})
	if err != nil {
		log.Errorf("Error creating client: %v\n", err)
		return
	}

	end := time.Now().UTC()

	r := v1.Range{
		Start: end.Add(-4 * time.Minute),
		End:   end,
		Step:  time.Minute,
	}
	log.Debugf("start: %v, end time: %v", end.Add(-4*time.Minute), end)

	p := devops.NewDevops().Prometheus()
	res, err := p.QueryRange(ctx, client, "dynatrace_api_latency", r, v1.WithTimeout(5*time.Second))
	if err != nil {
		log.Errorf("Error querying Prometheus: %v\n", err)
	}
	matrix, err := res.ConvertByte()
	if err != nil {
		log.Errorf("Convert matrix result to byte error, err: %v", err)
	}
	var result prometheus.Matrix
	if err := jsoniter.Unmarshal(matrix, &result); err != nil {
		log.Errorf("error jsoniter unmarshal result to prometheus.Matrix, err: %v", err)
	}
	fmt.Println(result)

}

Output: