metrics

package

v0.0.0-...-88878d6 Latest Latest Go to latest Published: Oct 5, 2017 License: MIT Imports: 16 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/chanwit/faas

Documentation ¶

Index ¶

func AddMetricsHandler(handler http.HandlerFunc, host string, port int) http.HandlerFunc
func AttachExternalWatcher(endpointURL url.URL, metricsOptions MetricOptions, label string, ...)
func AttachSwarmWatcher(dockerClient *client.Client, metricsOptions MetricOptions, label string)
func PrometheusHandler() http.Handler
func RegisterMetrics(metricsOptions MetricOptions)
type MetricOptions
- func BuildMetricsOptions() MetricOptions
type PrometheusQuery
- func NewPrometheusQuery(host string, port int, client *http.Client) PrometheusQuery
- func (q *PrometheusQuery) Fetch(query string) (*VectorQueryResponse, error)
type VectorQueryResponse

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AddMetricsHandler ¶

func AddMetricsHandler(handler http.HandlerFunc, host string, port int) http.HandlerFunc

AddMetricsHandler wraps a http.HandlerFunc with Prometheus metrics

func AttachExternalWatcher ¶

func AttachExternalWatcher(endpointURL url.URL, metricsOptions MetricOptions, label string, interval time.Duration)

func AttachSwarmWatcher ¶

func AttachSwarmWatcher(dockerClient *client.Client, metricsOptions MetricOptions, label string)

AttachSwarmWatcher adds a go-route to monitor the amount of service replicas in the swarm matching a 'function' label.

func PrometheusHandler ¶

func PrometheusHandler() http.Handler

PrometheusHandler Bootstraps prometheus for metrics collection

func RegisterMetrics ¶

func RegisterMetrics(metricsOptions MetricOptions)

RegisterMetrics registers with Prometheus for tracking

Types ¶

type MetricOptions ¶

type MetricOptions struct {
	GatewayFunctionInvocation *prometheus.CounterVec
	GatewayFunctionsHistogram *prometheus.HistogramVec
	ServiceReplicasCounter    *prometheus.GaugeVec
}

MetricOptions to be used by web handlers

func BuildMetricsOptions ¶

func BuildMetricsOptions() MetricOptions

BuildMetricsOptions builds metrics for tracking functions in the API gateway

type PrometheusQuery ¶

type PrometheusQuery struct {
	Port   int
	Host   string
	Client *http.Client
}

PrometheusQuery a PrometheusQuery

func NewPrometheusQuery ¶

func NewPrometheusQuery(host string, port int, client *http.Client) PrometheusQuery

NewPrometheusQuery create a NewPrometheusQuery

func (*PrometheusQuery) Fetch ¶

func (q *PrometheusQuery) Fetch(query string) (*VectorQueryResponse, error)

Fetch queries aggregated stats

type VectorQueryResponse ¶

type VectorQueryResponse struct {
	Data struct {
		Result []struct {
			Metric struct {
				Code         string `json:"code"`
				FunctionName string `json:"function_name"`
			}
			Value []interface{} `json:"value"`
		}
	}
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL