prometheus

Documentation

Index

• func StartPrometheusEndpoint(certsDirectory string)
• type ProgressMetric
• type ProgressReader
  • func NewProgressReader(r io.ReadCloser, metric ProgressMetric, total uint64) *ProgressReader
  • func (r *ProgressReader) SetNextReader(reader io.ReadCloser, final bool)
  • func (r *ProgressReader) StartTimedUpdate()

Functions

func StartPrometheusEndpoint

func StartPrometheusEndpoint(certsDirectory string)

StartPrometheusEndpoint starts an http server providing a prometheus endpoint using the passed in directory to store the self signed certificates that will be generated before starting the http server.

Types

type ProgressMetric

type ProgressMetric interface {
	Add(value float64)
	Get() (float64, error)
	Delete()
}

type ProgressReader

type ProgressReader struct {
	util.CountingReader
	// contains filtered or unexported fields
}

ProgressReader is a counting reader that reports progress to prometheus.

func NewProgressReader

func NewProgressReader(r io.ReadCloser, metric ProgressMetric, total uint64) *ProgressReader

NewProgressReader creates a new instance of a prometheus updating progress reader.

func (*ProgressReader) SetNextReader

func (r *ProgressReader) SetNextReader(reader io.ReadCloser, final bool)

SetNextReader replaces the current counting reader with a new one, for tracking progress over multiple readers.

func (*ProgressReader) StartTimedUpdate

func (r *ProgressReader) StartTimedUpdate()

StartTimedUpdate starts the update timer to automatically update every second.