controllers

package

v0.2.0 Latest Latest Go to latest Published: Feb 13, 2020 License: MIT Imports: 35 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/improbable-eng/etcd-cluster-operator

Links

Open Source Insights

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
type PeerPVCDeleter
- func (o *PeerPVCDeleter) Execute(ctx context.Context) error
type Schedule
type ScheduleMap
- func NewScheduleMap() *ScheduleMap

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type CronScheduler ¶ added in v0.2.0

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 ¶ added in v0.2.0

type MembersByName []etcdclient.Member

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

func (MembersByName) Len ¶ added in v0.2.0

func (a MembersByName) Len() int

func (MembersByName) Less ¶ added in v0.2.0

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

func (MembersByName) Swap ¶ added in v0.2.0

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

type PeerPVCDeleter ¶ added in v0.2.0

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

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

func (*PeerPVCDeleter) Execute ¶ added in v0.2.0

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

Execute performs the deletiong and finalizer removal

type Schedule ¶ added in v0.2.0

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

type ScheduleMap ¶ added in v0.2.0

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

ScheduleMap is a thread-safe mapping of backup schedules.

func NewScheduleMap ¶ added in v0.2.0

func NewScheduleMap() *ScheduleMap

func (*ScheduleMap) Delete ¶ added in v0.2.0

func (s *ScheduleMap) Delete(key string)

func (*ScheduleMap) Read ¶ added in v0.2.0

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

func (*ScheduleMap) Write ¶ added in v0.2.0

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL