class AwsClient::ElastiCacheWrapper

Public Instance Methods

cache_clusters() click to toggle source
# File lib/elasticache_wrapper.rb, line 39
def cache_clusters
  all_cache_messages = get_all_instances
  return all_cache_messages.collect{|cache_message| cache_message.cache_clusters }.flatten
end
clusters_by_engine_type(engine_type) click to toggle source
# File lib/elasticache_wrapper.rb, line 35
def clusters_by_engine_type(engine_type)
  cache_clusters.select{|cache_cluster| cache_cluster.engine == engine_type }
end
get_all_instances() click to toggle source
# File lib/elasticache_wrapper.rb, line 44
def get_all_instances
  all_instances = []
  pages = client.describe_cache_clusters(:show_cache_node_info => true)
  all_instances << pages.data
  while pages.next_page?
    pages = pages.next_page
    @all_instances << pages.data
  end
  return all_instances
end
memcache_clusters() click to toggle source
# File lib/elasticache_wrapper.rb, line 31
def memcache_clusters
  clusters_by_engine_type("memcached")
end
memcached_cluster_by_identifier(identifier) click to toggle source
# File lib/elasticache_wrapper.rb, line 23
def memcached_cluster_by_identifier(identifier)
  memcache_clusters.select{|cluster| cluster.cache_cluster_id == identifier }.first
end
memcached_endpoints_by_identifier(identifier) click to toggle source
# File lib/elasticache_wrapper.rb, line 7
 def memcached_endpoints_by_identifier(identifier)
  cluster = memcached_cluster_by_identifier(identifier)
  return [] unless cluster
  cluster.cache_nodes.collect{|cache_node| cache_node.endpoint }
end
redis_cluster_by_identifier(identifier) click to toggle source
# File lib/elasticache_wrapper.rb, line 19
def redis_cluster_by_identifier(identifier)
  redis_clusters.select{|cluster| cluster.cache_cluster_id == identifier }.first
end
redis_clusters() click to toggle source
# File lib/elasticache_wrapper.rb, line 27
def redis_clusters
  clusters_by_engine_type("redis")
end
redis_endpoints_by_identifier(identifier) click to toggle source
# File lib/elasticache_wrapper.rb, line 13
def redis_endpoints_by_identifier(identifier)
  cluster = redis_cluster_by_identifier(identifier)
  return [] unless cluster
  cluster.cache_nodes.collect{|cache_node| cache_node.endpoint }
end