storage

Documentation

Index

• func EnsureDirExists(path string) error
• func ResolveDuplicateFilename(dir, baseName string) string
• 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 ResolveDuplicateFilename

func ResolveDuplicateFilename(dir, baseName string) string

ResolveDuplicateFilename finds an available filename by appending numbers if the file exists.

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.