stream

type KinesisStream struct {
	StreamName string
	BatchCount int
	BatchSize  int
	RecordSize int
	MaxWait    time.Duration
	// contains filtered or unexported fields
}

type StdoutStream struct{}

type Stream interface {
	Handle(recieve chan pgx.WalMessage, ack chan uint64)
}