backup

Documentation

Index

• Constants
• type BackupSessionController
  • func (c *BackupSessionController) HandleBackupSetupFailure(setupErr error)
  • func (c *BackupSessionController) RunBackup() error
• type Controller
  • func New(k8sClient kubernetes.Interface, stashClient cs.Interface, opt Options) *Controller
  • func (c *Controller) Backup() error
  • func (c *Controller) BackupScheduler() error
  • func (c *Controller) GroupingKeys(resource *api.Restic) map[string]string
  • func (c *Controller) JobName(resource *api.Restic) string
• type Options

Constants

const (
	CheckRole            = "stash-check"
	BackupEventComponent = "stash-backup"
)

Types

type BackupSessionController

type BackupSessionController struct {
	K8sClient            kubernetes.Interface
	StashClient          cs.Interface
	MasterURL            string
	KubeconfigPath       string
	StashInformerFactory stashinformers.SharedInformerFactory
	MaxNumRequeues       int
	NumThreads           int
	ResyncPeriod         time.Duration
	//backupConfiguration
	BackupConfigurationName string
	Namespace               string
	//Restic
	SetupOpt restic.SetupOptions
	Metrics  restic.MetricsOptions

	Status   status.UpdateStatusOptions
	Recorder record.EventRecorder
	// contains filtered or unexported fields
}

func (*BackupSessionController) HandleBackupSetupFailure

func (c *BackupSessionController) HandleBackupSetupFailure(setupErr error)

func (*BackupSessionController) RunBackup

func (c *BackupSessionController) RunBackup() error

type Controller

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

func New

func New(k8sClient kubernetes.Interface, stashClient cs.Interface, opt Options) *Controller

func (*Controller) Backup

func (c *Controller) Backup() error

func (*Controller) BackupScheduler

func (c *Controller) BackupScheduler() error

func (*Controller) GroupingKeys

func (c *Controller) GroupingKeys(resource *api.Restic) map[string]string

func (*Controller) JobName

func (c *Controller) JobName(resource *api.Restic) string

type Options

type Options struct {
	Workload         api.LocalTypedReference
	Namespace        string
	ResticName       string
	ScratchDir       string
	PushgatewayURL   string
	NodeName         string
	PodName          string
	SmartPrefix      string
	SnapshotHostname string
	PodLabelsPath    string
	QPS              float64
	Burst            int
	ResyncPeriod     time.Duration
	MaxNumRequeues   int
	RunViaCron       bool
	DockerRegistry   string // image registry for check job
	ImageTag         string // image tag for check job
	NumThreads       int
}