authenticate(options={})
click to toggle source
def authenticate(options={})
super({
:rackspace_api_key => @rackspace_api_key,
:rackspace_username => @rackspace_username,
:rackspace_auth_url => @rackspace_auth_url,
:connection_options => @connection_options
})
end
create_access_rule(load_balancer_id, address, type)
click to toggle source
def create_access_rule(load_balancer_id, address, type)
data = {
'accessList' => [
{
'address' => address,
'type' => type
}
]}
request(
:body => Fog::JSON.encode(data),
:expects => [200, 202],
:method => 'POST',
:path => "loadbalancers/#{load_balancer_id}/accesslist"
)
end
create_load_balancer(name, protocol, port, virtual_ips, nodes, options = {})
click to toggle source
def create_load_balancer(name, protocol, port, virtual_ips, nodes, options = {})
data = {
'loadBalancer' => {
'name' => name,
'port' => port,
'protocol' => protocol,
'virtualIps' => virtual_ips,
'nodes' => nodes
}
}
data['loadBalancer']['algorithm'] = options[:algorithm] if options.has_key? :algorithm
data['loadBalancer']['timeout'] = options[:timeout] if options.has_key? :timeout
request(
:body => Fog::JSON.encode(data),
:expects => 202,
:method => 'POST',
:path => 'loadbalancers.json'
)
end
create_node(load_balancer_id, address, port, condition, options = {})
click to toggle source
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
create_virtual_ip(load_balancer_id, type)
click to toggle source
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
delete_access_rule(load_balancer_id, access_rule_id)
click to toggle source
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
delete_all_access_rules(load_balancer_id)
click to toggle source
def delete_all_access_rules(load_balancer_id)
request(
:expects => [200, 202],
:path => "loadbalancers/#{load_balancer_id}/accesslist",
:method => 'DELETE'
)
end
delete_load_balancer(load_balancer_id)
click to toggle source
def delete_load_balancer(load_balancer_id)
request(
:expects => 202,
:path => "loadbalancers/#{load_balancer_id}.json",
:method => 'DELETE'
)
end
delete_node(load_balancer_id, node_id)
click to toggle source
def delete_node(load_balancer_id, node_id)
request(
:expects => [200, 202],
:path => "loadbalancers/#{load_balancer_id}/nodes/#{node_id}",
:method => 'DELETE'
)
end
delete_nodes(load_balancer_id, *node_ids)
click to toggle source
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
delete_virtual_ip(load_balancer_id, virtual_ip_id)
click to toggle source
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
endpoint_uri(service_endpoint_url=nil)
click to toggle source
def endpoint_uri(service_endpoint_url=nil)
@uri = super(@rackspace_endpoint || service_endpoint_url, :rackspace_load_balancers_url)
end
get_connection_logging(load_balancer_id)
click to toggle source
def get_connection_logging(load_balancer_id)
request(
:expects => 200,
:path => "loadbalancers/#{load_balancer_id}/connectionlogging",
:method => 'GET'
)
end
get_connection_throttling(load_balancer_id)
click to toggle source
def get_connection_throttling(load_balancer_id)
request(
:expects => 200,
:path => "loadbalancers/#{load_balancer_id}/connectionthrottle",
:method => 'GET'
)
end
get_content_caching(load_balancer_id)
click to toggle source
def get_content_caching(load_balancer_id)
request(
:expects => 200,
:path => "loadbalancers/#{load_balancer_id}/contentcaching",
:method => 'GET'
)
end
get_error_page(load_balancer_id)
click to toggle source
def get_error_page(load_balancer_id)
request(
:expects => 200,
:path => "loadbalancers/#{load_balancer_id}/errorpage",
:method => 'GET'
)
end
get_load_balancer(load_balancer_id)
click to toggle source
def get_load_balancer(load_balancer_id)
request(
:expects => 200,
:path => "loadbalancers/#{load_balancer_id}.json",
:method => 'GET'
)
end
get_load_balancer_usage(load_balancer_id, options = {})
click to toggle source
def get_load_balancer_usage(load_balancer_id, 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/#{load_balancer_id}/usage#{query}",
:method => 'GET'
)
end
get_monitor(load_balancer_id)
click to toggle source
def get_monitor(load_balancer_id)
request(
:expects => 200,
:path => "loadbalancers/#{load_balancer_id}/healthmonitor",
:method => 'GET'
)
end
get_node(load_balancer_id, node_id)
click to toggle source
def get_node(load_balancer_id, node_id)
request(
:expects => 200,
:path => "loadbalancers/#{load_balancer_id}/nodes/#{node_id}.json",
:method => 'GET'
)
end
get_session_persistence(load_balancer_id)
click to toggle source
def get_session_persistence(load_balancer_id)
request(
:expects => 200,
:path => "loadbalancers/#{load_balancer_id}/sessionpersistence",
:method => 'GET'
)
end
get_ssl_termination(load_balancer_id)
click to toggle source
def get_ssl_termination(load_balancer_id)
request(
:expects => [200],
:path => "loadbalancers/#{load_balancer_id}/ssltermination",
:method => 'GET'
)
end
get_usage(options = {})
click to toggle source
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
list_access_rules(load_balancer_id)
click to toggle source
def list_access_rules(load_balancer_id)
request(
:expects => 200,
:method => 'GET',
:path => "loadbalancers/#{load_balancer_id}/accesslist"
)
end
list_algorithms()
click to toggle source
def list_algorithms
request(
:expects => 200,
:method => 'GET',
:path => 'loadbalancers/algorithms'
)
end
list_load_balancers(options = {})
click to toggle source
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
list_nodes(load_balancer_id)
click to toggle source
def list_nodes(load_balancer_id)
request(
:expects => 200,
:method => 'GET',
:path => "loadbalancers/#{load_balancer_id}/nodes.json"
)
end
list_protocols()
click to toggle source
def list_protocols
request(
:expects => 200,
:method => 'GET',
:path => 'loadbalancers/protocols'
)
end
list_virtual_ips(load_balancer_id)
click to toggle source
def list_virtual_ips(load_balancer_id)
request(
:expects => 200,
:method => 'GET',
:path => "loadbalancers/#{load_balancer_id}/virtualips.json"
)
end
region()
click to toggle source
def region
@rackspace_region
end
remove_connection_throttling(load_balancer_id)
click to toggle source
def remove_connection_throttling(load_balancer_id)
request(
:expects => [200, 202],
:path => "loadbalancers/#{load_balancer_id}/connectionthrottle",
:method => 'DELETE'
)
end
remove_error_page(load_balancer_id)
click to toggle source
def remove_error_page(load_balancer_id)
request(
:expects => [200, 202],
:path => "loadbalancers/#{load_balancer_id}/errorpage",
:method => 'DELETE'
)
end
remove_monitor(load_balancer_id)
click to toggle source
def remove_monitor(load_balancer_id)
request(
:expects => [200, 202],
:path => "loadbalancers/#{load_balancer_id}/healthmonitor",
:method => 'DELETE'
)
end
remove_session_persistence(load_balancer_id)
click to toggle source
def remove_session_persistence(load_balancer_id)
request(
:expects => [200, 202],
:path => "loadbalancers/#{load_balancer_id}/sessionpersistence",
:method => 'DELETE'
)
end
remove_ssl_termination(load_balancer_id)
click to toggle source
def remove_ssl_termination(load_balancer_id)
request(
:expects => [200, 202],
:path => "loadbalancers/#{load_balancer_id}/ssltermination",
:method => 'DELETE'
)
end
request(params, parse_json = true, &block)
click to toggle source
def request(params, parse_json = true, &block)
super(params, parse_json, &block)
rescue Excon::Errors::NotFound => error
raise NotFound.slurp(error, self)
rescue Excon::Errors::BadRequest => error
raise BadRequest.slurp(error, self)
rescue Excon::Errors::InternalServerError => error
raise InternalServerError.slurp(error, self)
rescue Excon::Errors::HTTPStatusError => error
raise ServiceError.slurp(error, self)
end
service_name()
click to toggle source
def service_name
:cloudLoadBalancers
end
set_connection_logging(load_balancer_id, value)
click to toggle source
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
set_connection_throttling(load_balancer_id, max_connections, min_connections, max_connection_rate, rate_interval)
click to toggle source
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
set_content_caching(load_balancer_id, value)
click to toggle source
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
set_error_page(load_balancer_id, content)
click to toggle source
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
set_monitor(load_balancer_id, type, delay, timeout, attempsBeforeDeactivation, options = {})
click to toggle source
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
set_session_persistence(load_balancer_id, persistence_type)
click to toggle source
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
set_ssl_termination(load_balancer_id, securePort, privatekey, certificate, options = {})
click to toggle source
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
update_load_balancer(load_balancer_id, options = {})
click to toggle source
def update_load_balancer(load_balancer_id, options = {})
data = {
'loadBalancer' => {
'name' => options[:name],
'port' => options[:port],
'protocol' => options[:protocol],
'algorithm' => options[:algorithm],
'timeout' => options[:timeout]
}
}
request(
:body => Fog::JSON.encode(data),
:expects => 202,
:method => 'PUT',
:path => "loadbalancers/#{load_balancer_id}.json"
)
end
update_node(load_balancer_id, node_id, options = {})
click to toggle source
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
request(
:body => Fog::JSON.encode(data),
:expects => [200, 202],
:method => 'PUT',
:path => "loadbalancers/#{load_balancer_id}/nodes/#{node_id}.json"
)
end