drivers

package

v0.0.0-...-367f9bc Latest Latest Go to latest Published: Mar 10, 2021 License: MPL-2.0 Imports: 10 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/wweir/mafia

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type FSAdaptor
type FTPAdaptor
type FTPDriver
- func NewFTPDriver(ftp FTPAdaptor, dav WebdavAdaptor) *FTPDriver
type FileAdaptor
type MockFSFull
type WebdavAdaptor
type WebdavDriver

Constants ¶

This section is empty.

Variables ¶

View Source

var Defer zerolog.Logger

View Source

var Drivers = map[string]server.Driver{}

Functions ¶

This section is empty.

Types ¶

type FSAdaptor ¶

type FSAdaptor interface {
	DeleteDir(path string) error
	DeleteFile(path string) error
	Rename(fromPath string, toPath string) error
	Mkdir(dirpath string, perm os.FileMode) error
	Stat(path string) (os.FileInfo, error)
	ReadDir(dirpath string) ([]os.FileInfo, error)
}

type FTPAdaptor ¶

type FTPAdaptor interface {
	FSAdaptor

	GetFile(path string, offset int64) (int64, io.ReadCloser, error)
	PutFile(destPath string, data io.Reader, offset int64) (int64, error)
}

type FTPDriver ¶

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

func NewFTPDriver ¶

func NewFTPDriver(ftp FTPAdaptor, dav WebdavAdaptor) *FTPDriver

func (*FTPDriver) DeleteDir ¶

func (ftp *FTPDriver) DeleteDir(ctx *server.Context, path string) (err error)

func (*FTPDriver) DeleteFile ¶

func (ftp *FTPDriver) DeleteFile(ctx *server.Context, path string) (err error)

func (*FTPDriver) GetFile ¶

func (ftp *FTPDriver) GetFile(ctx *server.Context, path string, offset int64) (size int64, _ io.ReadCloser, err error)

func (*FTPDriver) ListDir ¶

func (ftp *FTPDriver) ListDir(ctx *server.Context, path string, callback func(os.FileInfo) error) (err error)

func (*FTPDriver) MakeDir ¶

func (ftp *FTPDriver) MakeDir(ctx *server.Context, path string) (err error)

func (*FTPDriver) PutFile ¶

func (ftp *FTPDriver) PutFile(ctx *server.Context, path string, data io.Reader, offset int64) (size int64, err error)

func (*FTPDriver) Rename ¶

func (ftp *FTPDriver) Rename(ctx *server.Context, fromPath string, toPath string) (err error)

func (*FTPDriver) Stat ¶

func (ftp *FTPDriver) Stat(ctx *server.Context, path string) (fi os.FileInfo, err error)

type FileAdaptor ¶

type FileAdaptor interface {
	io.Reader
	io.Writer
	io.Seeker
	io.Closer
}

type MockFSFull ¶

type MockFSFull struct{}

func (*MockFSFull) DeleteDir ¶

func (f *MockFSFull) DeleteDir(path string) error

common

func (*MockFSFull) DeleteFile ¶

func (f *MockFSFull) DeleteFile(path string) error

func (*MockFSFull) GetFile ¶

func (f *MockFSFull) GetFile(path string, offset int64) (int64, io.ReadCloser, error)

ftp

func (*MockFSFull) Mkdir ¶

func (f *MockFSFull) Mkdir(name string, perm os.FileMode) error

func (*MockFSFull) OpenFile ¶

func (f *MockFSFull) OpenFile(path string, flag int, perm os.FileMode) (FileAdaptor, error)

webdav

func (*MockFSFull) PutFile ¶

func (f *MockFSFull) PutFile(destPath string, data io.Reader, offset int64) (int64, error)

func (*MockFSFull) ReadDir ¶

func (f *MockFSFull) ReadDir(name string) ([]os.FileInfo, error)

func (*MockFSFull) Rename ¶

func (f *MockFSFull) Rename(fromPath string, toPath string) error

func (*MockFSFull) Stat ¶

func (f *MockFSFull) Stat(name string) (os.FileInfo, error)

type WebdavAdaptor ¶

type WebdavAdaptor interface {
	FSAdaptor

	OpenFile(path string, flag int, perm os.FileMode) (FileAdaptor, error)
}

type WebdavDriver ¶

type WebdavDriver struct {
	Adaptor WebdavAdaptor
}

func (*WebdavDriver) Mkdir ¶

func (dav *WebdavDriver) Mkdir(ctx context.Context, path string, perm os.FileMode) (err error)

func (*WebdavDriver) OpenFile ¶

func (dav *WebdavDriver) OpenFile(ctx context.Context, path string, flag int, perm os.FileMode) (_ webdav.File, err error)

func (*WebdavDriver) RemoveAll ¶

func (dav *WebdavDriver) RemoveAll(ctx context.Context, path string) (err error)

func (*WebdavDriver) Rename ¶

func (dav *WebdavDriver) Rename(ctx context.Context, oldpath, newpath string) (err error)

func (*WebdavDriver) Stat ¶

func (dav *WebdavDriver) Stat(ctx context.Context, path string) (fi os.FileInfo, err error)

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
s3
sftp
tar
zip

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL