lib/runcible/extensions/consumer_group.rb in runcible-0.4.12 vs lib/runcible/extensions/consumer_group.rb in runcible-1.0.0
- old
+ new
@@ -29,28 +29,28 @@
# Add consumers by ID to a consumer group
#
# @param [String] id the consumer group ID
# @param [Array] consumer_ids array of consumer IDs to add to the group
# @return [RestClient::Response] list of consumer IDs
- def self.add_consumers_by_id(id, consumer_ids)
- self.associate(id, make_consumer_criteria(consumer_ids))
+ def add_consumers_by_id(id, consumer_ids)
+ associate(id, make_consumer_criteria(consumer_ids))
end
# Remove consumers by ID from a consumer group
#
# @param [String] id the consumer group ID
# @param [Array] consumer_ids array of consumer IDs to remove from the group
# @return [RestClient::Response] list of consumer IDs
- def self.remove_consumers_by_id(id, consumer_ids)
- self.unassociate(id, make_consumer_criteria(consumer_ids))
+ def remove_consumers_by_id(id, consumer_ids)
+ unassociate(id, make_consumer_criteria(consumer_ids))
end
# Generates consumer criteria query
#
# @param [Array] consumer_ids array of consumer IDs
# @return [Hash] the formatted query for consumers
- def self.make_consumer_criteria(consumer_ids)
+ def make_consumer_criteria(consumer_ids)
{:criteria =>
{:filters =>
{:id =>{"$in" =>consumer_ids}}
}
}
@@ -61,41 +61,41 @@
# @param [String] id the consumer group ID
# @param [String] type_id the type of content to install (e.g. rpm, errata)
# @param [Array] units array of units to install
# @param [Hash] options to pass to content install
# @return [RestClient::Response] task representing the install operation
- def self.install_content(id, type_id, units, options={})
- self.install_units(id, generate_content(type_id, units), options)
+ def install_content(id, type_id, units, options={})
+ install_units(id, generate_content(type_id, units), options)
end
# Update content on a consumer group
#
# @param [String] id the consumer group ID
# @param [String] type_id the type of content to update (e.g. rpm, errata)
# @param [Array] units array of units to update
# @param [Hash] options to pass to content update
# @return [RestClient::Response] task representing the update operation
- def self.update_content(id, type_id, units, options={})
- self.update_units(id, generate_content(type_id, units, options), options)
+ def update_content(id, type_id, units, options={})
+ update_units(id, generate_content(type_id, units, options), options)
end
# Uninstall content from a consumer group
#
# @param [String] id the consumer group ID
# @param [String] type_id the type of content to uninstall (e.g. rpm, errata)
# @param [Array] units array of units to uninstall
# @return [RestClient::Response] task representing the uninstall operation
- def self.uninstall_content(id, type_id, units)
- self.uninstall_units(id, generate_content(type_id, units))
+ def uninstall_content(id, type_id, units)
+ uninstall_units(id, generate_content(type_id, units))
end
# Generate the content units used by other functions
#
# @param [String] type_id the type of content (e.g. rpm, errata)
# @param [Array] units array of units
# @param [Hash] options contains options which may impact the format of the content (e.g :all => true)
# @return [Array] array of formatted content units
- def self.generate_content(type_id, units, options={})
+ def generate_content(type_id, units, options={})
content = []
case type_id
when 'rpm', 'package_group'
unit_key = :name