package kubernetes
import (
"context"
"errors"
"fmt"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/metrics/pkg/apis/metrics"
metricsv1beta1api "k8s.io/metrics/pkg/apis/metrics/v1beta1"
)
func (k *Kubernetes) NodesLog(ctx context.Context, name string, query string, tailLines int64) (string, error) {
// Use the node proxy API to access logs from the kubelet
// https://kubernetes.io/docs/concepts/cluster-administration/system-logs/#log-query
// Common log paths:
// - /var/log/kubelet.log - kubelet logs
// - /var/log/kube-proxy.log - kube-proxy logs
// - /var/log/containers/ - container logs
req, err := k.AccessControlClientset().NodesLogs(ctx, name)
if err != nil {
return "", err
}
req.Param("query", query)
// Query parameters for tail
if tailLines > 0 {
req.Param("tailLines", fmt.Sprintf("%d", tailLines))
}
result := req.Do(ctx)
if result.Error() != nil {
return "", fmt.Errorf("failed to get node logs: %w", result.Error())
}
rawData, err := result.Raw()
if err != nil {
return "", fmt.Errorf("failed to read node log response: %w", err)
}
return string(rawData), nil
}
func (k *Kubernetes) NodesStatsSummary(ctx context.Context, name string) (string, error) {
// Use the node proxy API to access stats summary from the kubelet
// https://kubernetes.io/docs/reference/instrumentation/understand-psi-metrics/
// This endpoint provides CPU, memory, filesystem, and network statistics
req, err := k.AccessControlClientset().NodesStatsSummary(ctx, name)
if err != nil {
return "", err
}
result := req.Do(ctx)
if result.Error() != nil {
return "", fmt.Errorf("failed to get node stats summary: %w", result.Error())
}
rawData, err := result.Raw()
if err != nil {
return "", fmt.Errorf("failed to read node stats summary response: %w", err)
}
return string(rawData), nil
}
type NodesTopOptions struct {
metav1.ListOptions
Name string
}
func (k *Kubernetes) NodesTop(ctx context.Context, options NodesTopOptions) (*metrics.NodeMetricsList, error) {
// TODO, maybe move to mcp Tools setup and omit in case metrics aren't available in the target cluster
if !k.supportsGroupVersion(metrics.GroupName + "/" + metricsv1beta1api.SchemeGroupVersion.Version) {
return nil, errors.New("metrics API is not available")
}
return k.manager.accessControlClientSet.NodesMetricses(ctx, options.Name, options.ListOptions)
}
