Module: Fluent::KinesisHelper::API

Defined in:
lib/fluent/plugin/kinesis_helper/api.rb

Defined Under Namespace

Classes: Backoff

Instance Method Summary collapse

Instance Method Details

#configure(conf) ⇒ Object 



20
21
22
23
24
25
26
27
28
29
 
# File 'lib/fluent/plugin/kinesis_helper/api.rb', line 20

def configure(conf)
  super
  if @batch_request_max_count > self.class::BatchRequestLimitCount
    raise ConfigError, "batch_request_max_count can't be grater than #{self.class::BatchRequestLimitCount}."
  end
  if @batch_request_max_size > self.class::BatchRequestLimitSize
    raise ConfigError, "batch_request_max_size can't be grater than #{self.class::BatchRequestLimitSize}."
  end
  @region = client.config.region if @region.nil?
end

#start ⇒ Object 



31
32
33
34
35
 
# File 'lib/fluent/plugin/kinesis_helper/api.rb', line 31

def start
  detach_multi_process do
    super
  end
end