TODO : unit tests PushStream compresses a stream and push it
(ctx context.Context, stream io.Reader)
| 21 | // TODO : unit tests |
| 22 | // PushStream compresses a stream and push it |
| 23 | func (uploader *RegularUploader) PushStream(ctx context.Context, stream io.Reader) (string, error) { |
| 24 | backupName := StreamPrefix + utility.TimeNowCrossPlatformUTC().Format(utility.BackupTimeFormat) |
| 25 | dstPath := GetStreamName(backupName, uploader.Compressor.FileExtension()) |
| 26 | err := uploader.PushStreamToDestination(ctx, stream, dstPath) |
| 27 | |
| 28 | return backupName, err |
| 29 | } |
| 30 | |
| 31 | // TODO : unit tests |
| 32 | // returns backup_prefix |
nothing calls this directly
no test coverage detected