File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/loadbalancer/drivers/__pycache__/rackspace.cpython-310.pyc
Back
o ;j�� � @ sz d dl m Z d dlmZ d dlmZ d dlmZmZ d dlm Z d dl m Z d dl m Z d dlmZmZmZmZmZ d d lmZmZ d d lmZ zd d lZW n ey[ d d lZY nw d d dd�d d dd�d d dd�d d dd�d d dd�d d dd�d�Z G dd� de�Z G dd� d�Z G dd� de �Z G d d � d �Z G d d � d �Z!G d d!� d!�Z"G d"d#� d#ee�ZG d$d%� d%ee �Z#d S )&� )�datetime)�httplib)� reverse_dict)� JsonResponse�PollingConnection)� LibcloudError)�OpenStackDriverMixin)�AUTH_URL)�DEFAULT_ALGORITHM�Driver�Member� Algorithm� LoadBalancer)�State�MemberCondition)�RackspaceConnectionNzrax:load-balancerZcloudLoadBalancersZDFW)Z service_type�name�regionZORDZIADZLONZSYDZHKG)Zdfw�ordZiadZlonZsydZhkgc s$ e Zd Z� fdd�Zdd� Z� ZS )�RackspaceResponsec s | j sd S t� �� S �N)�body�super� parse_body��self�� __class__� �[/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/loadbalancer/drivers/rackspace.pyr E s z RackspaceResponse.parse_bodyc C s dt | j� ko dkS S )N�� i+ )�int�statusr r r r �successJ s zRackspaceResponse.success)�__name__� __module__� __qualname__r r# � __classcell__r r r r r D s r c @ �( e Zd ZdZdd� Zdd� Zdd� ZdS ) �RackspaceHealthMonitora] :param type: type of load balancer. currently CONNECT (connection monitoring), HTTP, HTTPS (connection and HTTP monitoring) are supported. :type type: ``str`` :param delay: minimum seconds to wait before executing the health monitor. (Must be between 1 and 3600) :type delay: ``int`` :param timeout: maximum seconds to wait when establishing a connection before timing out. (Must be between 1 and 3600) :type timeout: ``int`` :param attempts_before_deactivation: Number of monitor failures before removing a node from rotation. (Must be between 1 and 10) :type attempts_before_deactivation: ``int`` c C � || _ || _|| _|| _d S r ��type�delay�timeout� attempts_before_deactivation)r r, r- r. r/ r r r �__init__e s z RackspaceHealthMonitor.__init__c C � d| j | j| j| jf S )NzX<RackspaceHealthMonitor: type=%s, delay=%d, timeout=%d, attempts_before_deactivation=%d>r+ r r r r �__repr__k s ��z RackspaceHealthMonitor.__repr__c C � | j | j| j| jd�S )N)r, r- r. �attemptsBeforeDeactivationr+ r r r r �_to_dictr � �z RackspaceHealthMonitor._to_dictN�r$ r% r& �__doc__r0 r2 r5 r r r r r) N s r) c s4 e Zd ZdZ� fdd�Zdd� Z� fdd�Z� ZS )�RackspaceHTTPHealthMonitora� A HTTP health monitor adds extra features to a Rackspace health monitor. :param path: the HTTP path to monitor. :type path: ``str`` :param body_regex: Regular expression used to evaluate the body of the HTTP response. :type body_regex: ``str`` :param status_regex: Regular expression used to evaluate the HTTP status code of the response. :type status_regex: ``str`` c s( t � �||||� || _|| _|| _d S r )r r0 �path� body_regex� status_regex)r r, r- r. r/ r: r; r< r r r r0 � s z#RackspaceHTTPHealthMonitor.__init__c C s$ d| j | j| j| j| j| j| jf S )Nz�<RackspaceHTTPHealthMonitor: type=%s, delay=%d, timeout=%d, attempts_before_deactivation=%d, path=%s, body_regex=%s, status_regex=%s>)r, r- r. r/ r: r; r< r r r r r2 � s ���z#RackspaceHTTPHealthMonitor.__repr__c s2 t � �� }| j|d< | j|d< | jr| j|d< |S )Nr: � statusRegex� bodyRegex)r r5 r: r< r; )r Z super_dictr r r r5 � s z#RackspaceHTTPHealthMonitor._to_dict)r$ r% r& r8 r0 r2 r5 r' r r r r r9 { s r9 c @ r( ) �RackspaceConnectionThrottlea� :param min_connections: Minimum number of connections per IP address before applying throttling. :type min_connections: ``int`` :param max_connections: Maximum number of connections per IP address. (Must be between 0 and 100000, 0 allows an unlimited number of connections.) :type max_connections: ``int`` :param max_connection_rate: Maximum number of connections allowed from a single IP address within the given rate_interval_seconds. (Must be between 0 and 100000, 0 allows an unlimited number of connections.) :type max_connection_rate: ``int`` :param rate_interval_seconds: Interval at which the max_connection_rate is enforced. (Must be between 1 and 3600.) :type rate_interval_seconds: ``int`` c C r* r ��min_connections�max_connections�max_connection_rate�rate_interval_seconds)r rA rB rC rD r r r r0 � s z$RackspaceConnectionThrottle.__init__c C r1 )Nzw<RackspaceConnectionThrottle: min_connections=%d, max_connections=%d, max_connection_rate=%d, rate_interval_seconds=%d>r@ r r r r r2 � s ���z$RackspaceConnectionThrottle.__repr__c C r3 )N)�maxConnections�minConnections�maxConnectionRate� rateInterval)rB rA rC rD r r r r r5 � r6 z$RackspaceConnectionThrottle._to_dictNr7 r r r r r? � s r? c @ s e Zd ZdZdZedediZdS )�RackspaceAccessRuleTyper � �ALLOW�DENYN)r$ r% r& rK rL �_RULE_TYPE_STRING_MAPr r r r rI � s rI c @ s" e Zd ZdZddd�Zdd� ZdS )�RackspaceAccessRulea� An access rule allows or denies traffic to a Load Balancer based on the incoming IPs. :param id: Unique identifier to refer to this rule by. :type id: ``str`` :param rule_type: RackspaceAccessRuleType.ALLOW or RackspaceAccessRuleType.DENY. :type id: ``int`` :param address: IP address or cidr (can be IPv4 or IPv6). :type address: ``str`` Nc C s || _ || _|| _d S r ��id� rule_type�address)r rP rQ rR r r r r0 s z RackspaceAccessRule.__init__c C s0 t j| j }|| jd�}| jd ur| j|d< |S )N)r, rR rP )rI rM rQ rR rP )r Z type_stringZas_dictr r r r5 s z RackspaceAccessRule._to_dict)NNN)r$ r% r& r8 r0 r5 r r r r rN � s rN c sJ e Zd ZeZeZdZdZdZ d� fdd� Z d d � Z d d � Z d d� Z � ZS )r � �P TN� �GETc s6 |si }|si }|dv rd|d< t � j|||||d�S )N)�POST�PUTzapplication/jsonz Content-Type)�action�params�data�method�headers)r �request)r rY rZ r[ r] r\ r r r r^ s �zRackspaceConnection.requestc C s |d dd�S )NrY rV �rY r\ r )r �response�contextZrequest_kwargsr r r �get_poll_request_kwargs* s z+RackspaceConnection.get_poll_request_kwargsc C s, |j d d }|dkrtd| jd��|dkS )N� loadBalancerr" �ERRORz%Load balancer entered an ERROR state.��driver�ACTIVE)�objectr rf )r r` �stater r r � has_completed- s z!RackspaceConnection.has_completedc C s |S r r )r r[ r r r � encode_data4 s z RackspaceConnection.encode_data)NrU NrV )r$ r% r& r Z responseClsr Zauth_urlZ poll_intervalr. Z cache_bustingr^ rb rj rk r' r r r r r s r c s� e Zd ZeZdZdZdZej ej ej ej ej ej d�Z ejejejd�Zee�Zejejejejejd�Zee�Z d�� fd d � Z e d d � �Z dd� Z dd� Z!dd� Z"dddi fdd�Z#dde$fdd�Z%dde$dfdd �Z&d d � Z'd d � Z(d!d"� Z)d#d$� Z*d%d&� Z+d'd(� Z,d)d*� Z-d+d,� Z.d-d.� Z/d/d0� Z0d1d2� Z1d3d4� Z2d5d6� Z3d7d8� Z4d9d:� Z5d;d<� Z6d=d>� Z7d?d@� Z8dAdB� Z9dCdD� Z:dEdF� Z;dGdH� Z<dIdJ� Z=dKdL� Z>dMdN� Z?dOdP� Z@dQdR� ZAdSdT� ZBdUdV� ZCdWdX� ZDdYdZ� ZEd[d\� ZFd]d^� ZGd_d`� ZHdadb� ZIdcdd� ZJdedf� ZKdgdh� ZLdidj� ZMdkdl� ZNdmdn� ZOdodp� ZPdqdr� ZQdsdt� ZRdudv� ZSdwdx� ZTdydz� ZUd{d|� ZVd}d~� ZWdd�� ZXd�d�� ZYd�d�� ZZd�d�d��Z[d�d�d��Z\d�d�� Z]d�d�� Z^d�d�� Z_d�d�� Z`d�d�� Zad�d�� Zbd�d�� Zcd�d�� Zd� ZeS )��RackspaceLBDriverZ rackspace_lbz Rackspace LBzhttp://www.rackspace.com/)rg ZBUILDrd �DELETEDZPENDING_UPDATEZPENDING_DELETE)�ENABLED�DISABLED�DRAINING)�RANDOM� ROUND_ROBIN�LEAST_CONNECTIONS�WEIGHTED_ROUND_ROBIN�WEIGHTED_LEAST_CONNECTIONSNTr c sB |� dd �}|r |}tj| fi |�� t� j||||||d� d S )N�ex_force_region)�key�secret�secure�host�portr )�popr r0 r ) r rw rx ry rz r{ r �kwargsrv r r r r0 Y s zRackspaceLBDriver.__init__c C s t �� S r )�ENDPOINT_ARGS_MAP�keys)�clsr r r � list_regionsj s z RackspaceLBDriver.list_regionsc C s t | j }| �� }||d< |S )NZget_endpoint_args)r~ r Zopenstack_connection_kwargs)r Z endpoint_argsr} r r r �_ex_connection_class_kwargsn s z-RackspaceLBDriver._ex_connection_class_kwargsc C � | � | j�d�j�S )N�/loadbalancers/protocols)� _to_protocols� connectionr^ rh r r r r �list_protocolst s z RackspaceLBDriver.list_protocolsc C r� )z� List protocols with default ports. :rtype: ``list`` of ``tuple`` :return: A list of protocols with default ports included. r� )� _to_protocols_with_default_portsr� r^ rh r r r r �$ex_list_protocols_with_default_portsw s �z6RackspaceLBDriver.ex_list_protocols_with_default_portsc C sZ i }|r||d< |r||d< |r||d< |� � D ]\}}|||< q| �| jjd|d�j�S )a @inherits: :class:`Driver.list_balancers` :param ex_member_address: Optional IP address of the attachment member. If provided, only the load balancers which have this member attached will be returned. :type ex_member_address: ``str`` :param ex_status: Optional. Filter balancers by status :type ex_status: ``str`` :param ex_changes_since: Optional. List all load balancers that have changed since the specified date/time :type ex_changes_since: ``str`` :param ex_params: Optional. Set parameters to be submitted to the API in the query string :type ex_params: ``dict`` Z nodeaddressr" z changes-since�/loadbalancers)rZ )�items� _to_balancersr� r^ rh )r Zex_member_addressZ ex_statusZex_changes_sinceZ ex_paramsrZ rw �valuer r r �list_balancers� s z RackspaceLBDriver.list_balancers�httprT c C s | � |||||�S r )�ex_create_balancer)r r �members�protocolr{ � algorithmr r r �create_balancer� s z!RackspaceLBDriver.create_balancer�PUBLICc s` � j |||||d�}|�d� fdd�|D �i� d|i}� jjddt�|�d�} � �| jd �S ) a- Creates a new load balancer instance :param name: Name of the new load balancer (required) :type name: ``str`` :param members: ``list`` of:class:`Member`s to attach to balancer :type members: ``list`` of :class:`Member` :param protocol: Loadbalancer protocol, defaults to http. :type protocol: ``str`` :param port: Port the load balancer should listen on, defaults to 80 :type port: ``str`` :param algorithm: Load balancing algorithm, defaults to LBAlgorithm.ROUND_ROBIN :type algorithm: :class:`Algorithm` :param vip: Virtual ip type of PUBLIC, SERVICENET, or ID of a virtual ip :type vip: ``str`` :rtype: :class:`LoadBalancer` )r r� r{ r� �vip�nodesc � g | ]}� � |��qS r ��_member_attributes��.0�memberr r r � <listcomp>� � z8RackspaceLBDriver.ex_create_balancer.<locals>.<listcomp>rc r� rW �r\ r[ )�_kwargs_to_mutable_attrs�updater� r^ �json�dumps� _to_balancerrh ) r r r� r� r{ r� r� Zbalancer_attrsZbalancer_object�respr r r r� � s " � �z$RackspaceLBDriver.ex_create_balancerc C sB |j |jd�}|�| jdi |j��� d|vr | jtj |d< |S )N)rR r{ � conditionr )�ipr{ r� � _kwargs_to_mutable_member_attrs�extra�CONDITION_LB_MEMBER_MAPr rn )r r� Zmember_attributesr r r r� � s z$RackspaceLBDriver._member_attributesc C �& d|j }| jj|dd�}|jtjkS )N�/loadbalancers/%s�DELETE�r\ �rP r� r^ r" r �ACCEPTED�r �balancer�urir� r r r �destroy_balancer� s z"RackspaceLBDriver.destroy_balancerc C s, dd� |D �}| j jdd|d�}|jtjkS )a Destroys a list of Balancers (the API supports up to 10). :param balancers: A list of Balancers to destroy. :type balancers: ``list`` of :class:`LoadBalancer` :return: Returns whether the destroy request was accepted. :rtype: ``bool`` c S � g | ]}d |j f�qS �rP r� )r� r� r r r r� � r� z:RackspaceLBDriver.ex_destroy_balancers.<locals>.<listcomp>r� r� �r\ rZ )r� r^ r" r r� )r Z balancers�idsr� r r r �ex_destroy_balancers� s z&RackspaceLBDriver.ex_destroy_balancersc C s$ d| }| j �|�}| �|jd �S )Nr� rc )r� r^ r� rh )r Z balancer_idr� r� r r r � get_balancer s z RackspaceLBDriver.get_balancerc C sD d| � |�gi}d|j }| jj|dt�|�d�}| �|j|�d S )Nr� �/loadbalancers/%s/nodesrW r� r )r� rP r� r^ r� r� � _to_membersrh )r r� r� Z member_objectr� r� r r r �balancer_attach_member s z(RackspaceLBDriver.balancer_attach_memberc sF d� fdd�|D �i}d|j }� jj|dt�|�d�}� �|j|�S )aP Attaches a list of members to a load balancer. :param balancer: The Balancer to which members will be attached. :type balancer: :class:`LoadBalancer` :param members: A list of Members to attach. :type members: ``list`` of :class:`Member` :rtype: ``list`` of :class:`Member` r� c r� r r� r� r r r r� r� z@RackspaceLBDriver.ex_balancer_attach_members.<locals>.<listcomp>r� rW r� )rP r� r^ r� r� r� rh )r r� r� Zmember_objectsr� r� r r r �ex_balancer_attach_members s z,RackspaceLBDriver.ex_balancer_attach_membersc C �, d� |j|j�}| jj|dd�}|jtjkS )N�/loadbalancers/{}/nodes/{}r� r� ��formatrP r� r^ r" r r� )r r� r� r� r� r r r �balancer_detach_member s z(RackspaceLBDriver.balancer_detach_memberc C �* | � ||�}|sd}t|| d��| �|�S )a� Detaches a list of members from a balancer (the API supports up to 10). This method blocks until the detach request has been processed and the balancer is in a RUNNING state again. :param balancer: The Balancer to detach members from. :type balancer: :class:`LoadBalancer` :param members: A list of Members to detach. :type members: ``list`` of :class:`Member` :return: Updated Balancer. :rtype: :class:`LoadBalancer` z'Detach members request was not acceptedre )�"ex_balancer_detach_members_no_pollr �_get_updated_balancer)r r� r� �accepted�msgr r r �ex_balancer_detach_members( s z,RackspaceLBDriver.ex_balancer_detach_membersc C s6 d|j }dd� |D �}| jj|d|d�}|jtjkS )a� Detaches a list of members from a balancer (the API supports up to 10). This method returns immediately. :param balancer: The Balancer to detach members from. :type balancer: :class:`LoadBalancer` :param members: A list of Members to detach. :type members: ``list`` of :class:`Member` :return: Returns whether the detach request was accepted. :rtype: ``bool`` r� c S r� r� r� r� r r r r� N r� zHRackspaceLBDriver.ex_balancer_detach_members_no_poll.<locals>.<listcomp>r� r� r� )r r� r� r� r� r� r r r r� ? s z4RackspaceLBDriver.ex_balancer_detach_members_no_pollc C s$ d|j }| j�|�j}| �||�S )Nr� )rP r� r^ rh r� )r r� r� r[ r r r �balancer_list_membersS s z'RackspaceLBDriver.balancer_list_membersc K s> | j di |��}| jjd|j dt�|�d�}| �|jd �S )Nr� rX �rY r\ r[ rc r )r� r� � async_requestrP r� r� r� rh �r r� r} �attrsr� r r r �update_balancerX s �z!RackspaceLBDriver.update_balancerc K s: | j di |��}| jjd|j dt�|�d�}|jtjkS )z^ Update balancer no poll. @inherits: :class:`Driver.update_balancer` r� rX r� Nr ) r� r� r^ rP r� r� r" r r� r� r r r �ex_update_balancer_no_polla s � z,RackspaceLBDriver.ex_update_balancer_no_pollc sb | j |� fi |��}|sd}t|| d��| �|�}|jd }� fdd�|D �}|s-td��|d S )a� Updates a Member's extra attributes for a Balancer. The attributes can include 'weight' or 'condition'. This method blocks until the update request has been processed and the balancer is in a RUNNING state again. :param balancer: Balancer to update the member on. :type balancer: :class:`LoadBalancer` :param member: Member which should be used :type member: :class:`Member` :keyword **kwargs: New attributes. Should contain either 'weight' or 'condition'. 'condition' can be set to 'ENABLED', 'DISABLED'. or 'DRAINING'. 'weight' can be set to a positive integer between 1 and 100, with a higher weight indicating that the node will receive more traffic (assuming the Balancer is using a weighted algorithm). :type **kwargs: ``dict`` :return: Updated Member. :rtype: :class:`Member` z)Update member attributes was not acceptedre r� c s g | ] }|j � j kr|�qS r r� )r� �m�r� r r r� � s z?RackspaceLBDriver.ex_balancer_update_member.<locals>.<listcomp>z Could not find updated memberr )�!ex_balancer_update_member_no_pollr r� r� )r r� r� r} r� r� r� Zupdated_membersr r� r �ex_balancer_update_membero s z+RackspaceLBDriver.ex_balancer_update_memberc K s< | j jd�|j|j�dt�| jdi |���d�}|jtj kS )a^ Updates a Member's extra attributes for a Balancer. The attribute can include 'weight' or 'condition'. This method returns immediately. :param balancer: Balancer to update the member on. :type balancer: :class:`LoadBalancer` :param member: Member which should be used :type member: :class:`Member` :keyword **kwargs: New attributes. Should contain either 'weight' or 'condition'. 'condition' can be set to 'ENABLED', 'DISABLED'. or 'DRAINING'. 'weight' can be set to a positive integer between 1 and 100, with a higher weight indicating that the node will receive more traffic (assuming the Balancer is using a weighted algorithm). :type **kwargs: ``dict`` :return: Returns whether the update request was accepted. :rtype: ``bool`` r� rX r� Nr ) r� r^ r� rP r� r� r� r" r r� )r r� r� r} r� r r r r� � s � z3RackspaceLBDriver.ex_balancer_update_member_no_pollc C s | j �d�}dd� |jd D �S )z� Lists algorithms supported by the API. Returned as strings because this list may change in the future. :rtype: ``list`` of ``str`` z/loadbalancers/algorithmsc S s g | ]}|d � � �qS )r )�upper)r� �ar r r r� � � z=RackspaceLBDriver.ex_list_algorithm_names.<locals>.<listcomp>Z algorithms)r� r^ rh )r r` r r r �ex_list_algorithm_names� s z)RackspaceLBDriver.ex_list_algorithm_namesc C s$ d|j }| j�|�}|jd d S )z� List error page configured for the specified load balancer. :param balancer: Balancer which should be used :type balancer: :class:`LoadBalancer` :rtype: ``str`` �/loadbalancers/%s/errorpage� errorpage�content�rP r� r^ rh r� r r r �ex_get_balancer_error_page� s z,RackspaceLBDriver.ex_get_balancer_error_pagec s. d|j }� j�|�}� fdd�|jd D �S )z� List the access list. :param balancer: Balancer which should be used :type balancer: :class:`LoadBalancer` :rtype: ``list`` of :class:`RackspaceAccessRule` � /loadbalancers/%s/accesslistc r� r ��_to_access_rule�r� �elr r r r� � r� z=RackspaceLBDriver.ex_balancer_access_list.<locals>.<listcomp>� accessListr� r� r r r �ex_balancer_access_list� s z)RackspaceLBDriver.ex_balancer_access_listc C s& | j jd|j dd�}| �|jd �S )z� Updating a balancer's attributes puts a balancer into 'PENDING_UPDATE' status. Wait until the balancer is back in 'ACTIVE' status and then return the individual balancer details call. r� rV r_ rc )r� r� rP r� rh )r r� r� r r r r� � s z'RackspaceLBDriver._get_updated_balancerc C r� )a� Sets a Balancer's health monitor. This method blocks until the update request has been processed and the balancer is in a RUNNING state again. :param balancer: Balancer to update. :type balancer: :class:`LoadBalancer` :param health_monitor: Health Monitor for the balancer. :type health_monitor: :class:`RackspaceHealthMonitor` :return: Updated Balancer. :rtype: :class:`LoadBalancer` z*Update health monitor request not acceptedre )�)ex_update_balancer_health_monitor_no_pollr r� )r r� �health_monitorr� r� r r r �!ex_update_balancer_health_monitor� � z3RackspaceLBDriver.ex_update_balancer_health_monitorc C �2 d|j }| jj|dt�|�� �d�}|jtjkS )a� Sets a Balancer's health monitor. This method returns immediately. :param balancer: Balancer to update health monitor on. :type balancer: :class:`LoadBalancer` :param health_monitor: Health Monitor for the balancer. :type health_monitor: :class:`RackspaceHealthMonitor` :return: Returns whether the update request was accepted. :rtype: ``bool`` � /loadbalancers/%s/healthmonitorrX r� � rP r� r^ r� r� r5 r" r r� )r r� r� r� r� r r r r� � s � z;RackspaceLBDriver.ex_update_balancer_health_monitor_no_pollc C �$ | � |�s d}t|| d��| �|�S )ap Disables a Balancer's health monitor. This method blocks until the disable request has been processed and the balancer is in a RUNNING state again. :param balancer: Balancer to disable health monitor on. :type balancer: :class:`LoadBalancer` :return: Updated Balancer. :rtype: :class:`LoadBalancer` z+Disable health monitor request not acceptedre )�*ex_disable_balancer_health_monitor_no_pollr r� �r r� r� r r r �"ex_disable_balancer_health_monitor � z4RackspaceLBDriver.ex_disable_balancer_health_monitorc C r� )a. Disables a Balancer's health monitor. This method returns immediately. :param balancer: Balancer to disable health monitor on. :type balancer: :class:`LoadBalancer` :return: Returns whether the disable request was accepted. :rtype: ``bool`` r� r� r� r� r� r r r r� ! s z<RackspaceLBDriver.ex_disable_balancer_health_monitor_no_pollc C r� )a Updates a Balancer's connection throttle. This method blocks until the update request has been processed and the balancer is in a RUNNING state again. :param balancer: Balancer to update connection throttle on. :type balancer: :class:`LoadBalancer` :param connection_throttle: Connection Throttle for the balancer. :type connection_throttle: :class:`RackspaceConnectionThrottle` :return: Updated Balancer. :rtype: :class:`LoadBalancer` z/Update connection throttle request not acceptedre )�.ex_update_balancer_connection_throttle_no_pollr r� )r r� �connection_throttler� r� r r r �&ex_update_balancer_connection_throttle2 s � z8RackspaceLBDriver.ex_update_balancer_connection_throttlec C r� )a� Sets a Balancer's connection throttle. This method returns immediately. :param balancer: Balancer to update connection throttle on. :type balancer: :class:`LoadBalancer` :param connection_throttle: Connection Throttle for the balancer. :type connection_throttle: :class:`RackspaceConnectionThrottle` :return: Returns whether the update request was accepted. :rtype: ``bool`` �$/loadbalancers/%s/connectionthrottlerX r� r� )r r� r� r� r� r r r r� K s � z@RackspaceLBDriver.ex_update_balancer_connection_throttle_no_pollc C r� )az Disables a Balancer's connection throttle. This method blocks until the disable request has been processed and the balancer is in a RUNNING state again. :param balancer: Balancer to disable connection throttle on. :type balancer: :class:`LoadBalancer` :return: Updated Balancer. :rtype: :class:`LoadBalancer` z0Disable connection throttle request not acceptedre )�/ex_disable_balancer_connection_throttle_no_pollr r� r� r r r �'ex_disable_balancer_connection_throttle` r� z9RackspaceLBDriver.ex_disable_balancer_connection_throttlec C r� )a8 Disables a Balancer's connection throttle. This method returns immediately. :param balancer: Balancer to disable connection throttle on. :type balancer: :class:`LoadBalancer` :return: Returns whether the disable request was accepted. :rtype: ``bool`` r� r� r� r� r� r r r r� r � zARackspaceLBDriver.ex_disable_balancer_connection_throttle_no_pollc C r� )aw Enables connection logging for a Balancer. This method blocks until the enable request has been processed and the balancer is in a RUNNING state again. :param balancer: Balancer to enable connection logging on. :type balancer: :class:`LoadBalancer` :return: Updated Balancer. :rtype: :class:`LoadBalancer` z.Enable connection logging request not acceptedre )�-ex_enable_balancer_connection_logging_no_pollr r� r� r r r �%ex_enable_balancer_connection_logging� r� z7RackspaceLBDriver.ex_enable_balancer_connection_loggingc C �6 d|j }| jj|dt�dddii�d�}|jtjkS )a5 Enables connection logging for a Balancer. This method returns immediately. :param balancer: Balancer to enable connection logging on. :type balancer: :class:`LoadBalancer` :return: Returns whether the enable request was accepted. :rtype: ``bool`` �#/loadbalancers/%s/connectionloggingrX �connectionLogging�enabledTr� �rP r� r^ r� r� r" r r� r� r r r r� � s � z?RackspaceLBDriver.ex_enable_balancer_connection_logging_no_pollc C r� )ay Disables connection logging for a Balancer. This method blocks until the enable request has been processed and the balancer is in a RUNNING state again. :param balancer: Balancer to disable connection logging on. :type balancer: :class:`LoadBalancer` :return: Updated Balancer. :rtype: :class:`LoadBalancer` z/Disable connection logging request not acceptedre )�.ex_disable_balancer_connection_logging_no_pollr r� r� r r r �&ex_disable_balancer_connection_logging� r� z8RackspaceLBDriver.ex_disable_balancer_connection_loggingc C r� )a8 Disables connection logging for a Balancer. This method returns immediately. :param balancer: Balancer to disable connection logging on. :type balancer: :class:`LoadBalancer` :return: Returns whether the disable request was accepted. :rtype: ``bool`` r� rX r� r� Fr� r� r� r r r r � � � z@RackspaceLBDriver.ex_disable_balancer_connection_logging_no_pollc C r� )a� Enables session persistence for a Balancer by setting the persistence type to 'HTTP_COOKIE'. This method blocks until the enable request has been processed and the balancer is in a RUNNING state again. :param balancer: Balancer to enable session persistence on. :type balancer: :class:`LoadBalancer` :return: Updated Balancer. :rtype: :class:`LoadBalancer` z/Enable session persistence request not acceptedre )�.ex_enable_balancer_session_persistence_no_pollr r� r� r r r �&ex_enable_balancer_session_persistence� r� z8RackspaceLBDriver.ex_enable_balancer_session_persistencec C r� )ah Enables session persistence for a Balancer by setting the persistence type to 'HTTP_COOKIE'. This method returns immediately. :param balancer: Balancer to enable session persistence on. :type balancer: :class:`LoadBalancer` :return: Returns whether the enable request was accepted. :rtype: ``bool`` �$/loadbalancers/%s/sessionpersistencerX �sessionPersistence�persistenceTypeZ HTTP_COOKIEr� r� r� r r r r � r z@RackspaceLBDriver.ex_enable_balancer_session_persistence_no_pollc C r� )a| Disables session persistence for a Balancer. This method blocks until the disable request has been processed and the balancer is in a RUNNING state again. :param balancer: Balancer to disable session persistence on. :type balancer: :class:`LoadBalancer` :return: Updated Balancer. :rtype: :class:`LoadBalancer` z0Disable session persistence request not acceptedre )�/ex_disable_balancer_session_persistence_no_pollr r� r� r r r �'ex_disable_balancer_session_persistence� r� z9RackspaceLBDriver.ex_disable_balancer_session_persistencec C r� )a; Disables session persistence for a Balancer. This method returns immediately. :param balancer: Balancer to disable session persistence for. :type balancer: :class:`LoadBalancer` :return: Returns whether the disable request was accepted. :rtype: ``bool`` r r� r� r� r� r r r r r� zARackspaceLBDriver.ex_disable_balancer_session_persistence_no_pollc C r� )a� Updates a Balancer's custom error page. This method blocks until the update request has been processed and the balancer is in a RUNNING state again. :param balancer: Balancer to update the custom error page for. :type balancer: :class:`LoadBalancer` :param page_content: HTML content for the custom error page. :type page_content: ``str`` :return: Updated Balancer. :rtype: :class:`LoadBalancer` z&Update error page request not acceptedre )�%ex_update_balancer_error_page_no_pollr r� )r r� � page_contentr� r� r r r � ex_update_balancer_error_page r� z/RackspaceLBDriver.ex_update_balancer_error_pagec C s6 d|j }| jj|dt�dd|ii�d�}|jtjkS )a� Updates a Balancer's custom error page. This method returns immediately. :param balancer: Balancer to update the custom error page for. :type balancer: :class:`LoadBalancer` :param page_content: HTML content for the custom error page. :type page_content: ``str`` :return: Returns whether the update request was accepted. :rtype: ``bool`` r� rX r� r� r� r� )r r� r r� r� r r r r + � � z7RackspaceLBDriver.ex_update_balancer_error_page_no_pollc C r� )a� Disables a Balancer's custom error page, returning its error page to the Rackspace-provided default. This method blocks until the disable request has been processed and the balancer is in a RUNNING state again. :param balancer: Balancer to disable the custom error page for. :type balancer: :class:`LoadBalancer` :return: Updated Balancer. :rtype: :class:`LoadBalancer` z.Disable custom error page request not acceptedre )�-ex_disable_balancer_custom_error_page_no_pollr r� r� r r r �%ex_disable_balancer_custom_error_page@ s z7RackspaceLBDriver.ex_disable_balancer_custom_error_pagec C s2 d|j }| jj|dd�}|jtjkp|jtjkS )au Disables a Balancer's custom error page, returning its error page to the Rackspace-provided default. This method returns immediately. :param balancer: Balancer to disable the custom error page for. :type balancer: :class:`LoadBalancer` :return: Returns whether the disable request was accepted. :rtype: ``bool`` r� r� r� )rP r� r^ r" r �OKr� r� r r r r S s z?RackspaceLBDriver.ex_disable_balancer_custom_error_page_no_pollc C sP | � ||�}|sd}t|| d��| �|�}|jd }| �||�}|s&td��|S )a� Adds an access rule to a Balancer's access list. This method blocks until the update request has been processed and the balancer is in a RUNNING state again. :param balancer: Balancer to create the access rule for. :type balancer: :class:`LoadBalancer` :param rule: Access Rule to add to the balancer. :type rule: :class:`RackspaceAccessRule` :return: The created access rule. :rtype: :class:`RackspaceAccessRule` z Create access rule not acceptedre r� zCould not find created rule)�&ex_create_balancer_access_rule_no_pollr r� r� �_find_matching_rule)r r� �ruler� r� � access_listZ created_ruler r r � ex_create_balancer_access_rulee s z0RackspaceLBDriver.ex_create_balancer_access_rulec C s6 d|j }| jj|dt�d|�� i�d�}|jtjkS )a� Adds an access rule to a Balancer's access list. This method returns immediately. :param balancer: Balancer to create the access rule for. :type balancer: :class:`LoadBalancer` :param rule: Access Rule to add to the balancer. :type rule: :class:`RackspaceAccessRule` :return: Returns whether the create request was accepted. :rtype: ``bool`` r� rW Z networkItemr� r� �r r� r r� r� r r r r � r z8RackspaceLBDriver.ex_create_balancer_access_rule_no_pollc C sx | � ||�}|sd}t|| d��| �|�}|jd }g }|D ]}| �||�}|r-|�|� q t|�t|�kr:td��|S )a; Adds a list of access rules to a Balancer's access list. This method blocks until the update request has been processed and the balancer is in a RUNNING state again. :param balancer: Balancer to create the access rule for. :type balancer: :class:`LoadBalancer` :param rules: List of :class:`RackspaceAccessRule` to add to the balancer. :type rules: ``list`` of :class:`RackspaceAccessRule` :return: The created access rules. :rtype: :class:`RackspaceAccessRule` z Create access rules not acceptedre r� z Could not find all created rules)�'ex_create_balancer_access_rules_no_pollr r� r� r �append�len) r r� �rulesr� r� r Z created_rules�rZ matched_ruler r r � ex_create_balancer_access_rules� s �z1RackspaceLBDriver.ex_create_balancer_access_rulesc C s. |D ]}|j |j kr|j|jkr| S qdS )a LB API does not return the ID for the newly created rules, so we have to search the list to find the rule with a matching rule type and address to return an object with the right identifier.it. The API enforces rule type and address uniqueness. N)rQ rR )r Z rule_to_findr r r r r r � s �z%RackspaceLBDriver._find_matching_rulec C s< d|j }| jj|dt�ddd� |D �i�d�}|jtjkS )a� Adds a list of access rules to a Balancer's access list. This method returns immediately. :param balancer: Balancer to create the access rule for. :type balancer: :class:`LoadBalancer` :param rules: List of :class:`RackspaceAccessRule` to add to the balancer. :type rules: ``list`` of :class:`RackspaceAccessRule` :return: Returns whether the create request was accepted. :rtype: ``bool`` r� rW r� c S s g | ]}|� � �qS r )r5 �r� r r r r r� � s zMRackspaceLBDriver.ex_create_balancer_access_rules_no_poll.<locals>.<listcomp>r� r� )r r� r r� r� r r r r � s � z9RackspaceLBDriver.ex_create_balancer_access_rules_no_pollc C r� )a� Removes an access rule from a Balancer's access list. This method blocks until the update request has been processed and the balancer is in a RUNNING state again. :param balancer: Balancer to remove the access rule from. :type balancer: :class:`LoadBalancer` :param rule: Access Rule to remove from the balancer. :type rule: :class:`RackspaceAccessRule` :return: Updated Balancer. :rtype: :class:`LoadBalancer` z Delete access rule not acceptedre )�'ex_destroy_balancer_access_rule_no_pollr r� )r r� r r� r� r r r � ex_destroy_balancer_access_rule� r� z1RackspaceLBDriver.ex_destroy_balancer_access_rulec C r� )a� Removes an access rule from a Balancer's access list. This method returns immediately. :param balancer: Balancer to remove the access rule from. :type balancer: :class:`LoadBalancer` :param rule: Access Rule to remove from the balancer. :type rule: :class:`RackspaceAccessRule` :return: Returns whether the destroy request was accepted. :rtype: ``bool`` z /loadbalancers/{}/accesslist/{}r� r� r� r r r r r � s z9RackspaceLBDriver.ex_destroy_balancer_access_rule_no_pollc C r� )a@ Removes a list of access rules from a Balancer's access list. This method blocks until the update request has been processed and the balancer is in a RUNNING state again. :param balancer: Balancer to remove the access rules from. :type balancer: :class:`LoadBalancer` :param rules: List of :class:`RackspaceAccessRule` objects to remove from the balancer. :type rules: ``list`` of :class:`RackspaceAccessRule` :return: Updated Balancer. :rtype: :class:`LoadBalancer` z)Destroy access rules request not acceptedre )�(ex_destroy_balancer_access_rules_no_pollr r� )r r� r r� r� r r r � ex_destroy_balancer_access_rules s z2RackspaceLBDriver.ex_destroy_balancer_access_rulesc C s6 dd� |D �}d|j }| jj|d|d�}|jtjkS )a� Removes a list of access rules from a Balancer's access list. This method returns immediately. :param balancer: Balancer to remove the access rules from. :type balancer: :class:`LoadBalancer` :param rules: List of :class:`RackspaceAccessRule` objects to remove from the balancer. :type rules: ``list`` of :class:`RackspaceAccessRule` :return: Returns whether the destroy request was accepted. :rtype: ``bool`` c S r� r� r� r r r r r� 0 r� zNRackspaceLBDriver.ex_destroy_balancer_access_rules_no_poll.<locals>.<listcomp>r� r� r� r� )r r� r r� r� r� r r r r ! s z:RackspaceLBDriver.ex_destroy_balancer_access_rules_no_pollc C s d|j }| jj|dd�}|jS )z� Return current load balancer usage report. :param balancer: Balancer to remove the access rules from. :type balancer: :class:`LoadBalancer` :return: Raw load balancer usage object. :rtype: ``dict`` z /loadbalancers/%s/usage/currentrV r� r� r� r r r �ex_list_current_usage7 s z'RackspaceLBDriver.ex_list_current_usagec C s( g }|d D ] }|� |d �� � q|S )N� protocolsr )r �lower)r rh r# �itemr r r r� F s z RackspaceLBDriver._to_protocolsc C s< g }|d D ]}|d � � }t|d �}|�||f� q|S )Nr# r r{ )r$ r! r )r rh r# r% r r{ r r r r� L s z2RackspaceLBDriver._to_protocols_with_default_portsc s � fdd�|d D �S )Nc r� r )r� r� r r r r� V r� z3RackspaceLBDriver._to_balancers.<locals>.<listcomp>Z loadBalancersr )r rh r r r r� U s z RackspaceLBDriver._to_balancersc s� d }d }i }d|v r|d }d|v r|d }|� d�|� d�|� d�� j�� d� jj� jj|d f d�}d |v rG|d d d }|d |d < d |v rQ|d |d < d |v re|d � jv re� �|d �|d < d|v rt� �|�}|rt||d< d|v r� �|�|d< d|v r�|d }|� d�|d< d|v r�|d }|� d�|d< d|v r�� � |�|d< d|v r�� � |d d �|d< d|v rƈ � |d d �|d< d|v rׇ fd d �|d D �|d< t |d |d � j � |d t j�||� jj|d �S )!Nr{ �sourceAddressesZ ipv6PublicZ ipv4PublicZipv4Servicenetz https://%s%s/loadbalancers/%srP )Zipv6PublicSourceZipv4PublicSourceZipv4PrivateSourceZ service_namer� � virtualIpsr rR r� r� � healthMonitor�connectionThrottler r ZsessionPersistenceTyper� r� ZconnectionLoggingEnabledr� r� �created�time�updatedr� c r� r r� r r r r r� � r� z2RackspaceLBDriver._to_balancer.<locals>.<listcomp>r r" )rP r ri r� r{ rf r� )�getr� Zget_service_namerz Z request_path�_VALUE_TO_ALGORITHM_MAPZ_value_to_algorithm�_to_health_monitor�_to_connection_throttler� �_iso_to_datetimer � LB_STATE_MAPr �UNKNOWNrf ) r r� r� r{ r& r� r� Z persistence�loggingr r r r� X sf �� �z RackspaceLBDriver._to_balancerc s � �fdd�|d D �S )Nc s g | ]}�� |� ��qS r )� _to_memberr� �r� r r r r� � r� z1RackspaceLBDriver._to_members.<locals>.<listcomp>r� r )r rh r� r r6 r r� � s z RackspaceLBDriver._to_membersc C sx i }d|v r |d |d< d|v r!|d | j v r!| j �|d �|d< d|v r+|d |d< t|d |d |d ||d�}|S )N�weightr� r" rP rR r{ )rP r� r{ r� r� )�LB_MEMBER_CONDITION_MAPr- r )r r� r� r� Zlbmemberr r r r5 � s �z RackspaceLBDriver._to_memberc C s4 dddd�}|� � }||v r|| }|S |�� }|S )NZIMAPv2ZIMAPv3ZIMAPv4)Zimapv2Zimapv3Zimapv4)r$ r� )r r� Znon_standard_protocolsZ protocol_nameZprotocol_valuer r r �_protocol_to_value� s ��z$RackspaceLBDriver._protocol_to_valuec K s� i }d|v r |d |d< d|v r| � |d �}||d< d|v r(| �|d �|d< d|v r4t|d �|d< d|v rX|d dksD|d dkrOd|d ig|d < |S d |d ig|d < |S ) Nr r� r� r{ r� r� Z SERVICENETr, r' rP )Z_algorithm_to_valuer9 r! )r r� � update_attrsZalgorithm_valuer r r r� � s �z*RackspaceLBDriver._kwargs_to_mutable_attrsc K s8 i }d|v r| j �|d �|d< d|v r|d |d< |S )Nr� r7 )r� r- )r r� r: r r r r� � s z1RackspaceLBDriver._kwargs_to_mutable_member_attrsc C s� |d }|� d�}|� d�}|� d�}|� d�}|dkr$t||||d�S |dks,|d krAt|||||� d �|� d �|� d d �d�S d S )Nr( r, r- r. r4 ZCONNECTr+ ZHTTPZHTTPSr: r= r> rU )r, r- r. r/ r: r< r; )r- r) r9 )r r� Zhealth_monitor_datar, r- r. r/ r r r r/ � s. � � z$RackspaceLBDriver._to_health_monitorc C s@ |d }|� d�}|� d�}|� d�}|� d�}t||||d�S )Nr) rF rE rG rH r@ )r- r? )r r� Zconnection_throttle_datarA rB rC Z rate_intervalr r r r0 s �z)RackspaceLBDriver._to_connection_throttlec C s& t |�d�| �|�d��|�d�d�S )NrP r, rR rO )rN r- �_to_access_rule_type)r r� r r r r� s �z!RackspaceLBDriver._to_access_rulec C s |dkrt jS |dkrt jS d S )NrK rL )rI rK rL )r r, r r r r; s �z&RackspaceLBDriver._to_access_rule_typec C sD d}d }|D ]}zt �||�}W n ty Y nw |r |S q|S )N)z%Y-%m-%dT%H:%M:%SZz%Y-%m-%dT%H:%M:%S%z)r �strptime� ValueError)r ZisodateZ date_formats�dateZ date_formatr r r r1 s ��z"RackspaceLBDriver._iso_to_datetime)NTNNr r )fr$ r% r& r Z connectionClsZapi_namer Zwebsiter ZRUNNINGZPENDINGrd rm r2 r rn ro rp r8 r r� r rq rr rs rt ru r. Z_ALGORITHM_TO_VALUE_MAPr0 � classmethodr� r� r� r� r� r r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r� r r r r r r r r r r r r r r r r r r! r r" r� r� r� r� r� r5 r9 r� r� r/ r0 r� r; r1 r' r r r r rl 8 s� � ��� �+ �/ ' # D rl )$r Zlibcloud.utils.py3r Zlibcloud.utils.miscr Zlibcloud.common.baser r Zlibcloud.common.typesr Zlibcloud.common.openstackr Zlibcloud.common.rackspacer Zlibcloud.loadbalancer.baser r r r r Zlibcloud.loadbalancer.typesr r Z"libcloud.compute.drivers.rackspacer Z simplejsonr� � ImportErrorr~ r r) r9 r? rI rN rl r r r r �<module> s` ��������" -:: "
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings