[s3metadataenricher] extend S3Client
This commit is contained in:
parent
c948f70b99
commit
04b5d4eded
2 changed files with 3 additions and 1 deletions
|
@ -6,7 +6,7 @@ import fs2.Stream
|
||||||
import cats.effect.IO
|
import cats.effect.IO
|
||||||
import Main.putStrLn
|
import Main.putStrLn
|
||||||
|
|
||||||
trait S3MetaDataEnricher {
|
trait S3MetaDataEnricher extends S3Client {
|
||||||
|
|
||||||
def enrichWithS3MetaData: Path => Stream[IO, S3MetaData] =
|
def enrichWithS3MetaData: Path => Stream[IO, S3MetaData] =
|
||||||
path => Stream.eval(for {
|
path => Stream.eval(for {
|
||||||
|
|
|
@ -37,4 +37,6 @@ object Sync extends LocalFileStream with S3MetaDataEnricher {
|
||||||
// upload
|
// upload
|
||||||
p = Promise[Unit]()
|
p = Promise[Unit]()
|
||||||
} yield p)
|
} yield p)
|
||||||
|
|
||||||
|
override def objectHead(bucket: String, key: String): (Hash, LastModified) = ???
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue