replay

type Archive interface {
	// Scan the s3 archive and emit objects on the returned channel
	Scan() chan *Object
}

type Object struct {
	Data   []byte
	Object *s3.Object
}

type Parser interface {
	Parse(chan *Object, chan *kinesis.PutRecordsRequestEntry)
}

type Producer interface {
	// Returns a channel that accepts kinesis messages to replay
	Stream() chan *kinesis.PutRecordsRequestEntry
	// Wait for producer to finish replaying messages
	Wait()
}