replay

Documentation

Overview

Package replay implements types and interfaces that describe the appication domain

Index

• type Archive
• type Object
• type Parser
• type Producer

Types

type Archive

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

Archive is a consumer responsible for scanning an s3 message archive and returning a buffered stream of s3 objects

type Object

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

Object is a wrapper around an s3 object that includes the downloaded object data

type Parser

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

Parser is responsible for processing the stream of archived s3 messages and preparing them for replay

type Producer

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

Producer is responsible for replaying processed messages to kinesis