a3no

module Fluent
  class MapOutput < Fluent::Output
    Fluent::Plugin.register_output('multimap', self)

    config_param :timeout, :time, :default => 1

    MMAP_MAX_NUM = 50

    def configure(conf)
      super

a3no

module Fluent
  class MapOutput < Fluent::Output
    Fluent::Plugin.register_output('map', self)

    config_param :map, :string, :default => nil
    config_param :tag, :string, :default => nil
    config_param :key, :string, :default => nil #deprected
    config_param :time, :string, :default => nil
    config_param :record, :string, :default => nil
    config_param :multi, :bool, :default => false

a3no

module Fluent
  class DstatStdinInput < Input
    Plugin.register_input('dstat_stdin', self)

    def initialize
      super
    end

    config_param :tag, :string
    config_param :dstat_path, :string, :default => "dstat"

a3no

  /**
   * dump_key data for all servers
   * 
   * Returns a map keyed on the servername. The value is list which contains
   * dump_key data for a server.
   * 
   * @return map
   */
  public Map<String, List<String>> dumpKey() {
    return dumpKey(null);