metrics

Documentation

Index

• func AddMetricsTransportWrapper(server *MetricsServer, config *rest.Config) *rest.Config
• type MetricsServer
  • func NewMetricsServer() (*MetricsServer, error)
  • func (m *MetricsServer) InGitSyncUpdateError(gitSync *v1alpha1.GitSync)
  • func (m *MetricsServer) IncGitRequest()
  • func (m *MetricsServer) IncGitRequestFailed()
  • func (m *MetricsServer) IncKubeCacheFailed()
  • func (m *MetricsServer) IncKubectlExec(command string)
  • func (m *MetricsServer) IncKubernetesRequest(statusCode, verb, resourceKind, resourceNamespace string)
  • func (m *MetricsServer) IncSync(gitSync *v1alpha1.GitSync, state gitopsSyncCommon.OperationPhase)
  • func (m *MetricsServer) ObserveGitRequestLatency(duration time.Duration)
  • func (m *MetricsServer) ObserveReconcile(gitSync *v1alpha1.GitSync, duration time.Duration)
  • func (m *MetricsServer) ObserveWorkerQueueSyncWaitTime(duration time.Duration)
  • func (m *MetricsServer) SetKubeCachedResource(cache float64)
  • func (m *MetricsServer) SetMonitoredKubeAPI(apiRequest float64)

Functions

func AddMetricsTransportWrapper

func AddMetricsTransportWrapper(server *MetricsServer, config *rest.Config) *rest.Config

AddMetricsTransportWrapper adds a transport wrapper which increments 'numaplane_app_k8s_request_total' counter on each kubernetes request

Types

type MetricsServer

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

func NewMetricsServer

func NewMetricsServer() (*MetricsServer, error)

func (*MetricsServer) InGitSyncUpdateError

func (m *MetricsServer) InGitSyncUpdateError(gitSync *v1alpha1.GitSync)

InGitSyncUpdateError increments the sync counter for git sync status update failure

func (*MetricsServer) IncGitRequest

func (m *MetricsServer) IncGitRequest()

func (*MetricsServer) IncGitRequestFailed

func (m *MetricsServer) IncGitRequestFailed()

func (*MetricsServer) IncKubeCacheFailed

func (m *MetricsServer) IncKubeCacheFailed()

func (*MetricsServer) IncKubectlExec

func (m *MetricsServer) IncKubectlExec(command string)

func (*MetricsServer) IncKubernetesRequest

func (m *MetricsServer) IncKubernetesRequest(statusCode, verb, resourceKind, resourceNamespace string)

IncKubernetesRequest increments the kubernetes requests counter for an application

func (*MetricsServer) IncSync

func (m *MetricsServer) IncSync(gitSync *v1alpha1.GitSync, state gitopsSyncCommon.OperationPhase)

IncSync increments the sync counter for an application

func (*MetricsServer) ObserveGitRequestLatency

func (m *MetricsServer) ObserveGitRequestLatency(duration time.Duration)

func (*MetricsServer) ObserveReconcile

func (m *MetricsServer) ObserveReconcile(gitSync *v1alpha1.GitSync, duration time.Duration)

ObserveReconcile increments the reconciled counter for an application

func (*MetricsServer) ObserveWorkerQueueSyncWaitTime

func (m *MetricsServer) ObserveWorkerQueueSyncWaitTime(duration time.Duration)

ObserveWorkerQueueSyncWaitTime increments the sync counter for an application

func (*MetricsServer) SetKubeCachedResource

func (m *MetricsServer) SetKubeCachedResource(cache float64)

func (*MetricsServer) SetMonitoredKubeAPI

func (m *MetricsServer) SetMonitoredKubeAPI(apiRequest float64)