backup

Documentation

Index

• Constants
• type BackupSessionController
  • func (c *BackupSessionController) HandleBackupSetupFailure(ref *core.ObjectReference, setupErr error) error
  • func (c *BackupSessionController) RunBackup(targetInfo apis.TargetInfo, invokerRef *core.ObjectReference) 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 {
	Config               *rest.Config
	K8sClient            kubernetes.Interface
	StashClient          cs.Interface
	MasterURL            string
	KubeconfigPath       string
	StashInformerFactory stashinformers.SharedInformerFactory
	MaxNumRequeues       int
	NumThreads           int
	ResyncPeriod         time.Duration
	//backupConfiguration/BackupBatch
	InvokerType      string
	InvokerName      string
	Namespace        string
	BackupTargetName string
	BackupTargetKind string

	SetupOpt restic.SetupOptions
	Host     string
	Metrics  restic.MetricsOptions
	Recorder record.EventRecorder
	// contains filtered or unexported fields
}

func (*BackupSessionController) HandleBackupSetupFailure

func (c *BackupSessionController) HandleBackupSetupFailure(ref *core.ObjectReference, setupErr error) error

func (*BackupSessionController) RunBackup

func (c *BackupSessionController) RunBackup(targetInfo apis.TargetInfo, invokerRef *core.ObjectReference) 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
}