telemetry

README

telemetry

This module exposes channels that are meant be used for logging to Azure Application Insights and Prometheus. The information that is conveyed through the channel is either to Azure Application Insights or used to set/increase an internal Prometheus metric.

This package is currently dependent on the modules "github.com/3lvia/hn-config-lib-go/vault" which again means that you need a running instance of Hashicorp Vault in order to use this functionality. This dependency will probably become optional in a future version. The Vault instance is used for the sole purpose of fetching the instrumentation key for Application Insights.

The functionality is made available through the func Start which internally starts a go-routine listening to the different channels that are contained in the returned instance of LogChans. The follwoing code sample shows how to bootstrap the functionality:

import (
    "context"
    "github.com/3lvia/telemetry-go"
    "github.com/3lvia/hn-config-lib-go/vault"
    "github.com/prometheus/client_golang/prometheus/promhttp"
)

ctx := context.Background()
v, err := vault.New()
if err != nil {
    log.Fatal(err)
}
systemName := "my-system"
appName := "my-app"
applicationInsightsVaultPath := "mount/kv/path/to/appinsights-instrumentationkey"
logChannels := telemetry.Start(ctx, systemName, appName, applicationInsightsVaultPath, v)
// logChannels are ready to use!

// 
metricsPort := "2112"
http.Handle("/metrics", promhttp.Handler())
http.ListenAndServe(metricsPort, nil)

Log Channels

• CountChan Increases the named Prometheus counter.
• GaugeChan Sets the named Prometheus counter.
• ErrorChan Sends the error to Application Insights. It is registered as an Exception in App Insights.
• EventChan Sends the event to Application Insights. It is registered as a Cusom Event in App Insights.
• DebugChan Prints the debug string to the console.

About Prometheus Names

The metric instances that are used in the two channels CountChan and GaugeChan contain the element Name. It is assumed that this name contains a human readable sentence that describes the metric, for instance Number of succesful API requests.

This sentence is internally transformed as follows: Number of succesful API requests -> number_of_succesful_api_requests

Simultaneously, the given sentence-based name is used as the "Help" of the metric.

Documentation

Index

• type Event
• type LogChans
  • func Start(ctx context.Context, options Options, v vault.SecretsManager) LogChans
• type Metric
• type Options

Types

type Event

type Event struct {
	Name string
	Data map[string]string
}

Event is raised when something interesting happens in the application. Consists of a name an a map of key/value pairs.

type LogChans

type LogChans struct {
	// CountChan increases the named Prometheus counter.
	CountChan chan Metric

	// GaugeChan increases the named Prometheus gauge.
	GaugeChan chan Metric

	// ErrorChan sends the error to Application Insights.
	ErrorChan chan error

	// EventChan sends the event to Application Insights.
	EventChan chan Event

	// DebugChan prints a debug message to the console.
	DebugChan chan string
}

LogChans a set of channels used for communicating events, metrics, errors and other telemetry types to the logger.

func Start

func Start(ctx context.Context, options Options, v vault.SecretsManager) LogChans

Start starts the logger in a go routine and returns a set of channels that can be used to send telemetry to the logger.

type Metric

type Metric struct {
	Name  string
	Value float64
}

Metric is a named numeric value.

type Options

type Options struct {
	// SystemName the name of the containing system.
	SystemName string

	// The name of the running application/micro-service.
	AppName string

	// AppInsightsSecretPath the path to Application Insights instrumentation key in Vault.
	AppInsightsSecretPath string

	// SendMetricsToAppInsights indicates whether metrics should be sent to Application Insights
	// in addition to Prometheus.
	SendMetricsToAppInsights bool
}

Options is used to configure the functionality of this entire module.