class Fluent::Plugin::KinesisHelper::API::BatchRequest::Backoff
Public Class Methods
new()
click to toggle source
# File lib/fluent/plugin/kinesis_helper/api.rb, line 170 def initialize @count = 0 end
Public Instance Methods
next()
click to toggle source
# File lib/fluent/plugin/kinesis_helper/api.rb, line 174 def next value = calc(@count) @count += 1 value end
reset()
click to toggle source
# File lib/fluent/plugin/kinesis_helper/api.rb, line 180 def reset @count = 0 end
Private Instance Methods
calc(count)
click to toggle source
# File lib/fluent/plugin/kinesis_helper/api.rb, line 186 def calc(count) (2 ** count) * scaling_factor end
scaling_factor()
click to toggle source
# File lib/fluent/plugin/kinesis_helper/api.rb, line 190 def scaling_factor 0.3 + (0.5-rand) * 0.1 end