mirror of
https://github.com/fog/fog.git
synced 2022-11-09 13:51:43 -05:00
45 lines
1.4 KiB
Ruby
45 lines
1.4 KiB
Ruby
|
module Fog
|
||
|
|
module AWS
|
||
|
|
class Elasticache
|
||
|
|
class Real
|
||
|
|
|
||
|
|
require 'fog/aws/parsers/elasticache/single_cache_cluster'
|
||
|
|
|
||
|
|
# Reboots some or all of an existing cache cluster's nodes
|
||
|
|
# Returns a cache cluster description
|
||
|
|
#
|
||
|
|
# === Required Parameters
|
||
|
|
# * id <~String> - The ID of the existing cluster to be rebooted
|
||
|
|
# === Optional Parameters
|
||
|
|
# * nodes_to_reboot <~Array> - Array of node IDs to reboot
|
||
|
|
# === Returns
|
||
|
|
# * response <~Excon::Response>:
|
||
|
|
# * body <~Hash>
|
||
|
|
def reboot_cache_cluster(id, nodes_to_reboot)
|
||
|
|
# Construct CacheNodeIdsToReboot parameters in the format:
|
||
|
|
# CacheNodeIdsToReboot.member.N => "node_id"
|
||
|
|
node_ids = nodes_to_reboot || []
|
||
|
|
node_id_params = node_ids.inject({}) do |node_hash, node_id|
|
||
|
|
index = node_ids.index(node_id) + 1
|
||
|
|
node_hash["CacheNodeIdsToReboot.member.#{index}"] = node_id
|
||
|
|
node_hash
|
||
|
|
end
|
||
|
|
# Merge the CacheNodeIdsToReboot parameters with the normal options
|
||
|
|
request(node_id_params.merge(
|
||
|
|
'Action' => 'RebootCacheCluster',
|
||
|
|
'CacheClusterId' => id,
|
||
|
|
:parser => Fog::Parsers::AWS::Elasticache::SingleCacheCluster.new
|
||
|
|
))
|
||
|
|
end
|
||
|
|
|
||
|
|
end
|
||
|
|
|
||
|
|
class Mock
|
||
|
|
def reboot_cache_cluster
|
||
|
|
Fog::Mock.not_implemented
|
||
|
|
end
|
||
|
|
end
|
||
|
|
end
|
||
|
|
end
|
||
|
|
end
|