Method: Fluent::Counter::Client#init

Defined in:
lib/fluent/counter/client.rb

#init(params, options: {}) ⇒ Object

Example

init receives various arguments.

  1. init(name: ‘name’)

  2. init({ name: ‘name’,reset_interval: 20 }, options: {})

  3. init([{ name: ‘name1’,reset_interval: 20 }, { name: ‘name2’,reset_interval: 20 }])

  4. init([{ name: ‘name1’,reset_interval: 20 }, { name: ‘name2’,reset_interval: 20 }], options: {})

  5. init([{ name: ‘name1’,reset_interval: 20 }, { name: ‘name2’,reset_interval: 20 }]) { |res| … }



80
81
82
83
84
85
86
87
88
89
90
91
92
93
 
# File 'lib/fluent/counter/client.rb', line 80

def init(params, options: {})
  exist_scope!
  params = [params] unless params.is_a?(Array)
  res = send_request('init', @scope, params, options)

  # if `async` is false or missing, block at this method and return a Future::Result object.
  if block_given?
    Thread.start do
      yield res.get
    end
  else
    res
  end
end