Class: Fluent::EventStream

Inherits:
Object
  • Object
show all
Includes:
Enumerable
Defined in:
lib/fluent/event.rb

Instance Method Summary collapse

Instance Method Details

#each(&block) ⇒ Object

Raises:

  • (NotImplementedError) 


27
28
29
 
# File 'lib/fluent/event.rb', line 27

def each(&block)
  raise NotImplementedError, "DO NOT USE THIS CLASS directly."
end

#repeatable? ⇒ Boolean

Returns:

  • (Boolean) 


23
24
25
 
# File 'lib/fluent/event.rb', line 23

def repeatable?
  false
end

#to_msgpack_stream ⇒ Object 



31
32
33
34
35
36
37
 
# File 'lib/fluent/event.rb', line 31

def to_msgpack_stream
  out = Fluent::Engine.msgpack_factory.packer
  each {|time,record|
    out.write([time,record])
  }
  out.to_s
end