kube

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
  • func (c ClientRequestLatencyMetric) Observe(verb string, u url.URL, latency time.Duration)
• type ClientRequestResultMetric
  • func (c ClientRequestResultMetric) Increment(code string, method string, host string)
• type KubernetesClient
  • func NewFakeKubernetesClient() KubernetesClient

Variables

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
}

func (ClientRequestLatencyMetric) Observe

func (c ClientRequestLatencyMetric) Observe(verb string, u url.URL, latency time.Duration)

type ClientRequestResultMetric

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

func (ClientRequestResultMetric) Increment

func (c ClientRequestResultMetric) Increment(code string, method string, host string)

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