backup

Documentation

Index

• Variables
• type BackupManager
  • func NewBackupManager(cfg *rest.Config, bc bucket.Bucket, dir, ns, name, password string, ...) (*BackupManager, error)
  • func (bm *BackupManager) Backup(ctx context.Context) error
  • func (bm *BackupManager) ChoosePod(ctx context.Context, pods []*corev1.Pod) (int, error)
• type ByteCountWriter
  • func (w *ByteCountWriter) Write(data []byte) (int, error)
  • func (w *ByteCountWriter) Written() int64
• type RestoreManager
  • func NewRestoreManager(cfg *rest.Config, bc bucket.Bucket, ...) (*RestoreManager, error)
  • func (rm *RestoreManager) FindNearestDump(keys []string) (string, string, time.Time)
  • func (rm *RestoreManager) Restore(ctx context.Context) error

Variables

var ErrBadConnection = errors.New("the connection hasn't reflected the latest user's privileges")

Types

type BackupManager

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

func NewBackupManager

func NewBackupManager(cfg *rest.Config, bc bucket.Bucket, dir, ns, name, password string, threads int) (*BackupManager, error)

func (*BackupManager) Backup

func (bm *BackupManager) Backup(ctx context.Context) error

func (*BackupManager) ChoosePod

func (bm *BackupManager) ChoosePod(ctx context.Context, pods []*corev1.Pod) (int, error)

type ByteCountWriter

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

ByteCountWriter counts the written data in bytes

func (*ByteCountWriter) Write

func (w *ByteCountWriter) Write(data []byte) (int, error)

Write implements io.Writer interface.

func (*ByteCountWriter) Written

func (w *ByteCountWriter) Written() int64

Written returns the number of written bytes.

type RestoreManager

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

func NewRestoreManager

func NewRestoreManager(cfg *rest.Config, bc bucket.Bucket, dir, srcNS, srcName, ns, name, password string, threads int, restorePoint time.Time) (*RestoreManager, error)

func (*RestoreManager) FindNearestDump

func (rm *RestoreManager) FindNearestDump(keys []string) (string, string, time.Time)

func (*RestoreManager) Restore

func (rm *RestoreManager) Restore(ctx context.Context) error