Class: Terastream::Output::Kinesis

Inherits:

Object

Object
Terastream::Output::Kinesis

show all

Defined in:: lib/terastream/middleware/output/kinesis.rb

Instance Method Summary collapse

#<<(record) ⇒ Object
#initialize(options = {}) ⇒ Kinesis constructor

A new instance of Kinesis.

Constructor Details

#initialize(options = {}) ⇒ `Kinesis`

Returns a new instance of Kinesis.

# File 'lib/terastream/middleware/output/kinesis.rb', line 6

def initialize(options = {})
  @options = options || {}
  @connection = Aws::Kinesis::Client.new
  @max_retries = 4
end

Instance Method Details

#<<(record) ⇒ `Object`



12
13
14

# File 'lib/terastream/middleware/output/kinesis.rb', line 12

def <<(record)
  put_record(record)
end