controllers

Documentation

Index

• type CronScheduler
• type EtcdBackupReconciler
  • func (r *EtcdBackupReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *EtcdBackupReconciler) SetupWithManager(mgr ctrl.Manager) error
• type EtcdBackupScheduleReconciler
  • func (r *EtcdBackupScheduleReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)
  • func (r *EtcdBackupScheduleReconciler) SetupWithManager(mgr ctrl.Manager) error
• type EtcdClusterReconciler
  • func (r *EtcdClusterReconciler) Reconcile(req ctrl.Request) (_ ctrl.Result, reterr error)
  • func (r *EtcdClusterReconciler) SetupWithManager(mgr ctrl.Manager) error
• type EtcdPeerReconciler
  • func (r *EtcdPeerReconciler) Reconcile(req ctrl.Request) (_ ctrl.Result, reterr error)
  • func (r *EtcdPeerReconciler) SetupWithManager(mgr ctrl.Manager) error
• type MembersByName
  • func (a MembersByName) Len() int
  • func (a MembersByName) Less(i, j int) bool
  • func (a MembersByName) Swap(i, j int)
• type PeerPVCDeleter
  • func (o *PeerPVCDeleter) Execute(ctx context.Context) error
• type Schedule
• type ScheduleMap
  • func NewScheduleMap() *ScheduleMap
  • func (s *ScheduleMap) Delete(key string)
  • func (s *ScheduleMap) Read(key string) (Schedule, bool)
  • func (s *ScheduleMap) Write(key string, value Schedule)

Types

type CronScheduler

type CronScheduler interface {
	AddFunc(spec string, cmd func()) (cron.EntryID, error)
	Remove(id cron.EntryID)
}

type EtcdBackupReconciler

type EtcdBackupReconciler struct {
	client.Client
	Log logr.Logger

	// An absolute path to a directory which will contain backups that have not yet been pushed to their destination.
	TempDir string
}

EtcdBackupReconciler reconciles a EtcdBackup object

func (*EtcdBackupReconciler) Reconcile

func (r *EtcdBackupReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

func (*EtcdBackupReconciler) SetupWithManager

func (r *EtcdBackupReconciler) SetupWithManager(mgr ctrl.Manager) error

type EtcdBackupScheduleReconciler

type EtcdBackupScheduleReconciler struct {
	client.Client
	Log logr.Logger

	// CronHandler is able to schedule cronjobs to occur at given times.
	CronHandler CronScheduler

	// Schedules holds a mapping of resources to the object responsible for scheduling the backup to be taken.
	Schedules *ScheduleMap
}

EtcdBackupScheduleReconciler reconciles a EtcdBackupSchedule object

func (*EtcdBackupScheduleReconciler) Reconcile

func (r *EtcdBackupScheduleReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error)

func (*EtcdBackupScheduleReconciler) SetupWithManager

func (r *EtcdBackupScheduleReconciler) SetupWithManager(mgr ctrl.Manager) error

type EtcdClusterReconciler

type EtcdClusterReconciler struct {
	client.Client
	Log      logr.Logger
	Recorder record.EventRecorder
	Etcd     etcd.APIBuilder
}

EtcdClusterReconciler reconciles a EtcdCluster object

func (*EtcdClusterReconciler) Reconcile

func (r *EtcdClusterReconciler) Reconcile(req ctrl.Request) (_ ctrl.Result, reterr error)

func (*EtcdClusterReconciler) SetupWithManager

func (r *EtcdClusterReconciler) SetupWithManager(mgr ctrl.Manager) error

type EtcdPeerReconciler

type EtcdPeerReconciler struct {
	client.Client
	Log  logr.Logger
	Etcd etcd.APIBuilder
}

EtcdPeerReconciler reconciles a EtcdPeer object

func (*EtcdPeerReconciler) Reconcile

func (r *EtcdPeerReconciler) Reconcile(req ctrl.Request) (_ ctrl.Result, reterr error)

func (*EtcdPeerReconciler) SetupWithManager

func (r *EtcdPeerReconciler) SetupWithManager(mgr ctrl.Manager) error

type MembersByName

type MembersByName []etcdclient.Member

MembersByName provides a sort.Sort interface for etcdClient.Member.Name

func (MembersByName) Len

func (a MembersByName) Len() int

func (MembersByName) Less

func (a MembersByName) Less(i, j int) bool

func (MembersByName) Swap

func (a MembersByName) Swap(i, j int)

type PeerPVCDeleter

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

PeerPVCDeleter deletes the PVC for an EtcdPeer and removes the PVC deletion finalizer.

func (*PeerPVCDeleter) Execute

func (o *PeerPVCDeleter) Execute(ctx context.Context) error

Execute performs the deletiong and finalizer removal

type Schedule

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

type ScheduleMap

type ScheduleMap struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

ScheduleMap is a thread-safe mapping of backup schedules.

func NewScheduleMap

func NewScheduleMap() *ScheduleMap

func (*ScheduleMap) Delete

func (s *ScheduleMap) Delete(key string)

func (*ScheduleMap) Read

func (s *ScheduleMap) Read(key string) (Schedule, bool)

func (*ScheduleMap) Write

func (s *ScheduleMap) Write(key string, value Schedule)