Sha256: 6434948cd3a1f2ff18e8279f86a47b9b2869a145ae63b503b2b4ae5dc880a8d2
Contents?: true
Size: 861 Bytes
Versions: 34
Compression:
Stored size: 861 Bytes
Contents
require 'flydata/fluent-plugins/flydata_plugin_ext/flydata_sync'
module Fluent
module FlydataSyncDiffBased
def self.include_modules(base)
base.send(:include, FlydataSync)
base.send(:include, self)
end
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
def configure(conf)
super
@table_src_pos_files = @tables.inject({}) do |ret, table_name|
ret[table_name.to_sym] = self.class::SOURCE_POSITION_FILE_CLASS.new(
@sync_fm.table_source_pos_file_path(table_name)
)
ret
end
end
end
end
Version data entries
34 entries across 34 versions & 1 rubygems