Versions in this module Expand all Collapse all v0 v0.1.0 Jan 22, 2018 Changes in this version + type Archive interface + Scan func() chan *Object + type Object struct + Data []byte + Object *s3.Object + type Parser interface + Parse func(chan *Object, chan *kinesis.PutRecordsRequestEntry) + type Producer interface + Stream func() chan *kinesis.PutRecordsRequestEntry + Wait func()