controllers

Documentation

Index

• func Requeue() ctrl.Result
• func SkipUpdate() error
• type BackupReconciler
  • func (r *BackupReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *BackupReconciler) RemoveStale(ctx context.Context, backup *api.Backup) (ctrl.Result, error)
  • func (r *BackupReconciler) SetupWithManager(mgr ctrl.Manager) error
  • func (r *BackupReconciler) Snapshot(ctx context.Context, backup *api.Backup) (io.ReadCloser, error)
  • func (r *BackupReconciler) UploadBackup(ctx context.Context, backup *api.Backup) (ctrl.Result, error)
• type BackupScheduleReconciler
  • func (r *BackupScheduleReconciler) CreateBackup(ctx context.Context, schedule *api.BackupSchedule) error
  • func (r *BackupScheduleReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *BackupScheduleReconciler) Schedule(ctx context.Context, schedule *api.BackupSchedule) (ctrl.Result, error)
  • func (r *BackupScheduleReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ClusterReconciler
  • func (r *ClusterReconciler) CleanupSecrets(ctx context.Context, cluster *api.Cluster) (ctrl.Result, error)
  • func (r *ClusterReconciler) EnsureBackupSchedule(ctx context.Context, cluster *api.Cluster) (ctrl.Result, error)
  • func (r *ClusterReconciler) EnsureCA(ctx context.Context, cluster *api.Cluster) (ctrl.Result, error)
  • func (r *ClusterReconciler) EnsureCACertificate(ctx context.Context, cluster *api.Cluster) (ctrl.Result, error)
  • func (r *ClusterReconciler) EnsureCAIssuer(ctx context.Context, cluster *api.Cluster) (ctrl.Result, error)
  • func (r *ClusterReconciler) EnsureMember(ctx context.Context, cluster *api.Cluster, num int) (*api.Member, error)
  • func (r *ClusterReconciler) EnsureMembers(ctx context.Context, cluster *api.Cluster) (ctrl.Result, error)
  • func (r *ClusterReconciler) EnsureService(ctx context.Context, cluster *api.Cluster) (ctrl.Result, error)
  • func (r *ClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *ClusterReconciler) RepairMembers(ctx context.Context, cluster *api.Cluster) (ctrl.Result, error)
  • func (r *ClusterReconciler) SetupWithManager(mgr ctrl.Manager) error
  • func (r *ClusterReconciler) UpdateMembers(ctx context.Context, cluster *api.Cluster) (ctrl.Result, error)
• type MemberReconciler
  • func (r *MemberReconciler) CheckCertificateExpires(ctx context.Context, member *api.Member) (ctrl.Result, error)
  • func (r *MemberReconciler) DeletePVC(ctx context.Context, member *api.Member) (ctrl.Result, error)
  • func (r *MemberReconciler) DeletePod(ctx context.Context, member *api.Member) (ctrl.Result, error)
  • func (r *MemberReconciler) EnsureCertificates(ctx context.Context, member *api.Member) (ctrl.Result, error)
  • func (r *MemberReconciler) EnsurePVC(ctx context.Context, member *api.Member) (ctrl.Result, error)
  • func (r *MemberReconciler) EnsurePod(ctx context.Context, member *api.Member) (ctrl.Result, error)
  • func (r *MemberReconciler) ReaddToCluster(ctx context.Context, member *api.Member) (ctrl.Result, error)
  • func (r *MemberReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *MemberReconciler) Repair(ctx context.Context, member *api.Member) (ctrl.Result, error)
  • func (r *MemberReconciler) SetupWithManager(mgr ctrl.Manager) error

Functions

func Requeue

func Requeue() ctrl.Result

func SkipUpdate

func SkipUpdate() error

Types

type BackupReconciler

type BackupReconciler struct {
	client.Client
	Scheme     *runtime.Scheme
	S3API      s3iface.S3API
	S3Uploader *s3manager.Uploader
	S3Bucket   string
	S3Prefix   string
}

BackupReconciler reconciles a Backup object

func (*BackupReconciler) Reconcile

func (r *BackupReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

func (*BackupReconciler) RemoveStale

func (r *BackupReconciler) RemoveStale(ctx context.Context, backup *api.Backup) (ctrl.Result, error)

func (*BackupReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

func (*BackupReconciler) Snapshot

func (r *BackupReconciler) Snapshot(ctx context.Context, backup *api.Backup) (io.ReadCloser, error)

func (*BackupReconciler) UploadBackup

func (r *BackupReconciler) UploadBackup(ctx context.Context, backup *api.Backup) (ctrl.Result, error)

type BackupScheduleReconciler

type BackupScheduleReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

BackupScheduleReconciler reconciles a BackupSchedule object

func (*BackupScheduleReconciler) CreateBackup

func (r *BackupScheduleReconciler) CreateBackup(ctx context.Context, schedule *api.BackupSchedule) error

func (*BackupScheduleReconciler) Reconcile

func (r *BackupScheduleReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

func (*BackupScheduleReconciler) Schedule

func (r *BackupScheduleReconciler) Schedule(ctx context.Context, schedule *api.BackupSchedule) (ctrl.Result, error)

func (*BackupScheduleReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type ClusterReconciler

type ClusterReconciler struct {
	client.Client
	Scheme        *runtime.Scheme
	ClusterIssuer string
}

ClusterReconciler reconciles a Cluster object

func (*ClusterReconciler) CleanupSecrets

func (r *ClusterReconciler) CleanupSecrets(ctx context.Context, cluster *api.Cluster) (ctrl.Result, error)

func (*ClusterReconciler) EnsureBackupSchedule

func (r *ClusterReconciler) EnsureBackupSchedule(ctx context.Context, cluster *api.Cluster) (ctrl.Result, error)

func (*ClusterReconciler) EnsureCA

func (r *ClusterReconciler) EnsureCA(ctx context.Context, cluster *api.Cluster) (ctrl.Result, error)

func (*ClusterReconciler) EnsureCACertificate

func (r *ClusterReconciler) EnsureCACertificate(ctx context.Context, cluster *api.Cluster) (ctrl.Result, error)

func (*ClusterReconciler) EnsureCAIssuer

func (r *ClusterReconciler) EnsureCAIssuer(ctx context.Context, cluster *api.Cluster) (ctrl.Result, error)

func (*ClusterReconciler) EnsureMember

func (r *ClusterReconciler) EnsureMember(ctx context.Context, cluster *api.Cluster, num int) (*api.Member, error)

func (*ClusterReconciler) EnsureMembers

func (r *ClusterReconciler) EnsureMembers(ctx context.Context, cluster *api.Cluster) (ctrl.Result, error)

func (*ClusterReconciler) EnsureService

func (r *ClusterReconciler) EnsureService(ctx context.Context, cluster *api.Cluster) (ctrl.Result, error)

func (*ClusterReconciler) Reconcile

func (r *ClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

func (*ClusterReconciler) RepairMembers

func (r *ClusterReconciler) RepairMembers(ctx context.Context, cluster *api.Cluster) (ctrl.Result, error)

func (*ClusterReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

func (*ClusterReconciler) UpdateMembers

func (r *ClusterReconciler) UpdateMembers(ctx context.Context, cluster *api.Cluster) (ctrl.Result, error)

type MemberReconciler

type MemberReconciler struct {
	client.Client
	Scheme *runtime.Scheme
}

MemberReconciler reconciles a Member object

func (*MemberReconciler) CheckCertificateExpires

func (r *MemberReconciler) CheckCertificateExpires(ctx context.Context, member *api.Member) (ctrl.Result, error)

func (*MemberReconciler) DeletePVC

func (r *MemberReconciler) DeletePVC(ctx context.Context, member *api.Member) (ctrl.Result, error)

func (*MemberReconciler) DeletePod

func (r *MemberReconciler) DeletePod(ctx context.Context, member *api.Member) (ctrl.Result, error)

func (*MemberReconciler) EnsureCertificates

func (r *MemberReconciler) EnsureCertificates(ctx context.Context, member *api.Member) (ctrl.Result, error)

func (*MemberReconciler) EnsurePVC

func (r *MemberReconciler) EnsurePVC(ctx context.Context, member *api.Member) (ctrl.Result, error)

func (*MemberReconciler) EnsurePod

func (r *MemberReconciler) EnsurePod(ctx context.Context, member *api.Member) (ctrl.Result, error)

func (*MemberReconciler) ReaddToCluster

func (r *MemberReconciler) ReaddToCluster(ctx context.Context, member *api.Member) (ctrl.Result, error)

func (*MemberReconciler) Reconcile

func (r *MemberReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.

func (*MemberReconciler) Repair

func (r *MemberReconciler) Repair(ctx context.Context, member *api.Member) (ctrl.Result, error)

func (*MemberReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.