backup

Documentation

Index

• Constants
• type BackupController
  • func NewBackupController(config *BackupControllerConfig) (*BackupController, error)
  • func (bc *BackupController) Run()
  • func (bc *BackupController) StartHTTP()
• type BackupControllerConfig
• type BackupManager
  • func NewBackupManager(kubecli kubernetes.Interface, clusterName string, namespace string, ...) *BackupManager
  • func (bm *BackupManager) SaveSnap(lastSnapRev int64) (*backupapi.BackupStatus, error)
• type BackupServer
  • func NewBackupServer(backend backend.Backend) *BackupServer
  • func (bs *BackupServer) ServeBackup(w http.ResponseWriter, r *http.Request)

Constants

const (
	HTTPHeaderEtcdVersion = "X-etcd-Version"
	HTTPHeaderRevision    = "X-Revision"
)

const (
	PVBackupV1 = "v1"
)

Types

type BackupController

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

BackupController controls when to do backup based on backup policy and incoming HTTP backup requests.

func NewBackupController

func NewBackupController(config *BackupControllerConfig) (*BackupController, error)

NewBackupController creates a BackupController.

func (*BackupController) Run

func (bc *BackupController) Run()

Run starts BackupController controller where it controlls backups based on backup policy and HTTP backup requests.

func (*BackupController) StartHTTP

func (bc *BackupController) StartHTTP()

type BackupControllerConfig

type BackupControllerConfig struct {
	Kubecli kubernetes.Interface

	ListenAddr  string
	ClusterName string
	Namespace   string

	TLS          *api.TLSPolicy
	BackupPolicy *api.BackupPolicy
}

BackupControllerConfig contains configuration data to construct BackupController.

type BackupManager

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

BackupManager backups an etcd cluster.

func NewBackupManager

func NewBackupManager(kubecli kubernetes.Interface, clusterName string, namespace string, etcdTLSConfig *tls.Config, be backend.Backend) *BackupManager

NewBackupManager creates a BackupManager.

func (*BackupManager) SaveSnap

func (bm *BackupManager) SaveSnap(lastSnapRev int64) (*backupapi.BackupStatus, error)

SaveSnap saves the latest snapshot if its revision is greater than the given lastSnapRev and returns a BackupStatus containing saving backup metadata if SaveSnap succeeds.

type BackupServer

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

BackupServer provides the http handlers to handle backup related requests.

func NewBackupServer

func NewBackupServer(backend backend.Backend) *BackupServer

NewBackupServer creates a BackupServer.

func (*BackupServer) ServeBackup

func (bs *BackupServer) ServeBackup(w http.ResponseWriter, r *http.Request)

ServeBackup serves the backup request:

• For GET, it returns the headers of etcd version and revision, with backup data. For HEAD, it only returns the headers.
• It checks compatibility and fails any incompatible backup request
• If both etcd version and revision, it returns the specified backup. If etcd version and revision is not given, it returns the latest compatible backup. If etcd version is not given, it returns the latest backup.