mirror of
https://github.com/fog/fog-aws.git
synced 2022-11-09 13:50:52 -05:00
Cleanup
This commit is contained in:
parent
b5a1a3576c
commit
4012f0dc43
4 changed files with 16 additions and 20 deletions
|
@ -19,11 +19,10 @@ module Fog
|
|||
"StreamName" => options.delete("StreamName")
|
||||
}.reject{ |_,v| v.nil? }
|
||||
|
||||
response = request({
|
||||
'X-Amz-Target' => "Kinesis_#{@version}.CreateStream",
|
||||
:body => body,
|
||||
}.merge(options))
|
||||
response
|
||||
request({
|
||||
'X-Amz-Target' => "Kinesis_#{@version}.CreateStream",
|
||||
:body => body,
|
||||
}.merge(options))
|
||||
end
|
||||
end
|
||||
|
||||
|
|
|
@ -17,11 +17,10 @@ module Fog
|
|||
"StreamName" => options.delete("StreamName")
|
||||
}.reject{ |_,v| v.nil? }
|
||||
|
||||
response = request({
|
||||
'X-Amz-Target' => "Kinesis_#{@version}.DeleteStream",
|
||||
:body => body,
|
||||
}.merge(options))
|
||||
response
|
||||
request({
|
||||
'X-Amz-Target' => "Kinesis_#{@version}.DeleteStream",
|
||||
:body => body,
|
||||
}.merge(options))
|
||||
end
|
||||
end
|
||||
|
||||
|
|
|
@ -21,11 +21,10 @@ module Fog
|
|||
"StreamName" => options.delete("StreamName")
|
||||
}.reject{ |_,v| v.nil? }
|
||||
|
||||
response = request({
|
||||
'X-Amz-Target' => "Kinesis_#{@version}.MergeShards",
|
||||
:body => body,
|
||||
}.merge(options))
|
||||
response
|
||||
request({
|
||||
'X-Amz-Target' => "Kinesis_#{@version}.MergeShards",
|
||||
:body => body,
|
||||
}.merge(options))
|
||||
end
|
||||
end
|
||||
|
||||
|
|
|
@ -21,11 +21,10 @@ module Fog
|
|||
"StreamName" => options.delete("StreamName")
|
||||
}.reject{ |_,v| v.nil? }
|
||||
|
||||
response = request({
|
||||
'X-Amz-Target' => "Kinesis_#{@version}.SplitShard",
|
||||
:body => body,
|
||||
}.merge(options))
|
||||
response
|
||||
request({
|
||||
'X-Amz-Target' => "Kinesis_#{@version}.SplitShard",
|
||||
:body => body,
|
||||
}.merge(options))
|
||||
end
|
||||
end
|
||||
|
||||
|
|
Loading…
Reference in a new issue