Versions in this module Expand all Collapse all v0 v0.1.0 Apr 5, 2024 Changes in this version + type FakeInputDataRegistry struct + HasNoCACertificate bool + MinSampleGap time.Duration + ShouldWatcherNotifyOfPreexisting bool + Watcher *KapiWatcher + func (fidr *FakeInputDataRegistry) AddKapiWatcher(watcher *KapiWatcher, shouldNotifyOfPreexisting bool) + func (fidr *FakeInputDataRegistry) DataSource() InputDataSource + func (fidr *FakeInputDataRegistry) GetKapiData(shootNamespace string, podName string) *KapiData + func (fidr *FakeInputDataRegistry) GetKapis() []*KapiData + func (fidr *FakeInputDataRegistry) GetShootAuthSecret(_ string) string + func (fidr *FakeInputDataRegistry) GetShootCACertificate(_ string) *x509.CertPool + func (fidr *FakeInputDataRegistry) NotifyKapiMetricsFault(_ string, _ string) int + func (fidr *FakeInputDataRegistry) RemoveKapiData(shootNamespace string, podName string) bool + func (fidr *FakeInputDataRegistry) RemoveKapiWatcher(*KapiWatcher) bool + func (fidr *FakeInputDataRegistry) RemoveShootAuthSecret() + func (fidr *FakeInputDataRegistry) SetKapiData(shootNamespace string, podName string, uid types.UID, ...) + func (fidr *FakeInputDataRegistry) SetKapiLastScrapeTime(shootNamespace string, podName string, value time.Time) + func (fidr *FakeInputDataRegistry) SetKapiMetrics(shootNamespace string, podName string, currentTotalRequestCount int64) + func (fidr *FakeInputDataRegistry) SetKapiMetricsWithTime(shootNamespace string, podName string, currentTotalRequestCount int64, ...) + func (fidr *FakeInputDataRegistry) SetKapis(kapis []*KapiData) + func (fidr *FakeInputDataRegistry) SetShootAuthSecret(_ string, _ string) + func (fidr *FakeInputDataRegistry) SetShootCACertificate(_ string, _ []byte) + type InputDataRegistry interface + AddKapiWatcher func(watcher *KapiWatcher, shouldNotifyOfPreexisting bool) + DataSource func() InputDataSource + GetKapiData func(shootNamespace string, podName string) *KapiData + GetShootAuthSecret func(shootNamespace string) string + GetShootCACertificate func(shootNamespace string) *x509.CertPool + NotifyKapiMetricsFault func(shootNamespace string, podName string) int + RemoveKapiData func(shootNamespace string, podName string) bool + RemoveKapiWatcher func(watcher *KapiWatcher) bool + SetKapiData func(shootNamespace string, podName string, podUID types.UID, ...) + SetKapiLastScrapeTime func(shootNamespace string, podName string, value time.Time) + SetKapiMetrics func(shootNamespace string, podName string, currentTotalRequestCount int64) + SetShootAuthSecret func(shootNamespace string, authSecret string) + SetShootCACertificate func(shootNamespace string, certificate []byte) + func NewInputDataRegistry(minSampleGap time.Duration, log logr.Logger) InputDataRegistry + type InputDataSource interface + AddKapiWatcher func(watcher *KapiWatcher, shouldNotifyOfPreexisting bool) + GetShootKapis func(shootNamespace string) []ShootKapi + RemoveKapiWatcher func(watcher *KapiWatcher) bool + type KapiData struct + FaultCount int + LastMetricsScrapeTime time.Time + MetricsTimeNew time.Time + MetricsTimeOld time.Time + MetricsUrl string + PodLabels map[string]string + PodUID types.UID + TotalRequestCountNew int64 + TotalRequestCountOld int64 + func (kapi *KapiData) Copy() *KapiData + func (kapi *KapiData) PodName() string + func (kapi *KapiData) ShootNamespace() string + type KapiEventType int + const KapiEventCreate + const KapiEventDelete + type KapiWatcher func(kapi ShootKapi, event KapiEventType) + type ShootKapi interface + MetricsTimeNew func() time.Time + MetricsTimeOld func() time.Time + PodLabels func() map[string]string + PodName func() string + PodUID func() types.UID + ShootNamespace func() string + TotalRequestCountNew func() int64 + TotalRequestCountOld func() int64
Go to main page