Class: Intake::Sink

Inherits:
Object
  • Object
show all
Defined in:
lib/intake/sink.rb

Overview

Sink receives log event and writes to a permanent storage.

Direct Known Subclasses

IOSink

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Sink

Returns a new instance of Sink.



8
9
10
 
# File 'lib/intake/sink.rb', line 8

def initialize
  @filters = []
end

Instance Method Details

#add_filter(filter) ⇒ Object 



22
23
24
 
# File 'lib/intake/sink.rb', line 22

def add_filter(filter)
  @filters << filter
end

#drain(_event) ⇒ Object

Receives a message and write to a permanent storage



27
28
29
 
# File 'lib/intake/sink.rb', line 27

def drain(_event)
  nil
end

#flush ⇒ Object 



12
13
14
 
# File 'lib/intake/sink.rb', line 12

def flush
  @has_events_flag.set if @thread_model == :dedicated_thread
end

#receive(event) ⇒ Object 



16
17
18
19
20
 
# File 'lib/intake/sink.rb', line 16

def receive(event)
  return unless accept_event?(event)

  drain event
end