driver

Documentation

Index

• type FtpClientDriver
  • func NewFtpClientDriver(id *int64, ctx ftpserver.ClientContext, repo *di.FtpRepository) *FtpClientDriver
  • func (f *FtpClientDriver) Chmod(name string, mode os.FileMode) error
  • func (f *FtpClientDriver) Chown(name string, uid, gid int) error
  • func (f *FtpClientDriver) Chtimes(name string, atime time.Time, mtime time.Time) error
  • func (f *FtpClientDriver) Create(name string) (afero.File, error)
  • func (f *FtpClientDriver) Mkdir(name string, perm os.FileMode) error
  • func (f *FtpClientDriver) MkdirAll(path string, perm os.FileMode) error
  • func (f *FtpClientDriver) Name() string
  • func (f *FtpClientDriver) Open(name string) (afero.File, error)
  • func (f *FtpClientDriver) OpenFile(name string, flag int, perm os.FileMode) (afero.File, error)
  • func (f *FtpClientDriver) Remove(name string) error
  • func (f *FtpClientDriver) RemoveAll(path string) error
  • func (f *FtpClientDriver) Rename(oldname, newname string) error
  • func (f *FtpClientDriver) Stat(name string) (os.FileInfo, error)
• type FtpClientDriverFactory
  • func NewFtpClientDriverFactory(repo *di.FtpRepository) *FtpClientDriverFactory
  • func (f *FtpClientDriverFactory) FromContext(ctx ftpserver.ClientContext) *FtpClientDriver
  • func (f *FtpClientDriverFactory) GetClientIdFromContent(ctx ftpserver.ClientContext) int64
• type FtpFile
  • func NewFtpFile(name string, gen *filesystem.FilesystemGenerator, ctx ftpserver.ClientContext, ...) *FtpFile
  • func (f *FtpFile) Close() error
  • func (f *FtpFile) Name() string
  • func (f *FtpFile) Read(p []byte) (n int, err error)
  • func (f *FtpFile) ReadAt(p []byte, off int64) (n int, err error)
  • func (f *FtpFile) Readdir(count int) ([]os.FileInfo, error)
  • func (f *FtpFile) Readdirnames(n int) ([]string, error)
  • func (f *FtpFile) Seek(offset int64, whence int) (int64, error)
  • func (f *FtpFile) Stat() (os.FileInfo, error)
  • func (f *FtpFile) Sync() error
  • func (f *FtpFile) Truncate(size int64) error
  • func (f *FtpFile) Write(p []byte) (n int, err error)
  • func (f *FtpFile) WriteAt(p []byte, off int64) (n int, err error)
  • func (f *FtpFile) WriteString(s string) (ret int, err error)
• type FtpFileInfo
  • func NewFtpFileInfo(path string, fileSize int) *FtpFileInfo
  • func (f *FtpFileInfo) IsDir() bool
  • func (f *FtpFileInfo) ModTime() time.Time
  • func (f *FtpFileInfo) Mode() os.FileMode
  • func (f *FtpFileInfo) Name() string
  • func (f *FtpFileInfo) Size() int64
  • func (f *FtpFileInfo) Sys() any
• type FtpServerDriver
  • func NewFtpServerDriver(c *config.Config, cf *FtpClientDriverFactory, throttle *throttle.FtpThrottle, ...) (*FtpServerDriver, error)
  • func (f *FtpServerDriver) AuthUser(cc ftpserver.ClientContext, user, pass string) (ftpserver.ClientDriver, error)
  • func (f *FtpServerDriver) ClientConnected(cc ftpserver.ClientContext) (string, error)
  • func (f *FtpServerDriver) ClientDisconnected(cc ftpserver.ClientContext)
  • func (f *FtpServerDriver) GetSettings() (*ftpserver.Settings, error)
  • func (f *FtpServerDriver) GetTLSConfig() (*tls.Config, error)

Types

type FtpClientDriver

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

func NewFtpClientDriver

func NewFtpClientDriver(id *int64, ctx ftpserver.ClientContext, repo *di.FtpRepository) *FtpClientDriver

func (*FtpClientDriver) Chmod

func (f *FtpClientDriver) Chmod(name string, mode os.FileMode) error

func (*FtpClientDriver) Chown

func (f *FtpClientDriver) Chown(name string, uid, gid int) error

func (*FtpClientDriver) Chtimes

func (f *FtpClientDriver) Chtimes(name string, atime time.Time, mtime time.Time) error

func (*FtpClientDriver) Create

func (f *FtpClientDriver) Create(name string) (afero.File, error)

func (*FtpClientDriver) Mkdir

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

func (*FtpClientDriver) MkdirAll

func (f *FtpClientDriver) MkdirAll(path string, perm os.FileMode) error

func (*FtpClientDriver) Name

func (f *FtpClientDriver) Name() string

func (*FtpClientDriver) Open

func (f *FtpClientDriver) Open(name string) (afero.File, error)

func (*FtpClientDriver) OpenFile

func (f *FtpClientDriver) OpenFile(name string, flag int, perm os.FileMode) (afero.File, error)

func (*FtpClientDriver) Remove

func (f *FtpClientDriver) Remove(name string) error

func (*FtpClientDriver) RemoveAll

func (f *FtpClientDriver) RemoveAll(path string) error

func (*FtpClientDriver) Rename

func (f *FtpClientDriver) Rename(oldname, newname string) error

func (*FtpClientDriver) Stat

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

type FtpClientDriverFactory

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

func NewFtpClientDriverFactory

func NewFtpClientDriverFactory(
	repo *di.FtpRepository,
) *FtpClientDriverFactory

func (*FtpClientDriverFactory) FromContext

func (f *FtpClientDriverFactory) FromContext(ctx ftpserver.ClientContext) *FtpClientDriver

func (*FtpClientDriverFactory) GetClientIdFromContent

func (f *FtpClientDriverFactory) GetClientIdFromContent(ctx ftpserver.ClientContext) int64

type FtpFile

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

FTP File handles I/O operations for a single file FTP Sever Driver --> FTP Client Driver --> [FTP File], FTP File Info

func NewFtpFile

func NewFtpFile(name string, gen *filesystem.FilesystemGenerator, ctx ftpserver.ClientContext, repo *di.FtpRepository, logger logging.CommandLogger) *FtpFile

func (*FtpFile) Close

func (f *FtpFile) Close() error

func (*FtpFile) Name

func (f *FtpFile) Name() string

func (*FtpFile) Read

func (f *FtpFile) Read(p []byte) (n int, err error)

func (*FtpFile) ReadAt

func (f *FtpFile) ReadAt(p []byte, off int64) (n int, err error)

func (*FtpFile) Readdir

func (f *FtpFile) Readdir(count int) ([]os.FileInfo, error)

func (*FtpFile) Readdirnames

func (f *FtpFile) Readdirnames(n int) ([]string, error)

func (*FtpFile) Seek

func (f *FtpFile) Seek(offset int64, whence int) (int64, error)

func (*FtpFile) Stat

func (f *FtpFile) Stat() (os.FileInfo, error)

func (*FtpFile) Sync

func (f *FtpFile) Sync() error

func (*FtpFile) Truncate

func (f *FtpFile) Truncate(size int64) error

func (*FtpFile) Write

func (f *FtpFile) Write(p []byte) (n int, err error)

func (*FtpFile) WriteAt

func (f *FtpFile) WriteAt(p []byte, off int64) (n int, err error)

func (*FtpFile) WriteString

func (f *FtpFile) WriteString(s string) (ret int, err error)

type FtpFileInfo

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

func NewFtpFileInfo

func NewFtpFileInfo(path string, fileSize int) *FtpFileInfo

func (*FtpFileInfo) IsDir

func (f *FtpFileInfo) IsDir() bool

func (*FtpFileInfo) ModTime

func (f *FtpFileInfo) ModTime() time.Time

func (*FtpFileInfo) Mode

func (f *FtpFileInfo) Mode() os.FileMode

func (*FtpFileInfo) Name

func (f *FtpFileInfo) Name() string

func (*FtpFileInfo) Size

func (f *FtpFileInfo) Size() int64

func (*FtpFileInfo) Sys

func (f *FtpFileInfo) Sys() any

type FtpServerDriver

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

func NewFtpServerDriver

func NewFtpServerDriver(c *config.Config, cf *FtpClientDriverFactory, throttle *throttle.FtpThrottle, logger *logging.FtpCommandLogger) (*FtpServerDriver, error)

func (*FtpServerDriver) AuthUser

func (f *FtpServerDriver) AuthUser(cc ftpserver.ClientContext, user, pass string) (ftpserver.ClientDriver, error)

func (*FtpServerDriver) ClientConnected

func (f *FtpServerDriver) ClientConnected(cc ftpserver.ClientContext) (string, error)

func (*FtpServerDriver) ClientDisconnected

func (f *FtpServerDriver) ClientDisconnected(cc ftpserver.ClientContext)

func (*FtpServerDriver) GetSettings

func (f *FtpServerDriver) GetSettings() (*ftpserver.Settings, error)

func (*FtpServerDriver) GetTLSConfig

func (f *FtpServerDriver) GetTLSConfig() (*tls.Config, error)