backup

Documentation

Index

• func NewBackupManager(deps *controller.Dependencies) backup.BackupManager
• type BackupCleaner
  • func NewBackupCleaner(deps *controller.Dependencies, ...) BackupCleaner
• type BackupTracker
  • func NewBackupTracker(deps *controller.Dependencies, ...) BackupTracker
• type FakeBackupManager
  • func NewFakeBackupManager() *FakeBackupManager
  • func (m *FakeBackupManager) SetSyncError(err error)
  • func (m *FakeBackupManager) Sync(_ *v1alpha1.Backup) error
  • func (m *FakeBackupManager) UpdateStatus(_ *v1alpha1.Backup, _ *v1alpha1.BackupCondition, ...) error
• type ManifestFetcher
  • func NewTiDBClusterAutoScalerFetcher(lister listers.TidbClusterAutoScalerLister) ManifestFetcher
  • func NewTiDBDashboardFetcher(lister listers.TidbDashboardLister) ManifestFetcher
  • func NewTiDBInitializerFetcher(lister listers.TidbInitializerLister) ManifestFetcher
  • func NewTiDBMonitorFetcher(lister listers.TidbMonitorLister) ManifestFetcher
  • func NewTiDBNgMonitoringFetcher(lister listers.TidbNGMonitoringLister) ManifestFetcher
• type TiDBClusterAutoScalerFetcher
  • func (f *TiDBClusterAutoScalerFetcher) ListByTC(tc *v1alpha1.TidbCluster) (objects []runtime.Object, err error)
• type TiDBDashboardFetcher
  • func (f *TiDBDashboardFetcher) ListByTC(tc *v1alpha1.TidbCluster) (objects []runtime.Object, err error)
• type TiDBInitializerFetcher
  • func (f *TiDBInitializerFetcher) ListByTC(tc *v1alpha1.TidbCluster) (objects []runtime.Object, err error)
• type TiDBMonitorFetcher
  • func (f *TiDBMonitorFetcher) ListByTC(tc *v1alpha1.TidbCluster) (objects []runtime.Object, err error)
• type TiDBNgMonitoringFetcher
  • func (f *TiDBNgMonitoringFetcher) ListByTC(tc *v1alpha1.TidbCluster) (objects []runtime.Object, err error)

Functions

func NewBackupManager

func NewBackupManager(deps *controller.Dependencies) backup.BackupManager

NewBackupManager return backupManager

Types

type BackupCleaner

type BackupCleaner interface {
	Clean(backup *v1alpha1.Backup) error
}

BackupCleaner implements the logic for cleaning backup

func NewBackupCleaner

func NewBackupCleaner(deps *controller.Dependencies, statusUpdater controller.BackupConditionUpdaterInterface) BackupCleaner

NewBackupCleaner returns a BackupCleaner

type BackupTracker

type BackupTracker interface {
	StartTrackLogBackupProgress(backup *v1alpha1.Backup) error
}

BackupTracker implements the logic for tracking log backup progress

func NewBackupTracker

func NewBackupTracker(deps *controller.Dependencies, statusUpdater controller.BackupConditionUpdaterInterface) BackupTracker

NewBackupTracker returns a BackupTracker

type FakeBackupManager

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

func NewFakeBackupManager

func NewFakeBackupManager() *FakeBackupManager

func (*FakeBackupManager) SetSyncError

func (m *FakeBackupManager) SetSyncError(err error)

func (*FakeBackupManager) Sync

func (m *FakeBackupManager) Sync(_ *v1alpha1.Backup) error

func (*FakeBackupManager) UpdateStatus

func (m *FakeBackupManager) UpdateStatus(_ *v1alpha1.Backup, _ *v1alpha1.BackupCondition, newStatus *controller.BackupUpdateStatus) error

UpdateStatus updates the status for a Backup, include condition and status info.

type ManifestFetcher

type ManifestFetcher interface {
	ListByTC(tc *v1alpha1.TidbCluster) (objects []runtime.Object, err error)
}

func NewTiDBClusterAutoScalerFetcher

func NewTiDBClusterAutoScalerFetcher(lister listers.TidbClusterAutoScalerLister) ManifestFetcher

func NewTiDBDashboardFetcher

func NewTiDBDashboardFetcher(lister listers.TidbDashboardLister) ManifestFetcher

func NewTiDBInitializerFetcher

func NewTiDBInitializerFetcher(lister listers.TidbInitializerLister) ManifestFetcher

func NewTiDBMonitorFetcher

func NewTiDBMonitorFetcher(lister listers.TidbMonitorLister) ManifestFetcher

func NewTiDBNgMonitoringFetcher

func NewTiDBNgMonitoringFetcher(lister listers.TidbNGMonitoringLister) ManifestFetcher

type TiDBClusterAutoScalerFetcher

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

func (*TiDBClusterAutoScalerFetcher) ListByTC

func (f *TiDBClusterAutoScalerFetcher) ListByTC(tc *v1alpha1.TidbCluster) (objects []runtime.Object, err error)

type TiDBDashboardFetcher

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

func (*TiDBDashboardFetcher) ListByTC

func (f *TiDBDashboardFetcher) ListByTC(tc *v1alpha1.TidbCluster) (objects []runtime.Object, err error)

type TiDBInitializerFetcher

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

func (*TiDBInitializerFetcher) ListByTC

func (f *TiDBInitializerFetcher) ListByTC(tc *v1alpha1.TidbCluster) (objects []runtime.Object, err error)

type TiDBMonitorFetcher

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

func (*TiDBMonitorFetcher) ListByTC

func (f *TiDBMonitorFetcher) ListByTC(tc *v1alpha1.TidbCluster) (objects []runtime.Object, err error)

type TiDBNgMonitoringFetcher

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

func (*TiDBNgMonitoringFetcher) ListByTC

func (f *TiDBNgMonitoringFetcher) ListByTC(tc *v1alpha1.TidbCluster) (objects []runtime.Object, err error)