<commit_before>require 'riemann/client'

class Fluent::RiemannOutput < Fluent::BufferedOutput
  Fluent::Plugin.register_output('riemann', self)

  config_param :host, :string, :default => '127.0.0.1'
  config_param :post, :integer, :default => 5555
  config_param :timeout, :integer, :default => 5
  config_param :protocol, :string, :default => 'tcp'
  config_param :service, :string, :default => nil
  config_param :types, :string, :default => 'metric:float'
  config_param :fields, :string, :default => 'message:description,level:state,metric'

  def initialize
    super
  end

  def configure(c)
    super

    @_types = parse_map(@types) do |k, t|<commit_msg>Fix typo on port parameter name expected<commit_after>require 'riemann/client'

class Fluent::RiemannOutput < Fluent::BufferedOutput
  Fluent::Plugin.register_output('riemann', self)

  config_param :host, :string, :default => '127.0.0.1'
  config_param :port, :integer, :default => 5555
  config_param :timeout, :integer, :default => 5
  config_param :protocol, :string, :default => 'tcp'
  config_param :service, :string, :default => nil
  config_param :types, :string, :default => 'metric:float'
  config_param :fields, :string, :default => 'message:description,level:state,metric'

  def initialize
    super
  end

  def configure(c)
    super

    @_types = parse_map(@types) do |k, t|
{'fraction_non_alphanumeric': 0.13874538745387455, 'fraction_numerical': 0.016236162361623615, 'mean_word_length': 5.191780821917808, 'pattern_counts': {'":': 0, '<': 5, '<?xml version=': 0, '>': 17, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 2, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 1, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '3691517', 'n_tokens_mistral': 464, 'n_tokens_neox': 436, 'n_words': 113}