Class: Fluent::Pipeline

Inherits:
Object
  • Object
show all
Includes:
Helpers
Defined in:
lib/fluent/pipeline.rb,
lib/fluent/pipeline/version.rb

Constant Summary collapse

VERSION = 
'0.2.0'

Class Method Summary collapse

Instance Method Summary collapse

Methods included from Helpers

#with_undefined_method_handle

Class Method Details

.dispatch(passable) ⇒ Object 



11
12
13
 
# File 'lib/fluent/pipeline.rb', line 11

def self.dispatch(passable)
  new(passable)
end

Instance Method Details

#then(callback = nil) ⇒ Object 



25
26
27
28
29
30
 
# File 'lib/fluent/pipeline.rb', line 25

def then(callback = nil)
  handle_pipes
  return passable unless callback

  callback.call(passable)
end

#through(pipes) ⇒ Object 



15
16
17
18
 
# File 'lib/fluent/pipeline.rb', line 15

def through(pipes)
  self.pipes.push(*pipes)
  self
end

#via(method_name) ⇒ Object 



20
21
22
23
 
# File 'lib/fluent/pipeline.rb', line 20

def via(method_name)
  self.pipe_method = method_name
  self
end