| /* |
| Copyright 2017 The Kubernetes Authors. |
| |
| Licensed under the Apache License, Version 2.0 (the "License"); |
| you may not use this file except in compliance with the License. |
| You may obtain a copy of the License at |
| |
| http://www.apache.org/licenses/LICENSE-2.0 |
| |
| Unless required by applicable law or agreed to in writing, software |
| distributed under the License is distributed on an "AS IS" BASIS, |
| WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| See the License for the specific language governing permissions and |
| limitations under the License. |
| */ |
| |
| package internalversion |
| |
| import ( |
| "bytes" |
| "fmt" |
| "net" |
| "sort" |
| "strconv" |
| "strings" |
| "time" |
| |
| apiserverinternalv1alpha1 "k8s.io/api/apiserverinternal/v1alpha1" |
| appsv1beta1 "k8s.io/api/apps/v1beta1" |
| autoscalingv1 "k8s.io/api/autoscaling/v1" |
| autoscalingv2beta1 "k8s.io/api/autoscaling/v2beta1" |
| batchv1 "k8s.io/api/batch/v1" |
| batchv1beta1 "k8s.io/api/batch/v1beta1" |
| certificatesv1alpha1 "k8s.io/api/certificates/v1alpha1" |
| certificatesv1beta1 "k8s.io/api/certificates/v1beta1" |
| coordinationv1 "k8s.io/api/coordination/v1" |
| apiv1 "k8s.io/api/core/v1" |
| discoveryv1beta1 "k8s.io/api/discovery/v1beta1" |
| extensionsv1beta1 "k8s.io/api/extensions/v1beta1" |
| flowcontrolv1 "k8s.io/api/flowcontrol/v1" |
| networkingv1alpha1 "k8s.io/api/networking/v1alpha1" |
| rbacv1beta1 "k8s.io/api/rbac/v1beta1" |
| resourcev1alpha2 "k8s.io/api/resource/v1alpha2" |
| schedulingv1 "k8s.io/api/scheduling/v1" |
| storagev1 "k8s.io/api/storage/v1" |
| storagev1alpha1 "k8s.io/api/storage/v1alpha1" |
| metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" |
| "k8s.io/apimachinery/pkg/labels" |
| "k8s.io/apimachinery/pkg/runtime" |
| "k8s.io/apimachinery/pkg/runtime/schema" |
| "k8s.io/apimachinery/pkg/util/duration" |
| "k8s.io/apimachinery/pkg/util/sets" |
| "k8s.io/client-go/util/certificate/csr" |
| "k8s.io/kubernetes/pkg/apis/admissionregistration" |
| "k8s.io/kubernetes/pkg/apis/apiserverinternal" |
| "k8s.io/kubernetes/pkg/apis/apps" |
| "k8s.io/kubernetes/pkg/apis/autoscaling" |
| "k8s.io/kubernetes/pkg/apis/batch" |
| "k8s.io/kubernetes/pkg/apis/certificates" |
| "k8s.io/kubernetes/pkg/apis/coordination" |
| api "k8s.io/kubernetes/pkg/apis/core" |
| "k8s.io/kubernetes/pkg/apis/core/helper" |
| "k8s.io/kubernetes/pkg/apis/discovery" |
| "k8s.io/kubernetes/pkg/apis/flowcontrol" |
| apihelpers "k8s.io/kubernetes/pkg/apis/flowcontrol/util" |
| "k8s.io/kubernetes/pkg/apis/networking" |
| nodeapi "k8s.io/kubernetes/pkg/apis/node" |
| "k8s.io/kubernetes/pkg/apis/policy" |
| "k8s.io/kubernetes/pkg/apis/rbac" |
| "k8s.io/kubernetes/pkg/apis/resource" |
| "k8s.io/kubernetes/pkg/apis/scheduling" |
| "k8s.io/kubernetes/pkg/apis/storage" |
| storageutil "k8s.io/kubernetes/pkg/apis/storage/util" |
| svmv1alpha1 "k8s.io/kubernetes/pkg/apis/storagemigration" |
| "k8s.io/kubernetes/pkg/printers" |
| "k8s.io/kubernetes/pkg/util/node" |
| ) |
| |
| const ( |
| loadBalancerWidth = 16 |
| |
| // labelNodeRolePrefix is a label prefix for node roles |
| // It's copied over to here until it's merged in core: https://github.com/kubernetes/kubernetes/pull/39112 |
| labelNodeRolePrefix = "node-role.kubernetes.io/" |
| |
| // nodeLabelRole specifies the role of a node |
| nodeLabelRole = "kubernetes.io/role" |
| ) |
| |
| // AddHandlers adds print handlers for default Kubernetes types dealing with internal versions. |
| func AddHandlers(h printers.PrintHandler) { |
| podColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Ready", Type: "string", Description: "The aggregate readiness state of this pod for accepting traffic."}, |
| {Name: "Status", Type: "string", Description: "The aggregate status of the containers in this pod."}, |
| {Name: "Restarts", Type: "string", Description: "The number of times the containers in this pod have been restarted and when the last container in this pod has restarted."}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| {Name: "IP", Type: "string", Priority: 1, Description: apiv1.PodStatus{}.SwaggerDoc()["podIP"]}, |
| {Name: "Node", Type: "string", Priority: 1, Description: apiv1.PodSpec{}.SwaggerDoc()["nodeName"]}, |
| {Name: "Nominated Node", Type: "string", Priority: 1, Description: apiv1.PodStatus{}.SwaggerDoc()["nominatedNodeName"]}, |
| {Name: "Readiness Gates", Type: "string", Priority: 1, Description: apiv1.PodSpec{}.SwaggerDoc()["readinessGates"]}, |
| } |
| |
| // Errors are suppressed as TableHandler already logs internally |
| _ = h.TableHandler(podColumnDefinitions, printPodList) |
| _ = h.TableHandler(podColumnDefinitions, printPod) |
| |
| podTemplateColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Containers", Type: "string", Description: "Names of each container in the template."}, |
| {Name: "Images", Type: "string", Description: "Images referenced by each container in the template."}, |
| {Name: "Pod Labels", Type: "string", Description: "The labels for the pod template."}, |
| } |
| _ = h.TableHandler(podTemplateColumnDefinitions, printPodTemplate) |
| _ = h.TableHandler(podTemplateColumnDefinitions, printPodTemplateList) |
| |
| podDisruptionBudgetColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Min Available", Type: "string", Description: "The minimum number of pods that must be available."}, |
| {Name: "Max Unavailable", Type: "string", Description: "The maximum number of pods that may be unavailable."}, |
| {Name: "Allowed Disruptions", Type: "integer", Description: "Calculated number of pods that may be disrupted at this time."}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| _ = h.TableHandler(podDisruptionBudgetColumnDefinitions, printPodDisruptionBudget) |
| _ = h.TableHandler(podDisruptionBudgetColumnDefinitions, printPodDisruptionBudgetList) |
| |
| replicationControllerColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Desired", Type: "integer", Description: apiv1.ReplicationControllerSpec{}.SwaggerDoc()["replicas"]}, |
| {Name: "Current", Type: "integer", Description: apiv1.ReplicationControllerStatus{}.SwaggerDoc()["replicas"]}, |
| {Name: "Ready", Type: "integer", Description: apiv1.ReplicationControllerStatus{}.SwaggerDoc()["readyReplicas"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| {Name: "Containers", Type: "string", Priority: 1, Description: "Names of each container in the template."}, |
| {Name: "Images", Type: "string", Priority: 1, Description: "Images referenced by each container in the template."}, |
| {Name: "Selector", Type: "string", Priority: 1, Description: apiv1.ReplicationControllerSpec{}.SwaggerDoc()["selector"]}, |
| } |
| _ = h.TableHandler(replicationControllerColumnDefinitions, printReplicationController) |
| _ = h.TableHandler(replicationControllerColumnDefinitions, printReplicationControllerList) |
| |
| replicaSetColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Desired", Type: "integer", Description: extensionsv1beta1.ReplicaSetSpec{}.SwaggerDoc()["replicas"]}, |
| {Name: "Current", Type: "integer", Description: extensionsv1beta1.ReplicaSetStatus{}.SwaggerDoc()["replicas"]}, |
| {Name: "Ready", Type: "integer", Description: extensionsv1beta1.ReplicaSetStatus{}.SwaggerDoc()["readyReplicas"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| {Name: "Containers", Type: "string", Priority: 1, Description: "Names of each container in the template."}, |
| {Name: "Images", Type: "string", Priority: 1, Description: "Images referenced by each container in the template."}, |
| {Name: "Selector", Type: "string", Priority: 1, Description: extensionsv1beta1.ReplicaSetSpec{}.SwaggerDoc()["selector"]}, |
| } |
| _ = h.TableHandler(replicaSetColumnDefinitions, printReplicaSet) |
| _ = h.TableHandler(replicaSetColumnDefinitions, printReplicaSetList) |
| |
| daemonSetColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Desired", Type: "integer", Description: extensionsv1beta1.DaemonSetStatus{}.SwaggerDoc()["desiredNumberScheduled"]}, |
| {Name: "Current", Type: "integer", Description: extensionsv1beta1.DaemonSetStatus{}.SwaggerDoc()["currentNumberScheduled"]}, |
| {Name: "Ready", Type: "integer", Description: extensionsv1beta1.DaemonSetStatus{}.SwaggerDoc()["numberReady"]}, |
| {Name: "Up-to-date", Type: "integer", Description: extensionsv1beta1.DaemonSetStatus{}.SwaggerDoc()["updatedNumberScheduled"]}, |
| {Name: "Available", Type: "integer", Description: extensionsv1beta1.DaemonSetStatus{}.SwaggerDoc()["numberAvailable"]}, |
| {Name: "Node Selector", Type: "string", Description: apiv1.PodSpec{}.SwaggerDoc()["nodeSelector"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| {Name: "Containers", Type: "string", Priority: 1, Description: "Names of each container in the template."}, |
| {Name: "Images", Type: "string", Priority: 1, Description: "Images referenced by each container in the template."}, |
| {Name: "Selector", Type: "string", Priority: 1, Description: extensionsv1beta1.DaemonSetSpec{}.SwaggerDoc()["selector"]}, |
| } |
| _ = h.TableHandler(daemonSetColumnDefinitions, printDaemonSet) |
| _ = h.TableHandler(daemonSetColumnDefinitions, printDaemonSetList) |
| |
| jobColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Status", Type: "string", Description: "Status of the job."}, |
| {Name: "Completions", Type: "string", Description: batchv1.JobStatus{}.SwaggerDoc()["succeeded"]}, |
| {Name: "Duration", Type: "string", Description: "Time required to complete the job."}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| {Name: "Containers", Type: "string", Priority: 1, Description: "Names of each container in the template."}, |
| {Name: "Images", Type: "string", Priority: 1, Description: "Images referenced by each container in the template."}, |
| {Name: "Selector", Type: "string", Priority: 1, Description: batchv1.JobSpec{}.SwaggerDoc()["selector"]}, |
| } |
| _ = h.TableHandler(jobColumnDefinitions, printJob) |
| _ = h.TableHandler(jobColumnDefinitions, printJobList) |
| |
| cronJobColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Schedule", Type: "string", Description: batchv1beta1.CronJobSpec{}.SwaggerDoc()["schedule"]}, |
| {Name: "Timezone", Type: "string", Description: batchv1beta1.CronJobSpec{}.SwaggerDoc()["timeZone"]}, |
| {Name: "Suspend", Type: "boolean", Description: batchv1beta1.CronJobSpec{}.SwaggerDoc()["suspend"]}, |
| {Name: "Active", Type: "integer", Description: batchv1beta1.CronJobStatus{}.SwaggerDoc()["active"]}, |
| {Name: "Last Schedule", Type: "string", Description: batchv1beta1.CronJobStatus{}.SwaggerDoc()["lastScheduleTime"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| {Name: "Containers", Type: "string", Priority: 1, Description: "Names of each container in the template."}, |
| {Name: "Images", Type: "string", Priority: 1, Description: "Images referenced by each container in the template."}, |
| {Name: "Selector", Type: "string", Priority: 1, Description: batchv1.JobSpec{}.SwaggerDoc()["selector"]}, |
| } |
| _ = h.TableHandler(cronJobColumnDefinitions, printCronJob) |
| _ = h.TableHandler(cronJobColumnDefinitions, printCronJobList) |
| |
| serviceColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Type", Type: "string", Description: apiv1.ServiceSpec{}.SwaggerDoc()["type"]}, |
| {Name: "Cluster-IP", Type: "string", Description: apiv1.ServiceSpec{}.SwaggerDoc()["clusterIP"]}, |
| {Name: "External-IP", Type: "string", Description: apiv1.ServiceSpec{}.SwaggerDoc()["externalIPs"]}, |
| {Name: "Port(s)", Type: "string", Description: apiv1.ServiceSpec{}.SwaggerDoc()["ports"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| {Name: "Selector", Type: "string", Priority: 1, Description: apiv1.ServiceSpec{}.SwaggerDoc()["selector"]}, |
| } |
| |
| _ = h.TableHandler(serviceColumnDefinitions, printService) |
| _ = h.TableHandler(serviceColumnDefinitions, printServiceList) |
| |
| ingressColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Class", Type: "string", Description: "The name of the IngressClass resource that should be used for additional configuration"}, |
| {Name: "Hosts", Type: "string", Description: "Hosts that incoming requests are matched against before the ingress rule"}, |
| {Name: "Address", Type: "string", Description: "Address is a list containing ingress points for the load-balancer"}, |
| {Name: "Ports", Type: "string", Description: "Ports of TLS configurations that open"}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| _ = h.TableHandler(ingressColumnDefinitions, printIngress) |
| _ = h.TableHandler(ingressColumnDefinitions, printIngressList) |
| |
| ingressClassColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Controller", Type: "string", Description: "Controller that is responsible for handling this class"}, |
| {Name: "Parameters", Type: "string", Description: "A reference to a resource with additional parameters"}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| _ = h.TableHandler(ingressClassColumnDefinitions, printIngressClass) |
| _ = h.TableHandler(ingressClassColumnDefinitions, printIngressClassList) |
| |
| statefulSetColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Ready", Type: "string", Description: "Number of the pod with ready state"}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| {Name: "Containers", Type: "string", Priority: 1, Description: "Names of each container in the template."}, |
| {Name: "Images", Type: "string", Priority: 1, Description: "Images referenced by each container in the template."}, |
| } |
| _ = h.TableHandler(statefulSetColumnDefinitions, printStatefulSet) |
| _ = h.TableHandler(statefulSetColumnDefinitions, printStatefulSetList) |
| |
| endpointColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Endpoints", Type: "string", Description: apiv1.Endpoints{}.SwaggerDoc()["subsets"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| _ = h.TableHandler(endpointColumnDefinitions, printEndpoints) |
| _ = h.TableHandler(endpointColumnDefinitions, printEndpointsList) |
| |
| nodeColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Status", Type: "string", Description: "The status of the node"}, |
| {Name: "Roles", Type: "string", Description: "The roles of the node"}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| {Name: "Version", Type: "string", Description: apiv1.NodeSystemInfo{}.SwaggerDoc()["kubeletVersion"]}, |
| {Name: "Internal-IP", Type: "string", Priority: 1, Description: apiv1.NodeStatus{}.SwaggerDoc()["addresses"]}, |
| {Name: "External-IP", Type: "string", Priority: 1, Description: apiv1.NodeStatus{}.SwaggerDoc()["addresses"]}, |
| {Name: "OS-Image", Type: "string", Priority: 1, Description: apiv1.NodeSystemInfo{}.SwaggerDoc()["osImage"]}, |
| {Name: "Kernel-Version", Type: "string", Priority: 1, Description: apiv1.NodeSystemInfo{}.SwaggerDoc()["kernelVersion"]}, |
| {Name: "Container-Runtime", Type: "string", Priority: 1, Description: apiv1.NodeSystemInfo{}.SwaggerDoc()["containerRuntimeVersion"]}, |
| } |
| |
| _ = h.TableHandler(nodeColumnDefinitions, printNode) |
| _ = h.TableHandler(nodeColumnDefinitions, printNodeList) |
| |
| eventColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Last Seen", Type: "string", Description: apiv1.Event{}.SwaggerDoc()["lastTimestamp"]}, |
| {Name: "Type", Type: "string", Description: apiv1.Event{}.SwaggerDoc()["type"]}, |
| {Name: "Reason", Type: "string", Description: apiv1.Event{}.SwaggerDoc()["reason"]}, |
| {Name: "Object", Type: "string", Description: apiv1.Event{}.SwaggerDoc()["involvedObject"]}, |
| {Name: "Subobject", Type: "string", Priority: 1, Description: apiv1.Event{}.InvolvedObject.SwaggerDoc()["fieldPath"]}, |
| {Name: "Source", Type: "string", Priority: 1, Description: apiv1.Event{}.SwaggerDoc()["source"]}, |
| {Name: "Message", Type: "string", Description: apiv1.Event{}.SwaggerDoc()["message"]}, |
| {Name: "First Seen", Type: "string", Priority: 1, Description: apiv1.Event{}.SwaggerDoc()["firstTimestamp"]}, |
| {Name: "Count", Type: "string", Priority: 1, Description: apiv1.Event{}.SwaggerDoc()["count"]}, |
| {Name: "Name", Type: "string", Priority: 1, Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| } |
| _ = h.TableHandler(eventColumnDefinitions, printEvent) |
| _ = h.TableHandler(eventColumnDefinitions, printEventList) |
| |
| namespaceColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Status", Type: "string", Description: "The status of the namespace"}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| _ = h.TableHandler(namespaceColumnDefinitions, printNamespace) |
| _ = h.TableHandler(namespaceColumnDefinitions, printNamespaceList) |
| |
| secretColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Type", Type: "string", Description: apiv1.Secret{}.SwaggerDoc()["type"]}, |
| {Name: "Data", Type: "string", Description: apiv1.Secret{}.SwaggerDoc()["data"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| _ = h.TableHandler(secretColumnDefinitions, printSecret) |
| _ = h.TableHandler(secretColumnDefinitions, printSecretList) |
| |
| serviceAccountColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Secrets", Type: "string", Description: apiv1.ServiceAccount{}.SwaggerDoc()["secrets"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| _ = h.TableHandler(serviceAccountColumnDefinitions, printServiceAccount) |
| _ = h.TableHandler(serviceAccountColumnDefinitions, printServiceAccountList) |
| |
| persistentVolumeColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Capacity", Type: "string", Description: apiv1.PersistentVolumeSpec{}.SwaggerDoc()["capacity"]}, |
| {Name: "Access Modes", Type: "string", Description: apiv1.PersistentVolumeSpec{}.SwaggerDoc()["accessModes"]}, |
| {Name: "Reclaim Policy", Type: "string", Description: apiv1.PersistentVolumeSpec{}.SwaggerDoc()["persistentVolumeReclaimPolicy"]}, |
| {Name: "Status", Type: "string", Description: apiv1.PersistentVolumeStatus{}.SwaggerDoc()["phase"]}, |
| {Name: "Claim", Type: "string", Description: apiv1.PersistentVolumeSpec{}.SwaggerDoc()["claimRef"]}, |
| {Name: "StorageClass", Type: "string", Description: "StorageClass of the pv"}, |
| {Name: "VolumeAttributesClass", Type: "string", Description: "VolumeAttributesClass of the pv"}, |
| {Name: "Reason", Type: "string", Description: apiv1.PersistentVolumeStatus{}.SwaggerDoc()["reason"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| {Name: "VolumeMode", Type: "string", Priority: 1, Description: apiv1.PersistentVolumeSpec{}.SwaggerDoc()["volumeMode"]}, |
| } |
| _ = h.TableHandler(persistentVolumeColumnDefinitions, printPersistentVolume) |
| _ = h.TableHandler(persistentVolumeColumnDefinitions, printPersistentVolumeList) |
| |
| persistentVolumeClaimColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Status", Type: "string", Description: apiv1.PersistentVolumeClaimStatus{}.SwaggerDoc()["phase"]}, |
| {Name: "Volume", Type: "string", Description: apiv1.PersistentVolumeClaimSpec{}.SwaggerDoc()["volumeName"]}, |
| {Name: "Capacity", Type: "string", Description: apiv1.PersistentVolumeClaimStatus{}.SwaggerDoc()["capacity"]}, |
| {Name: "Access Modes", Type: "string", Description: apiv1.PersistentVolumeClaimStatus{}.SwaggerDoc()["accessModes"]}, |
| {Name: "StorageClass", Type: "string", Description: "StorageClass of the pvc"}, |
| {Name: "VolumeAttributesClass", Type: "string", Description: "VolumeAttributesClass of the pvc"}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| {Name: "VolumeMode", Type: "string", Priority: 1, Description: apiv1.PersistentVolumeClaimSpec{}.SwaggerDoc()["volumeMode"]}, |
| } |
| _ = h.TableHandler(persistentVolumeClaimColumnDefinitions, printPersistentVolumeClaim) |
| _ = h.TableHandler(persistentVolumeClaimColumnDefinitions, printPersistentVolumeClaimList) |
| |
| componentStatusColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Status", Type: "string", Description: "Status of the component conditions"}, |
| {Name: "Message", Type: "string", Description: "Message of the component conditions"}, |
| {Name: "Error", Type: "string", Description: "Error of the component conditions"}, |
| } |
| _ = h.TableHandler(componentStatusColumnDefinitions, printComponentStatus) |
| _ = h.TableHandler(componentStatusColumnDefinitions, printComponentStatusList) |
| |
| deploymentColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Ready", Type: "string", Description: "Number of the pod with ready state"}, |
| {Name: "Up-to-date", Type: "string", Description: extensionsv1beta1.DeploymentStatus{}.SwaggerDoc()["updatedReplicas"]}, |
| {Name: "Available", Type: "string", Description: extensionsv1beta1.DeploymentStatus{}.SwaggerDoc()["availableReplicas"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| {Name: "Containers", Type: "string", Priority: 1, Description: "Names of each container in the template."}, |
| {Name: "Images", Type: "string", Priority: 1, Description: "Images referenced by each container in the template."}, |
| {Name: "Selector", Type: "string", Priority: 1, Description: extensionsv1beta1.DeploymentSpec{}.SwaggerDoc()["selector"]}, |
| } |
| _ = h.TableHandler(deploymentColumnDefinitions, printDeployment) |
| _ = h.TableHandler(deploymentColumnDefinitions, printDeploymentList) |
| |
| horizontalPodAutoscalerColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Reference", Type: "string", Description: autoscalingv2beta1.HorizontalPodAutoscalerSpec{}.SwaggerDoc()["scaleTargetRef"]}, |
| {Name: "Targets", Type: "string", Description: autoscalingv2beta1.HorizontalPodAutoscalerSpec{}.SwaggerDoc()["metrics"]}, |
| {Name: "MinPods", Type: "string", Description: autoscalingv2beta1.HorizontalPodAutoscalerSpec{}.SwaggerDoc()["minReplicas"]}, |
| {Name: "MaxPods", Type: "string", Description: autoscalingv2beta1.HorizontalPodAutoscalerSpec{}.SwaggerDoc()["maxReplicas"]}, |
| {Name: "Replicas", Type: "string", Description: autoscalingv2beta1.HorizontalPodAutoscalerStatus{}.SwaggerDoc()["currentReplicas"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| _ = h.TableHandler(horizontalPodAutoscalerColumnDefinitions, printHorizontalPodAutoscaler) |
| _ = h.TableHandler(horizontalPodAutoscalerColumnDefinitions, printHorizontalPodAutoscalerList) |
| |
| configMapColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Data", Type: "string", Description: apiv1.ConfigMap{}.SwaggerDoc()["data"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| _ = h.TableHandler(configMapColumnDefinitions, printConfigMap) |
| _ = h.TableHandler(configMapColumnDefinitions, printConfigMapList) |
| |
| networkPolicyColumnDefinitioins := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Pod-Selector", Type: "string", Description: extensionsv1beta1.NetworkPolicySpec{}.SwaggerDoc()["podSelector"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| _ = h.TableHandler(networkPolicyColumnDefinitioins, printNetworkPolicy) |
| _ = h.TableHandler(networkPolicyColumnDefinitioins, printNetworkPolicyList) |
| |
| roleBindingsColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Role", Type: "string", Description: rbacv1beta1.RoleBinding{}.SwaggerDoc()["roleRef"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| {Name: "Users", Type: "string", Priority: 1, Description: "Users in the roleBinding"}, |
| {Name: "Groups", Type: "string", Priority: 1, Description: "Groups in the roleBinding"}, |
| {Name: "ServiceAccounts", Type: "string", Priority: 1, Description: "ServiceAccounts in the roleBinding"}, |
| } |
| _ = h.TableHandler(roleBindingsColumnDefinitions, printRoleBinding) |
| _ = h.TableHandler(roleBindingsColumnDefinitions, printRoleBindingList) |
| |
| clusterRoleBindingsColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Role", Type: "string", Description: rbacv1beta1.ClusterRoleBinding{}.SwaggerDoc()["roleRef"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| {Name: "Users", Type: "string", Priority: 1, Description: "Users in the clusterRoleBinding"}, |
| {Name: "Groups", Type: "string", Priority: 1, Description: "Groups in the clusterRoleBinding"}, |
| {Name: "ServiceAccounts", Type: "string", Priority: 1, Description: "ServiceAccounts in the clusterRoleBinding"}, |
| } |
| _ = h.TableHandler(clusterRoleBindingsColumnDefinitions, printClusterRoleBinding) |
| _ = h.TableHandler(clusterRoleBindingsColumnDefinitions, printClusterRoleBindingList) |
| |
| certificateSigningRequestColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| {Name: "SignerName", Type: "string", Description: certificatesv1beta1.CertificateSigningRequestSpec{}.SwaggerDoc()["signerName"]}, |
| {Name: "Requestor", Type: "string", Description: certificatesv1beta1.CertificateSigningRequestSpec{}.SwaggerDoc()["request"]}, |
| {Name: "RequestedDuration", Type: "string", Description: certificatesv1beta1.CertificateSigningRequestSpec{}.SwaggerDoc()["expirationSeconds"]}, |
| {Name: "Condition", Type: "string", Description: certificatesv1beta1.CertificateSigningRequestStatus{}.SwaggerDoc()["conditions"]}, |
| } |
| _ = h.TableHandler(certificateSigningRequestColumnDefinitions, printCertificateSigningRequest) |
| _ = h.TableHandler(certificateSigningRequestColumnDefinitions, printCertificateSigningRequestList) |
| |
| clusterTrustBundleColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "SignerName", Type: "string", Description: certificatesv1alpha1.ClusterTrustBundleSpec{}.SwaggerDoc()["signerName"]}, |
| } |
| h.TableHandler(clusterTrustBundleColumnDefinitions, printClusterTrustBundle) |
| h.TableHandler(clusterTrustBundleColumnDefinitions, printClusterTrustBundleList) |
| |
| leaseColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Holder", Type: "string", Description: coordinationv1.LeaseSpec{}.SwaggerDoc()["holderIdentity"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| _ = h.TableHandler(leaseColumnDefinitions, printLease) |
| _ = h.TableHandler(leaseColumnDefinitions, printLeaseList) |
| |
| storageClassColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Provisioner", Type: "string", Description: storagev1.StorageClass{}.SwaggerDoc()["provisioner"]}, |
| {Name: "ReclaimPolicy", Type: "string", Description: storagev1.StorageClass{}.SwaggerDoc()["reclaimPolicy"]}, |
| {Name: "VolumeBindingMode", Type: "string", Description: storagev1.StorageClass{}.SwaggerDoc()["volumeBindingMode"]}, |
| {Name: "AllowVolumeExpansion", Type: "string", Description: storagev1.StorageClass{}.SwaggerDoc()["allowVolumeExpansion"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| |
| _ = h.TableHandler(storageClassColumnDefinitions, printStorageClass) |
| _ = h.TableHandler(storageClassColumnDefinitions, printStorageClassList) |
| |
| volumeAttributesClassColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "DriverName", Type: "string", Description: storagev1alpha1.VolumeAttributesClass{}.SwaggerDoc()["driverName"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| |
| _ = h.TableHandler(volumeAttributesClassColumnDefinitions, printVolumeAttributesClass) |
| _ = h.TableHandler(volumeAttributesClassColumnDefinitions, printVolumeAttributesClassList) |
| |
| statusColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Status", Type: "string", Description: metav1.Status{}.SwaggerDoc()["status"]}, |
| {Name: "Reason", Type: "string", Description: metav1.Status{}.SwaggerDoc()["reason"]}, |
| {Name: "Message", Type: "string", Description: metav1.Status{}.SwaggerDoc()["Message"]}, |
| } |
| |
| _ = h.TableHandler(statusColumnDefinitions, printStatus) |
| |
| controllerRevisionColumnDefinition := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Controller", Type: "string", Description: "Controller of the object"}, |
| {Name: "Revision", Type: "string", Description: appsv1beta1.ControllerRevision{}.SwaggerDoc()["revision"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| _ = h.TableHandler(controllerRevisionColumnDefinition, printControllerRevision) |
| _ = h.TableHandler(controllerRevisionColumnDefinition, printControllerRevisionList) |
| |
| resourceQuotaColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| {Name: "Request", Type: "string", Description: "Request represents a minimum amount of cpu/memory that a container may consume."}, |
| {Name: "Limit", Type: "string", Description: "Limits control the maximum amount of cpu/memory that a container may use independent of contention on the node."}, |
| } |
| _ = h.TableHandler(resourceQuotaColumnDefinitions, printResourceQuota) |
| _ = h.TableHandler(resourceQuotaColumnDefinitions, printResourceQuotaList) |
| |
| priorityClassColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Value", Type: "integer", Description: schedulingv1.PriorityClass{}.SwaggerDoc()["value"]}, |
| {Name: "Global-Default", Type: "boolean", Description: schedulingv1.PriorityClass{}.SwaggerDoc()["globalDefault"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| _ = h.TableHandler(priorityClassColumnDefinitions, printPriorityClass) |
| _ = h.TableHandler(priorityClassColumnDefinitions, printPriorityClassList) |
| |
| runtimeClassColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Handler", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["handler"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| _ = h.TableHandler(runtimeClassColumnDefinitions, printRuntimeClass) |
| _ = h.TableHandler(runtimeClassColumnDefinitions, printRuntimeClassList) |
| |
| volumeAttachmentColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Attacher", Type: "string", Format: "name", Description: storagev1.VolumeAttachmentSpec{}.SwaggerDoc()["attacher"]}, |
| {Name: "PV", Type: "string", Description: storagev1.VolumeAttachmentSource{}.SwaggerDoc()["persistentVolumeName"]}, |
| {Name: "Node", Type: "string", Description: storagev1.VolumeAttachmentSpec{}.SwaggerDoc()["nodeName"]}, |
| {Name: "Attached", Type: "boolean", Description: storagev1.VolumeAttachmentStatus{}.SwaggerDoc()["attached"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| _ = h.TableHandler(volumeAttachmentColumnDefinitions, printVolumeAttachment) |
| _ = h.TableHandler(volumeAttachmentColumnDefinitions, printVolumeAttachmentList) |
| |
| endpointSliceColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "AddressType", Type: "string", Description: discoveryv1beta1.EndpointSlice{}.SwaggerDoc()["addressType"]}, |
| {Name: "Ports", Type: "string", Description: discoveryv1beta1.EndpointSlice{}.SwaggerDoc()["ports"]}, |
| {Name: "Endpoints", Type: "string", Description: discoveryv1beta1.EndpointSlice{}.SwaggerDoc()["endpoints"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| _ = h.TableHandler(endpointSliceColumnDefinitions, printEndpointSlice) |
| _ = h.TableHandler(endpointSliceColumnDefinitions, printEndpointSliceList) |
| |
| csiNodeColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Drivers", Type: "integer", Description: "Drivers indicates the number of CSI drivers registered on the node"}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| _ = h.TableHandler(csiNodeColumnDefinitions, printCSINode) |
| _ = h.TableHandler(csiNodeColumnDefinitions, printCSINodeList) |
| |
| csiDriverColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "AttachRequired", Type: "boolean", Description: storagev1.CSIDriverSpec{}.SwaggerDoc()["attachRequired"]}, |
| {Name: "PodInfoOnMount", Type: "boolean", Description: storagev1.CSIDriverSpec{}.SwaggerDoc()["podInfoOnMount"]}, |
| {Name: "StorageCapacity", Type: "boolean", Description: storagev1.CSIDriverSpec{}.SwaggerDoc()["storageCapacity"]}, |
| } |
| csiDriverColumnDefinitions = append(csiDriverColumnDefinitions, []metav1.TableColumnDefinition{ |
| {Name: "TokenRequests", Type: "string", Description: storagev1.CSIDriverSpec{}.SwaggerDoc()["tokenRequests"]}, |
| {Name: "RequiresRepublish", Type: "boolean", Description: storagev1.CSIDriverSpec{}.SwaggerDoc()["requiresRepublish"]}, |
| }...) |
| |
| csiDriverColumnDefinitions = append(csiDriverColumnDefinitions, []metav1.TableColumnDefinition{ |
| {Name: "Modes", Type: "string", Description: storagev1.CSIDriverSpec{}.SwaggerDoc()["volumeLifecycleModes"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| }...) |
| _ = h.TableHandler(csiDriverColumnDefinitions, printCSIDriver) |
| _ = h.TableHandler(csiDriverColumnDefinitions, printCSIDriverList) |
| |
| csiStorageCapacityColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "StorageClassName", Type: "string", Description: storagev1.CSIStorageCapacity{}.SwaggerDoc()["storageClassName"]}, |
| {Name: "Capacity", Type: "string", Description: storagev1.CSIStorageCapacity{}.SwaggerDoc()["capacity"]}, |
| } |
| _ = h.TableHandler(csiStorageCapacityColumnDefinitions, printCSIStorageCapacity) |
| _ = h.TableHandler(csiStorageCapacityColumnDefinitions, printCSIStorageCapacityList) |
| |
| mutatingWebhookColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Webhooks", Type: "integer", Description: "Webhooks indicates the number of webhooks registered in this configuration"}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| _ = h.TableHandler(mutatingWebhookColumnDefinitions, printMutatingWebhook) |
| _ = h.TableHandler(mutatingWebhookColumnDefinitions, printMutatingWebhookList) |
| |
| validatingWebhookColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Webhooks", Type: "integer", Description: "Webhooks indicates the number of webhooks registered in this configuration"}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| _ = h.TableHandler(validatingWebhookColumnDefinitions, printValidatingWebhook) |
| _ = h.TableHandler(validatingWebhookColumnDefinitions, printValidatingWebhookList) |
| |
| validatingAdmissionPolicy := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Validations", Type: "integer", Description: "Validations indicates the number of validation rules defined in this configuration"}, |
| {Name: "ParamKind", Type: "string", Description: "ParamKind specifies the kind of resources used to parameterize this policy"}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| _ = h.TableHandler(validatingAdmissionPolicy, printValidatingAdmissionPolicy) |
| _ = h.TableHandler(validatingAdmissionPolicy, printValidatingAdmissionPolicyList) |
| |
| validatingAdmissionPolicyBinding := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "PolicyName", Type: "string", Description: "PolicyName indicates the policy definition which the policy binding binded to"}, |
| {Name: "ParamRef", Type: "string", Description: "ParamRef indicates the param resource which sets the configration param"}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| _ = h.TableHandler(validatingAdmissionPolicyBinding, printValidatingAdmissionPolicyBinding) |
| _ = h.TableHandler(validatingAdmissionPolicyBinding, printValidatingAdmissionPolicyBindingList) |
| |
| flowSchemaColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "PriorityLevel", Type: "string", Description: flowcontrolv1.PriorityLevelConfigurationReference{}.SwaggerDoc()["name"]}, |
| {Name: "MatchingPrecedence", Type: "string", Description: flowcontrolv1.FlowSchemaSpec{}.SwaggerDoc()["matchingPrecedence"]}, |
| {Name: "DistinguisherMethod", Type: "string", Description: flowcontrolv1.FlowSchemaSpec{}.SwaggerDoc()["distinguisherMethod"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| {Name: "MissingPL", Type: "string", Description: "references a broken or non-existent PriorityLevelConfiguration"}, |
| } |
| _ = h.TableHandler(flowSchemaColumnDefinitions, printFlowSchema) |
| _ = h.TableHandler(flowSchemaColumnDefinitions, printFlowSchemaList) |
| |
| priorityLevelColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Type", Type: "string", Description: flowcontrolv1.PriorityLevelConfigurationSpec{}.SwaggerDoc()["type"]}, |
| {Name: "NominalConcurrencyShares", Type: "string", Description: flowcontrolv1.LimitedPriorityLevelConfiguration{}.SwaggerDoc()["nominalConcurrencyShares"]}, |
| {Name: "Queues", Type: "string", Description: flowcontrolv1.QueuingConfiguration{}.SwaggerDoc()["queues"]}, |
| {Name: "HandSize", Type: "string", Description: flowcontrolv1.QueuingConfiguration{}.SwaggerDoc()["handSize"]}, |
| {Name: "QueueLengthLimit", Type: "string", Description: flowcontrolv1.QueuingConfiguration{}.SwaggerDoc()["queueLengthLimit"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| _ = h.TableHandler(priorityLevelColumnDefinitions, printPriorityLevelConfiguration) |
| _ = h.TableHandler(priorityLevelColumnDefinitions, printPriorityLevelConfigurationList) |
| |
| storageVersionColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "CommonEncodingVersion", Type: "string", Description: apiserverinternalv1alpha1.StorageVersionStatus{}.SwaggerDoc()["commonEncodingVersion"]}, |
| {Name: "StorageVersions", Type: "string", Description: apiserverinternalv1alpha1.StorageVersionStatus{}.SwaggerDoc()["storageVersions"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| _ = h.TableHandler(storageVersionColumnDefinitions, printStorageVersion) |
| _ = h.TableHandler(storageVersionColumnDefinitions, printStorageVersionList) |
| |
| scaleColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Desired", Type: "integer", Description: autoscalingv1.ScaleSpec{}.SwaggerDoc()["replicas"]}, |
| {Name: "Available", Type: "integer", Description: autoscalingv1.ScaleStatus{}.SwaggerDoc()["replicas"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| _ = h.TableHandler(scaleColumnDefinitions, printScale) |
| |
| resourceClassColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "DriverName", Type: "string", Description: resourcev1alpha2.ResourceClass{}.SwaggerDoc()["driverName"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| _ = h.TableHandler(resourceClassColumnDefinitions, printResourceClass) |
| _ = h.TableHandler(resourceClassColumnDefinitions, printResourceClassList) |
| |
| resourceClaimColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "ResourceClassName", Type: "string", Description: resourcev1alpha2.ResourceClaimSpec{}.SwaggerDoc()["resourceClassName"]}, |
| {Name: "AllocationMode", Type: "string", Description: resourcev1alpha2.ResourceClaimSpec{}.SwaggerDoc()["allocationMode"]}, |
| {Name: "State", Type: "string", Description: "A summary of the current state (allocated, pending, reserved, etc.)."}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| _ = h.TableHandler(resourceClaimColumnDefinitions, printResourceClaim) |
| _ = h.TableHandler(resourceClaimColumnDefinitions, printResourceClaimList) |
| |
| resourceClaimTemplateColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "ResourceClassName", Type: "string", Description: resourcev1alpha2.ResourceClaimSpec{}.SwaggerDoc()["resourceClassName"]}, |
| {Name: "AllocationMode", Type: "string", Description: resourcev1alpha2.ResourceClaimSpec{}.SwaggerDoc()["allocationMode"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| _ = h.TableHandler(resourceClaimTemplateColumnDefinitions, printResourceClaimTemplate) |
| _ = h.TableHandler(resourceClaimTemplateColumnDefinitions, printResourceClaimTemplateList) |
| |
| podSchedulingCtxColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "SelectedNode", Type: "string", Description: resourcev1alpha2.PodSchedulingContextSpec{}.SwaggerDoc()["selectedNode"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| _ = h.TableHandler(podSchedulingCtxColumnDefinitions, printPodSchedulingContext) |
| _ = h.TableHandler(podSchedulingCtxColumnDefinitions, printPodSchedulingContextList) |
| |
| resourceClaimParametersColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "GeneratedFrom", Type: "string", Description: resourcev1alpha2.ResourceClaimParameters{}.SwaggerDoc()["generatedFrom"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| _ = h.TableHandler(resourceClaimParametersColumnDefinitions, printResourceClaimParameters) |
| _ = h.TableHandler(resourceClaimParametersColumnDefinitions, printResourceClaimParametersList) |
| |
| resourceClassParametersColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "GeneratedFrom", Type: "string", Description: resourcev1alpha2.ResourceClassParameters{}.SwaggerDoc()["generatedFrom"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| _ = h.TableHandler(resourceClassParametersColumnDefinitions, printResourceClassParameters) |
| _ = h.TableHandler(resourceClassParametersColumnDefinitions, printResourceClassParametersList) |
| |
| nodeResourceCapacityColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Node", Type: "string", Description: resourcev1alpha2.ResourceSlice{}.SwaggerDoc()["nodeName"]}, |
| {Name: "Driver", Type: "string", Description: resourcev1alpha2.ResourceSlice{}.SwaggerDoc()["driverName"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| _ = h.TableHandler(nodeResourceCapacityColumnDefinitions, printResourceSlice) |
| _ = h.TableHandler(nodeResourceCapacityColumnDefinitions, printResourceSliceList) |
| |
| serviceCIDRColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "CIDRs", Type: "string", Description: networkingv1alpha1.ServiceCIDRSpec{}.SwaggerDoc()["cidrs"]}, |
| {Name: "Age", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["creationTimestamp"]}, |
| } |
| |
| _ = h.TableHandler(serviceCIDRColumnDefinitions, printServiceCIDR) |
| _ = h.TableHandler(serviceCIDRColumnDefinitions, printServiceCIDRList) |
| |
| ipAddressColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Format: "name", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "ParentRef", Type: "string", Description: networkingv1alpha1.IPAddressSpec{}.SwaggerDoc()["parentRef"]}, |
| } |
| |
| _ = h.TableHandler(ipAddressColumnDefinitions, printIPAddress) |
| _ = h.TableHandler(ipAddressColumnDefinitions, printIPAddressList) |
| |
| storageVersionMigrationColumnDefinitions := []metav1.TableColumnDefinition{ |
| {Name: "Name", Type: "string", Description: metav1.ObjectMeta{}.SwaggerDoc()["name"]}, |
| {Name: "Resource", Type: "string", Description: "Fully qualified resource to migrate"}, |
| } |
| _ = h.TableHandler(storageVersionMigrationColumnDefinitions, printStorageVersionMigration) |
| _ = h.TableHandler(storageVersionMigrationColumnDefinitions, printStorageVersionMigrationList) |
| } |
| |
| // Pass ports=nil for all ports. |
| func formatEndpoints(endpoints *api.Endpoints, ports sets.String) string { |
| if len(endpoints.Subsets) == 0 { |
| return "<none>" |
| } |
| list := []string{} |
| max := 3 |
| more := false |
| count := 0 |
| for i := range endpoints.Subsets { |
| ss := &endpoints.Subsets[i] |
| if len(ss.Ports) == 0 { |
| // It's possible to have headless services with no ports. |
| count += len(ss.Addresses) |
| for i := range ss.Addresses { |
| if len(list) == max { |
| more = true |
| // the next loop is redundant |
| break |
| } |
| list = append(list, ss.Addresses[i].IP) |
| } |
| // avoid nesting code too deeply |
| continue |
| } |
| |
| // "Normal" services with ports defined. |
| for i := range ss.Ports { |
| port := &ss.Ports[i] |
| if ports == nil || ports.Has(port.Name) { |
| count += len(ss.Addresses) |
| for i := range ss.Addresses { |
| if len(list) == max { |
| more = true |
| // the next loop is redundant |
| break |
| } |
| addr := &ss.Addresses[i] |
| hostPort := net.JoinHostPort(addr.IP, strconv.Itoa(int(port.Port))) |
| list = append(list, hostPort) |
| } |
| } |
| } |
| } |
| |
| ret := strings.Join(list, ",") |
| if more { |
| return fmt.Sprintf("%s + %d more...", ret, count-max) |
| } |
| return ret |
| } |
| |
| func formatDiscoveryPorts(ports []discovery.EndpointPort) string { |
| list := []string{} |
| max := 3 |
| more := false |
| count := 0 |
| for _, port := range ports { |
| if len(list) < max { |
| portNum := "*" |
| if port.Port != nil { |
| portNum = strconv.Itoa(int(*port.Port)) |
| } else if port.Name != nil { |
| portNum = *port.Name |
| } |
| list = append(list, portNum) |
| } else if len(list) == max { |
| more = true |
| } |
| count++ |
| } |
| return listWithMoreString(list, more, count, max) |
| } |
| |
| func formatDiscoveryEndpoints(endpoints []discovery.Endpoint) string { |
| list := []string{} |
| max := 3 |
| more := false |
| count := 0 |
| for _, endpoint := range endpoints { |
| for _, address := range endpoint.Addresses { |
| if len(list) < max { |
| list = append(list, address) |
| } else if len(list) == max { |
| more = true |
| } |
| count++ |
| } |
| } |
| return listWithMoreString(list, more, count, max) |
| } |
| |
| func listWithMoreString(list []string, more bool, count, max int) string { |
| ret := strings.Join(list, ",") |
| if more { |
| return fmt.Sprintf("%s + %d more...", ret, count-max) |
| } |
| if ret == "" { |
| ret = "<unset>" |
| } |
| return ret |
| } |
| |
| // translateMicroTimestampSince returns the elapsed time since timestamp in |
| // human-readable approximation. |
| func translateMicroTimestampSince(timestamp metav1.MicroTime) string { |
| if timestamp.IsZero() { |
| return "<unknown>" |
| } |
| |
| return duration.HumanDuration(time.Since(timestamp.Time)) |
| } |
| |
| // translateTimestampSince returns the elapsed time since timestamp in |
| // human-readable approximation. |
| func translateTimestampSince(timestamp metav1.Time) string { |
| if timestamp.IsZero() { |
| return "<unknown>" |
| } |
| |
| return duration.HumanDuration(time.Since(timestamp.Time)) |
| } |
| |
| // translateTimestampUntil returns the elapsed time until timestamp in |
| // human-readable approximation. |
| func translateTimestampUntil(timestamp metav1.Time) string { |
| if timestamp.IsZero() { |
| return "<unknown>" |
| } |
| |
| return duration.HumanDuration(time.Until(timestamp.Time)) |
| } |
| |
| var ( |
| podSuccessConditions = []metav1.TableRowCondition{{Type: metav1.RowCompleted, Status: metav1.ConditionTrue, Reason: string(api.PodSucceeded), Message: "The pod has completed successfully."}} |
| podFailedConditions = []metav1.TableRowCondition{{Type: metav1.RowCompleted, Status: metav1.ConditionTrue, Reason: string(api.PodFailed), Message: "The pod failed."}} |
| ) |
| |
| func printPodList(podList *api.PodList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(podList.Items)) |
| for i := range podList.Items { |
| r, err := printPod(&podList.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printPod(pod *api.Pod, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| restarts := 0 |
| restartableInitContainerRestarts := 0 |
| totalContainers := len(pod.Spec.Containers) |
| readyContainers := 0 |
| lastRestartDate := metav1.NewTime(time.Time{}) |
| lastRestartableInitContainerRestartDate := metav1.NewTime(time.Time{}) |
| |
| reason := string(pod.Status.Phase) |
| if pod.Status.Reason != "" { |
| reason = pod.Status.Reason |
| } |
| |
| // If the Pod carries {type:PodScheduled, reason:SchedulingGated}, set reason to 'SchedulingGated'. |
| for _, condition := range pod.Status.Conditions { |
| if condition.Type == api.PodScheduled && condition.Reason == apiv1.PodReasonSchedulingGated { |
| reason = apiv1.PodReasonSchedulingGated |
| } |
| } |
| |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: pod}, |
| } |
| |
| switch pod.Status.Phase { |
| case api.PodSucceeded: |
| row.Conditions = podSuccessConditions |
| case api.PodFailed: |
| row.Conditions = podFailedConditions |
| } |
| |
| initContainers := make(map[string]*api.Container) |
| for i := range pod.Spec.InitContainers { |
| initContainers[pod.Spec.InitContainers[i].Name] = &pod.Spec.InitContainers[i] |
| if isRestartableInitContainer(&pod.Spec.InitContainers[i]) { |
| totalContainers++ |
| } |
| } |
| |
| initializing := false |
| for i := range pod.Status.InitContainerStatuses { |
| container := pod.Status.InitContainerStatuses[i] |
| restarts += int(container.RestartCount) |
| if container.LastTerminationState.Terminated != nil { |
| terminatedDate := container.LastTerminationState.Terminated.FinishedAt |
| if lastRestartDate.Before(&terminatedDate) { |
| lastRestartDate = terminatedDate |
| } |
| } |
| if isRestartableInitContainer(initContainers[container.Name]) { |
| restartableInitContainerRestarts += int(container.RestartCount) |
| if container.LastTerminationState.Terminated != nil { |
| terminatedDate := container.LastTerminationState.Terminated.FinishedAt |
| if lastRestartableInitContainerRestartDate.Before(&terminatedDate) { |
| lastRestartableInitContainerRestartDate = terminatedDate |
| } |
| } |
| } |
| switch { |
| case container.State.Terminated != nil && container.State.Terminated.ExitCode == 0: |
| continue |
| case isRestartableInitContainer(initContainers[container.Name]) && |
| container.Started != nil && *container.Started: |
| if container.Ready { |
| readyContainers++ |
| } |
| continue |
| case container.State.Terminated != nil: |
| // initialization is failed |
| if len(container.State.Terminated.Reason) == 0 { |
| if container.State.Terminated.Signal != 0 { |
| reason = fmt.Sprintf("Init:Signal:%d", container.State.Terminated.Signal) |
| } else { |
| reason = fmt.Sprintf("Init:ExitCode:%d", container.State.Terminated.ExitCode) |
| } |
| } else { |
| reason = "Init:" + container.State.Terminated.Reason |
| } |
| initializing = true |
| case container.State.Waiting != nil && len(container.State.Waiting.Reason) > 0 && container.State.Waiting.Reason != "PodInitializing": |
| reason = "Init:" + container.State.Waiting.Reason |
| initializing = true |
| default: |
| reason = fmt.Sprintf("Init:%d/%d", i, len(pod.Spec.InitContainers)) |
| initializing = true |
| } |
| break |
| } |
| |
| if !initializing || isPodInitializedConditionTrue(&pod.Status) { |
| restarts = restartableInitContainerRestarts |
| lastRestartDate = lastRestartableInitContainerRestartDate |
| hasRunning := false |
| for i := len(pod.Status.ContainerStatuses) - 1; i >= 0; i-- { |
| container := pod.Status.ContainerStatuses[i] |
| |
| restarts += int(container.RestartCount) |
| if container.LastTerminationState.Terminated != nil { |
| terminatedDate := container.LastTerminationState.Terminated.FinishedAt |
| if lastRestartDate.Before(&terminatedDate) { |
| lastRestartDate = terminatedDate |
| } |
| } |
| if container.State.Waiting != nil && container.State.Waiting.Reason != "" { |
| reason = container.State.Waiting.Reason |
| } else if container.State.Terminated != nil && container.State.Terminated.Reason != "" { |
| reason = container.State.Terminated.Reason |
| } else if container.State.Terminated != nil && container.State.Terminated.Reason == "" { |
| if container.State.Terminated.Signal != 0 { |
| reason = fmt.Sprintf("Signal:%d", container.State.Terminated.Signal) |
| } else { |
| reason = fmt.Sprintf("ExitCode:%d", container.State.Terminated.ExitCode) |
| } |
| } else if container.Ready && container.State.Running != nil { |
| hasRunning = true |
| readyContainers++ |
| } |
| } |
| |
| // change pod status back to "Running" if there is at least one container still reporting as "Running" status |
| if reason == "Completed" && hasRunning { |
| if hasPodReadyCondition(pod.Status.Conditions) { |
| reason = "Running" |
| } else { |
| reason = "NotReady" |
| } |
| } |
| } |
| |
| if pod.DeletionTimestamp != nil && pod.Status.Reason == node.NodeUnreachablePodReason { |
| reason = "Unknown" |
| } else if pod.DeletionTimestamp != nil { |
| reason = "Terminating" |
| } |
| |
| restartsStr := strconv.Itoa(restarts) |
| if restarts != 0 && !lastRestartDate.IsZero() { |
| restartsStr = fmt.Sprintf("%d (%s ago)", restarts, translateTimestampSince(lastRestartDate)) |
| } |
| |
| row.Cells = append(row.Cells, pod.Name, fmt.Sprintf("%d/%d", readyContainers, totalContainers), reason, restartsStr, translateTimestampSince(pod.CreationTimestamp)) |
| if options.Wide { |
| nodeName := pod.Spec.NodeName |
| nominatedNodeName := pod.Status.NominatedNodeName |
| podIP := "" |
| if len(pod.Status.PodIPs) > 0 { |
| podIP = pod.Status.PodIPs[0].IP |
| } |
| |
| if podIP == "" { |
| podIP = "<none>" |
| } |
| if nodeName == "" { |
| nodeName = "<none>" |
| } |
| if nominatedNodeName == "" { |
| nominatedNodeName = "<none>" |
| } |
| |
| readinessGates := "<none>" |
| if len(pod.Spec.ReadinessGates) > 0 { |
| trueConditions := 0 |
| for _, readinessGate := range pod.Spec.ReadinessGates { |
| conditionType := readinessGate.ConditionType |
| for _, condition := range pod.Status.Conditions { |
| if condition.Type == conditionType { |
| if condition.Status == api.ConditionTrue { |
| trueConditions++ |
| } |
| break |
| } |
| } |
| } |
| readinessGates = fmt.Sprintf("%d/%d", trueConditions, len(pod.Spec.ReadinessGates)) |
| } |
| row.Cells = append(row.Cells, podIP, nodeName, nominatedNodeName, readinessGates) |
| } |
| |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func hasPodReadyCondition(conditions []api.PodCondition) bool { |
| for _, condition := range conditions { |
| if condition.Type == api.PodReady && condition.Status == api.ConditionTrue { |
| return true |
| } |
| } |
| return false |
| } |
| |
| func hasJobCondition(conditions []batch.JobCondition, conditionType batch.JobConditionType) bool { |
| for _, condition := range conditions { |
| if condition.Type == conditionType { |
| return condition.Status == api.ConditionTrue |
| } |
| } |
| return false |
| } |
| |
| func printPodTemplate(obj *api.PodTemplate, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| names, images := layoutContainerCells(obj.Template.Spec.Containers) |
| row.Cells = append(row.Cells, obj.Name, names, images, labels.FormatLabels(obj.Template.Labels)) |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printPodTemplateList(list *api.PodTemplateList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printPodTemplate(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printPodDisruptionBudget(obj *policy.PodDisruptionBudget, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| |
| var minAvailable string |
| var maxUnavailable string |
| if obj.Spec.MinAvailable != nil { |
| minAvailable = obj.Spec.MinAvailable.String() |
| } else { |
| minAvailable = "N/A" |
| } |
| |
| if obj.Spec.MaxUnavailable != nil { |
| maxUnavailable = obj.Spec.MaxUnavailable.String() |
| } else { |
| maxUnavailable = "N/A" |
| } |
| |
| row.Cells = append(row.Cells, obj.Name, minAvailable, maxUnavailable, int64(obj.Status.DisruptionsAllowed), translateTimestampSince(obj.CreationTimestamp)) |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printPodDisruptionBudgetList(list *policy.PodDisruptionBudgetList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printPodDisruptionBudget(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| // TODO(AdoHe): try to put wide output in a single method |
| func printReplicationController(obj *api.ReplicationController, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| |
| desiredReplicas := obj.Spec.Replicas |
| currentReplicas := obj.Status.Replicas |
| readyReplicas := obj.Status.ReadyReplicas |
| |
| row.Cells = append(row.Cells, obj.Name, int64(desiredReplicas), int64(currentReplicas), int64(readyReplicas), translateTimestampSince(obj.CreationTimestamp)) |
| if options.Wide { |
| names, images := layoutContainerCells(obj.Spec.Template.Spec.Containers) |
| row.Cells = append(row.Cells, names, images, labels.FormatLabels(obj.Spec.Selector)) |
| } |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printReplicationControllerList(list *api.ReplicationControllerList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printReplicationController(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printReplicaSet(obj *apps.ReplicaSet, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| |
| desiredReplicas := obj.Spec.Replicas |
| currentReplicas := obj.Status.Replicas |
| readyReplicas := obj.Status.ReadyReplicas |
| |
| row.Cells = append(row.Cells, obj.Name, int64(desiredReplicas), int64(currentReplicas), int64(readyReplicas), translateTimestampSince(obj.CreationTimestamp)) |
| if options.Wide { |
| names, images := layoutContainerCells(obj.Spec.Template.Spec.Containers) |
| row.Cells = append(row.Cells, names, images, metav1.FormatLabelSelector(obj.Spec.Selector)) |
| } |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printReplicaSetList(list *apps.ReplicaSetList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printReplicaSet(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printJob(obj *batch.Job, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| |
| var completions string |
| if obj.Spec.Completions != nil { |
| completions = fmt.Sprintf("%d/%d", obj.Status.Succeeded, *obj.Spec.Completions) |
| } else { |
| parallelism := int32(0) |
| if obj.Spec.Parallelism != nil { |
| parallelism = *obj.Spec.Parallelism |
| } |
| if parallelism > 1 { |
| completions = fmt.Sprintf("%d/1 of %d", obj.Status.Succeeded, parallelism) |
| } else { |
| completions = fmt.Sprintf("%d/1", obj.Status.Succeeded) |
| } |
| } |
| var jobDuration string |
| switch { |
| case obj.Status.StartTime == nil: |
| case obj.Status.CompletionTime == nil: |
| jobDuration = duration.HumanDuration(time.Since(obj.Status.StartTime.Time)) |
| default: |
| jobDuration = duration.HumanDuration(obj.Status.CompletionTime.Sub(obj.Status.StartTime.Time)) |
| } |
| var status string |
| if hasJobCondition(obj.Status.Conditions, batch.JobComplete) { |
| status = "Complete" |
| } else if hasJobCondition(obj.Status.Conditions, batch.JobFailed) { |
| status = "Failed" |
| } else if obj.ObjectMeta.DeletionTimestamp != nil { |
| status = "Terminating" |
| } else if hasJobCondition(obj.Status.Conditions, batch.JobSuspended) { |
| status = "Suspended" |
| } else if hasJobCondition(obj.Status.Conditions, batch.JobFailureTarget) { |
| status = "FailureTarget" |
| } else { |
| status = "Running" |
| } |
| |
| row.Cells = append(row.Cells, obj.Name, status, completions, jobDuration, translateTimestampSince(obj.CreationTimestamp)) |
| if options.Wide { |
| names, images := layoutContainerCells(obj.Spec.Template.Spec.Containers) |
| row.Cells = append(row.Cells, names, images, metav1.FormatLabelSelector(obj.Spec.Selector)) |
| } |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printJobList(list *batch.JobList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printJob(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printCronJob(obj *batch.CronJob, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| |
| lastScheduleTime := "<none>" |
| if obj.Status.LastScheduleTime != nil { |
| lastScheduleTime = translateTimestampSince(*obj.Status.LastScheduleTime) |
| } |
| |
| timeZone := "<none>" |
| if obj.Spec.TimeZone != nil { |
| timeZone = *obj.Spec.TimeZone |
| } |
| |
| row.Cells = append(row.Cells, obj.Name, obj.Spec.Schedule, timeZone, printBoolPtr(obj.Spec.Suspend), int64(len(obj.Status.Active)), lastScheduleTime, translateTimestampSince(obj.CreationTimestamp)) |
| if options.Wide { |
| names, images := layoutContainerCells(obj.Spec.JobTemplate.Spec.Template.Spec.Containers) |
| row.Cells = append(row.Cells, names, images, metav1.FormatLabelSelector(obj.Spec.JobTemplate.Spec.Selector)) |
| } |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printCronJobList(list *batch.CronJobList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printCronJob(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| // loadBalancerStatusStringer behaves mostly like a string interface and converts the given status to a string. |
| // `wide` indicates whether the returned value is meant for --o=wide output. If not, it's clipped to 16 bytes. |
| func loadBalancerStatusStringer(s api.LoadBalancerStatus, wide bool) string { |
| ingress := s.Ingress |
| result := sets.NewString() |
| for i := range ingress { |
| if ingress[i].IP != "" { |
| result.Insert(ingress[i].IP) |
| } else if ingress[i].Hostname != "" { |
| result.Insert(ingress[i].Hostname) |
| } |
| } |
| |
| r := strings.Join(result.List(), ",") |
| if !wide && len(r) > loadBalancerWidth { |
| r = r[0:(loadBalancerWidth-3)] + "..." |
| } |
| return r |
| } |
| |
| func getServiceExternalIP(svc *api.Service, wide bool) string { |
| switch svc.Spec.Type { |
| case api.ServiceTypeClusterIP: |
| if len(svc.Spec.ExternalIPs) > 0 { |
| return strings.Join(svc.Spec.ExternalIPs, ",") |
| } |
| return "<none>" |
| case api.ServiceTypeNodePort: |
| if len(svc.Spec.ExternalIPs) > 0 { |
| return strings.Join(svc.Spec.ExternalIPs, ",") |
| } |
| return "<none>" |
| case api.ServiceTypeLoadBalancer: |
| lbIps := loadBalancerStatusStringer(svc.Status.LoadBalancer, wide) |
| if len(svc.Spec.ExternalIPs) > 0 { |
| results := []string{} |
| if len(lbIps) > 0 { |
| results = append(results, strings.Split(lbIps, ",")...) |
| } |
| results = append(results, svc.Spec.ExternalIPs...) |
| return strings.Join(results, ",") |
| } |
| if len(lbIps) > 0 { |
| return lbIps |
| } |
| return "<pending>" |
| case api.ServiceTypeExternalName: |
| return svc.Spec.ExternalName |
| } |
| return "<unknown>" |
| } |
| |
| func makePortString(ports []api.ServicePort) string { |
| pieces := make([]string, len(ports)) |
| for ix := range ports { |
| port := &ports[ix] |
| pieces[ix] = fmt.Sprintf("%d/%s", port.Port, port.Protocol) |
| if port.NodePort > 0 { |
| pieces[ix] = fmt.Sprintf("%d:%d/%s", port.Port, port.NodePort, port.Protocol) |
| } |
| } |
| return strings.Join(pieces, ",") |
| } |
| |
| func printService(obj *api.Service, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| svcType := obj.Spec.Type |
| internalIP := "<none>" |
| if len(obj.Spec.ClusterIPs) > 0 { |
| internalIP = obj.Spec.ClusterIPs[0] |
| } |
| |
| externalIP := getServiceExternalIP(obj, options.Wide) |
| svcPorts := makePortString(obj.Spec.Ports) |
| if len(svcPorts) == 0 { |
| svcPorts = "<none>" |
| } |
| |
| row.Cells = append(row.Cells, obj.Name, string(svcType), internalIP, externalIP, svcPorts, translateTimestampSince(obj.CreationTimestamp)) |
| if options.Wide { |
| row.Cells = append(row.Cells, labels.FormatLabels(obj.Spec.Selector)) |
| } |
| |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printServiceList(list *api.ServiceList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printService(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func formatHosts(rules []networking.IngressRule) string { |
| list := []string{} |
| max := 3 |
| more := false |
| for _, rule := range rules { |
| if len(list) == max { |
| more = true |
| } |
| if !more && len(rule.Host) != 0 { |
| list = append(list, rule.Host) |
| } |
| } |
| if len(list) == 0 { |
| return "*" |
| } |
| ret := strings.Join(list, ",") |
| if more { |
| return fmt.Sprintf("%s + %d more...", ret, len(rules)-max) |
| } |
| return ret |
| } |
| |
| func formatPorts(tls []networking.IngressTLS) string { |
| if len(tls) != 0 { |
| return "80, 443" |
| } |
| return "80" |
| } |
| |
| func printIngress(obj *networking.Ingress, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| className := "<none>" |
| if obj.Spec.IngressClassName != nil { |
| className = *obj.Spec.IngressClassName |
| } |
| hosts := formatHosts(obj.Spec.Rules) |
| address := ingressLoadBalancerStatusStringer(obj.Status.LoadBalancer, options.Wide) |
| ports := formatPorts(obj.Spec.TLS) |
| createTime := translateTimestampSince(obj.CreationTimestamp) |
| row.Cells = append(row.Cells, obj.Name, className, hosts, address, ports, createTime) |
| return []metav1.TableRow{row}, nil |
| } |
| |
| // ingressLoadBalancerStatusStringer behaves mostly like a string interface and converts the given status to a string. |
| // `wide` indicates whether the returned value is meant for --o=wide output. If not, it's clipped to 16 bytes. |
| func ingressLoadBalancerStatusStringer(s networking.IngressLoadBalancerStatus, wide bool) string { |
| ingress := s.Ingress |
| result := sets.NewString() |
| for i := range ingress { |
| if ingress[i].IP != "" { |
| result.Insert(ingress[i].IP) |
| } else if ingress[i].Hostname != "" { |
| result.Insert(ingress[i].Hostname) |
| } |
| } |
| |
| r := strings.Join(result.List(), ",") |
| if !wide && len(r) > loadBalancerWidth { |
| r = r[0:(loadBalancerWidth-3)] + "..." |
| } |
| return r |
| } |
| |
| func printIngressList(list *networking.IngressList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printIngress(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printIngressClass(obj *networking.IngressClass, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| parameters := "<none>" |
| if obj.Spec.Parameters != nil { |
| parameters = obj.Spec.Parameters.Kind |
| if obj.Spec.Parameters.APIGroup != nil { |
| parameters = parameters + "." + *obj.Spec.Parameters.APIGroup |
| } |
| parameters = parameters + "/" + obj.Spec.Parameters.Name |
| } |
| createTime := translateTimestampSince(obj.CreationTimestamp) |
| row.Cells = append(row.Cells, obj.Name, obj.Spec.Controller, parameters, createTime) |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printIngressClassList(list *networking.IngressClassList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printIngressClass(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printStatefulSet(obj *apps.StatefulSet, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| desiredReplicas := obj.Spec.Replicas |
| readyReplicas := obj.Status.ReadyReplicas |
| createTime := translateTimestampSince(obj.CreationTimestamp) |
| row.Cells = append(row.Cells, obj.Name, fmt.Sprintf("%d/%d", int64(readyReplicas), int64(desiredReplicas)), createTime) |
| if options.Wide { |
| names, images := layoutContainerCells(obj.Spec.Template.Spec.Containers) |
| row.Cells = append(row.Cells, names, images) |
| } |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printStatefulSetList(list *apps.StatefulSetList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printStatefulSet(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printDaemonSet(obj *apps.DaemonSet, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| |
| desiredScheduled := obj.Status.DesiredNumberScheduled |
| currentScheduled := obj.Status.CurrentNumberScheduled |
| numberReady := obj.Status.NumberReady |
| numberUpdated := obj.Status.UpdatedNumberScheduled |
| numberAvailable := obj.Status.NumberAvailable |
| |
| row.Cells = append(row.Cells, obj.Name, int64(desiredScheduled), int64(currentScheduled), int64(numberReady), int64(numberUpdated), int64(numberAvailable), labels.FormatLabels(obj.Spec.Template.Spec.NodeSelector), translateTimestampSince(obj.CreationTimestamp)) |
| if options.Wide { |
| names, images := layoutContainerCells(obj.Spec.Template.Spec.Containers) |
| row.Cells = append(row.Cells, names, images, metav1.FormatLabelSelector(obj.Spec.Selector)) |
| } |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printDaemonSetList(list *apps.DaemonSetList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printDaemonSet(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printEndpoints(obj *api.Endpoints, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| row.Cells = append(row.Cells, obj.Name, formatEndpoints(obj, nil), translateTimestampSince(obj.CreationTimestamp)) |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printEndpointsList(list *api.EndpointsList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printEndpoints(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printEndpointSlice(obj *discovery.EndpointSlice, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| row.Cells = append(row.Cells, obj.Name, string(obj.AddressType), formatDiscoveryPorts(obj.Ports), formatDiscoveryEndpoints(obj.Endpoints), translateTimestampSince(obj.CreationTimestamp)) |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printEndpointSliceList(list *discovery.EndpointSliceList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printEndpointSlice(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printCSINode(obj *storage.CSINode, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| row.Cells = append(row.Cells, obj.Name, int64(len(obj.Spec.Drivers)), translateTimestampSince(obj.CreationTimestamp)) |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printCSINodeList(list *storage.CSINodeList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printCSINode(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printCSIDriver(obj *storage.CSIDriver, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| attachRequired := true |
| if obj.Spec.AttachRequired != nil { |
| attachRequired = *obj.Spec.AttachRequired |
| } |
| podInfoOnMount := false |
| if obj.Spec.PodInfoOnMount != nil { |
| podInfoOnMount = *obj.Spec.PodInfoOnMount |
| } |
| allModes := []string{} |
| for _, mode := range obj.Spec.VolumeLifecycleModes { |
| allModes = append(allModes, string(mode)) |
| } |
| modes := strings.Join(allModes, ",") |
| if len(modes) == 0 { |
| modes = "<none>" |
| } |
| |
| row.Cells = append(row.Cells, obj.Name, attachRequired, podInfoOnMount) |
| storageCapacity := false |
| if obj.Spec.StorageCapacity != nil { |
| storageCapacity = *obj.Spec.StorageCapacity |
| } |
| row.Cells = append(row.Cells, storageCapacity) |
| |
| tokenRequests := "<unset>" |
| if obj.Spec.TokenRequests != nil { |
| audiences := []string{} |
| for _, t := range obj.Spec.TokenRequests { |
| audiences = append(audiences, t.Audience) |
| } |
| tokenRequests = strings.Join(audiences, ",") |
| } |
| requiresRepublish := false |
| if obj.Spec.RequiresRepublish != nil { |
| requiresRepublish = *obj.Spec.RequiresRepublish |
| } |
| row.Cells = append(row.Cells, tokenRequests, requiresRepublish) |
| |
| row.Cells = append(row.Cells, modes, translateTimestampSince(obj.CreationTimestamp)) |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printCSIDriverList(list *storage.CSIDriverList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printCSIDriver(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printCSIStorageCapacity(obj *storage.CSIStorageCapacity, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| |
| capacity := "<unset>" |
| if obj.Capacity != nil { |
| capacity = obj.Capacity.String() |
| } |
| |
| row.Cells = append(row.Cells, obj.Name, obj.StorageClassName, capacity) |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printCSIStorageCapacityList(list *storage.CSIStorageCapacityList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printCSIStorageCapacity(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printMutatingWebhook(obj *admissionregistration.MutatingWebhookConfiguration, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| row.Cells = append(row.Cells, obj.Name, int64(len(obj.Webhooks)), translateTimestampSince(obj.CreationTimestamp)) |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printMutatingWebhookList(list *admissionregistration.MutatingWebhookConfigurationList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printMutatingWebhook(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printValidatingWebhook(obj *admissionregistration.ValidatingWebhookConfiguration, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| row.Cells = append(row.Cells, obj.Name, int64(len(obj.Webhooks)), translateTimestampSince(obj.CreationTimestamp)) |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printValidatingWebhookList(list *admissionregistration.ValidatingWebhookConfigurationList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printValidatingWebhook(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printValidatingAdmissionPolicy(obj *admissionregistration.ValidatingAdmissionPolicy, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| paramKind := "<unset>" |
| if obj.Spec.ParamKind != nil { |
| paramKind = obj.Spec.ParamKind.APIVersion + "/" + obj.Spec.ParamKind.Kind |
| } |
| row.Cells = append(row.Cells, obj.Name, int64(len(obj.Spec.Validations)), paramKind, translateTimestampSince(obj.CreationTimestamp)) |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printValidatingAdmissionPolicyList(list *admissionregistration.ValidatingAdmissionPolicyList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printValidatingAdmissionPolicy(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printValidatingAdmissionPolicyBinding(obj *admissionregistration.ValidatingAdmissionPolicyBinding, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| paramName := "<unset>" |
| if pr := obj.Spec.ParamRef; pr != nil { |
| if len(pr.Name) > 0 { |
| if pr.Namespace != "" { |
| paramName = pr.Namespace + "/" + pr.Name |
| } else { |
| // Can't tell from here if param is cluster-scoped, so all |
| // params without names get * namespace |
| paramName = "*/" + pr.Name |
| } |
| } else if pr.Selector != nil { |
| paramName = pr.Selector.String() |
| } |
| } |
| row.Cells = append(row.Cells, obj.Name, obj.Spec.PolicyName, paramName, translateTimestampSince(obj.CreationTimestamp)) |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printValidatingAdmissionPolicyBindingList(list *admissionregistration.ValidatingAdmissionPolicyBindingList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printValidatingAdmissionPolicyBinding(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printNamespace(obj *api.Namespace, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| row.Cells = append(row.Cells, obj.Name, string(obj.Status.Phase), translateTimestampSince(obj.CreationTimestamp)) |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printNamespaceList(list *api.NamespaceList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printNamespace(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printSecret(obj *api.Secret, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| row.Cells = append(row.Cells, obj.Name, string(obj.Type), int64(len(obj.Data)), translateTimestampSince(obj.CreationTimestamp)) |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printSecretList(list *api.SecretList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printSecret(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printServiceAccount(obj *api.ServiceAccount, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| row.Cells = append(row.Cells, obj.Name, int64(len(obj.Secrets)), translateTimestampSince(obj.CreationTimestamp)) |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printServiceAccountList(list *api.ServiceAccountList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printServiceAccount(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printNode(obj *api.Node, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| |
| conditionMap := make(map[api.NodeConditionType]*api.NodeCondition) |
| NodeAllConditions := []api.NodeConditionType{api.NodeReady} |
| for i := range obj.Status.Conditions { |
| cond := obj.Status.Conditions[i] |
| conditionMap[cond.Type] = &cond |
| } |
| var status []string |
| for _, validCondition := range NodeAllConditions { |
| if condition, ok := conditionMap[validCondition]; ok { |
| if condition.Status == api.ConditionTrue { |
| status = append(status, string(condition.Type)) |
| } else { |
| status = append(status, "Not"+string(condition.Type)) |
| } |
| } |
| } |
| if len(status) == 0 { |
| status = append(status, "Unknown") |
| } |
| if obj.Spec.Unschedulable { |
| status = append(status, "SchedulingDisabled") |
| } |
| |
| roles := strings.Join(findNodeRoles(obj), ",") |
| if len(roles) == 0 { |
| roles = "<none>" |
| } |
| |
| row.Cells = append(row.Cells, obj.Name, strings.Join(status, ","), roles, translateTimestampSince(obj.CreationTimestamp), obj.Status.NodeInfo.KubeletVersion) |
| if options.Wide { |
| osImage, kernelVersion, crVersion := obj.Status.NodeInfo.OSImage, obj.Status.NodeInfo.KernelVersion, obj.Status.NodeInfo.ContainerRuntimeVersion |
| if osImage == "" { |
| osImage = "<unknown>" |
| } |
| if kernelVersion == "" { |
| kernelVersion = "<unknown>" |
| } |
| if crVersion == "" { |
| crVersion = "<unknown>" |
| } |
| row.Cells = append(row.Cells, getNodeInternalIP(obj), getNodeExternalIP(obj), osImage, kernelVersion, crVersion) |
| } |
| |
| return []metav1.TableRow{row}, nil |
| } |
| |
| // Returns first external ip of the node or "<none>" if none is found. |
| func getNodeExternalIP(node *api.Node) string { |
| for _, address := range node.Status.Addresses { |
| if address.Type == api.NodeExternalIP { |
| return address.Address |
| } |
| } |
| |
| return "<none>" |
| } |
| |
| // Returns the internal IP of the node or "<none>" if none is found. |
| func getNodeInternalIP(node *api.Node) string { |
| for _, address := range node.Status.Addresses { |
| if address.Type == api.NodeInternalIP { |
| return address.Address |
| } |
| } |
| |
| return "<none>" |
| } |
| |
| // findNodeRoles returns the roles of a given node. |
| // The roles are determined by looking for: |
| // * a node-role.kubernetes.io/<role>="" label |
| // * a kubernetes.io/role="<role>" label |
| func findNodeRoles(node *api.Node) []string { |
| roles := sets.NewString() |
| for k, v := range node.Labels { |
| switch { |
| case strings.HasPrefix(k, labelNodeRolePrefix): |
| if role := strings.TrimPrefix(k, labelNodeRolePrefix); len(role) > 0 { |
| roles.Insert(role) |
| } |
| |
| case k == nodeLabelRole && v != "": |
| roles.Insert(v) |
| } |
| } |
| return roles.List() |
| } |
| |
| func printNodeList(list *api.NodeList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printNode(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printPersistentVolume(obj *api.PersistentVolume, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| |
| claimRefUID := "" |
| if obj.Spec.ClaimRef != nil { |
| claimRefUID += obj.Spec.ClaimRef.Namespace |
| claimRefUID += "/" |
| claimRefUID += obj.Spec.ClaimRef.Name |
| } |
| |
| modesStr := helper.GetAccessModesAsString(obj.Spec.AccessModes) |
| reclaimPolicyStr := string(obj.Spec.PersistentVolumeReclaimPolicy) |
| |
| aQty := obj.Spec.Capacity[api.ResourceStorage] |
| aSize := aQty.String() |
| |
| phase := obj.Status.Phase |
| if obj.ObjectMeta.DeletionTimestamp != nil { |
| phase = "Terminating" |
| } |
| volumeMode := "<unset>" |
| if obj.Spec.VolumeMode != nil { |
| volumeMode = string(*obj.Spec.VolumeMode) |
| } |
| |
| volumeAttributeClass := "<unset>" |
| if obj.Spec.VolumeAttributesClassName != nil { |
| volumeAttributeClass = *obj.Spec.VolumeAttributesClassName |
| } |
| |
| row.Cells = append(row.Cells, obj.Name, aSize, modesStr, reclaimPolicyStr, |
| string(phase), claimRefUID, helper.GetPersistentVolumeClass(obj), volumeAttributeClass, |
| obj.Status.Reason, translateTimestampSince(obj.CreationTimestamp), volumeMode) |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printPersistentVolumeList(list *api.PersistentVolumeList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printPersistentVolume(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printPersistentVolumeClaim(obj *api.PersistentVolumeClaim, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| |
| phase := obj.Status.Phase |
| if obj.ObjectMeta.DeletionTimestamp != nil { |
| phase = "Terminating" |
| } |
| |
| volumeAttributeClass := "<unset>" |
| storage := obj.Spec.Resources.Requests[api.ResourceStorage] |
| capacity := "" |
| accessModes := "" |
| volumeMode := "<unset>" |
| |
| if obj.Spec.VolumeAttributesClassName != nil { |
| volumeAttributeClass = *obj.Spec.VolumeAttributesClassName |
| } |
| |
| if obj.Spec.VolumeName != "" { |
| accessModes = helper.GetAccessModesAsString(obj.Status.AccessModes) |
| storage = obj.Status.Capacity[api.ResourceStorage] |
| capacity = storage.String() |
| } |
| |
| if obj.Spec.VolumeMode != nil { |
| volumeMode = string(*obj.Spec.VolumeMode) |
| } |
| |
| row.Cells = append(row.Cells, obj.Name, string(phase), obj.Spec.VolumeName, capacity, accessModes, |
| helper.GetPersistentVolumeClaimClass(obj), volumeAttributeClass, translateTimestampSince(obj.CreationTimestamp), volumeMode) |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printPersistentVolumeClaimList(list *api.PersistentVolumeClaimList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printPersistentVolumeClaim(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printEvent(obj *api.Event, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| |
| firstTimestamp := translateTimestampSince(obj.FirstTimestamp) |
| if obj.FirstTimestamp.IsZero() { |
| firstTimestamp = translateMicroTimestampSince(obj.EventTime) |
| } |
| |
| lastTimestamp := translateTimestampSince(obj.LastTimestamp) |
| if obj.LastTimestamp.IsZero() { |
| lastTimestamp = firstTimestamp |
| } |
| |
| count := obj.Count |
| if obj.Series != nil { |
| lastTimestamp = translateMicroTimestampSince(obj.Series.LastObservedTime) |
| count = obj.Series.Count |
| } else if count == 0 { |
| // Singleton events don't have a count set in the new API. |
| count = 1 |
| } |
| |
| var target string |
| if len(obj.InvolvedObject.Name) > 0 { |
| target = fmt.Sprintf("%s/%s", strings.ToLower(obj.InvolvedObject.Kind), obj.InvolvedObject.Name) |
| } else { |
| target = strings.ToLower(obj.InvolvedObject.Kind) |
| } |
| if options.Wide { |
| row.Cells = append(row.Cells, |
| lastTimestamp, |
| obj.Type, |
| obj.Reason, |
| target, |
| obj.InvolvedObject.FieldPath, |
| formatEventSource(obj.Source, obj.ReportingController, obj.ReportingInstance), |
| strings.TrimSpace(obj.Message), |
| firstTimestamp, |
| int64(count), |
| obj.Name, |
| ) |
| } else { |
| row.Cells = append(row.Cells, |
| lastTimestamp, |
| obj.Type, |
| obj.Reason, |
| target, |
| strings.TrimSpace(obj.Message), |
| ) |
| } |
| |
| return []metav1.TableRow{row}, nil |
| } |
| |
| // Sorts and prints the EventList in a human-friendly format. |
| func printEventList(list *api.EventList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printEvent(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printRoleBinding(obj *rbac.RoleBinding, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| |
| roleRef := fmt.Sprintf("%s/%s", obj.RoleRef.Kind, obj.RoleRef.Name) |
| row.Cells = append(row.Cells, obj.Name, roleRef, translateTimestampSince(obj.CreationTimestamp)) |
| if options.Wide { |
| users, groups, sas, _ := rbac.SubjectsStrings(obj.Subjects) |
| row.Cells = append(row.Cells, strings.Join(users, ", "), strings.Join(groups, ", "), strings.Join(sas, ", ")) |
| } |
| return []metav1.TableRow{row}, nil |
| } |
| |
| // Prints the RoleBinding in a human-friendly format. |
| func printRoleBindingList(list *rbac.RoleBindingList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printRoleBinding(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printClusterRoleBinding(obj *rbac.ClusterRoleBinding, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| |
| roleRef := fmt.Sprintf("%s/%s", obj.RoleRef.Kind, obj.RoleRef.Name) |
| row.Cells = append(row.Cells, obj.Name, roleRef, translateTimestampSince(obj.CreationTimestamp)) |
| if options.Wide { |
| users, groups, sas, _ := rbac.SubjectsStrings(obj.Subjects) |
| row.Cells = append(row.Cells, strings.Join(users, ", "), strings.Join(groups, ", "), strings.Join(sas, ", ")) |
| } |
| return []metav1.TableRow{row}, nil |
| } |
| |
| // Prints the ClusterRoleBinding in a human-friendly format. |
| func printClusterRoleBindingList(list *rbac.ClusterRoleBindingList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printClusterRoleBinding(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printCertificateSigningRequest(obj *certificates.CertificateSigningRequest, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| status := extractCSRStatus(obj) |
| signerName := "<none>" |
| if obj.Spec.SignerName != "" { |
| signerName = obj.Spec.SignerName |
| } |
| requestedDuration := "<none>" |
| if obj.Spec.ExpirationSeconds != nil { |
| requestedDuration = duration.HumanDuration(csr.ExpirationSecondsToDuration(*obj.Spec.ExpirationSeconds)) |
| } |
| row.Cells = append(row.Cells, obj.Name, translateTimestampSince(obj.CreationTimestamp), signerName, obj.Spec.Username, requestedDuration, status) |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func extractCSRStatus(csr *certificates.CertificateSigningRequest) string { |
| var approved, denied, failed bool |
| for _, c := range csr.Status.Conditions { |
| switch c.Type { |
| case certificates.CertificateApproved: |
| approved = true |
| case certificates.CertificateDenied: |
| denied = true |
| case certificates.CertificateFailed: |
| failed = true |
| } |
| } |
| var status string |
| // must be in order of presidence |
| if denied { |
| status += "Denied" |
| } else if approved { |
| status += "Approved" |
| } else { |
| status += "Pending" |
| } |
| if failed { |
| status += ",Failed" |
| } |
| if len(csr.Status.Certificate) > 0 { |
| status += ",Issued" |
| } |
| return status |
| } |
| |
| func printCertificateSigningRequestList(list *certificates.CertificateSigningRequestList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printCertificateSigningRequest(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printClusterTrustBundle(obj *certificates.ClusterTrustBundle, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| signerName := "<none>" |
| if obj.Spec.SignerName != "" { |
| signerName = obj.Spec.SignerName |
| } |
| row.Cells = append(row.Cells, obj.Name, signerName) |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printClusterTrustBundleList(list *certificates.ClusterTrustBundleList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printClusterTrustBundle(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printComponentStatus(obj *api.ComponentStatus, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| status := "Unknown" |
| message := "" |
| error := "" |
| for _, condition := range obj.Conditions { |
| if condition.Type == api.ComponentHealthy { |
| if condition.Status == api.ConditionTrue { |
| status = "Healthy" |
| } else { |
| status = "Unhealthy" |
| } |
| message = condition.Message |
| error = condition.Error |
| break |
| } |
| } |
| row.Cells = append(row.Cells, obj.Name, status, message, error) |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printComponentStatusList(list *api.ComponentStatusList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printComponentStatus(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printDeployment(obj *apps.Deployment, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| desiredReplicas := obj.Spec.Replicas |
| updatedReplicas := obj.Status.UpdatedReplicas |
| readyReplicas := obj.Status.ReadyReplicas |
| availableReplicas := obj.Status.AvailableReplicas |
| age := translateTimestampSince(obj.CreationTimestamp) |
| containers := obj.Spec.Template.Spec.Containers |
| selector, err := metav1.LabelSelectorAsSelector(obj.Spec.Selector) |
| selectorString := "" |
| if err != nil { |
| selectorString = "<invalid>" |
| } else { |
| selectorString = selector.String() |
| } |
| row.Cells = append(row.Cells, obj.Name, fmt.Sprintf("%d/%d", int64(readyReplicas), int64(desiredReplicas)), int64(updatedReplicas), int64(availableReplicas), age) |
| if options.Wide { |
| containers, images := layoutContainerCells(containers) |
| row.Cells = append(row.Cells, containers, images, selectorString) |
| } |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printDeploymentList(list *apps.DeploymentList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printDeployment(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func formatHPAMetrics(specs []autoscaling.MetricSpec, statuses []autoscaling.MetricStatus) string { |
| if len(specs) == 0 { |
| return "<none>" |
| } |
| list := []string{} |
| max := 2 |
| more := false |
| count := 0 |
| for i, spec := range specs { |
| switch spec.Type { |
| case autoscaling.ExternalMetricSourceType: |
| if spec.External.Target.AverageValue != nil { |
| current := "<unknown>" |
| if len(statuses) > i && statuses[i].External != nil && statuses[i].External.Current.AverageValue != nil { |
| current = statuses[i].External.Current.AverageValue.String() |
| } |
| list = append(list, fmt.Sprintf("%s/%s (avg)", current, spec.External.Target.AverageValue.String())) |
| } else { |
| current := "<unknown>" |
| if len(statuses) > i && statuses[i].External != nil { |
| current = statuses[i].External.Current.Value.String() |
| } |
| list = append(list, fmt.Sprintf("%s/%s", current, spec.External.Target.Value.String())) |
| } |
| case autoscaling.PodsMetricSourceType: |
| current := "<unknown>" |
| if len(statuses) > i && statuses[i].Pods != nil { |
| current = statuses[i].Pods.Current.AverageValue.String() |
| } |
| list = append(list, fmt.Sprintf("%s/%s", current, spec.Pods.Target.AverageValue.String())) |
| case autoscaling.ObjectMetricSourceType: |
| if spec.Object.Target.AverageValue != nil { |
| current := "<unknown>" |
| if len(statuses) > i && statuses[i].Object != nil && statuses[i].Object.Current.AverageValue != nil { |
| current = statuses[i].Object.Current.AverageValue.String() |
| } |
| list = append(list, fmt.Sprintf("%s/%s (avg)", current, spec.Object.Target.AverageValue.String())) |
| } else { |
| current := "<unknown>" |
| if len(statuses) > i && statuses[i].Object != nil { |
| current = statuses[i].Object.Current.Value.String() |
| } |
| list = append(list, fmt.Sprintf("%s/%s", current, spec.Object.Target.Value.String())) |
| } |
| case autoscaling.ResourceMetricSourceType: |
| if spec.Resource.Target.AverageValue != nil { |
| current := "<unknown>" |
| if len(statuses) > i && statuses[i].Resource != nil { |
| current = statuses[i].Resource.Current.AverageValue.String() |
| } |
| list = append(list, fmt.Sprintf("%s: %s/%s", spec.Resource.Name.String(), current, spec.Resource.Target.AverageValue.String())) |
| } else { |
| current := "<unknown>" |
| if len(statuses) > i && statuses[i].Resource != nil && statuses[i].Resource.Current.AverageUtilization != nil { |
| current = fmt.Sprintf("%d%%", *statuses[i].Resource.Current.AverageUtilization) |
| } |
| |
| target := "<auto>" |
| if spec.Resource.Target.AverageUtilization != nil { |
| target = fmt.Sprintf("%d%%", *spec.Resource.Target.AverageUtilization) |
| } |
| list = append(list, fmt.Sprintf("%s: %s/%s", spec.Resource.Name.String(), current, target)) |
| } |
| case autoscaling.ContainerResourceMetricSourceType: |
| if spec.ContainerResource.Target.AverageValue != nil { |
| current := "<unknown>" |
| if len(statuses) > i && statuses[i].ContainerResource != nil { |
| current = statuses[i].ContainerResource.Current.AverageValue.String() |
| } |
| list = append(list, fmt.Sprintf("%s: %s/%s", spec.ContainerResource.Name.String(), current, spec.ContainerResource.Target.AverageValue.String())) |
| } else { |
| current := "<unknown>" |
| if len(statuses) > i && statuses[i].ContainerResource != nil && statuses[i].ContainerResource.Current.AverageUtilization != nil { |
| current = fmt.Sprintf("%d%%", *statuses[i].ContainerResource.Current.AverageUtilization) |
| } |
| |
| target := "<auto>" |
| if spec.ContainerResource.Target.AverageUtilization != nil { |
| target = fmt.Sprintf("%d%%", *spec.ContainerResource.Target.AverageUtilization) |
| } |
| list = append(list, fmt.Sprintf("%s: %s/%s", spec.ContainerResource.Name.String(), current, target)) |
| } |
| default: |
| list = append(list, "<unknown type>") |
| } |
| |
| count++ |
| } |
| |
| if count > max { |
| list = list[:max] |
| more = true |
| } |
| |
| ret := strings.Join(list, ", ") |
| if more { |
| return fmt.Sprintf("%s + %d more...", ret, count-max) |
| } |
| return ret |
| } |
| |
| func printHorizontalPodAutoscaler(obj *autoscaling.HorizontalPodAutoscaler, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| |
| reference := fmt.Sprintf("%s/%s", |
| obj.Spec.ScaleTargetRef.Kind, |
| obj.Spec.ScaleTargetRef.Name) |
| minPods := "<unset>" |
| metrics := formatHPAMetrics(obj.Spec.Metrics, obj.Status.CurrentMetrics) |
| if obj.Spec.MinReplicas != nil { |
| minPods = fmt.Sprintf("%d", *obj.Spec.MinReplicas) |
| } |
| maxPods := obj.Spec.MaxReplicas |
| currentReplicas := obj.Status.CurrentReplicas |
| row.Cells = append(row.Cells, obj.Name, reference, metrics, minPods, int64(maxPods), int64(currentReplicas), translateTimestampSince(obj.CreationTimestamp)) |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printHorizontalPodAutoscalerList(list *autoscaling.HorizontalPodAutoscalerList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printHorizontalPodAutoscaler(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printConfigMap(obj *api.ConfigMap, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| row.Cells = append(row.Cells, obj.Name, int64(len(obj.Data)+len(obj.BinaryData)), translateTimestampSince(obj.CreationTimestamp)) |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printConfigMapList(list *api.ConfigMapList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printConfigMap(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printNetworkPolicy(obj *networking.NetworkPolicy, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| row.Cells = append(row.Cells, obj.Name, metav1.FormatLabelSelector(&obj.Spec.PodSelector), translateTimestampSince(obj.CreationTimestamp)) |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printNetworkPolicyList(list *networking.NetworkPolicyList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printNetworkPolicy(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printStorageClass(obj *storage.StorageClass, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| |
| name := obj.Name |
| if storageutil.IsDefaultAnnotation(obj.ObjectMeta) { |
| name += " (default)" |
| } |
| provtype := obj.Provisioner |
| reclaimPolicy := string(api.PersistentVolumeReclaimDelete) |
| if obj.ReclaimPolicy != nil { |
| reclaimPolicy = string(*obj.ReclaimPolicy) |
| } |
| |
| volumeBindingMode := string(storage.VolumeBindingImmediate) |
| if obj.VolumeBindingMode != nil { |
| volumeBindingMode = string(*obj.VolumeBindingMode) |
| } |
| |
| allowVolumeExpansion := false |
| if obj.AllowVolumeExpansion != nil { |
| allowVolumeExpansion = *obj.AllowVolumeExpansion |
| } |
| |
| row.Cells = append(row.Cells, name, provtype, reclaimPolicy, volumeBindingMode, allowVolumeExpansion, |
| translateTimestampSince(obj.CreationTimestamp)) |
| |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printStorageClassList(list *storage.StorageClassList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printStorageClass(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printVolumeAttributesClass(obj *storage.VolumeAttributesClass, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| |
| name := obj.Name |
| if storageutil.IsDefaultAnnotationForVolumeAttributesClass(obj.ObjectMeta) { |
| name += " (default)" |
| } |
| |
| row.Cells = append(row.Cells, name, obj.DriverName, translateTimestampSince(obj.CreationTimestamp)) |
| |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printVolumeAttributesClassList(list *storage.VolumeAttributesClassList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printVolumeAttributesClass(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printLease(obj *coordination.Lease, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| |
| var holderIdentity string |
| if obj.Spec.HolderIdentity != nil { |
| holderIdentity = *obj.Spec.HolderIdentity |
| } |
| row.Cells = append(row.Cells, obj.Name, holderIdentity, translateTimestampSince(obj.CreationTimestamp)) |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printLeaseList(list *coordination.LeaseList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printLease(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printStatus(obj *metav1.Status, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| row.Cells = append(row.Cells, obj.Status, string(obj.Reason), obj.Message) |
| |
| return []metav1.TableRow{row}, nil |
| } |
| |
| // Lay out all the containers on one line if use wide output. |
| func layoutContainerCells(containers []api.Container) (names string, images string) { |
| var namesBuffer bytes.Buffer |
| var imagesBuffer bytes.Buffer |
| |
| for i, container := range containers { |
| namesBuffer.WriteString(container.Name) |
| imagesBuffer.WriteString(container.Image) |
| if i != len(containers)-1 { |
| namesBuffer.WriteString(",") |
| imagesBuffer.WriteString(",") |
| } |
| } |
| return namesBuffer.String(), imagesBuffer.String() |
| } |
| |
| // formatEventSource formats EventSource as a comma separated string excluding Host when empty. |
| // It uses reportingController when Source.Component is empty and reportingInstance when Source.Host is empty |
| func formatEventSource(es api.EventSource, reportingController, reportingInstance string) string { |
| return formatEventSourceComponentInstance( |
| firstNonEmpty(es.Component, reportingController), |
| firstNonEmpty(es.Host, reportingInstance), |
| ) |
| } |
| |
| func firstNonEmpty(ss ...string) string { |
| for _, s := range ss { |
| if len(s) > 0 { |
| return s |
| } |
| } |
| return "" |
| } |
| |
| func formatEventSourceComponentInstance(component, instance string) string { |
| if len(instance) == 0 { |
| return component |
| } |
| return component + ", " + instance |
| } |
| |
| func printControllerRevision(obj *apps.ControllerRevision, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| |
| controllerRef := metav1.GetControllerOf(obj) |
| controllerName := "<none>" |
| if controllerRef != nil { |
| withKind := true |
| gv, err := schema.ParseGroupVersion(controllerRef.APIVersion) |
| if err != nil { |
| return nil, err |
| } |
| gvk := gv.WithKind(controllerRef.Kind) |
| controllerName = formatResourceName(gvk.GroupKind(), controllerRef.Name, withKind) |
| } |
| revision := obj.Revision |
| age := translateTimestampSince(obj.CreationTimestamp) |
| row.Cells = append(row.Cells, obj.Name, controllerName, revision, age) |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printControllerRevisionList(list *apps.ControllerRevisionList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printControllerRevision(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| // formatResourceName receives a resource kind, name, and boolean specifying |
| // whether or not to update the current name to "kind/name" |
| func formatResourceName(kind schema.GroupKind, name string, withKind bool) string { |
| if !withKind || kind.Empty() { |
| return name |
| } |
| |
| return strings.ToLower(kind.String()) + "/" + name |
| } |
| |
| func printResourceQuota(resourceQuota *api.ResourceQuota, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: resourceQuota}, |
| } |
| |
| resources := make([]api.ResourceName, 0, len(resourceQuota.Status.Hard)) |
| for resource := range resourceQuota.Status.Hard { |
| resources = append(resources, resource) |
| } |
| sort.Sort(SortableResourceNames(resources)) |
| |
| requestColumn := bytes.NewBuffer([]byte{}) |
| limitColumn := bytes.NewBuffer([]byte{}) |
| for i := range resources { |
| w := requestColumn |
| resource := resources[i] |
| usedQuantity := resourceQuota.Status.Used[resource] |
| hardQuantity := resourceQuota.Status.Hard[resource] |
| |
| // use limitColumn writer if a resource name prefixed with "limits" is found |
| if pieces := strings.Split(resource.String(), "."); len(pieces) > 1 && pieces[0] == "limits" { |
| w = limitColumn |
| } |
| |
| fmt.Fprintf(w, "%s: %s/%s, ", resource, usedQuantity.String(), hardQuantity.String()) |
| } |
| |
| age := translateTimestampSince(resourceQuota.CreationTimestamp) |
| row.Cells = append(row.Cells, resourceQuota.Name, age, strings.TrimSuffix(requestColumn.String(), ", "), strings.TrimSuffix(limitColumn.String(), ", ")) |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printResourceQuotaList(list *api.ResourceQuotaList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printResourceQuota(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printPriorityClass(obj *scheduling.PriorityClass, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| |
| name := obj.Name |
| value := obj.Value |
| globalDefault := obj.GlobalDefault |
| row.Cells = append(row.Cells, name, int64(value), globalDefault, translateTimestampSince(obj.CreationTimestamp)) |
| |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printPriorityClassList(list *scheduling.PriorityClassList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printPriorityClass(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printRuntimeClass(obj *nodeapi.RuntimeClass, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| |
| name := obj.Name |
| handler := obj.Handler |
| row.Cells = append(row.Cells, name, handler, translateTimestampSince(obj.CreationTimestamp)) |
| |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printRuntimeClassList(list *nodeapi.RuntimeClassList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printRuntimeClass(&list.Items[i], options) |
| |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printVolumeAttachment(obj *storage.VolumeAttachment, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| |
| name := obj.Name |
| pvName := "" |
| if obj.Spec.Source.PersistentVolumeName != nil { |
| pvName = *obj.Spec.Source.PersistentVolumeName |
| } |
| row.Cells = append(row.Cells, name, obj.Spec.Attacher, pvName, obj.Spec.NodeName, obj.Status.Attached, translateTimestampSince(obj.CreationTimestamp)) |
| |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printVolumeAttachmentList(list *storage.VolumeAttachmentList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printVolumeAttachment(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printFlowSchema(obj *flowcontrol.FlowSchema, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| |
| name := obj.Name |
| plName := obj.Spec.PriorityLevelConfiguration.Name |
| distinguisherMethod := "<none>" |
| if obj.Spec.DistinguisherMethod != nil { |
| distinguisherMethod = string(obj.Spec.DistinguisherMethod.Type) |
| } |
| badPLRef := "?" |
| for _, cond := range obj.Status.Conditions { |
| if cond.Type == flowcontrol.FlowSchemaConditionDangling { |
| badPLRef = string(cond.Status) |
| break |
| } |
| } |
| row.Cells = append(row.Cells, name, plName, int64(obj.Spec.MatchingPrecedence), distinguisherMethod, translateTimestampSince(obj.CreationTimestamp), badPLRef) |
| |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printFlowSchemaList(list *flowcontrol.FlowSchemaList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| fsSeq := make(apihelpers.FlowSchemaSequence, len(list.Items)) |
| for i := range list.Items { |
| fsSeq[i] = &list.Items[i] |
| } |
| sort.Sort(fsSeq) |
| for i := range fsSeq { |
| r, err := printFlowSchema(fsSeq[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printStorageVersion(obj *apiserverinternal.StorageVersion, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| commonEncodingVersion := "<unset>" |
| if obj.Status.CommonEncodingVersion != nil { |
| commonEncodingVersion = *obj.Status.CommonEncodingVersion |
| } |
| row.Cells = append(row.Cells, obj.Name, commonEncodingVersion, formatStorageVersions(obj.Status.StorageVersions), translateTimestampSince(obj.CreationTimestamp)) |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func formatStorageVersions(storageVersions []apiserverinternal.ServerStorageVersion) string { |
| list := []string{} |
| max := 3 |
| more := false |
| count := 0 |
| for _, sv := range storageVersions { |
| if len(list) < max { |
| list = append(list, fmt.Sprintf("%s=%s", sv.APIServerID, sv.EncodingVersion)) |
| } else if len(list) == max { |
| more = true |
| } |
| count++ |
| } |
| return listWithMoreString(list, more, count, max) |
| } |
| |
| func printStorageVersionList(list *apiserverinternal.StorageVersionList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printStorageVersion(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printPriorityLevelConfiguration(obj *flowcontrol.PriorityLevelConfiguration, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| name := obj.Name |
| ncs := interface{}("<none>") |
| queues := interface{}("<none>") |
| handSize := interface{}("<none>") |
| queueLengthLimit := interface{}("<none>") |
| if obj.Spec.Limited != nil { |
| ncs = obj.Spec.Limited.NominalConcurrencyShares |
| if qc := obj.Spec.Limited.LimitResponse.Queuing; qc != nil { |
| queues = qc.Queues |
| handSize = qc.HandSize |
| queueLengthLimit = qc.QueueLengthLimit |
| } |
| } |
| row.Cells = append(row.Cells, name, string(obj.Spec.Type), ncs, queues, handSize, queueLengthLimit, translateTimestampSince(obj.CreationTimestamp)) |
| |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printPriorityLevelConfigurationList(list *flowcontrol.PriorityLevelConfigurationList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printPriorityLevelConfiguration(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printServiceCIDR(obj *networking.ServiceCIDR, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| |
| cidrs := strings.Join(obj.Spec.CIDRs, ",") |
| row.Cells = append(row.Cells, obj.Name, cidrs, translateTimestampSince(obj.CreationTimestamp)) |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printServiceCIDRList(list *networking.ServiceCIDRList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printServiceCIDR(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printIPAddress(obj *networking.IPAddress, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| |
| parentRefName := "<none>" |
| if obj.Spec.ParentRef != nil { |
| gr := schema.GroupResource{ |
| Group: obj.Spec.ParentRef.Group, |
| Resource: obj.Spec.ParentRef.Resource, |
| } |
| parentRefName = strings.ToLower(gr.String()) |
| if obj.Spec.ParentRef.Namespace != "" { |
| parentRefName += "/" + obj.Spec.ParentRef.Namespace |
| } |
| parentRefName += "/" + obj.Spec.ParentRef.Name |
| } |
| age := translateTimestampSince(obj.CreationTimestamp) |
| row.Cells = append(row.Cells, obj.Name, parentRefName, age) |
| |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printIPAddressList(list *networking.IPAddressList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printIPAddress(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printScale(obj *autoscaling.Scale, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| row.Cells = append(row.Cells, obj.Name, int64(obj.Spec.Replicas), int64(obj.Status.Replicas), translateTimestampSince(obj.CreationTimestamp)) |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printResourceClass(obj *resource.ResourceClass, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| row.Cells = append(row.Cells, obj.Name, obj.DriverName, translateTimestampSince(obj.CreationTimestamp)) |
| |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printResourceClassList(list *resource.ResourceClassList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printResourceClass(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printResourceClaim(obj *resource.ResourceClaim, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| row.Cells = append(row.Cells, obj.Name, obj.Spec.ResourceClassName, string(obj.Spec.AllocationMode), resourceClaimState(obj), translateTimestampSince(obj.CreationTimestamp)) |
| |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func resourceClaimState(obj *resource.ResourceClaim) string { |
| var states []string |
| if obj.DeletionTimestamp != nil { |
| states = append(states, "deleted") |
| } |
| if obj.Status.Allocation == nil { |
| if obj.DeletionTimestamp == nil { |
| states = append(states, "pending") |
| } |
| } else { |
| states = append(states, "allocated") |
| if len(obj.Status.ReservedFor) > 0 { |
| states = append(states, "reserved") |
| } else if obj.DeletionTimestamp != nil || obj.Status.DeallocationRequested { |
| states = append(states, "deallocating") |
| } |
| } |
| return strings.Join(states, ",") |
| } |
| |
| func printResourceClaimList(list *resource.ResourceClaimList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printResourceClaim(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printResourceClaimTemplate(obj *resource.ResourceClaimTemplate, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| row.Cells = append(row.Cells, obj.Name, obj.Spec.Spec.ResourceClassName, string(obj.Spec.Spec.AllocationMode), translateTimestampSince(obj.CreationTimestamp)) |
| |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printResourceClaimTemplateList(list *resource.ResourceClaimTemplateList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printResourceClaimTemplate(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printPodSchedulingContext(obj *resource.PodSchedulingContext, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| row.Cells = append(row.Cells, obj.Name, obj.Spec.SelectedNode, translateTimestampSince(obj.CreationTimestamp)) |
| |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printPodSchedulingContextList(list *resource.PodSchedulingContextList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printPodSchedulingContext(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printResourceClaimParameters(obj *resource.ResourceClaimParameters, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| generatedFrom := "" |
| if obj.GeneratedFrom != nil { |
| generatedFrom = fmt.Sprintf("%s.%s %s", obj.GeneratedFrom.Kind, obj.GeneratedFrom.APIGroup, obj.GeneratedFrom.Name) |
| } |
| row.Cells = append(row.Cells, obj.Name, generatedFrom, translateTimestampSince(obj.CreationTimestamp)) |
| |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printResourceClaimParametersList(list *resource.ResourceClaimParametersList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printResourceClaimParameters(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printResourceClassParameters(obj *resource.ResourceClassParameters, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| generatedFrom := "" |
| if obj.GeneratedFrom != nil { |
| generatedFrom = fmt.Sprintf("%s.%s %s", obj.GeneratedFrom.Kind, obj.GeneratedFrom.APIGroup, obj.GeneratedFrom.Name) |
| } |
| row.Cells = append(row.Cells, obj.Name, generatedFrom, translateTimestampSince(obj.CreationTimestamp)) |
| |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printResourceClassParametersList(list *resource.ResourceClassParametersList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printResourceClassParameters(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printResourceSlice(obj *resource.ResourceSlice, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| row.Cells = append(row.Cells, obj.Name, obj.NodeName, obj.DriverName, translateTimestampSince(obj.CreationTimestamp)) |
| |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printResourceSliceList(list *resource.ResourceSliceList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| for i := range list.Items { |
| r, err := printResourceSlice(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printStorageVersionMigration(obj *svmv1alpha1.StorageVersionMigration, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| row := metav1.TableRow{ |
| Object: runtime.RawExtension{Object: obj}, |
| } |
| |
| migrationGVR := obj.Spec.Resource.Resource + "." + obj.Spec.Resource.Version + "." + obj.Spec.Resource.Group |
| row.Cells = append(row.Cells, obj.Name, migrationGVR) |
| //ToDo: add migration condition 'status' and 'type' (migration successful | failed) |
| |
| return []metav1.TableRow{row}, nil |
| } |
| |
| func printStorageVersionMigrationList(list *svmv1alpha1.StorageVersionMigrationList, options printers.GenerateOptions) ([]metav1.TableRow, error) { |
| rows := make([]metav1.TableRow, 0, len(list.Items)) |
| |
| for i := range list.Items { |
| r, err := printStorageVersionMigration(&list.Items[i], options) |
| if err != nil { |
| return nil, err |
| } |
| rows = append(rows, r...) |
| } |
| return rows, nil |
| } |
| |
| func printBoolPtr(value *bool) string { |
| if value != nil { |
| return printBool(*value) |
| } |
| |
| return "<unset>" |
| } |
| |
| func printBool(value bool) string { |
| if value { |
| return "True" |
| } |
| |
| return "False" |
| } |
| |
| // SortableResourceNames - An array of sortable resource names |
| type SortableResourceNames []api.ResourceName |
| |
| func (list SortableResourceNames) Len() int { |
| return len(list) |
| } |
| |
| func (list SortableResourceNames) Swap(i, j int) { |
| list[i], list[j] = list[j], list[i] |
| } |
| |
| func (list SortableResourceNames) Less(i, j int) bool { |
| return list[i] < list[j] |
| } |
| |
| func isRestartableInitContainer(initContainer *api.Container) bool { |
| if initContainer == nil { |
| return false |
| } |
| if initContainer.RestartPolicy == nil { |
| return false |
| } |
| |
| return *initContainer.RestartPolicy == api.ContainerRestartPolicyAlways |
| } |
| |
| func isPodInitializedConditionTrue(status *api.PodStatus) bool { |
| for _, condition := range status.Conditions { |
| if condition.Type != api.PodInitialized { |
| continue |
| } |
| |
| return condition.Status == api.ConditionTrue |
| } |
| return false |
| } |
