metrics

Documentation

Index

• func StartMetricsServer(port int) chan error
• type ApplicationMetrics
  • func Applications() *ApplicationMetrics
  • func NewApplicationsMetrics() *ApplicationMetrics
  • func (apm *ApplicationMetrics) IncreaseImageUpdate(application string, by int)
  • func (apm *ApplicationMetrics) IncreaseUpdateErrors(application string, by int)
  • func (apm *ApplicationMetrics) SetNumberOfApplications(num int)
  • func (apm *ApplicationMetrics) SetNumberOfImagesWatched(application string, num int)
• type ClientMetrics
  • func Clients() *ClientMetrics
  • func NewClientMetrics() *ClientMetrics
  • func (cpm *ClientMetrics) IncreaseArgoCDClientError(server string, by int)
  • func (cpm *ClientMetrics) IncreaseArgoCDClientRequest(server string, by int)
  • func (cpm *ClientMetrics) IncreaseK8sClientError(by int)
  • func (cpm *ClientMetrics) IncreaseK8sClientRequest(by int)
• type EndpointMetrics
  • func Endpoint() *EndpointMetrics
  • func NewEndpointMetrics() *EndpointMetrics
  • func (epm *EndpointMetrics) IncreaseRequest(registryURL string, isFailed bool)

Functions

func StartMetricsServer

func StartMetricsServer(port int) chan error

StartMetricsServer starts a new HTTP server for metrics on given port

Types

type ApplicationMetrics

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

ApplicationMetrics stores metrics for applications

func Applications

func Applications() *ApplicationMetrics

Applications returns the global ApplicationMetrics object

func NewApplicationsMetrics

func NewApplicationsMetrics() *ApplicationMetrics

NewApplicationsMetrics returns a new application metrics object

func (*ApplicationMetrics) IncreaseImageUpdate

func (apm *ApplicationMetrics) IncreaseImageUpdate(application string, by int)

IncreaseImageUpdate increases the number of image updates for given application

func (*ApplicationMetrics) IncreaseUpdateErrors

func (apm *ApplicationMetrics) IncreaseUpdateErrors(application string, by int)

IncreaseUpdateErrors increases the number of errors for given application occured during update process

func (*ApplicationMetrics) SetNumberOfApplications

func (apm *ApplicationMetrics) SetNumberOfApplications(num int)

SetNumberOfApplications sets the total number of currently watched applications

func (*ApplicationMetrics) SetNumberOfImagesWatched

func (apm *ApplicationMetrics) SetNumberOfImagesWatched(application string, num int)

SetNumberOfImagesWatched sets the total number of currently watched images for given application

type ClientMetrics

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

ClientMetrics stores metrics for K8s and ArgoCD clients

func Clients

func Clients() *ClientMetrics

Clients returns the global ClientMetrics object

func NewClientMetrics

func NewClientMetrics() *ClientMetrics

NewClientMetrics returns a new client metrics object

func (*ClientMetrics) IncreaseArgoCDClientError

func (cpm *ClientMetrics) IncreaseArgoCDClientError(server string, by int)

IncreaseArgoCDClientError increases the number of failed Argo CD API requests for given server

func (*ClientMetrics) IncreaseArgoCDClientRequest

func (cpm *ClientMetrics) IncreaseArgoCDClientRequest(server string, by int)

IncreaseArgoCDClientRequest increases the number of Argo CD API requests for given server

func (*ClientMetrics) IncreaseK8sClientError

func (cpm *ClientMetrics) IncreaseK8sClientError(by int)

IncreaseK8sClientRequest increases the number of failed K8s API requests

func (*ClientMetrics) IncreaseK8sClientRequest

func (cpm *ClientMetrics) IncreaseK8sClientRequest(by int)

IncreaseK8sClientRequest increases the number of K8s API requests

type EndpointMetrics

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

EndpointMetrics stores metrics for registry endpoints

func Endpoint

func Endpoint() *EndpointMetrics

Endpoint returns the global EndpointMetrics object

func NewEndpointMetrics

func NewEndpointMetrics() *EndpointMetrics

NewEndpointMetrics returns a new endpoint metrics object

func (*EndpointMetrics) IncreaseRequest

func (epm *EndpointMetrics) IncreaseRequest(registryURL string, isFailed bool)

IncreaseRequest increases the request counter of EndpointMetrics object