Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/libcloud/loadbalancer/drivers/__pycache__/rackspace.cpython-39.pyc
Ðазад
a q�h3� � @ s� d dl m Z z d dlZW n ey2 d dlZY n0 d dlmZ d dlmZ d dlm Z m Z m Z m Z d dlm Z d dlmZ d dlmZ d d lmZmZ d d lmZmZ d d lmZ d d lmZ d ddd�d ddd�d ddd�d ddd�d ddd�d ddd�d�Z G dd� de�Z G dd� de �Z G dd � d e �Z G d d � d e �Z!G d d � d e �Z"G d!d"� d"e �Z#G d#d$� d$ee�ZG d%d&� d&e e�Z$dS )'� )�datetimeN)�httplib)� reverse_dict)� LoadBalancer�Member�Driver� Algorithm)�DEFAULT_ALGORITHM)�RackspaceConnection)� LibcloudError)� JsonResponse�PollingConnection)�State�MemberCondition)�OpenStackDriverMixin)�AUTH_URLzrax:load-balancerZcloudLoadBalancersZDFW)Z service_type�name�regionZORDZIADZLONZSYDZHKG)Zdfw�ordZiadZlonZsydZhkgc s$ e Zd Z� fdd�Zdd� Z� ZS )�RackspaceResponsec s | j s d S tt| ��� S �N)�body�superr � parse_body��self�� __class__� ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/libcloud/loadbalancer/drivers/rackspace.pyr : s z RackspaceResponse.parse_bodyc C s dt | j� kodkS S )N�� i+ )�int�statusr r r r �success? s zRackspaceResponse.success)�__name__� __module__� __qualname__r r# � __classcell__r r r r r 9 s r c @ s( 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 s || _ || _|| _|| _d S r ��type�delay�timeout� attempts_before_deactivation)r r* r+ r, r- r r r �__init__Z s z RackspaceHealthMonitor.__init__c C s d| j | j| j| jf S )NzX<RackspaceHealthMonitor: type=%s, delay=%d, timeout=%d, attempts_before_deactivation=%d>r) r r r r �__repr__` s ��z RackspaceHealthMonitor.__repr__c C s | j | j| j| jd�S )N)r* r+ r, �attemptsBeforeDeactivationr) r r r r �_to_dictf s �z RackspaceHealthMonitor._to_dictN�r$ r% r& �__doc__r. r/ r1 r r r r r( C 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 t| ��||||� || _|| _|| _d S r )r r4 r. �path� body_regex� status_regex)r r* r+ r, r- r5 r6 r7 r r r r. 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- r5 r6 r7 r r r r r/ � s ��z#RackspaceHTTPHealthMonitor.__repr__c s6 t t| ��� }| j|d< | j|d< | jr2| j|d< |S )Nr5 � statusRegex� bodyRegex)r r4 r1 r5 r7 r6 )r Z super_dictr r r r1 � s z#RackspaceHTTPHealthMonitor._to_dict)r$ r% r& r3 r. r/ r1 r' r r r r r4 o s r4 c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) �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 s || _ || _|| _|| _d S r ��min_connections�max_connections�max_connection_rate�rate_interval_seconds)r r< r= r> r? r r r r. � s z$RackspaceConnectionThrottle.__init__c C s d| j | j| j| jf S )Nzw<RackspaceConnectionThrottle: min_connections=%d, max_connections=%d, max_connection_rate=%d, rate_interval_seconds=%d>r; r r r r r/ � s ��z$RackspaceConnectionThrottle.__repr__c C s | j | j| j| jd�S )N)�maxConnections�minConnections�maxConnectionRate� rateInterval)r= r< r> r? r r r r r1 � s �z$RackspaceConnectionThrottle._to_dictNr2 r r r r r: � s r: c @ s e Zd ZdZdZedediZdS )�RackspaceAccessRuleTyper � �ALLOW�DENYN)r$ r% r& rF rG �_RULE_TYPE_STRING_MAPr r r r rD � s �rD 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 rK rL rM r r r r. � s z RackspaceAccessRule.__init__c C s0 t j| j }|| jd�}| jd ur,| j|d< |S )N)r* rM rK )rD rH rL rM rK )r Z type_string�as_dictr r r r1 � s �� z RackspaceAccessRule._to_dict)NNN)r$ r% r& r3 r. r1 r r r r rI � s rI c sJ e Zd ZeZeZdZdZdZ d� fdd� Z d d � Z d d � Z d d� Z � ZS )r � �P TN� �GETc s: |si }|si }|dv r d|d< t t| �j|||||d�S )N)�POST�PUTzapplication/jsonz Content-Type)�action�params�data�method�headers)r r �request)r rU rV rW rY rX r r r rZ � s �zRackspaceConnection.requestc C s |d dd�S )NrU rR �rU rX r )r �response�contextZrequest_kwargsr r r �get_poll_request_kwargs s �z+RackspaceConnection.get_poll_request_kwargsc C s, |j d d }|dkr$td| jd��|dkS )N� loadBalancerr" �ERRORz%Load balancer entered an ERROR state.��driver�ACTIVE)�objectr rb )r r\ �stater r r � has_completed s �z!RackspaceConnection.has_completedc C s |S r r )r rW r r r � encode_data s z RackspaceConnection.encode_data)NrQ NrR )r$ r% r& r Z responseClsr Zauth_url� poll_intervalr, Z cache_bustingrZ r^ rf rg 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/)rc �BUILDr` �DELETEDZPENDING_UPDATEZPENDING_DELETE)�ENABLED�DISABLED�DRAINING)�RANDOM� ROUND_ROBIN�LEAST_CONNECTIONS�WEIGHTED_ROUND_ROBIN�WEIGHTED_LEAST_CONNECTIONSNTr c sF |� dd �}|r|}tj| fi |�� tt| �j||||||d� d S )N�ex_force_region)�key�secret�secure�host�portr )�popr r. r ri ) r ru rv rw rx ry r �kwargsrt r r r r. = s �zRackspaceLBDriver.__init__c C s t �� S r )�ENDPOINT_ARGS_MAP�keys)�clsr r r � list_regionsH 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_kwargsL s z-RackspaceLBDriver._ex_connection_class_kwargsc C s | � | j�d�j�S )N�/loadbalancers/protocols)� _to_protocols� connectionrZ rd r r r r �list_protocolsR s �z RackspaceLBDriver.list_protocolsc C s | � | j�d�j�S )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� rZ rd r r r r �$ex_list_protocols_with_default_portsV s �z6RackspaceLBDriver.ex_list_protocols_with_default_portsc C sZ i }|r||d< |r ||d< |r(||d< |� � D ]\}}|||< q0| �| 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)rV )�items� _to_balancersr� rZ rd )r Zex_member_addressZ ex_statusZex_changes_sinceZ ex_paramsrV ru �valuer r r �list_balancers` s �z RackspaceLBDriver.list_balancers�httprP c C s | � |||||�S r )�ex_create_balancer)r r �members�protocolry � 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� ry r� �vip�nodesc s g | ]}� � |��qS r ��_member_attributes��.0�memberr r r � <listcomp>� � z8RackspaceLBDriver.ex_create_balancer.<locals>.<listcomp>r_ r� rS �rX rW )�_kwargs_to_mutable_attrs�updater� rZ �json�dumps� _to_balancerrd ) r r r� r� ry r� r� Zbalancer_attrsZbalancer_object�respr r r r� � s ���z$RackspaceLBDriver.ex_create_balancerc C sB |j |jd�}|�| jf i |j��� d|vr>| jtj |d< |S )N)rM ry � condition)�ipry r� � _kwargs_to_mutable_member_attrs�extra�CONDITION_LB_MEMBER_MAPr rl )r r� Zmember_attributesr r r r� � s � � �z$RackspaceLBDriver._member_attributesc C s& d|j }| jj|dd�}|jtjkS )N�/loadbalancers/%s�DELETE�rX �rK r� rZ 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 s g | ]}d |j f�qS �rK r� )r� r� r r r r� � r� z:RackspaceLBDriver.ex_destroy_balancers.<locals>.<listcomp>r� r� �rX rV )r� rZ 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� r_ )r� rZ r� rd )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/nodesrS r� r )r� rK r� rZ r� r� � _to_membersrd )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 s g | ]}� � |��qS r r� r� r r r r� � r� z@RackspaceLBDriver.ex_balancer_attach_members.<locals>.<listcomp>r� rS r� )rK r� rZ r� r� r� rd )r r� r� Zmember_objectsr� r� r r r �ex_balancer_attach_members� s � �z,RackspaceLBDriver.ex_balancer_attach_membersc C s, d|j |j f }| jj|dd�}|jtjkS )N�/loadbalancers/%s/nodes/%sr� r� r� )r r� r� r� r� r r r �balancer_detach_member s z(RackspaceLBDriver.balancer_detach_memberc C s* | � ||�}|s d}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 acceptedra )�"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 s g | ]}d |j f�qS r� r� r� r r r r� 0 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� )rK r� rZ rd r� )r r� r� rW r r r �balancer_list_members5 s z'RackspaceLBDriver.balancer_list_membersc K s> | j f i |��}| jjd|j dt�|�d�}| �|jd �S )Nr� rT �rU rX rW r_ )r� r� � async_requestrK r� r� r� rd �r r� r{ �attrsr� r r r �update_balancer: s �z!RackspaceLBDriver.update_balancerc K s: | j f i |��}| jjd|j dt�|�d�}|jtjkS )z^ Update balancer no poll. @inherits: :class:`Driver.update_balancer` r� rT r� ) r� r� rZ rK r� r� r" r r� r� r r r �ex_update_balancer_no_pollB s �z,RackspaceLBDriver.ex_update_balancer_no_pollc sb | j |� fi |��}|s(d}t|| d��| �|�}|jd }� fdd�|D �}|sZtd��|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 acceptedra r� c s g | ]}|j � j kr|�qS r r� )r� �m�r� r r r� p r� 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|jf dt�| jf i |���d�}|jtjkS )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� rT r� ) r� rZ rK r� r� r� r" r r� )r r� r� r{ r� r r r r� w 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� � r� z=RackspaceLBDriver.ex_list_algorithm_names.<locals>.<listcomp>Z algorithms)r� rZ rd )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�rK r� rZ rd 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 s g | ]}� � |��qS 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� rR r[ r_ )r� r� rK r� rd )r r� r� r r r r� � s �z'RackspaceLBDriver._get_updated_balancerc C s* | � ||�}|s d}t|| d��| �|�S )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 acceptedra )�)ex_update_balancer_health_monitor_no_pollr r� )r r� �health_monitorr� r� r r r �!ex_update_balancer_health_monitor� s � z3RackspaceLBDriver.ex_update_balancer_health_monitorc C s2 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/healthmonitorrT r� � rK r� rZ r� r� r1 r" r r� )r r� r� r� r� r r r r� � s �z;RackspaceLBDriver.ex_update_balancer_health_monitor_no_pollc C s$ | � |�sd}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 acceptedra )�*ex_disable_balancer_health_monitor_no_pollr r� �r r� r� r r r �"ex_disable_balancer_health_monitor� s z4RackspaceLBDriver.ex_disable_balancer_health_monitorc C s& d|j }| jj|dd�}|jtjkS )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 s* | � ||�}|s d}t|| d��| �|�S )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 acceptedra )�.ex_update_balancer_connection_throttle_no_pollr r� )r r� �connection_throttler� r� r r r �&ex_update_balancer_connection_throttle s � z8RackspaceLBDriver.ex_update_balancer_connection_throttlec C s2 d|j }| jj|dt�|�� �d�}|jtjkS )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/connectionthrottlerT r� r� )r r� r� r� r� r r r r� 0 s �z@RackspaceLBDriver.ex_update_balancer_connection_throttle_no_pollc C s$ | � |�sd}t|| d��| �|�S )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 acceptedra )�/ex_disable_balancer_connection_throttle_no_pollr r� r� r r r �'ex_disable_balancer_connection_throttleF s z9RackspaceLBDriver.ex_disable_balancer_connection_throttlec C s& d|j }| jj|dd�}|jtjkS )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� X s zARackspaceLBDriver.ex_disable_balancer_connection_throttle_no_pollc C s$ | � |�sd}t|| d��| �|�S )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 acceptedra )�-ex_enable_balancer_connection_logging_no_pollr r� r� r r r �%ex_enable_balancer_connection_loggingh s z7RackspaceLBDriver.ex_enable_balancer_connection_loggingc C s6 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/connectionloggingrT �connectionLogging�enabledTr� �rK r� rZ r� r� r" r r� r� r r r r� z s �z?RackspaceLBDriver.ex_enable_balancer_connection_logging_no_pollc C s$ | � |�sd}t|| d��| �|�S )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 acceptedra )�.ex_disable_balancer_connection_logging_no_pollr r� r� r r r �&ex_disable_balancer_connection_logging� s z8RackspaceLBDriver.ex_disable_balancer_connection_loggingc C s6 d|j }| jj|dt�dddii�d�}|jtjkS )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� rT r� r� Fr� r� r� r r r r� � s �z@RackspaceLBDriver.ex_disable_balancer_connection_logging_no_pollc C s$ | � |�sd}t|| d��| �|�S )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 acceptedra )�.ex_enable_balancer_session_persistence_no_pollr r� r� r r r �&ex_enable_balancer_session_persistence� s z8RackspaceLBDriver.ex_enable_balancer_session_persistencec C s6 d|j }| jj|dt�dddii�d�}|jtjkS )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/sessionpersistencerT �sessionPersistence�persistenceTypeZ HTTP_COOKIEr� r� r� r r r r� � s ��z@RackspaceLBDriver.ex_enable_balancer_session_persistence_no_pollc C s$ | � |�sd}t|| d��| �|�S )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 acceptedra )�/ex_disable_balancer_session_persistence_no_pollr r� r� r r r �'ex_disable_balancer_session_persistence� s z9RackspaceLBDriver.ex_disable_balancer_session_persistencec C s& d|j }| jj|dd�}|jtjkS )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� � s zARackspaceLBDriver.ex_disable_balancer_session_persistence_no_pollc C s* | � ||�}|s d}t|| d��| �|�S )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 acceptedra )�%ex_update_balancer_error_page_no_pollr r� )r r� � page_contentr� r� r r r � ex_update_balancer_error_page� s � 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� rT r� r� r� r� )r r� r� r� r� r r r r� s �z7RackspaceLBDriver.ex_update_balancer_error_page_no_pollc C s$ | � |�sd}t|| d��| �|�S )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 acceptedra )�-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�}|jtjkp0|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� )rK r� rZ r" r �OKr� r� r r r r� ; s z?RackspaceLBDriver.ex_disable_balancer_custom_error_page_no_pollc C sP | � ||�}|s d}t|| d��| �|�}|jd }| �||�}|sLtd��|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 acceptedra 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_ruleM 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� rS Z networkItemr� r� �r r� r r� r� r r r r� k s �z8RackspaceLBDriver.ex_create_balancer_access_rule_no_pollc C sx | � ||�}|s d}t|| d��| �|�}|jd }g }|D ] }| �||�}|r<|�|� q<t|�t|�krttd��|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 acceptedra 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)rL rM )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� rS r� c S s g | ] }|� � �qS r )r1 �r� r r r r r� � r� 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 s* | � ||�}|s d}t|| d��| �|�S )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 acceptedra )�'ex_destroy_balancer_access_rule_no_pollr r� )r r� r r� r� r r r � ex_destroy_balancer_access_rule� s z1RackspaceLBDriver.ex_destroy_balancer_access_rulec C s, d|j |j f }| jj|dd�}|jtjkS )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/%s/accesslist/%sr� r� r� r r r r r � s z9RackspaceLBDriver.ex_destroy_balancer_access_rule_no_pollc C s* | � ||�}|s d}t|| d��| �|�S )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 acceptedra )�(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 s g | ]}d |j f�qS r� r� r r r r r� 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/currentrR r� r� r� r r r �ex_list_current_usage% s z'RackspaceLBDriver.ex_list_current_usagec C s( g }|d D ]}|� |d �� � q |S )N� protocolsr )r �lower)r rd r �itemr r r r� 4 s z RackspaceLBDriver._to_protocolsc C s< g }|d D ]*}|d � � }t|d �}|�||f� q |S )Nr r ry )r r! r )r rd r r r ry r r r r� : s z2RackspaceLBDriver._to_protocols_with_default_portsc s � fdd�|d D �S )Nc s g | ]}� � |��qS r )r� r� r r r r� D r� z3RackspaceLBDriver._to_balancers.<locals>.<listcomp>Z loadBalancersr )r rd r r r r� C 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 r�|d d d }|d |d < d |v r�|d |d < d |v r�|d � jv rʈ �|d �|d < d|v r� �|�}|r�||d< d|v r�� �|�|d< d|v �r |d }|� d�|d< d|v �r>|d }|� d�|d< d|v �rV� � |�|d< d|v �rv� � |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 )!Nry �sourceAddressesZ ipv6PublicZ ipv4PublicZipv4Servicenetz https://%s%s/loadbalancers/%srK )Zipv6PublicSourceZipv4PublicSourceZipv4PrivateSource� service_namer� � virtualIpsr rM r� r� � healthMonitor�connectionThrottler� r� ZsessionPersistenceTyper� r� ZconnectionLoggingEnabledr� r� �created�time�updatedr� c s g | ]}� � |��qS r r� r r r r r� � s �z2RackspaceLBDriver._to_balancer.<locals>.<listcomp>r r" )rK r re r� ry rb r� )�getr� Zget_service_namerx � request_path�_VALUE_TO_ALGORITHM_MAPZ_value_to_algorithm�_to_health_monitor�_to_connection_throttler� �_iso_to_datetimer � LB_STATE_MAPr �UNKNOWNrb ) r r� r� ry r r� r� Z persistence�loggingr r r r� F sr �� � � � ��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 rd r� r r% r r� � s z RackspaceLBDriver._to_membersc C sx i }d|v r|d |d< d|v rB|d | j v rB| j �|d �|d< d|v rV|d |d< t|d |d |d ||d�}|S )N�weightr� r" rK rM ry )rK r� ry r� r� )�LB_MEMBER_CONDITION_MAPr r )r r� r� r� Zlbmemberr r r r$ � s" �� �z RackspaceLBDriver._to_memberc C s2 dddd�}|� � }||v r&|| }n|�� }|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 r6| � |d �}||d< d|v rP| �|d �|d< d|v rht|d �|d< d|v r�|d dks�|d dkr�d|d ig|d < nd |d ig|d < |S ) Nr r� r� ry r� r� Z SERVICENETr* r rK )Z_algorithm_to_valuer( 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 r4|d |d< |S )Nr� r& )r� r )r r� r) r r r r� � s � z1RackspaceLBDriver._kwargs_to_mutable_member_attrsc C s� |d }|� d�}|� d�}|� d�}|� d�}|dkrHt||||d�S |dksX|d kr�t|||||� d �|� d �|� d d �d�S d S )Nr r* r+ r, r0 ZCONNECTr) �HTTPZHTTPSr5 r8 r9 rQ )r* r+ r, r- r5 r7 r6 )r r( r4 )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 rA r@ rB rC r; )r r: )r r� Zconnection_throttle_datar< r= r> Z rate_intervalr r r r � s �z)RackspaceLBDriver._to_connection_throttlec C s& t |�d�| �|�d��|�d�d�S )NrK r* rM rJ )rI r �_to_access_rule_type)r r� r r r r� � s �z!RackspaceLBDriver._to_access_rulec C s |dkrt jS |dkr t jS d S )NrF rG )rD rF rG )r r* r r r r+ � s z&RackspaceLBDriver._to_access_rule_typec C sB d}d }|D ]0}zt �||�}W n ty2 Y n0 |r q>q |S )N)z%Y-%m-%dT%H:%M:%SZz%Y-%m-%dT%H:%M:%S%z)r �strptime� ValueError)r �isodateZ date_formats�dateZ date_formatr r r r s z"RackspaceLBDriver._iso_to_datetime)NTNNr )N)N)fr$ r% r& r Z connectionClsZapi_namer Zwebsiter ZRUNNINGZPENDINGr` rk r! r rl rm rn r' r r� r ro rp rq rr rs r Z_ALGORITHM_TO_VALUE_MAPr. � 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� r$ r( r� r� r r r� r+ r r' r r r r ri s� � �� � � '� � - ( $ F ri )%r Z simplejsonr� � ImportErrorZlibcloud.utils.py3r Zlibcloud.utils.miscr Zlibcloud.loadbalancer.baser r r r r Z"libcloud.compute.drivers.rackspacer Zlibcloud.common.typesr Zlibcloud.common.baser r Zlibcloud.loadbalancer.typesr r Zlibcloud.common.openstackr Zlibcloud.common.rackspacer r| r rd r( r4 r: rD rI ri r r r r �<module> s^ ������� ,+/ $%
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка