Method: Fluent::FlydataSyncDiffBased.included

Defined in:
lib/flydata/fluent-plugins/flydata_plugin_ext/flydata_sync_diff_based.rb

.included(base) ⇒ Object 



11
12
13
14
15
16
17
 
# File 'lib/flydata/fluent-plugins/flydata_plugin_ext/flydata_sync_diff_based.rb', line 11

def self.included(base)
  base.class_eval do
    config_param :fetch_interval, :time, default: 60   # 1 minute
    config_param :retry_interval, :time, default: 30   # 30 seconds
    config_param :emit_chunk_limit, :size, default: 64 * (1024 ** 2)   # 64MB, should be equal or less than buffer_chunk_limit
  end
end