Class: Bricolage::StreamingLoad::IncomingChunk

Inherits:
Object
  • Object
show all
Extended by:
Forwardable
Defined in:
lib/bricolage/streamingload/incomingchunk.rb

Overview

a Chunk which is not saved yet (received from SQS)

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(message, stream_name) ⇒ IncomingChunk

Returns a new instance of IncomingChunk.



12
13
14
15
16
 
# File 'lib/bricolage/streamingload/incomingchunk.rb', line 12

def initialize(message, stream_name)
  @chunk = message.chunk
  @message = message
  @stream_name = stream_name
end

Instance Attribute Details

#stream_name ⇒ Object (readonly)

Returns the value of attribute stream_name.



29
30
31
 
# File 'lib/bricolage/streamingload/incomingchunk.rb', line 29

def stream_name
  @stream_name
end

Instance Method Details

#event_time ⇒ Object 



25
26
27
 
# File 'lib/bricolage/streamingload/incomingchunk.rb', line 25

def event_time
  @message.time
end