# File lib/fog/rackspace/load_balancers.rb, line 107 def initialize(options={}) @rackspace_api_key = options[:rackspace_api_key] @rackspace_username = options[:rackspace_username] @rackspace_auth_url = options[:rackspace_auth_url] @rackspace_must_reauthenticate = false @connection_options = options[:connection_options] || {} setup_custom_endpoint(options) authenticate @persistent = options[:persistent] || false @connection = Fog::Connection.new(endpoint_uri.to_s, @persistent, @connection_options) end
# File lib/fog/rackspace/load_balancers.rb, line 149 def authenticate options = { :rackspace_api_key => @rackspace_api_key, :rackspace_username => @rackspace_username, :rackspace_auth_url => @rackspace_auth_url } super(options) end
# File lib/fog/rackspace/requests/load_balancers/create_access_rule.rb, line 5 def create_access_rule(load_balancer_id, address, type) #TODO - This can actually support adding multiple access rules. data = { 'accessList' => [ { 'address' => address, 'type' => type } ]} request( :body => Fog::JSON.encode(data), :expects => [200, 202], :method => 'POST', :path => "loadbalancers/#{load_balancer_id}/accesslist" ) end
# File lib/fog/rackspace/requests/load_balancers/create_load_balancer.rb, line 5 def create_load_balancer(name, protocol, port, virtual_ips, nodes, options = {}) data = { 'loadBalancer' => { 'name' => name, 'port' => port, 'protocol' => protocol, 'virtualIps' => virtual_ips, 'nodes' => nodes #Is algorithm allowed on create? } } data['loadBalancer']['algorithm'] = options[:algorithm] if options.has_key? :algorithm request( :body => Fog::JSON.encode(data), :expects => 202, :method => 'POST', :path => 'loadbalancers.json' ) end
# File lib/fog/rackspace/requests/load_balancers/create_node.rb, line 5 def create_node(load_balancer_id, address, port, condition, options = {}) data = { 'nodes' => [ { 'address' => address, 'port' => port, 'condition' => condition } ]} if options.has_key?(:weight) data['nodes'][0]['weight'] = options[:weight] end request( :body => Fog::JSON.encode(data), :expects => [200, 202], :method => 'POST', :path => "loadbalancers/#{load_balancer_id}/nodes.json" ) end
# File lib/fog/rackspace/requests/load_balancers/create_virtual_ip.rb, line 5 def create_virtual_ip(load_balancer_id, type) data = { 'type' => type, 'ipVersion' => 'IPV6' } request( :body => Fog::JSON.encode(data), :expects => [200, 202], :method => 'POST', :path => "loadbalancers/#{load_balancer_id}/virtualips.json" ) end
# File lib/fog/rackspace/requests/load_balancers/delete_access_rule.rb, line 5 def delete_access_rule(load_balancer_id, access_rule_id) request( :expects => [200, 202], :path => "loadbalancers/#{load_balancer_id}/accesslist/#{access_rule_id}", :method => 'DELETE' ) end
# File lib/fog/rackspace/requests/load_balancers/delete_all_access_rules.rb, line 5 def delete_all_access_rules(load_balancer_id) request( :expects => [200, 202], :path => "loadbalancers/#{load_balancer_id}/accesslist", :method => 'DELETE' ) end
# File lib/fog/rackspace/requests/load_balancers/delete_load_balancer.rb, line 5 def delete_load_balancer(load_balancer_id) request( :expects => 202, :path => "loadbalancers/#{load_balancer_id}.json", :method => 'DELETE' ) end
# File lib/fog/rackspace/requests/load_balancers/delete_node.rb, line 5 def delete_node(load_balancer_id, node_id) request( :expects => [200, 202], :path => "loadbalancers/#{load_balancer_id}/nodes/#{node_id}", :method => 'DELETE' ) end
# File lib/fog/rackspace/requests/load_balancers/delete_nodes.rb, line 5 def delete_nodes(load_balancer_id, *node_ids) query_string = node_ids.collect { |node_id| "id=#{node_id}" }.join('&') request( :expects => [200, 202], :path => "loadbalancers/#{load_balancer_id}/nodes?#{query_string}", :method => 'DELETE' ) end
# File lib/fog/rackspace/requests/load_balancers/delete_virtual_ip.rb, line 5 def delete_virtual_ip(load_balancer_id, virtual_ip_id) request( :expects => [200, 202], :path => "loadbalancers/#{load_balancer_id}/virtualips/#{virtual_ip_id}", :method => 'DELETE' ) end
# File lib/fog/rackspace/load_balancers.rb, line 166 def endpoint_uri(service_endpoint_url=nil) @uri = super(@rackspace_endpoint || service_endpoint_url, :rackspace_load_balancers_url) end
# File lib/fog/rackspace/requests/load_balancers/get_connection_logging.rb, line 5 def get_connection_logging(load_balancer_id) request( :expects => 200, :path => "loadbalancers/#{load_balancer_id}/connectionlogging", :method => 'GET' ) end
# File lib/fog/rackspace/requests/load_balancers/get_connection_throttling.rb, line 5 def get_connection_throttling(load_balancer_id) request( :expects => 200, :path => "loadbalancers/#{load_balancer_id}/connectionthrottle", :method => 'GET' ) end
# File lib/fog/rackspace/requests/load_balancers/get_content_caching.rb, line 5 def get_content_caching(load_balancer_id) request( :expects => 200, :path => "loadbalancers/#{load_balancer_id}/contentcaching", :method => 'GET' ) end
# File lib/fog/rackspace/requests/load_balancers/get_error_page.rb, line 5 def get_error_page(load_balancer_id) request( :expects => 200, :path => "loadbalancers/#{load_balancer_id}/errorpage", :method => 'GET' ) end
# File lib/fog/rackspace/requests/load_balancers/get_load_balancer.rb, line 5 def get_load_balancer(load_balancer_id) request( :expects => 200, :path => "loadbalancers/#{load_balancer_id}.json", :method => 'GET' ) end
# File lib/fog/rackspace/requests/load_balancers/get_load_balancer_usage.rb, line 5 def get_load_balancer_usage(load_balancer_id, options = {}) #TODO - Didn't implement usage/current. Not sure if it is needed if options.has_key? :start_time and options.has_key? :end_time query = "?startTime=#{options[:start_time]}&endTime=#{options[:end_time]}" else query = '' end request( :expects => 200, :path => "loadbalancers/#{load_balancer_id}/usage#{query}", :method => 'GET' ) end
# File lib/fog/rackspace/requests/load_balancers/get_monitor.rb, line 5 def get_monitor(load_balancer_id) request( :expects => 200, :path => "loadbalancers/#{load_balancer_id}/healthmonitor", :method => 'GET' ) end
# File lib/fog/rackspace/requests/load_balancers/get_node.rb, line 5 def get_node(load_balancer_id, node_id) request( :expects => 200, :path => "loadbalancers/#{load_balancer_id}/nodes/#{node_id}.json", :method => 'GET' ) end
# File lib/fog/rackspace/requests/load_balancers/get_session_persistence.rb, line 5 def get_session_persistence(load_balancer_id) request( :expects => 200, :path => "loadbalancers/#{load_balancer_id}/sessionpersistence", :method => 'GET' ) end
# File lib/fog/rackspace/requests/load_balancers/get_ssl_termination.rb, line 5 def get_ssl_termination(load_balancer_id) request( :expects => [200], :path => "loadbalancers/#{load_balancer_id}/ssltermination", :method => 'GET' ) end
# File lib/fog/rackspace/requests/load_balancers/get_usage.rb, line 5 def get_usage(options = {}) if options.has_key? :start_time and options.has_key? :end_time query = "?startTime=#{options[:start_time]}&endTime=#{options[:end_time]}" else query = '' end request( :expects => 200, :path => "loadbalancers/usage#{query}", :method => 'GET' ) end
# File lib/fog/rackspace/requests/load_balancers/list_access_rules.rb, line 5 def list_access_rules(load_balancer_id) request( :expects => 200, :method => 'GET', :path => "loadbalancers/#{load_balancer_id}/accesslist" ) end
# File lib/fog/rackspace/requests/load_balancers/list_algorithms.rb, line 5 def list_algorithms request( :expects => 200, :method => 'GET', :path => 'loadbalancers/algorithms' ) end
# File lib/fog/rackspace/requests/load_balancers/list_load_balancers.rb, line 5 def list_load_balancers(options = {}) if options.has_key? :node_address query_string = "?nodeaddress=#{options[:node_address]}" else query_string = '' end request( :expects => 200, :method => 'GET', :path => "loadbalancers.json?#{query_string}" ) end
# File lib/fog/rackspace/requests/load_balancers/list_nodes.rb, line 5 def list_nodes(load_balancer_id) request( :expects => 200, :method => 'GET', :path => "loadbalancers/#{load_balancer_id}/nodes.json" ) end
# File lib/fog/rackspace/requests/load_balancers/list_protocols.rb, line 5 def list_protocols request( :expects => 200, :method => 'GET', :path => 'loadbalancers/protocols' ) end
# File lib/fog/rackspace/requests/load_balancers/list_virtual_ips.rb, line 5 def list_virtual_ips(load_balancer_id) request( :expects => 200, :method => 'GET', :path => "loadbalancers/#{load_balancer_id}/virtualips.json" ) end
# File lib/fog/rackspace/load_balancers.rb, line 162 def region @rackspace_region end
# File lib/fog/rackspace/requests/load_balancers/remove_connection_throttling.rb, line 5 def remove_connection_throttling(load_balancer_id) request( :expects => [200, 202], :path => "loadbalancers/#{load_balancer_id}/connectionthrottle", :method => 'DELETE' ) end
# File lib/fog/rackspace/requests/load_balancers/remove_error_page.rb, line 5 def remove_error_page(load_balancer_id) request( :expects => [200, 202], :path => "loadbalancers/#{load_balancer_id}/errorpage", :method => 'DELETE' ) end
# File lib/fog/rackspace/requests/load_balancers/remove_monitor.rb, line 5 def remove_monitor(load_balancer_id) request( :expects => [200, 202], :path => "loadbalancers/#{load_balancer_id}/healthmonitor", :method => 'DELETE' ) end
# File lib/fog/rackspace/requests/load_balancers/remove_session_persistence.rb, line 5 def remove_session_persistence(load_balancer_id) request( :expects => [200, 202], :path => "loadbalancers/#{load_balancer_id}/sessionpersistence", :method => 'DELETE' ) end
# File lib/fog/rackspace/requests/load_balancers/remove_ssl_termination.rb, line 5 def remove_ssl_termination(load_balancer_id) request( :expects => [200, 202], :path => "loadbalancers/#{load_balancer_id}/ssltermination", :method => 'DELETE' ) end
# File lib/fog/rackspace/load_balancers.rb, line 122 def request(params) #TODO - Unify code with other rackspace services begin response = @connection.request(params.merge!({ :headers => { 'Content-Type' => 'application/json', 'Accept' => 'application/json', 'X-Auth-Token' => auth_token }.merge!(params[:headers] || {}), :host => endpoint_uri.host, :path => "#{endpoint_uri.path}/#{params[:path]}" })) rescue Excon::Errors::NotFound => error raise NotFound.slurp(error, region) rescue Excon::Errors::BadRequest => error raise BadRequest.slurp error rescue Excon::Errors::InternalServerError => error raise InternalServerError.slurp error rescue Excon::Errors::HTTPStatusError => error raise ServiceError.slurp error end unless response.body.empty? response.body = Fog::JSON.decode(response.body) end response end
# File lib/fog/rackspace/load_balancers.rb, line 158 def service_name :cloudLoadBalancers end
# File lib/fog/rackspace/requests/load_balancers/set_connection_logging.rb, line 5 def set_connection_logging(load_balancer_id, value) data = { 'connectionLogging' => { 'enabled' => value.to_s } } request( :body => Fog::JSON.encode(data), :expects => [200, 202], :path => "loadbalancers/#{load_balancer_id}/connectionlogging", :method => 'PUT' ) end
# File lib/fog/rackspace/requests/load_balancers/set_connection_throttling.rb, line 5 def set_connection_throttling(load_balancer_id, max_connections, min_connections, max_connection_rate, rate_interval) data = { 'maxConnections' => max_connections, 'minConnections' => min_connections, 'maxConnectionRate' => max_connection_rate, 'rateInterval' => rate_interval } request( :body => Fog::JSON.encode(data), :expects => [200, 202], :path => "loadbalancers/#{load_balancer_id}/connectionthrottle", :method => 'PUT' ) end
# File lib/fog/rackspace/requests/load_balancers/set_content_caching.rb, line 5 def set_content_caching(load_balancer_id, value) data = { 'contentCaching' => { 'enabled' => value.to_s } } request( :body => Fog::JSON.encode(data), :expects => [200, 202], :path => "loadbalancers/#{load_balancer_id}/contentcaching", :method => 'PUT' ) end
# File lib/fog/rackspace/requests/load_balancers/set_error_page.rb, line 5 def set_error_page(load_balancer_id, content) data = { 'errorpage' => { 'content' => content } } request( :body => Fog::JSON.encode(data), :expects => [200, 202], :path => "loadbalancers/#{load_balancer_id}/errorpage", :method => 'PUT' ) end
# File lib/fog/rackspace/requests/load_balancers/set_monitor.rb, line 5 def set_monitor(load_balancer_id, type, delay, timeout, attempsBeforeDeactivation, options = {}) data = { 'type' => type, 'delay' => delay, 'timeout' => timeout, 'attemptsBeforeDeactivation' => attempsBeforeDeactivation } if options.has_key? :path data['path'] = options[:path] end if options.has_key? :body_regex data['bodyRegex'] = options[:body_regex] end if options.has_key? :status_regex data['statusRegex'] = options[:status_regex] end request( :body => Fog::JSON.encode(data), :expects => [200, 202], :path => "loadbalancers/#{load_balancer_id}/healthmonitor", :method => 'PUT' ) end
# File lib/fog/rackspace/requests/load_balancers/set_session_persistence.rb, line 5 def set_session_persistence(load_balancer_id, persistence_type) data = { 'sessionPersistence' => { 'persistenceType' => persistence_type } } request( :body => Fog::JSON.encode(data), :expects => [200, 202], :path => "loadbalancers/#{load_balancer_id}/sessionpersistence", :method => 'PUT' ) end
# File lib/fog/rackspace/requests/load_balancers/set_ssl_termination.rb, line 5 def set_ssl_termination(load_balancer_id, securePort, privatekey, certificate, options = {}) data = { :securePort => securePort, :privatekey => privatekey, :certificate => certificate } if options.has_key? :intermediate_certificate data['intermediateCertificate'] = options[:intermediate_certificate] end if options.has_key? :enabled data['enabled'] = options[:enabled] end if options.has_key? :secure_traffic_only data['secureTrafficOnly'] = options[:secure_traffic_only] end request( :body => Fog::JSON.encode(data), :expects => [200, 202], :path => "loadbalancers/#{load_balancer_id}/ssltermination", :method => 'PUT' ) end
# File lib/fog/rackspace/requests/load_balancers/update_load_balancer.rb, line 5 def update_load_balancer(load_balancer_id, options = {}) data = { 'loadBalancer' => { 'name' => options[:name], 'port' => options[:port], 'protocol' => options[:protocol], 'algorithm' => options[:algorithm] } } request( :body => Fog::JSON.encode(data), :expects => 202, :method => 'PUT', :path => "loadbalancers/#{load_balancer_id}.json" ) end
# File lib/fog/rackspace/requests/load_balancers/update_node.rb, line 5 def update_node(load_balancer_id, node_id, options = {}) data = { 'node' => {} } if options.has_key? :weight data['node']['weight'] = options[:weight] end if options.has_key? :condition data['node']['condition'] = options[:condition] end #TODO - Do anything if no valid options are passed in? request( :body => Fog::JSON.encode(data), :expects => [200, 202], :method => 'PUT', :path => "loadbalancers/#{load_balancer_id}/nodes/#{node_id}.json" ) end
Generated with the Darkfish Rdoc Generator 2.