# File lib/fog/aws/models/data_pipeline/pipeline.rb, line 17 def initialize(attributes={}) # Extract the 'fields' portion of a response to attributes if attributes.include?('fields') string_fields = attributes['fields'].select { |f| f.include?('stringValue') } field_attributes = Hash[string_fields.map { |f| [f['key'][/^@(.+)$/, 1], f['stringValue']] }] merge_attributes(field_attributes) end super end
# File lib/fog/aws/models/data_pipeline/pipeline.rb, line 39 def activate requires :id service.activate_pipeline(id) true end
# File lib/fog/aws/models/data_pipeline/pipeline.rb, line 55 def destroy requires :id service.delete_pipeline(id) true end
# File lib/fog/aws/models/data_pipeline/pipeline.rb, line 47 def put(objects) requires :id service.put_pipeline_definition(id, objects) true end
# File lib/fog/aws/models/data_pipeline/pipeline.rb, line 29 def save requires :name requires :unique_id data = service.create_pipeline(unique_id, name) merge_attributes(data) true end