Contents

package org.embulk.output.fluentd

import com.google.common.base.Optional
import org.embulk.config.{Config, ConfigDefault, Task}
import org.embulk.spi.time.TimestampFormatter

trait PluginTask extends Task with TimestampFormatter.Task {

  @Config("host")
  @ConfigDefault("\"127.0.0.1\"")
  def getHost: String

  @Config("port")
  @ConfigDefault("24224")
  def getPort: Int

  @Config("async_size")
  @ConfigDefault("1")
  def getAsyncSize: Int

  @Config("request_per_seconds")
  @ConfigDefault("0")
  def getRequestPerSeconds: Int

  @Config("request_grouping_size")
  @ConfigDefault("100")
  def getRequestGroupingSize: Int

  @Config("tag")
  def getTag: String

  @Config("time_key")
  @ConfigDefault("null")
  def getTimeKey: Optional[String]

}

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
embulk-output-fluentd-0.1.0	src/main/scala/org/embulk/output/fluentd/PluginTask.scala