@@ -39,6 +39,14 @@ func (a *AccessControlClientset) DiscoveryClient() discovery.DiscoveryInterface
3939 return a .discoveryClient
4040}
4141
42+ func (a * AccessControlClientset ) Nodes () (corev1.NodeInterface , error ) {
43+ gvk := & schema.GroupVersionKind {Group : "" , Version : "v1" , Kind : "Node" }
44+ if ! isAllowed (a .staticConfig , gvk ) {
45+ return nil , isNotAllowedError (gvk )
46+ }
47+ return a .delegate .CoreV1 ().Nodes (), nil
48+ }
49+
4250func (a * AccessControlClientset ) NodesLogs (ctx context.Context , name string ) (* rest.Request , error ) {
4351 gvk := & schema.GroupVersionKind {Group : "" , Version : "v1" , Kind : "Node" }
4452 if ! isAllowed (a .staticConfig , gvk ) {
@@ -55,6 +63,29 @@ func (a *AccessControlClientset) NodesLogs(ctx context.Context, name string) (*r
5563 AbsPath (url ... ), nil
5664}
5765
66+ func (a * AccessControlClientset ) NodesMetricses (ctx context.Context , name string , listOptions metav1.ListOptions ) (* metrics.NodeMetricsList , error ) {
67+ gvk := & schema.GroupVersionKind {Group : metrics .GroupName , Version : metricsv1beta1api .SchemeGroupVersion .Version , Kind : "NodeMetrics" }
68+ if ! isAllowed (a .staticConfig , gvk ) {
69+ return nil , isNotAllowedError (gvk )
70+ }
71+ versionedMetrics := & metricsv1beta1api.NodeMetricsList {}
72+ var err error
73+ if name != "" {
74+ m , err := a .metricsV1beta1 .NodeMetricses ().Get (ctx , name , metav1.GetOptions {})
75+ if err != nil {
76+ return nil , fmt .Errorf ("failed to get metrics for node %s: %w" , name , err )
77+ }
78+ versionedMetrics .Items = []metricsv1beta1api.NodeMetrics {* m }
79+ } else {
80+ versionedMetrics , err = a .metricsV1beta1 .NodeMetricses ().List (ctx , listOptions )
81+ if err != nil {
82+ return nil , fmt .Errorf ("failed to list node metrics: %w" , err )
83+ }
84+ }
85+ convertedMetrics := & metrics.NodeMetricsList {}
86+ return convertedMetrics , metricsv1beta1api .Convert_v1beta1_NodeMetricsList_To_metrics_NodeMetricsList (versionedMetrics , convertedMetrics , nil )
87+ }
88+
5889func (a * AccessControlClientset ) NodesStatsSummary (ctx context.Context , name string ) (* rest.Request , error ) {
5990 gvk := & schema.GroupVersionKind {Group : "" , Version : "v1" , Kind : "Node" }
6091 if ! isAllowed (a .staticConfig , gvk ) {
0 commit comments