Rolling File Sink (#1121)

* Add RollingFileSink

Handles knowing when to roll a file based on time or space.
Also creates a new GzippedFramedFile when the first write comes
through. It ensures there is always an active file, making the act of
writing to it much easier.

* Replace manual Sink management with RollingFileSink

This file sink is now mostly conerned with collectig files for the
manifest, or forwarding to FileUpload.

* Remove unnecessary `tokio::select!`

* simplify init

there are patterns for reading from streams until they’re exhausted,
let’s use them.

* Avoid unwrap with early return

* avoid dangling false return with combinators

* Fix typo in inspect

We could also instrument the function, but we don’t have a strong usage
of spans in this library yet. I feel if we get to a point where we have
more complete span tracing for this library, we could come back and
consider properly instrumenting functions like

```rs
#[instrument(
  skip(self),
  err(Debug),
  fields(action = “write”, prefix = self.prefix)
)]
```

Until then, it kind of feels like an abuse of the macro.

Author: michaeldjeffrey

file_store/src/error.rs

@@ -2,7 +2,10 @@ use std::path::{Path, PathBuf};
 
 use thiserror::Error;
 
-use crate::{file_info::FileInfoError, gzipped_framed_file::GzippedFramedFileError};
+use crate::{
+    file_info::FileInfoError, gzipped_framed_file::GzippedFramedFileError,
+    rolling_file_sink::RollingFileSinkError,
+};
 
 pub use aws_error::AwsError;
 
@@ -35,6 +38,9 @@ pub enum Error {
     #[error("error write data to file on disk: {0}")]
     FileWriteError(#[from] GzippedFramedFileError),
 
+    #[error("rolling file sink error: {0}")]
+    RollingFileSink(#[from] RollingFileSinkError),
+
     // Generic error wrapper for external (out of that repository) traits implementations.
     // Not recommended for internal use!
     #[error("external error")]