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