library/go/yandex/solomon/reporters/puller/httppuller/example_test.go


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40

package httppuller_test

import (
	"net/http"
	"time"

	"github.com/ydb-platform/ydb/library/go/core/metrics/solomon"
	"github.com/ydb-platform/ydb/library/go/yandex/solomon/reporters/puller/httppuller"
	"github.com/ydb-platform/ydb/library/go/yandex/tvm"
)

func ExampleNewHandler() {
	// create metrics registry
	opts := solomon.NewRegistryOpts().
		SetSeparator('_').
		SetPrefix("myprefix")

	reg := solomon.NewRegistry(opts)

	// register new metric
	cnt := reg.Counter("cyclesCount")

	// pass metric to your function and do job
	go func() {
		for {
			cnt.Inc()
			time.Sleep(1 * time.Second)
		}
	}()

	// start HTTP server with handler on /metrics URI
	mux := http.NewServeMux()
	mux.Handle("/metrics", httppuller.NewHandler(reg))

	// Or start
	var tvm tvm.Client
	mux.Handle("/secure_metrics", httppuller.NewHandler(reg, httppuller.WithTVM(tvm)))

	_ = http.ListenAndServe(":80", mux)
}