Documentation
¶
Index ¶
- Variables
- func NewRequestLatencyMetric(metricStorage *metric_storage.MetricStorage) metrics.LatencyMetric
- func NewRequestResultMetric(metricStorage *metric_storage.MetricStorage) metrics.ResultMetric
- func RegisterKubernetesClientMetrics(metricStorage *metric_storage.MetricStorage)
- type ClientRequestLatencyMetric
- type ClientRequestResultMetric
- type KubernetesClient
Constants ¶
This section is empty.
Variables ¶
View Source
var NewKubernetesClient = func() KubernetesClient {
return &kubernetesClient{}
}
Functions ¶
func NewRequestLatencyMetric ¶
func NewRequestLatencyMetric(metricStorage *metric_storage.MetricStorage) metrics.LatencyMetric
func NewRequestResultMetric ¶
func NewRequestResultMetric(metricStorage *metric_storage.MetricStorage) metrics.ResultMetric
func RegisterKubernetesClientMetrics ¶
func RegisterKubernetesClientMetrics(metricStorage *metric_storage.MetricStorage)
Types ¶
type ClientRequestLatencyMetric ¶
type ClientRequestLatencyMetric struct {
// contains filtered or unexported fields
}
type ClientRequestResultMetric ¶
type ClientRequestResultMetric struct {
// contains filtered or unexported fields
}
type KubernetesClient ¶
type KubernetesClient interface {
kubernetes.Interface
WithContextName(contextName string)
WithConfigPath(configPath string)
WithServer(server string)
WithRateLimiterSettings(qps float32, burst int)
WithMetricStorage(metricStorage *metric_storage.MetricStorage)
Init() error
DefaultNamespace() string
Dynamic() dynamic.Interface
APIResourceList(apiVersion string) ([]*metav1.APIResourceList, error)
APIResource(apiVersion string, kind string) (*metav1.APIResource, error)
GroupVersionResource(apiVersion string, kind string) (schema.GroupVersionResource, error)
}
func NewFakeKubernetesClient ¶
func NewFakeKubernetesClient() KubernetesClient
Click to show internal directories.
Click to hide internal directories.