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, bool, error)
  • func (bm *BackupManager) GetUUIDSet(ctx context.Context, pods []*corev1.Pod) (map[string]string, 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, bool, error)

ChoosePod chooses a pod to take a backup from. It returns the index of the chosen pod and whether backupBinlog should be called.

func (*BackupManager) GetUUIDSet

func (bm *BackupManager) GetUUIDSet(ctx context.Context, pods []*corev1.Pod) (map[string]string, 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, schema string) (*RestoreManager, error)

func (*RestoreManager) FindNearestDump

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

FindNearestDump finds the nearest dump file and binlog file to the restore point. `keys` are object keys for the restoring instance. They need not be sorted.

func (*RestoreManager) Restore

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