metrics

Documentation

Index

• Constants
• func DurationMillis() int64
• func Emit(log *zap.SugaredLogger)
• func EmitFail(log *zap.SugaredLogger)
• func NewLogger(pkg string, ind string, level string, paths ...string) (*zap.SugaredLogger, error)
• type MetricsReceiver
  • func NewMetricsReceiver(cfg MetricsReceiverConfig) (MetricsReceiver, error)
• type MetricsReceiverConfig
• type PrometheusMetricsReceiver
  • func NewPrometheusMetricsReceiver(cfg PrometheusMetricsReceiverConfig) (*PrometheusMetricsReceiver, error)
  • func (rcvr *PrometheusMetricsReceiver) IncrementCounter(name string) error
  • func (rcvr *PrometheusMetricsReceiver) SetGauge(name string, value float64) error
• type PrometheusMetricsReceiverConfig
  • func (pcfg *PrometheusMetricsReceiverConfig) GetReceiverType() string
• type SearchWriter
  • func SearchWriterFromEnv(index string) (SearchWriter, error)
  • func (s SearchWriter) Close() error
  • func (s SearchWriter) Sync() error
  • func (s SearchWriter) Write(data []byte) (int, error)

Constants

const (
	Duration = "duration"
	Status   = "status"

	BuildURL          = "build_url"
	JenkinsJob        = "jenkins_job"
	BranchName        = "branch_name"
	CommitHash        = "commit_hash"
	KubernetesVersion = "kubernetes_version"
	TestEnv           = "test_env"
	Label             = "label"

	MetricsIndex = "metrics"
	TestLogIndex = "testlogs"
)

Functions

func DurationMillis

func DurationMillis() int64

func Emit

func Emit(log *zap.SugaredLogger)

func EmitFail

func EmitFail(log *zap.SugaredLogger)

func NewLogger

func NewLogger(pkg string, ind string, level string, paths ...string) (*zap.SugaredLogger, error)

NewLogger generates a new logger, and tees ginkgo output to the search db

Types

type MetricsReceiver

type MetricsReceiver interface {
	SetGauge(name string, value float64) error
	IncrementCounter(name string) error
}

func NewMetricsReceiver

func NewMetricsReceiver(cfg MetricsReceiverConfig) (MetricsReceiver, error)

type MetricsReceiverConfig

type MetricsReceiverConfig interface {
	GetReceiverType() string
}

type PrometheusMetricsReceiver

type PrometheusMetricsReceiver struct {
	Name string
	// contains filtered or unexported fields
}

func NewPrometheusMetricsReceiver

func NewPrometheusMetricsReceiver(cfg PrometheusMetricsReceiverConfig) (*PrometheusMetricsReceiver, error)

Create a new PrometheusMetricsReceiver based on the configuration options provided

func (*PrometheusMetricsReceiver) IncrementCounter

func (rcvr *PrometheusMetricsReceiver) IncrementCounter(name string) error

func (*PrometheusMetricsReceiver) SetGauge

func (rcvr *PrometheusMetricsReceiver) SetGauge(name string, value float64) error

type PrometheusMetricsReceiverConfig

type PrometheusMetricsReceiverConfig struct {
	PushGatewayURL      string
	PushGatewayUser     string
	PushGatewayPassword string
	PushInterval        time.Duration
	Name                string
}

func (*PrometheusMetricsReceiverConfig) GetReceiverType

func (pcfg *PrometheusMetricsReceiverConfig) GetReceiverType() string

type SearchWriter

type SearchWriter struct {
	// contains filtered or unexported fields
}

SearchWriter writes to a search endpoint, as an io.Writer and zapcore.WriteSyncer S

func SearchWriterFromEnv

func SearchWriterFromEnv(index string) (SearchWriter, error)

SearchWriterFromEnv creates a SearchWriter using environment variables

func (SearchWriter) Close

func (s SearchWriter) Close() error

Close implement as needed

func (SearchWriter) Sync

func (s SearchWriter) Sync() error

Sync implement as needed

func (SearchWriter) Write

func (s SearchWriter) Write(data []byte) (int, error)

Write out the record to the search data store