Contents

module Mysql
  class Context
    MANDATORY_OPTS = [
      :database, :tables, :tag, :sync_fm,
    ]
    OPTIONAL_OPTS = [
      :current_binlog_file,
    ]

    (MANDATORY_OPTS + OPTIONAL_OPTS).each do |opt|
      attr_accessor opt
    end

    def initialize(opts)
      missing_opts = MANDATORY_OPTS - opts.keys
      unless (missing_opts.empty?)
        raise "Mandatory option(s) are missing: #{missing_opts.join(', ')}"
      end

      opts.each do |k, v|
        self.instance_variable_set(:"@#{k}", v)
      end
    end
  end
end

Version data entries

9 entries across 9 versions & 1 rubygems

Version	Path
flydata-0.2.1	lib/flydata/fluent-plugins/mysql/context.rb
flydata-0.2.0	lib/flydata/fluent-plugins/mysql/context.rb
flydata-0.1.15	lib/flydata/fluent-plugins/mysql/context.rb
flydata-0.1.13	lib/flydata/fluent-plugins/mysql/context.rb
flydata-0.1.12	lib/flydata/fluent-plugins/mysql/context.rb
flydata-0.1.11	lib/flydata/fluent-plugins/mysql/context.rb
flydata-0.1.10	lib/flydata/fluent-plugins/mysql/context.rb
flydata-0.1.9	lib/flydata/fluent-plugins/mysql/context.rb
flydata-0.1.8	lib/flydata/fluent-plugins/mysql/context.rb