3
ܓil3 @ s d dl mZ d dlZd dlZd dlZd dlmZmZmZm Z m
Z
dZ dZ dZ
G d d d eZG d
d deeZG dd dee eZdS ) ) translateN)Plugin RedHatPlugin DebianPlugin UbuntuPlugin PluginOptkubelet
kuberneteskube-apiserver
kube-proxykube-schedulerkube-controller-manager/etc/kubernetes/admin.confc @ s e Zd ZdZdZdDZdZddddd gZd
gZd d d
dgZ dddddddddddddd d d d d d!gZ
d"d#d$d%gZ e d&d'd(d)e d*d'd+d)e d,d'd-d)e d.d'd/d)e d0d1e
d2d3gZd4Zd5d6 Zd7d8 Zd9d: Zd;d< Zd=d> Zd?d@ ZdAdB ZdCS )E
Kubernetesz+Kubernetes container orchestration platformr containeri z/etc/kubernetesz /run/flannelz /var/lib/kubelet/config.yamlz"/var/lib/kubelet/kubeadm-flags.envz /var/lib/kubelet/*_manager_statez/etc/kubernetes/pkiz /var/log/pods/kube-system_etcd-*z*/var/log/pods/kube-system_kube-apiserver-*z3/var/log/pods/kube-system_kube-controller-manager-*z*/var/log/pods/kube-system_kube-scheduler-*eventsZ deploymentsZ ingressespodsZpvcservicesZ
daemonsetsZ replicasetsZ endpointsZ statefulsetsZ
configmapsZserviceaccountsZsecretsZjobsZcronjobsZ clusterrolesZclusterrolebindingsZ limitrangesZresourcequotasZscZpvZrolesZ rolebindingsallFz'collect all namespace output separately)defaultdescdescribez(collect describe output of all resourceskubelogsz4copy some kube-system pod logs without using the APIpodlogsz2capture stdout/stderr logs from pods using the APIzpodlogs-filter z1only collect logs from pods matching this pattern)r Zval_typer Zkubectlc C sD t jjdrd S x.| jD ]$}| j|r| jd| 7 _P qW d S )N
KUBECONFIGz --kubeconfig=)osenvirongetfiles path_existskube_cmd)selfZ_kconf r# /usr/lib/python3.6/kubernetes.pyset_kubeconfigk s
zKubernetes.set_kubeconfigc s t fdd jD S )z" Check if this is the master node c 3 s | ]} j |V qd S )N)r ).0f)r" r# r$ u s z-Kubernetes.check_is_master..)anyr )r" r# )r" r$ check_is_masters s zKubernetes.check_is_masterc s j j j j jdr. j j jddddg j sLd S x&d D ] } j j d| d d
qRW jd r j fd d
j
D d d
n j fdd
j
D d d
j j dd d
}|d dko jdr>xR|d j dd D ]:}|j
}|sq |d } j j d| d d
q W j j dgd d
j j dd d
jdr jjddg jd j j d S ) Nr r ZKUBERNETES_HTTP_PROXYZKUBERNETES_HTTPS_PROXYZKUBERNETES_NO_PROXYversion config view z cluster-info)subdirr c s g | ]} j d | qS )z
get -o json )r! )r& res)r" r# r$
s z$Kubernetes.setup..c s g | ]} j d | qS )z get )r! )r& r/ )r" r# r$ r0 s z
get nodesstatusr r output z describe node z get -o json nodesz get --raw /metricszkubevirt-virtctlZvmsZvmiszvirtctl version)r+ r, )
add_copy_spec config_filesZadd_forbidden_pathforbidden_paths
get_optionkube_system_logsZ add_env_varr* add_cmd_outputr! global_resourcescollect_cmd_output
splitlinessplit is_installed resourcesextend collect_per_resource_detailscollect_all_resources)r" subcmdZnodeslineZwordsZnoder# )r" r$ setupw s\
zKubernetes.setupc C sr | j | j ddd}|d j dd }dd |D }x2|D ](}d | }| jd
r| j d | }x,| jD ]"}| j| d | d
| d qrW | jdrV| j d | }x| jD ]}|dkrq| j| d| }|d dkrdd |d j dd D } xH| D ]@}
| j d | }| j| d| d |
d
| d| d qW qW | jdr@| j| q@W dS )z7 Collect details about each resource in all namespaces z get namespacesz cluster-info)r. r2 r3 Nc S s( g | ] }|rt |j r|j d qS )r )lenr= )r& nr# r# r$ r0 s z;Kubernetes.collect_per_resource_details..z --namespace=r z
get -o json r- z
cluster-info/r r z get r1 r c S s g | ]}|j d qS )r )r= )r& kr# r# r$ r0 s z
describe /r )r; r! r< r7 r? r9 exec_cmd
_get_pod_logs) r" ZknsZ kn_outputZknspsZnspaceZknspk_cmdr/ retZk_listitemr# r# r$ rA s8
z'Kubernetes.collect_per_resource_detailsc
C sh | j d| }| j| d}|d dkrdtj|d }| jdrTt| jdnd }x|d D ]}|rtj||d d rqdd
|d d d |d d }d
|d krxN|d d
D ]>}|d d } |d }
| j| j d| d| d|
|d qW d|d krdxP|d d D ]@}|d d } |d }
| j| j d| d| d|
|d q W qdW d S )Nz
get -o json z podsr1 r r2 zpodlogs-filteritemsZmetadatanamez
cluster-info/ namespacez /podlogs/Z
containersspecr- z logs z -c )r. ZinitContainers) r! rJ jsonloadsr7 r rematchr9 ) r" rQ rL rM r ZregZpodZ_subdirZcontZpod_nameZ cont_namer# r# r$ rK s. zKubernetes._get_pod_logsc C sB | j ds>| j d}x&| jD ] }| j| d| dd q W dS )z% Collect details about all resources r z get --all-namespaces=truer- z cluster-info)r. N)r7 r! r? r9 )r" rL r/ r# r# r$ rB s
z Kubernetes.collect_all_resourcesc C sv d}| j | j|d | j| j ddj| j d}| j| d}d}ddjt| j| j d}| j||| d S )NzX(?P{\s*"name":\s*[^,]*(pass|pwd|key|token|cred|PASS|PWD|KEY)[^,]*,\s*"value":)[^}]*z\g "********"z^(|)zLS0tLS1CRUdJ[A-Za-z0-9+/=]+z ***** SCRUBBED BASE64 PEM *****) Zdo_cmd_output_subr! Zdo_cmd_private_subjoinr5 do_file_private_sublistr Zdo_path_regex_sub)r" Z
env_regexpZpathexpZregexpZsubstr# r# r$ postproc s
zKubernetes.postprocN)r )__name__
__module__ __qualname__Z
short_descZ plugin_nameZprofilesZplugin_timeoutr5 r6 r8 r? r: r strZ option_listr! r% r* rE rA rK rB r\ r# r# r# r$ r & sn
E(!
r c s4 e Zd ZeZeZeZ fddZ fddZ
Z S )RedHatKubernetesc s | j drdS t j S )Nzopenshift-hyperkubeF)r> super
check_enabled)r" ) __class__r# r$ rc / s
z RedHatKubernetes.check_enabledc s | j t j d S )N)r% rb rE )r" )rd r# r$ rE 5 s zRedHatKubernetes.setup) r] r^ r_
KUBE_PACKAGESpackages KUBECONFIGSr KUBE_SVCSr rc rE
__classcell__r# r# )rd r$ ra ' s
ra c sH e Zd Zed Zed Zed Z fd
d Z d d
Z
fddZ Z S )UbuntuKubernetesk8s#/root/cdk/cdk_addons_kubectl_config4/var/snap/microk8s/current/credentials/client.configsnap.kubelet.daemonsnap.kube-apiserver.daemonsnap.kube-proxy.daemonsnap.kube-scheduler.daemon#snap.kube-controller-manager.daemoncdk.master.auth-webhookc sP | j | jdrd| _n| jdr2d| _| j | jjddg t j d S )NZmicrok8szmicrok8s kubectlrk z k8s kubectlz /root/cdk/kubelet/config.yamlz!/root/cdk/audit/audit-policy.yaml)r% r> r! _canonical_kubernetesr5 r@ rb rE )r" )rd r# r$ rE O s
zUbuntuKubernetes.setupc s ddddddddg}| j |d d
d }d d
g}| j| d| d| d| d| d| d| dg | j fdd|D d S )Nzsnap.k8s.containerd.servicezsnap.k8s.etcd.servicezsnap.k8s.k8sd.servicez snap.k8s.kube-apiserver.servicez(snap.k8s.kube-controller-manager.servicezsnap.k8s.kube-proxy.servicez snap.k8s.kube-scheduler.servicezsnap.k8s.kubelet.service)Zunitsrk z/var/snap/k8s/commonr1 r z/argsz /var/lib/k8s-dqlite/info.yamlz /var/lib/k8s-dqlite/cluster.yamlz'/var/lib/k8sd/state/truststore/k8s.yamlz&/var/lib/k8sd/state/database/info.yamlz)/var/lib/k8sd/state/database/cluster.yamlz /var/lib/k8sd/state/daemon.yamlc s g | ]} d | qS )r- r# )r& rC )k8s_cmdr# r$ r0 | s z:UbuntuKubernetes._canonical_kubernetes..)Z add_journalr4 r9 )r" Z k8s_unitsZ
k8s_commonZ k8s_subcmdsr# )ru r$ rt ^ s. z&UbuntuKubernetes._canonical_kubernetesc s t j | jd d S )Nz;/var/snap/k8s/common/var/lib/k8sd/state/truststore/k8s.yaml)rb r\ rZ )r" )rd r# r$ r\ s
zUbuntuKubernetes.postproc)rk )rl rm )rn ro rp rq rr rs )
r] r^ r_ re rf rg r rh r rE rt r\ ri r# r# )rd r$ rj : s !rj )r r )r r
r r r
)r )Zfnmatchr rU rS r Zsos.report.pluginsr r r r r re rh rg r ra rj r# r# r# r$ s"