metric

Documentation

Index

• Variables
• func CountQueries(conn db.Conn) db.Conn
• func Deinitialize(logger lager.Logger)
• func Initialize(logger lager.Logger, host string, attributes map[string]string, ...) error
• func LogLockAcquired(logger lager.Logger, lockID lock.LockID)
• func LogLockReleased(logger lager.Logger, lockID lock.LockID)
• func PeriodicallyEmit(logger lager.Logger, interval time.Duration) ifrit.Runner
• func RegisterEmitter(factory EmitterFactory)
• func WireEmitters(group *flags.Group)
• func WrapHandler(logger lager.Logger, route string, handler http.Handler) http.Handler
• type ArtifactCollectorDuration
  • func (event ArtifactCollectorDuration) Emit(logger lager.Logger)
• type BuildCollectorDuration
  • func (event BuildCollectorDuration) Emit(logger lager.Logger)
• type BuildFinished
  • func (event BuildFinished) Emit(logger lager.Logger)
• type BuildStarted
  • func (event BuildStarted) Emit(logger lager.Logger)
• type ContainerCollectorDuration
  • func (event ContainerCollectorDuration) Emit(logger lager.Logger)
• type Counter
  • func (m *Counter) Delta() float64
  • func (m *Counter) Inc()
  • func (m *Counter) IncDelta(delta int)
• type CreatedContainersToBeGarbageCollected
  • func (event CreatedContainersToBeGarbageCollected) Emit(logger lager.Logger)
• type CreatedVolumesToBeGarbageCollected
  • func (event CreatedVolumesToBeGarbageCollected) Emit(logger lager.Logger)
• type CreatingContainersToBeGarbageCollected
  • func (event CreatingContainersToBeGarbageCollected) Emit(logger lager.Logger)
• type DestroyingContainersToBeGarbageCollected
  • func (event DestroyingContainersToBeGarbageCollected) Emit(logger lager.Logger)
• type DestroyingVolumesToBeGarbageCollected
  • func (event DestroyingVolumesToBeGarbageCollected) Emit(logger lager.Logger)
• type Emitter
• type EmitterFactory
• type ErrorLog
  • func (e ErrorLog) Emit(logger lager.Logger)
• type ErrorSinkCollector
  • func NewErrorSinkCollector(logger lager.Logger) ErrorSinkCollector
  • func (c *ErrorSinkCollector) Log(f lager.LogFormat)
• type Event
• type FailedContainersToBeGarbageCollected
  • func (event FailedContainersToBeGarbageCollected) Emit(logger lager.Logger)
• type FailedVolumesToBeGarbageCollected
  • func (event FailedVolumesToBeGarbageCollected) Emit(logger lager.Logger)
• type GarbageCollectionContainerCollectorJobDropped
  • func (event GarbageCollectionContainerCollectorJobDropped) Emit(logger lager.Logger)
• type Gauge
  • func (c *Gauge) Dec()
  • func (c *Gauge) Inc()
  • func (c *Gauge) Max() float64
  • func (c *Gauge) Set(val int64)
• type HTTPResponseTime
  • func (event HTTPResponseTime) Emit(logger lager.Logger)
• type LockAcquired
  • func (event LockAcquired) Emit(logger lager.Logger)
• type LockReleased
  • func (event LockReleased) Emit(logger lager.Logger)
• type MetricsHandler
  • func (handler MetricsHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type ResourceCacheCollectorDuration
  • func (event ResourceCacheCollectorDuration) Emit(logger lager.Logger)
• type ResourceCacheUseCollectorDuration
  • func (event ResourceCacheUseCollectorDuration) Emit(logger lager.Logger)
• type ResourceConfigCheckSessionCollectorDuration
  • func (event ResourceConfigCheckSessionCollectorDuration) Emit(logger lager.Logger)
• type ResourceConfigCollectorDuration
  • func (event ResourceConfigCollectorDuration) Emit(logger lager.Logger)
• type SchedulingJobDuration
  • func (event SchedulingJobDuration) Emit(logger lager.Logger)
• type VolumeCollectorDuration
  • func (event VolumeCollectorDuration) Emit(logger lager.Logger)
• type VolumesToBeGarbageCollected
  • func (event VolumesToBeGarbageCollected) Emit(logger lager.Logger)
• type WorkerCollectorDuration
  • func (event WorkerCollectorDuration) Emit(logger lager.Logger)
• type WorkerContainers
  • func (event WorkerContainers) Emit(logger lager.Logger)
• type WorkerTasks
  • func (event WorkerTasks) Emit(logger lager.Logger)
• type WorkerUnknownContainers
  • func (event WorkerUnknownContainers) Emit(logger lager.Logger)
• type WorkerUnknownVolumes
  • func (event WorkerUnknownVolumes) Emit(logger lager.Logger)
• type WorkerVolumes
  • func (event WorkerVolumes) Emit(logger lager.Logger)
• type WorkersState
  • func (event WorkersState) Emit(logger lager.Logger)

Variables

var BuildsRunning = &Gauge{}

var BuildsStarted = &Counter{}

var ChecksDeleted = &Counter{}

var ChecksEnqueued = &Counter{}

var ChecksFinishedWithError = &Counter{}

var ChecksFinishedWithSuccess = &Counter{}

var ChecksQueueSize = &Gauge{}

var ChecksStarted = &Counter{}

var ConcurrentRequests = map[string]*Gauge{}

var ConcurrentRequestsLimitHit = map[string]*Counter{}

var ContainersCreated = &Counter{}

var ContainersDeleted = &Counter{}

var DatabaseQueries = &Counter{}

var Databases []db.Conn

var ErrFailedToEmit = errors.New("failed to emit metric")

var FailedContainers = &Counter{}

var FailedVolumes = &Counter{}

var JobsScheduled = &Counter{}

var JobsScheduling = &Gauge{}

var TasksWaiting = &Gauge{}

var VolumesCreated = &Counter{}

var VolumesDeleted = &Counter{}

Functions

func CountQueries

func CountQueries(conn db.Conn) db.Conn

func Deinitialize

func Deinitialize(logger lager.Logger)

func Initialize

func Initialize(logger lager.Logger, host string, attributes map[string]string, bufferSize uint32) error

func LogLockAcquired

func LogLockAcquired(logger lager.Logger, lockID lock.LockID)

func LogLockReleased

func LogLockReleased(logger lager.Logger, lockID lock.LockID)

func PeriodicallyEmit

func PeriodicallyEmit(logger lager.Logger, interval time.Duration) ifrit.Runner

func RegisterEmitter

func RegisterEmitter(factory EmitterFactory)

func WireEmitters

func WireEmitters(group *flags.Group)

func WrapHandler

func WrapHandler(logger lager.Logger, route string, handler http.Handler) http.Handler

Types

type ArtifactCollectorDuration

type ArtifactCollectorDuration struct {
	Duration time.Duration
}

func (ArtifactCollectorDuration) Emit

func (event ArtifactCollectorDuration) Emit(logger lager.Logger)

type BuildCollectorDuration

type BuildCollectorDuration struct {
	Duration time.Duration
}

func (BuildCollectorDuration) Emit

func (event BuildCollectorDuration) Emit(logger lager.Logger)

type BuildFinished

type BuildFinished struct {
	PipelineName  string
	JobName       string
	BuildName     string
	BuildID       int
	BuildStatus   db.BuildStatus
	BuildDuration time.Duration
	TeamName      string
}

func (BuildFinished) Emit

func (event BuildFinished) Emit(logger lager.Logger)

type BuildStarted

type BuildStarted struct {
	PipelineName string
	JobName      string
	BuildName    string
	BuildID      int
	TeamName     string
}

func (BuildStarted) Emit

func (event BuildStarted) Emit(logger lager.Logger)

type ContainerCollectorDuration

type ContainerCollectorDuration struct {
	Duration time.Duration
}

func (ContainerCollectorDuration) Emit

func (event ContainerCollectorDuration) Emit(logger lager.Logger)

type Counter

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

func (*Counter) Delta

func (m *Counter) Delta() float64

func (*Counter) Inc

func (m *Counter) Inc()

func (*Counter) IncDelta

func (m *Counter) IncDelta(delta int)

type CreatedContainersToBeGarbageCollected

type CreatedContainersToBeGarbageCollected struct {
	Containers int
}

func (CreatedContainersToBeGarbageCollected) Emit

func (event CreatedContainersToBeGarbageCollected) Emit(logger lager.Logger)

type CreatedVolumesToBeGarbageCollected

type CreatedVolumesToBeGarbageCollected struct {
	Volumes int
}

func (CreatedVolumesToBeGarbageCollected) Emit

func (event CreatedVolumesToBeGarbageCollected) Emit(logger lager.Logger)

type CreatingContainersToBeGarbageCollected

type CreatingContainersToBeGarbageCollected struct {
	Containers int
}

func (CreatingContainersToBeGarbageCollected) Emit

func (event CreatingContainersToBeGarbageCollected) Emit(logger lager.Logger)

type DestroyingContainersToBeGarbageCollected

type DestroyingContainersToBeGarbageCollected struct {
	Containers int
}

func (DestroyingContainersToBeGarbageCollected) Emit

func (event DestroyingContainersToBeGarbageCollected) Emit(logger lager.Logger)

type DestroyingVolumesToBeGarbageCollected

type DestroyingVolumesToBeGarbageCollected struct {
	Volumes int
}

func (DestroyingVolumesToBeGarbageCollected) Emit

func (event DestroyingVolumesToBeGarbageCollected) Emit(logger lager.Logger)

type Emitter

type Emitter interface {
	Emit(lager.Logger, Event)
}

type EmitterFactory

type EmitterFactory interface {
	Description() string
	IsConfigured() bool
	NewEmitter() (Emitter, error)
}

type ErrorLog

type ErrorLog struct {
	Message string
	Value   int
}

func (ErrorLog) Emit

func (e ErrorLog) Emit(logger lager.Logger)

type ErrorSinkCollector

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

func NewErrorSinkCollector

func NewErrorSinkCollector(logger lager.Logger) ErrorSinkCollector

func (*ErrorSinkCollector) Log

func (c *ErrorSinkCollector) Log(f lager.LogFormat)

type Event

type Event struct {
	Name       string
	Value      float64
	Attributes map[string]string
	Host       string
	Time       time.Time
}

type FailedContainersToBeGarbageCollected

type FailedContainersToBeGarbageCollected struct {
	Containers int
}

func (FailedContainersToBeGarbageCollected) Emit

func (event FailedContainersToBeGarbageCollected) Emit(logger lager.Logger)

type FailedVolumesToBeGarbageCollected

type FailedVolumesToBeGarbageCollected struct {
	Volumes int
}

func (FailedVolumesToBeGarbageCollected) Emit

func (event FailedVolumesToBeGarbageCollected) Emit(logger lager.Logger)

type GarbageCollectionContainerCollectorJobDropped

type GarbageCollectionContainerCollectorJobDropped struct {
	WorkerName string
}

func (GarbageCollectionContainerCollectorJobDropped) Emit

func (event GarbageCollectionContainerCollectorJobDropped) Emit(logger lager.Logger)

type Gauge

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

func (*Gauge) Dec

func (c *Gauge) Dec()

func (*Gauge) Inc

func (c *Gauge) Inc()

func (*Gauge) Max

func (c *Gauge) Max() float64

func (*Gauge) Set

func (c *Gauge) Set(val int64)

type HTTPResponseTime

type HTTPResponseTime struct {
	Route      string
	Path       string
	Method     string
	StatusCode int
	Duration   time.Duration
}

func (HTTPResponseTime) Emit

func (event HTTPResponseTime) Emit(logger lager.Logger)

type LockAcquired

type LockAcquired struct {
	LockType string
}

func (LockAcquired) Emit

func (event LockAcquired) Emit(logger lager.Logger)

type LockReleased

type LockReleased struct {
	LockType string
}

func (LockReleased) Emit

func (event LockReleased) Emit(logger lager.Logger)

type MetricsHandler

type MetricsHandler struct {
	Logger  lager.Logger
	Route   string
	Handler http.Handler
}

func (MetricsHandler) ServeHTTP

func (handler MetricsHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type ResourceCacheCollectorDuration

type ResourceCacheCollectorDuration struct {
	Duration time.Duration
}

func (ResourceCacheCollectorDuration) Emit

func (event ResourceCacheCollectorDuration) Emit(logger lager.Logger)

type ResourceCacheUseCollectorDuration

type ResourceCacheUseCollectorDuration struct {
	Duration time.Duration
}

func (ResourceCacheUseCollectorDuration) Emit

func (event ResourceCacheUseCollectorDuration) Emit(logger lager.Logger)

type ResourceConfigCheckSessionCollectorDuration

type ResourceConfigCheckSessionCollectorDuration struct {
	Duration time.Duration
}

func (ResourceConfigCheckSessionCollectorDuration) Emit

func (event ResourceConfigCheckSessionCollectorDuration) Emit(logger lager.Logger)

type ResourceConfigCollectorDuration

type ResourceConfigCollectorDuration struct {
	Duration time.Duration
}

func (ResourceConfigCollectorDuration) Emit

func (event ResourceConfigCollectorDuration) Emit(logger lager.Logger)

type SchedulingJobDuration

type SchedulingJobDuration struct {
	PipelineName string
	JobName      string
	JobID        int
	Duration     time.Duration
}

func (SchedulingJobDuration) Emit

func (event SchedulingJobDuration) Emit(logger lager.Logger)

type VolumeCollectorDuration

type VolumeCollectorDuration struct {
	Duration time.Duration
}

func (VolumeCollectorDuration) Emit

func (event VolumeCollectorDuration) Emit(logger lager.Logger)

type VolumesToBeGarbageCollected

type VolumesToBeGarbageCollected struct {
	Volumes int
}

func (VolumesToBeGarbageCollected) Emit

func (event VolumesToBeGarbageCollected) Emit(logger lager.Logger)

type WorkerCollectorDuration

type WorkerCollectorDuration struct {
	Duration time.Duration
}

func (WorkerCollectorDuration) Emit

func (event WorkerCollectorDuration) Emit(logger lager.Logger)

type WorkerContainers

type WorkerContainers struct {
	WorkerName string
	Platform   string
	Containers int
	TeamName   string
	Tags       []string
}

func (WorkerContainers) Emit

func (event WorkerContainers) Emit(logger lager.Logger)

type WorkerTasks

type WorkerTasks struct {
	WorkerName string
	Platform   string
	Tasks      int
}

func (WorkerTasks) Emit

func (event WorkerTasks) Emit(logger lager.Logger)

type WorkerUnknownContainers

type WorkerUnknownContainers struct {
	WorkerName string
	Containers int
}

func (WorkerUnknownContainers) Emit

func (event WorkerUnknownContainers) Emit(logger lager.Logger)

type WorkerUnknownVolumes

type WorkerUnknownVolumes struct {
	WorkerName string
	Volumes    int
}

func (WorkerUnknownVolumes) Emit

func (event WorkerUnknownVolumes) Emit(logger lager.Logger)

type WorkerVolumes

type WorkerVolumes struct {
	WorkerName string
	Platform   string
	Volumes    int
	TeamName   string
	Tags       []string
}

func (WorkerVolumes) Emit

func (event WorkerVolumes) Emit(logger lager.Logger)

type WorkersState

type WorkersState struct {
	WorkerStateByName map[string]db.WorkerState
}

func (WorkersState) Emit

func (event WorkersState) Emit(logger lager.Logger)