kotovalexarian-likes-github/fog--fog-aws
1
0
Fork 0
mirror of https://github.com/fog/fog-aws.git synced 2022-11-09 13:50:52 -05:00
Code Releases Activity

Extract version

Browse source
This commit is contained in:
Michael Hale 2015-06-24 16:41:21 -04:00
parent 7741d4035a
commit 398aa7b108
8 changed files with 12 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
lib/fog/aws/kinesis.rb
View file

@ -41,6 +41,7 @@ module Fog
@port = options[:port] || 443
@scheme = options[:scheme] || 'https'
@connection = Fog::XML::Connection.new("#{@scheme}://#{@host}:#{@port}#{@path}", @persistent, @connection_options)
@version = "20131202"
setup_credentials(options)
end

2
lib/fog/aws/requests/kinesis/create_stream.rb
View file

@ -20,7 +20,7 @@ module Fog
}.reject{ |_,v| v.nil? }
response = request({
'X-Amz-Target' => 'Kinesis_20131202.CreateStream',
'X-Amz-Target' => 'Kinesis_#{@version}.CreateStream',
:body => body,
}.merge(options))
# response.body = Fog::JSON.decode(response.body) unless response.body.nil?

2
lib/fog/aws/requests/kinesis/delete_stream.rb
View file

@ -18,7 +18,7 @@ module Fog
}.reject{ |_,v| v.nil? }
response = request({
'X-Amz-Target' => 'Kinesis_20131202.DeleteStream',
'X-Amz-Target' => 'Kinesis_#{@version}.DeleteStream',
:body => body,
}.merge(options))
# response.body = Fog::JSON.decode(response.body) unless response.body.nil?

3
lib/fog/aws/requests/kinesis/describe_stream.rb
View file

@ -22,7 +22,8 @@ module Fog
}.reject{ |_,v| v.nil? }
response = request({
'X-Amz-Target' => 'Kinesis_20131202.DescribeStream',
:idempotent => true,
'X-Amz-Target' => 'Kinesis_#{@version}.DescribeStream',
:body => body,
}.merge(options))
response.body = Fog::JSON.decode(response.body) unless response.body.nil?

3
lib/fog/aws/requests/kinesis/get_records.rb
View file

@ -20,7 +20,8 @@ module Fog
}.reject{ |_,v| v.nil? }
response = request({
'X-Amz-Target' => 'Kinesis_20131202.GetRecords',
:idempotent => true,
'X-Amz-Target' => 'Kinesis_#{@version}.GetRecords',
:body => body,
}.merge(options))
response.body = Fog::JSON.decode(response.body) unless response.body.nil?

3
lib/fog/aws/requests/kinesis/get_shard_iterator.rb
View file

@ -24,7 +24,8 @@ module Fog
}.reject{ |_,v| v.nil? }
response = request({
'X-Amz-Target' => 'Kinesis_20131202.GetShardIterator',
:idempotent => true,
'X-Amz-Target' => 'Kinesis_#{@version}.GetShardIterator',
:body => body,
}.merge(options))
response.body = Fog::JSON.decode(response.body) unless response.body.nil?

3
lib/fog/aws/requests/kinesis/list_streams.rb
View file

@ -15,7 +15,8 @@ module Fog
#
def list_streams(options={})
response = request({
'X-Amz-Target' => 'Kinesis_20131202.ListStreams',
:idempotent => true,
'X-Amz-Target' => 'Kinesis_#{@version}.ListStreams',
:body => {},
}.merge(options))
response.body = Fog::JSON.decode(response.body) unless response.body.nil?

2
lib/fog/aws/requests/kinesis/put_records.rb
View file

@ -24,7 +24,7 @@ module Fog
}.reject{ |_,v| v.nil? }
response = request({
'X-Amz-Target' => 'Kinesis_20131202.PutRecords',
'X-Amz-Target' => 'Kinesis_#{@version}.PutRecords',
:body => body,
}.merge(options))
response.body = Fog::JSON.decode(response.body) unless response.body.nil?