Class: Fluent::Plugin::MongoOutputReplset

Inherits:
MongoOutput
  • Object
show all
Defined in:
lib/fluent/plugin/out_mongo_replset.rb

Constant Summary

Constants inherited from MongoOutput

Fluent::Plugin::MongoOutput::DEFAULT_BUFFER_TYPE, Fluent::Plugin::MongoOutput::LIMIT_AFTER_v1_8, Fluent::Plugin::MongoOutput::LIMIT_BEFORE_v1_8

Instance Attribute Summary

Attributes inherited from MongoOutput

#client_options, #collection_options

Instance Method Summary collapse

Methods inherited from MongoOutput

#formatted_to_msgpack_binary, #initialize, #multi_workers_ready?, #shutdown, #start

Methods included from LoggerSupport

#configure_logger, included

Methods included from MongoAuth

#authenticate

Methods included from MongoAuthParams

included

Constructor Details

This class inherits a constructor from Fluent::Plugin::MongoOutput

Instance Method Details

#configure(conf) ⇒ Object 



19
20
21
22
23
24
25
26
27
28
29
30
 
# File 'lib/fluent/plugin/out_mongo_replset.rb', line 19

def configure(conf)
  super

  if replica_set = conf['replica_set']
    @client_options[:replica_set] = replica_set
  end
  if read = conf['read']
    @client_options[:read] = read.to_sym
  end

  log.debug "Setup replica set configuration: #{conf['replica_set']}"
end

#write(chunk) ⇒ Object 



32
33
34
 
# File 'lib/fluent/plugin/out_mongo_replset.rb', line 32

def write(chunk)
  super
end