Module: Fluent::KinesisHelper::API

Included in:
Fluent::KinesisOutput
Defined in:
lib/fluent/plugin/kinesis_helper/api.rb

Defined Under Namespace

Modules: APIParams, BatchRequest

Constant Summary collapse

MaxRecordSize =

1 MB

1024 * 1024

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.included(mod) ⇒ Object 



28
29
30
 
# File 'lib/fluent/plugin/kinesis_helper/api.rb', line 28

def self.included(mod)
  mod.include APIParams
end

Instance Method Details

#configure(conf) ⇒ Object 



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

def configure(conf)
  super
  if @max_record_size > MaxRecordSize
    raise ConfigError, "max_record_size can't be grater than #{MaxRecordSize/1024} KB."
  end
end