# File lib/fog/aws/requests/data_pipeline/put_pipeline_definition.rb, line 34 def initialize(object) @json_fields = object.clone @id = @json_fields.delete('id') @name = @json_fields.delete('name') || @id end
# File lib/fog/aws/requests/data_pipeline/put_pipeline_definition.rb, line 40 def to_api { 'id' => @id, 'name' => @name, 'fields' => fields } end
# File lib/fog/aws/requests/data_pipeline/put_pipeline_definition.rb, line 54 def field_for_kv(key, value) if value.is_a?(Hash) { 'key' => key, 'refValue' => value['ref'] } elsif value.is_a?(Array) value.map { |subvalue| field_for_kv(key, subvalue) } else { 'key' => key, 'stringValue' => value } end end
# File lib/fog/aws/requests/data_pipeline/put_pipeline_definition.rb, line 50 def fields @json_fields.map{|k,v| field_for_kv(k,v)}.flatten end