Class: Core::OutputSink::ConsoleSink

Inherits:
BaseSink
  • Object
show all
Defined in:
lib/core/output_sink/console_sink.rb

Instance Method Summary collapse

Instance Method Details

#delete(id) ⇒ Object 



29
30
31
32
 
# File 'lib/core/output_sink/console_sink.rb', line 29

def delete(id)
  print_header "Deleting single id: #{id}"
  puts id
end

#delete_multiple(ids) ⇒ Object 



34
35
36
37
 
# File 'lib/core/output_sink/console_sink.rb', line 34

def delete_multiple(ids)
  print_header "Deleting several ids: #{ids}"
  puts ids
end

#flush(size: nil) ⇒ Object 



19
20
21
22
 
# File 'lib/core/output_sink/console_sink.rb', line 19

def flush(size: nil)
  print_header 'Flushing'
  puts "Flush size: #{size}"
end

#ingest(document) ⇒ Object 



14
15
16
17
 
# File 'lib/core/output_sink/console_sink.rb', line 14

def ingest(document)
  print_header 'Got a single document:'
  puts document
end

#ingest_multiple(documents) ⇒ Object 



24
25
26
27
 
# File 'lib/core/output_sink/console_sink.rb', line 24

def ingest_multiple(documents)
  print_header 'Got multiple documents:'
  puts documents
end