def split_shard(options={})
stream_name = options.delete("StreamName")
shard_id = options.delete("ShardToSplit")
stream = data[:kinesis_streams].detect{ |s| s["StreamName"] == stream_name }
unless stream = data[:kinesis_streams].detect{ |s| s["StreamName"] == stream_name }
raise Fog::AWS::Kinesis::ResourceNotFound.new("Stream #{stream_name} under account #{@account_id} not found.")
end
unless shard = stream["Shards"].detect{ |shard| shard["ShardId"] == shard_id }
raise Fog::AWS::Kinesis::ResourceNotFound.new("Could not find shard #{shard_id} in stream #{stream_name} under account #{@account_id}.")
end
shard["SequenceNumberRange"]["EndingSequenceNumber"] = next_sequence_number
parent_starting_hash_key = shard["HashKeyRange"]["StartingHashKey"]
parent_ending_hash_key = shard["HashKeyRange"]["EndingHashKey"]
new_starting_hash_key = options.delete("NewStartingHashKey")
stream["Shards"] << {
"HashKeyRange"=> {
"EndingHashKey" => (new_starting_hash_key.to_i - 1).to_s,
"StartingHashKey" => parent_starting_hash_key
},
"SequenceNumberRange" => {
"StartingSequenceNumber" => next_sequence_number
},
"ShardId" => next_shard_id,
"ParentShardId" => shard_id
}
stream["Shards"] << {
"HashKeyRange" => {
"EndingHashKey" => parent_ending_hash_key,
"StartingHashKey" => new_starting_hash_key
},
"SequenceNumberRange" =>{
"StartingSequenceNumber" => next_sequence_number
},
"ShardId" => next_shard_id,
"ParentShardId" => shard_id
}
response = Excon::Response.new
response.status = 200
response.body = ""
response
end