Contents

module Mysql
  class Context
    MANDATORY_OPTS = [
      :database, :tables, :tag, :sync_fm, :omit_events, :table_meta, :table_revs,
    ]
    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

66 entries across 66 versions & 1 rubygems

Version	Path
flydata-0.6.11	lib/flydata/fluent-plugins/mysql/context.rb
flydata-0.6.10	lib/flydata/fluent-plugins/mysql/context.rb
flydata-0.6.9	lib/flydata/fluent-plugins/mysql/context.rb
flydata-0.6.8	lib/flydata/fluent-plugins/mysql/context.rb
flydata-0.6.7	lib/flydata/fluent-plugins/mysql/context.rb
flydata-0.6.6	lib/flydata/fluent-plugins/mysql/context.rb
flydata-0.6.5	lib/flydata/fluent-plugins/mysql/context.rb
flydata-0.6.4	lib/flydata/fluent-plugins/mysql/context.rb
flydata-0.6.3	lib/flydata/fluent-plugins/mysql/context.rb
flydata-0.6.2	lib/flydata/fluent-plugins/mysql/context.rb
flydata-0.6.1	lib/flydata/fluent-plugins/mysql/context.rb
flydata-0.6.0	lib/flydata/fluent-plugins/mysql/context.rb
flydata-0.5.21	lib/flydata/fluent-plugins/mysql/context.rb
flydata-0.5.20	lib/flydata/fluent-plugins/mysql/context.rb
flydata-0.5.17	lib/flydata/fluent-plugins/mysql/context.rb
flydata-0.5.16	lib/flydata/fluent-plugins/mysql/context.rb
flydata-0.5.15	lib/flydata/fluent-plugins/mysql/context.rb
flydata-0.5.14	lib/flydata/fluent-plugins/mysql/context.rb
flydata-0.5.13	lib/flydata/fluent-plugins/mysql/context.rb
flydata-0.5.12	lib/flydata/fluent-plugins/mysql/context.rb