kinesumeriface

type Checkpointer interface {
	DoneC() chan<- Record
	Begin() error
	End()
	GetStartSequence(shardID string) string
	Sync()
}

type Error interface {
	Severity() string
	Origin() error
	Error() string
}

type Kinesis kinesisiface.KinesisAPI

type Kinesumer interface {
	Begin() (int, error)
	End()
	Records() <-chan Record
}

type Provisioner interface {
	TryAcquire(shardID string) error
	Release(shardID string) error
	Heartbeat(shardID string) error
	TTL() time.Duration
}

type Record interface {
	Data() []byte
	PartitionKey() string
	SequenceNumber() string
	ShardId() string
	MillisBehindLatest() int64
	Done()
}