Class: Fluent::KinesisOutput

Inherits:
BufferedOutput
  • Object
show all
Includes:
Fluent::KinesisHelper::API, Fluent::KinesisHelper::Client, SetTagKeyMixin, SetTimeKeyMixin
Defined in:
lib/fluent/plugin/kinesis.rb

Defined Under Namespace

Classes: ExceedMaxRecordSizeError, InvalidRecordError, KeyNotFoundError, SkipRecordError

Constant Summary

Constants included from Fluent::KinesisHelper::API

Fluent::KinesisHelper::API::MaxRecordSize

Class Method Summary collapse

Instance Method Summary collapse

Methods included from Fluent::KinesisHelper::API

included

Methods included from Fluent::KinesisHelper::Client

#client, included

Class Method Details

.fluentd_v0_12? ⇒ Boolean

Returns:

  • (Boolean) 


21
22
23
 
# File 'lib/fluent/plugin/kinesis.rb', line 21

def self.fluentd_v0_12?
  @fluentd_v0_12 ||= Gem.loaded_specs['fluentd'].version < Gem::Version.create('0.14')
end

Instance Method Details

#configure(conf) ⇒ Object 



80
81
82
83
 
# File 'lib/fluent/plugin/kinesis.rb', line 80

def configure(conf)
  super
  @data_formatter = data_formatter_create(conf)
end

#multi_workers_ready? ⇒ Boolean

Returns:

  • (Boolean) 


85
86
87
 
# File 'lib/fluent/plugin/kinesis.rb', line 85

def multi_workers_ready?
  true
end