B `"@snddlmZmZmZeZdZdZddlm Z m Z m Z yddl mZWnek rXYnXGddde Z dS) )absolute_importdivisionprint_functiona_ name: openshift plugin_type: inventory author: - Chris Houseknecht <@chouseknecht> short_description: OpenShift inventory source description: - Fetch containers, services and routes for one or more clusters - Groups by cluster name, namespace, namespace_services, namespace_pods, namespace_routes, and labels - Uses openshift.(yml|yaml) YAML configuration file to set parameter values. options: plugin: description: token that ensures this is a source file for the 'openshift' plugin. required: True choices: ['openshift'] connections: description: - Optional list of cluster connection settings. If no connections are provided, the default I(~/.kube/config) and active context will be used, and objects will be returned for all namespaces the active user is authorized to access. suboptions: name: description: - Optional name to assign to the cluster. If not provided, a name is constructed from the server and port. kubeconfig: description: - Path to an existing Kubernetes config file. If not provided, and no other connection options are provided, the OpenShift client will attempt to load the default configuration file from I(~/.kube/config.json). Can also be specified via K8S_AUTH_KUBECONFIG environment variable. context: description: - The name of a context found in the config file. Can also be specified via K8S_AUTH_CONTEXT environment variable. host: description: - Provide a URL for accessing the API. Can also be specified via K8S_AUTH_HOST environment variable. api_key: description: - Token used to authenticate with the API. Can also be specified via K8S_AUTH_API_KEY environment variable. username: description: - Provide a username for authenticating with the API. Can also be specified via K8S_AUTH_USERNAME environment variable. password: description: - Provide a password for authenticating with the API. Can also be specified via K8S_AUTH_PASSWORD environment variable. client_cert: description: - Path to a certificate used to authenticate with the API. Can also be specified via K8S_AUTH_CERT_FILE environment variable. aliases: [ cert_file ] client_key: description: - Path to a key file used to authenticate with the API. Can also be specified via K8S_AUTH_KEY_FILE environment variable. aliases: [ key_file ] ca_cert: description: - Path to a CA certificate used to authenticate with the API. Can also be specified via K8S_AUTH_SSL_CA_CERT environment variable. aliases: [ ssl_ca_cert ] validate_certs: description: - "Whether or not to verify the API server's SSL certificates. Can also be specified via K8S_AUTH_VERIFY_SSL environment variable." type: bool aliases: [ verify_ssl ] namespaces: description: - List of namespaces. If not specified, will fetch all containers for all namespaces user is authorized to access. requirements: - "python >= 2.7" - "openshift >= 0.6" - "PyYAML >= 3.11" as # File must be named openshift.yaml or openshift.yml # Authenticate with token, and return all pods and services for all namespaces plugin: community.okd.openshift connections: - host: https://192.168.64.4:8443 api_key: xxxxxxxxxxxxxxxx verify_ssl: false # Use default config (~/.kube/config) file and active context, and return objects for a specific namespace plugin: community.okd.openshift connections: - namespaces: - testing # Use a custom config file, and a specific context. plugin: community.okd.openshift connections: - kubeconfig: /path/to/config context: 'awx/192-168-64-4:8443/developer' )K8sInventoryExceptionInventoryModuleformat_dynamic_api_exc)DynamicApiErrorcs0eZdZdZdZdZfddZddZZS)rzcommunity.okd.openshiftzcommunity.okd.ococcstt|||rt|ts&tdx|D]`}|jf|}|d||j j }|drf|d}n | |}x|D]}| |||qvWq,Wn<|}||j j }| |}x|D]}| |||qWdS)Nz#Expecting connections to be a list.name namespaces) superr fetch_objects isinstancelistrZget_api_clientgetZget_default_host_name configurationhostZget_available_namespacesget_routes_for_namespace)self connections connectionclientr r namespace) __class__l/home/dcms/DCMS/lib/python3.7/site-packages/ansible_collections/community/okd/plugins/inventory/openshift.pyr s"         zInventoryModule.fetch_objectsc CsL|jjddd}y|j|d}Wn>tk r^}z |j|tdt|Wdd}~XYnXd|}d|}|j ||j ||j |||j ||j ||x|j D]} | j j } | j jsin t| j j} |j| | j jrFx<| j jD]0\} } d| | }|j ||j || qWt| j j}ni}|j || |j| d ||j| d | |j| d | j j|j| d d |j| d| j j|j| d| j j|j| d| j j| jjr|j| d| jj| jjr|j| d| jjt| jjdr| jjjr|j| dt| jjqWdS)Nzroute.openshift.io/v1ZRoute) api_versionkind)rzError fetching Routes list: %sz namespace_{0}z {0}_routesz label_{0}_{1}labels annotationsZ cluster_nameZ object_typerouteZ self_linkZresource_versionuidrpath targetPortport) resourcesrrZdisplaydebugrrformatZ inventory add_groupZ add_childitemsmetadatar rdictZadd_hostrZ set_variableZ clusterNameZselfLinkZresourceVersionr!specrr"hasattrr$r#)rrr rZv1_routeobjexcZnamespace_groupZnamespace_routes_groupr Z route_nameZroute_annotationskeyvalueZ group_nameZ route_labelsrrrrsL "           z(InventoryModule.get_routes_for_namespace) __name__ __module__ __qualname__NAMEZconnection_plugin transportr r __classcell__rr)rrr|s  rN) __future__rrrtype __metaclass__Z DOCUMENTATIONZEXAMPLESZ9ansible_collections.kubernetes.core.plugins.inventory.k8srrZK8sInventoryModulerZopenshift.dynamic.exceptionsr ImportErrorrrrrsU