internal

Documentation

Index

• func CreateNodeInformer(ctx context.Context, client *kubernetes.Clientset, metric *prometheus.GaugeVec, ...)
• func GetLogEncoder(usePlain bool, config zapcore.EncoderConfig) zapcore.Encoder
• func MetricsProcessing(ctx context.Context, clientset *kubernetes.Clientset, ...)
• func ProcessSingleNodeMetrics(ctx context.Context, clientset *kubernetes.Clientset, ...) (*[]Pod, error)
• func RegisterPrometheusMetrics(ctx context.Context) *prometheus.GaugeVec
• func UpEndpointHandler(w http.ResponseWriter, r *http.Request)
• type Node
• type Pod
• type PodRef
• type RunConfiguration
  • func ParseInputArguments() (*RunConfiguration, error)

Functions

func CreateNodeInformer

func CreateNodeInformer(ctx context.Context,
	client *kubernetes.Clientset, metric *prometheus.GaugeVec,
	logger *zap.SugaredLogger, runtimeConfig *RunConfiguration)

func GetLogEncoder

func GetLogEncoder(usePlain bool, config zapcore.EncoderConfig) zapcore.Encoder

func MetricsProcessing

func MetricsProcessing(ctx context.Context, clientset *kubernetes.Clientset, metric *prometheus.GaugeVec, nodeName string, logger *zap.SugaredLogger, runtimeConfig *RunConfiguration)

func ProcessSingleNodeMetrics

func ProcessSingleNodeMetrics(ctx context.Context, clientset *kubernetes.Clientset, logger *zap.SugaredLogger, metric *prometheus.GaugeVec, nodeName string) (*[]Pod, error)

Gets Node statistics from API, parsing it and register prometheus metric for each pod on the node

func RegisterPrometheusMetrics

func RegisterPrometheusMetrics(ctx context.Context) *prometheus.GaugeVec

func UpEndpointHandler

func UpEndpointHandler(w http.ResponseWriter, r *http.Request)

Types

type Node

type Node struct {
	Node struct {
		NodeName string `json:"nodeName"`
	} `json:"node"`
	Pods []PodRef `json:"pods"`
}

type Pod

type Pod struct {
	PodName string
}

type PodRef

type PodRef struct {
	PodRef struct {
		Name      string `json:"name"`
		Namespace string `json:"namespace"`
	} `json:"podRef"`
	EphemeralStorage struct {
		Usedbytes any `json:"usedBytes"`
	} `json:"ephemeral-storage"`
}

type RunConfiguration

type RunConfiguration struct {
	KubeConfig      string
	Port            int
	RefreshInterval int
	PlainLogs       bool
}

func ParseInputArguments

func ParseInputArguments() (*RunConfiguration, error)