require 'flydata/fluent-plugins/flydata_plugin_ext/flydata_sync_diff_based'

module Fluent

  module FlydataSyncQueryBased
    def self.include_modules(base)
      FlydataSyncDiffBased.include_modules(base)
      base.send(:include, self)
    end

    def self.included(base)
      base.class_eval do
        config_param :host, :string
        config_param :port, :integer
        config_param :username, :string
        config_param :password, :string
        config_param :database, :string
        config_param :schema, :string, default: nil
      end
    end

    def configure(conf)
      super
    end
  end
end