File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/loadbalancer/drivers/__pycache__/gce.cpython-310.pyc
Back
o ;j 6 � @ sj zd dl ZW n ey d dlZY nw d dlmZmZmZmZ d dlm Z m Z ej Z G dd� de�Z dS )� N)�Driver�Member� Algorithm� LoadBalancer)� GCEConnection� GCENodeDriverc @ s� e Zd ZeZdZdZdZdej iZ dd� Z dd� Z d d � Z d*d d �Z d+dd�Zdd� Zdd� Zdd� Zdd� Zdd� Zdd� Zd d � Zd d � Zd d!� Zd"d#� Zd$d%� Zd&d'� Zd(d)� Z d S ),� GCELBDriverZ googleapisz#Google Compute Engine Load Balancerzhttps://cloud.google.com/�RANDOMc O s4 |� d�r |d | _nt|i |��| _| jj| _d S )NZ gce_driver)�get�gcer � connection��self�args�kwargs� r �U/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/loadbalancer/drivers/gce.py�__init__& s zGCELBDriver.__init__c C s. | j jdd�}|D ] }||jv r| S q dS )a Return the node object that matches a given public IP address. :param ip: Public IP address to search for :type ip: ``str`` :return: Node object that has the given IP, or None if not found. :rtype: :class:`Node` or None �all)Zex_zoneN)r Z list_nodes� public_ips)r �ipZ all_nodes�noder r r �_get_node_from_ip. s �z GCELBDriver._get_node_from_ipc C s ddgS )z� Return a list of supported protocols. For GCE, this is simply a hardcoded list. :rtype: ``list`` of ``str`` ZTCPZUDPr �r r r r �list_protocols> s zGCELBDriver.list_protocolsNc C s, g }| j j|d�D ] }|�| �|�� q |S )al List all loadbalancers :keyword ex_region: The region to return balancers from. If None, will default to self.region. If 'all', will return all balancers. :type ex_region: ``str`` or :class:`GCERegion` or ``None`` :rtype: ``list`` of :class:`LoadBalancer` )�region)r Zex_list_forwarding_rules�append� _forwarding_rule_to_loadbalancer)r � ex_regionZ balancers�fwrr r r �list_balancersH s zGCELBDriver.list_balancersc C s� g } |D ]5} t | d�r$| j�d�r| �| jd � q| �| �| j�� qt | d�r/| �| � q| �| j�| d�� qd| } | jj| ||| | d�} z| jj || ||||d�}W n t yc | � � � w | � |�S )a^ Create a new load balancer instance. For GCE, this means creating a forwarding rule and a matching target pool, then adding the members to the target pool. :param name: Name of the new load balancer (required) :type name: ``str`` :param port: Port or range of ports the load balancer should listen on, defaults to all ports. Examples: '80', '5000-5999' :type port: ``str`` :param protocol: Load balancer protocol. Should be 'tcp' or 'udp', defaults to 'tcp'. :type protocol: ``str`` :param members: List of Members to attach to balancer. Can be Member objects or Node objects. Node objects are preferred for GCE, but Member objects are accepted to comply with the established libcloud API. Note that the 'port' attribute of the members is ignored. :type members: ``list`` of :class:`Member` or :class:`Node` :param algorithm: Load balancing algorithm. Ignored for GCE which uses a hashing-based algorithm. :type algorithm: :class:`Algorithm` or ``None`` :keyword ex_region: Optional region to create the load balancer in. Defaults to the default region of the GCE Node Driver. :type ex_region: C{GCERegion} or ``str`` :keyword ex_healthchecks: Optional list of healthcheck objects or names to add to the load balancer. :type ex_healthchecks: ``list`` of :class:`GCEHealthCheck` or ``list`` of ``str`` :keyword ex_address: Optional static address object to be assigned to the load balancer. :type ex_address: C{GCEAddress} :keyword ex_session_affinity: Optional algorithm to use for session affinity. This will modify the hashing algorithm such that a client will tend to stick to a particular Member. :type ex_session_affinity: ``str`` :return: LoadBalancer object :rtype: :class:`LoadBalancer` r r �namer z%s-tp)r � healthchecks�nodesZsession_affinity)r �protocolZ port_range�address) �hasattr�extrar r r r r Z ex_get_nodeZex_create_targetpoolZex_create_forwarding_rule� Exception�destroyr )r r! �portr$ � algorithm�membersr Zex_healthchecksZ ex_addressZex_session_affinityZ node_list�memberZtp_name� targetpool�forwarding_ruler r r �create_balancerX s> ? � � � zGCELBDriver.create_balancerc C s( |j d �� }|r|j d �� }|S |S )ar Destroy a load balancer. For GCE, this means destroying the associated forwarding rule, then destroying the target pool that was attached to the forwarding rule. :param balancer: LoadBalancer which should be used :type balancer: :class:`LoadBalancer` :return: True if successful :rtype: ``bool`` r/ r. )r' r) )r �balancerr) Z tp_destroyr r r �destroy_balancer� s z GCELBDriver.destroy_balancerc C s | j �|�}| �|�S )aC Return a :class:`LoadBalancer` object. :param balancer_id: Name of load balancer you wish to fetch. For GCE, this is the name of the associated forwarding rule. :param balancer_id: ``str`` :rtype: :class:`LoadBalancer` )r Zex_get_forwarding_ruler )r Z balancer_idr r r r � get_balancer� s zGCELBDriver.get_balancerc C s$ |j d �|�}|r| �||�S dS )a_ Attach a compute node as a member to the load balancer. :param balancer: LoadBalancer which should be used :type balancer: :class:`LoadBalancer` :param node: Node to join to the balancer :type node: :class:`Node` :return: Member after joining the balancer. :rtype: :class:`Member` r. N)r' �add_node�_node_to_member)r r1 r r4 r r r � balancer_attach_compute_node� s �z(GCELBDriver.balancer_attach_compute_nodec C s< |j �d�p | �|j�}|j d �|�}|r | �||�S dS )aJ Attach a member to balancer :param balancer: LoadBalancer which should be used :type balancer: :class:`LoadBalancer` :param member: Member to join to the balancer :type member: :class:`Member` :return: Member after joining the balancer. :rtype: :class:`Member` r r. N)r' r r r r4 r5 )r r1 r- r r4 r r r �balancer_attach_member� s �z"GCELBDriver.balancer_attach_memberc C s, |j �d�p | �|j�}|j d �|�}|S )aS Detach member from balancer :param balancer: LoadBalancer which should be used :type balancer: :class:`LoadBalancer` :param member: Member which should be used :type member: :class:`Member` :return: True if member detach was successful, otherwise False :rtype: ``bool`` r r. )r' r r r � remove_node)r r1 r- r r8 r r r �balancer_detach_member s z"GCELBDriver.balancer_detach_memberc s � �fdd�� j d jD �S )z� Return list of members attached to balancer :param balancer: LoadBalancer which should be used :type balancer: :class:`LoadBalancer` :rtype: ``list`` of :class:`Member` c s g | ]}�� |� ��qS r )r5 )�.0�n�r1 r r r � <listcomp> s z5GCELBDriver.balancer_list_members.<locals>.<listcomp>r. )r' r# �r r1 r r< r �balancer_list_members s z!GCELBDriver.balancer_list_membersc O s | j j|i |��S �N)r �ex_create_healthcheckr r r r rA " s z!GCELBDriver.ex_create_healthcheckc C s | j �� S r@ )r �ex_list_healthchecksr r r r rB % s z GCELBDriver.ex_list_healthchecksc C � |j d �|�S )a@ Attach a healthcheck to balancer :param balancer: LoadBalancer which should be used :type balancer: :class:`LoadBalancer` :param healthcheck: Healthcheck to add :type healthcheck: :class:`GCEHealthCheck` :return: True if successful :rtype: ``bool`` r. )r' Zadd_healthcheck�r r1 Z healthcheckr r r � ex_balancer_attach_healthcheck( � z*GCELBDriver.ex_balancer_attach_healthcheckc C rC )aA Detach healtcheck from balancer :param balancer: LoadBalancer which should be used :type balancer: :class:`LoadBalancer` :param healthcheck: Healthcheck to remove :type healthcheck: :class:`GCEHealthCheck` :return: True if successful :rtype: ``bool`` r. )r' Zremove_healthcheckrD r r r � ex_balancer_detach_healthcheck7 rF z*GCELBDriver.ex_balancer_detach_healthcheckc C s |j d S )z� Return list of healthchecks attached to balancer :param balancer: LoadBalancer which should be used :type balancer: :class:`LoadBalancer` :rtype: ``list`` of :class:`HealthChecks` r" )r' r> r r r � ex_balancer_list_healthchecksF s z)GCELBDriver.ex_balancer_list_healthchecksc C sZ t |d�r |j}n|}t |d�r t|j�dkr |jd }nd}d|i}t|||j||d�S )a: Return a Member object based on a Node. :param node: Node object :type node: :class:`Node` :keyword balancer: The balancer the member is attached to. :type balancer: :class:`LoadBalancer` :return: Member object :rtype: :class:`Member` r! r r Nr )�idr r* r1 r' )r& r! �lenr r r* )r r r1 Z member_idZ member_ipr' r r r r5 Q s �zGCELBDriver._node_to_memberc C sD i }||d< |j |d< |j j|d< t|j|jd|j|jd | |d�S )a Return a Load Balancer object based on a GCEForwardingRule object. :param forwarding_rule: ForwardingRule object :type forwarding_rule: :class:`GCEForwardingRule` :return: LoadBalancer object :rtype: :class:`LoadBalancer` r/ r. r" NZ portRange)rI r! �stater r* Zdriverr' )r. r" r rI r! r% r' )r r/ r' r r r r t s �z,GCELBDriver._forwarding_rule_to_loadbalancerr@ )NNNN) �__name__� __module__� __qualname__r Z connectionClsZapinamer! Zwebsiter r Z_VALUE_TO_ALGORITHM_MAPr r r r r0 r2 r3 r6 r7 r9 r? rA rB rE rG rH r5 r r r r r r s8 �i #r )Z simplejson�json� ImportErrorZlibcloud.loadbalancer.baser r r r Z libcloud.compute.drivers.gcer r r ZDEFAULT_ALGORITHMr r r r r �<module> s �
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings