fsutil

Documentation

Index

• func CleanPathPrefix(path string) (string, error)
• func DetermineCopyDestPath(ctx context.Context, srcConn, destConn *connparse.Connection, ...) (srcPath, destPath string, srcInfo *wshrpc.FileInfo, err error)
• func GetParentPath(conn *connparse.Connection) string
• func GetParentPathString(hostAndPath string) string
• func PrefixCopyInternal(ctx context.Context, srcConn, destConn *connparse.Connection, ...) (bool, error)
• func PrefixCopyRemote(ctx context.Context, srcConn, destConn *connparse.Connection, ...) (bool, error)
• func ReadFileStream(ctx context.Context, readCh <-chan wshrpc.RespOrErrorUnion[wshrpc.FileData], ...) error
• func ReadFileStreamToWriter(ctx context.Context, readCh <-chan wshrpc.RespOrErrorUnion[wshrpc.FileData], ...) error
• func ReadStreamToFileData(ctx context.Context, readCh <-chan wshrpc.RespOrErrorUnion[wshrpc.FileData]) (*wshrpc.FileData, error)

Functions

func CleanPathPrefix

func CleanPathPrefix(path string) (string, error)

CleanPathPrefix corrects paths for prefix filesystems (i.e. ones that don't have directories)

func DetermineCopyDestPath

func DetermineCopyDestPath(ctx context.Context, srcConn, destConn *connparse.Connection, srcClient, destClient fstype.FileShareClient, opts *wshrpc.FileCopyOpts) (srcPath, destPath string, srcInfo *wshrpc.FileInfo, err error)

func GetParentPath

func GetParentPath(conn *connparse.Connection) string

func GetParentPathString

func GetParentPathString(hostAndPath string) string

func PrefixCopyInternal

func PrefixCopyInternal(ctx context.Context, srcConn, destConn *connparse.Connection, c fstype.FileShareClient, opts *wshrpc.FileCopyOpts, listEntriesPrefix func(ctx context.Context, host string, path string) ([]string, error), copyFunc func(ctx context.Context, host string, path string) error) (bool, error)

func PrefixCopyRemote

func PrefixCopyRemote(ctx context.Context, srcConn, destConn *connparse.Connection, srcClient, destClient fstype.FileShareClient, destPutFile func(host string, path string, size int64, reader io.Reader) error, opts *wshrpc.FileCopyOpts) (bool, error)

func ReadFileStream

func ReadFileStream(ctx context.Context, readCh <-chan wshrpc.RespOrErrorUnion[wshrpc.FileData], fileInfoCallback func(finfo wshrpc.FileInfo), dirCallback func(entries []*wshrpc.FileInfo) error, fileCallback func(data io.Reader) error) error

func ReadFileStreamToWriter

func ReadFileStreamToWriter(ctx context.Context, readCh <-chan wshrpc.RespOrErrorUnion[wshrpc.FileData], writer io.Writer) error

func ReadStreamToFileData

func ReadStreamToFileData(ctx context.Context, readCh <-chan wshrpc.RespOrErrorUnion[wshrpc.FileData]) (*wshrpc.FileData, error)