Documentation ¶
Index ¶
- Variables
- func FileChan() chan *PutFile
- func HasForm(engineName string, formName string) bool
- func MonitorBackupStop(id uint) error
- func RecordLog(ctx echo.Context, err error, cfg *dbschema.NgingCloudBackup, filePath string, ...)
- func Register(name string, constructor Constructor, forms []Form, label string)
- func ResetFileChan()
- func RetryablePut(ctx context.Context, mgr Storager, fp *os.File, objectName string, size int64) error
- type Cloudbackup
- type Constructor
- type ErrIsAccessDenied
- type Form
- type PutFile
- type StorageFTP
- func (s *StorageFTP) Close() (err error)
- func (s *StorageFTP) Connect() (err error)
- func (s *StorageFTP) MkdirAll(dir string) (err error)
- func (s *StorageFTP) Put(ctx context.Context, reader io.Reader, ppath string, size int64) (err error)
- func (s *StorageFTP) Remove(ctx context.Context, ppath string) error
- func (s *StorageFTP) RemoveDir(ctx context.Context, ppath string) error
- type StorageMock
- func (s *StorageMock) Close() (err error)
- func (s *StorageMock) Connect() (err error)
- func (s *StorageMock) Put(ctx context.Context, reader io.Reader, ppath string, size int64) (err error)
- func (s *StorageMock) Remove(ctx context.Context, ppath string) error
- func (s *StorageMock) RemoveDir(ctx context.Context, ppath string) error
- type StorageS3
- func (s *StorageS3) Close() (err error)
- func (s *StorageS3) Connect() (err error)
- func (s *StorageS3) Put(ctx context.Context, reader io.Reader, ppath string, size int64) (err error)
- func (s *StorageS3) Remove(ctx context.Context, ppath string) error
- func (s *StorageS3) RemoveDir(ctx context.Context, ppath string) error
- type StorageSMB
- func (s *StorageSMB) Close() (err error)
- func (s *StorageSMB) Connect() (err error)
- func (s *StorageSMB) Put(ctx context.Context, reader io.Reader, ppath string, size int64) (err error)
- func (s *StorageSMB) Remove(ctx context.Context, ppath string) error
- func (s *StorageSMB) RemoveDir(ctx context.Context, ppath string) error
- type StorageWebDAV
- func (s *StorageWebDAV) Close() (err error)
- func (s *StorageWebDAV) Connect() (err error)
- func (s *StorageWebDAV) Put(ctx context.Context, reader io.Reader, ppath string, size int64) (err error)
- func (s *StorageWebDAV) Remove(ctx context.Context, ppath string) error
- func (s *StorageWebDAV) RemoveDir(ctx context.Context, ppath string) error
- type Storager
- func NewStorage(ctx echo.Context, cfg dbschema.NgingCloudBackup) (Storager, error)
- func NewStorageFTP(addr, username, password string) Storager
- func NewStorageMock() Storager
- func NewStorageS3(cfg dbschema.NgingCloudStorage) Storager
- func NewStorageSMB(addr, username, password, sharename string) Storager
- func NewStorageWebDAV(uri, username, password string) Storager
Constants ¶
This section is empty.
Variables ¶
View Source
var (
BackupTasks = param.NewMap()
)
View Source
var ErrEmptyConfig = errors.New(`empty config`)
View Source
var ErrUnsupported = errors.New(`unsupported storage engine`)
View Source
var Forms = map[string][]Form{}
Functions ¶
func MonitorBackupStop ¶
func Register ¶ added in v5.2.1
func Register(name string, constructor Constructor, forms []Form, label string)
func ResetFileChan ¶
func ResetFileChan()
Types ¶
type Cloudbackup ¶
type Cloudbackup struct { SourcePath string DestPath string Filter func(string) bool WaitFillCompleted bool IgnoreWaitRegexp *regexp.Regexp // contains filtered or unexported fields }
func New ¶
func New(mgr Storager, cfg dbschema.NgingCloudBackup) *Cloudbackup
func (*Cloudbackup) OnCreate ¶
func (c *Cloudbackup) OnCreate(file string)
func (*Cloudbackup) OnDelete ¶
func (c *Cloudbackup) OnDelete(file string)
func (*Cloudbackup) OnModify ¶
func (c *Cloudbackup) OnModify(file string)
func (*Cloudbackup) OnRename ¶
func (c *Cloudbackup) OnRename(file string)
type Constructor ¶ added in v5.2.1
type ErrIsAccessDenied ¶ added in v5.2.1
type PutFile ¶
type StorageFTP ¶ added in v5.2.1
type StorageFTP struct {
// contains filtered or unexported fields
}
func (*StorageFTP) Close ¶ added in v5.2.1
func (s *StorageFTP) Close() (err error)
func (*StorageFTP) Connect ¶ added in v5.2.1
func (s *StorageFTP) Connect() (err error)
func (*StorageFTP) MkdirAll ¶ added in v5.2.1
func (s *StorageFTP) MkdirAll(dir string) (err error)
type StorageMock ¶ added in v5.2.1
type StorageMock struct { }
func (*StorageMock) Close ¶ added in v5.2.1
func (s *StorageMock) Close() (err error)
func (*StorageMock) Connect ¶ added in v5.2.1
func (s *StorageMock) Connect() (err error)
type StorageS3 ¶ added in v5.2.1
type StorageS3 struct {
// contains filtered or unexported fields
}
type StorageSMB ¶ added in v5.2.1
type StorageSMB struct {
// contains filtered or unexported fields
}
func (*StorageSMB) Close ¶ added in v5.2.1
func (s *StorageSMB) Close() (err error)
func (*StorageSMB) Connect ¶ added in v5.2.1
func (s *StorageSMB) Connect() (err error)
type StorageWebDAV ¶ added in v5.2.1
type StorageWebDAV struct {
// contains filtered or unexported fields
}
func (*StorageWebDAV) Close ¶ added in v5.2.1
func (s *StorageWebDAV) Close() (err error)
func (*StorageWebDAV) Connect ¶ added in v5.2.1
func (s *StorageWebDAV) Connect() (err error)
type Storager ¶ added in v5.2.1
type Storager interface { Connect() (err error) Put(ctx context.Context, reader io.Reader, ppath string, size int64) (err error) RemoveDir(ctx context.Context, ppath string) error Remove(ctx context.Context, ppath string) error Close() (err error) }
func NewStorage ¶ added in v5.2.1
func NewStorageFTP ¶ added in v5.2.1
func NewStorageMock ¶ added in v5.2.1
func NewStorageMock() Storager
func NewStorageS3 ¶ added in v5.2.1
func NewStorageS3(cfg dbschema.NgingCloudStorage) Storager
func NewStorageSMB ¶ added in v5.2.1
func NewStorageWebDAV ¶ added in v5.2.1
Click to show internal directories.
Click to hide internal directories.