storage

Documentation

Index

• func EnsureDirExists(path string) error
• func SaveStreamToFile(stream io.Reader, filePath string, onProgress func(bytesWritten int64)) error
• func SaveStreamToFileWithMetadata(stream io.Reader, filePath string, modified *string, accessed *string, ...) error
• type ProgressWriter
  • func (pw *ProgressWriter) Write(p []byte) (n int, err error)

Functions

func EnsureDirExists

func EnsureDirExists(path string) error

EnsureDirExists creates a directory if it doesn't exist.

func SaveStreamToFile

func SaveStreamToFile(stream io.Reader, filePath string, onProgress func(bytesWritten int64)) error

SaveStreamToFile saves an io.Reader stream to a specified file path. It creates necessary directories. It reports progress via the onProgress callback (bytes written).

func SaveStreamToFileWithMetadata

func SaveStreamToFileWithMetadata(stream io.Reader, filePath string, modified *string, accessed *string, onProgress func(bytesWritten int64), logger *zap.SugaredLogger) error

SaveStreamToFileWithMetadata saves an io.Reader stream and restores optional timestamps.

Types

type ProgressWriter

type ProgressWriter struct {
	Writer       io.Writer
	BytesWritten int64
	OnProgress   func(bytesWritten int64)
}

ProgressWriter is a wrapper around io.Writer that calls a callback on Write.

func (*ProgressWriter) Write

func (pw *ProgressWriter) Write(p []byte) (n int, err error)

Write implements the io.Writer interface.