source

Documentation

Index

• Variables
• func CopyDirToLocal(source Source, localDir, src string) (retErr error)
• func CopyToLocal(source Source, localFile, src string) (retErr error)
• type FTPServer
  • func OpenFTPServer(ctx context.Context, host, user, pass string) (*FTPServer, error)
  • func (s *FTPServer) Open(path string) (_ io.ReadCloser, retErr error)
  • func (s *FTPServer) Rename(oldPath, newPath string) error
  • func (s *FTPServer) Separator() string
  • func (s *FTPServer) Walk(dir string, walkFn func(string, fs.FileInfo) error) error
• type Local
  • func OpenLocal() (*Local, error)
  • func (l *Local) Open(path string) (io.ReadCloser, error)
  • func (l *Local) Rename(oldPath, newPath string) error
  • func (l *Local) Separator() string
  • func (l *Local) Walk(dir string, walkFn func(string, fs.FileInfo) error) error
• type Source

Variables

var (
	ErrSkipDir     = errors.New("skip dir")
	ErrStopWalking = errors.New("stop walking")
)

Functions

func CopyDirToLocal

func CopyDirToLocal(source Source, localDir, src string) (retErr error)

func CopyToLocal

func CopyToLocal(source Source, localFile, src string) (retErr error)

Types

type FTPServer

type FTPServer struct {
	// contains filtered or unexported fields
}

func OpenFTPServer

func OpenFTPServer(ctx context.Context, host, user, pass string) (*FTPServer, error)

func (*FTPServer) Open

func (s *FTPServer) Open(path string) (_ io.ReadCloser, retErr error)

func (*FTPServer) Rename

func (s *FTPServer) Rename(oldPath, newPath string) error

func (*FTPServer) Separator

func (s *FTPServer) Separator() string

func (*FTPServer) Walk

func (s *FTPServer) Walk(dir string, walkFn func(string, fs.FileInfo) error) error

Walk on the path

type Local

type Local struct {
	// contains filtered or unexported fields
}

func OpenLocal

func OpenLocal() (*Local, error)

func (*Local) Open

func (l *Local) Open(path string) (io.ReadCloser, error)

func (*Local) Rename

func (l *Local) Rename(oldPath, newPath string) error

func (*Local) Separator

func (l *Local) Separator() string

func (*Local) Walk

func (l *Local) Walk(dir string, walkFn func(string, fs.FileInfo) error) error

type Source

type Source interface {
	Walk(root string, walkFn func(string, fs.FileInfo) error) error
	Rename(oldPath, newPath string) error
	Open(path string) (io.ReadCloser, error)
	Separator() string
}