controller

package
v0.0.27 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 8, 2024 License: MIT Imports: 80 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BackupReconciler 

type BackupReconciler struct {
	client.Client
	Scheme            *runtime.Scheme
	Builder           *builder.Builder
	RefResolver       *refresolver.RefResolver
	ConditionComplete *condition.Complete
	RBACReconciler    *rbac.RBACReconciler
	BatchReconciler   *batch.BatchReconciler
}

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) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type ConnectionReconciler 

type ConnectionReconciler struct {
	client.Client
	Scheme          *runtime.Scheme
	Builder         *builder.Builder
	RefResolver     *refresolver.RefResolver
	ConditionReady  *condition.Ready
	RequeueInterval time.Duration
}

ConnectionReconciler reconciles a Connection object

func (*ConnectionReconciler) Reconcile 

func (r *ConnectionReconciler) 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 (*ConnectionReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type DatabaseReconciler 

type DatabaseReconciler struct {
	client.Client
	RefResolver     *refresolver.RefResolver
	ConditionReady  *condition.Ready
	RequeueInterval time.Duration
}

DatabaseReconciler reconciles a Database object

func NewDatabaseReconciler added in v0.0.24 

func NewDatabaseReconciler(client client.Client, refResolver *refresolver.RefResolver, conditionReady *condition.Ready,
	requeueInterval time.Duration) *DatabaseReconciler

func (*DatabaseReconciler) Reconcile 

func (r *DatabaseReconciler) 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 (*DatabaseReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type GrantReconciler 

type GrantReconciler struct {
	client.Client
	RefResolver     *refresolver.RefResolver
	ConditionReady  *condition.Ready
	RequeueInterval time.Duration
}

GrantReconciler reconciles a Grant object

func NewGrantReconciler added in v0.0.24 

func NewGrantReconciler(client client.Client, refResolver *refresolver.RefResolver, conditionReady *condition.Ready,
	requeueInterval time.Duration) *GrantReconciler

func (*GrantReconciler) Reconcile 

func (r *GrantReconciler) 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 (*GrantReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type MariaDBReconciler 

type MariaDBReconciler struct {
	client.Client
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder

	Builder         *builder.Builder
	RefResolver     *refresolver.RefResolver
	ConditionReady  *condition.Ready
	Environment     *environment.OperatorEnv
	DiscoveryClient *discovery.DiscoveryClient

	ConfigMapReconciler      *configmap.ConfigMapReconciler
	SecretReconciler         *secret.SecretReconciler
	StatefulSetReconciler    *statefulset.StatefulSetReconciler
	ServiceReconciler        *service.ServiceReconciler
	EndpointsReconciler      *endpoints.EndpointsReconciler
	RBACReconciler           *rbac.RBACReconciler
	AuthReconciler           *auth.AuthReconciler
	DeploymentReconciler     *deployment.DeploymentReconciler
	ServiceMonitorReconciler *servicemonitor.ServiceMonitorReconciler
	MaxScaleReconciler       *maxscale.MaxScaleReconciler

	ReplicationReconciler *replication.ReplicationReconciler
	GaleraReconciler      *galera.GaleraReconciler
}

MariaDBReconciler reconciles a MariaDB object

func (*MariaDBReconciler) Reconcile 

func (r *MariaDBReconciler) 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 (*MariaDBReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type MaxScaleReconciler added in v0.0.25 

type MaxScaleReconciler struct {
	client.Client
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder

	Builder        *builder.Builder
	ConditionReady *condition.Ready
	Environment    *environment.OperatorEnv
	RefResolver    *refresolver.RefResolver

	SecretReconciler      *secret.SecretReconciler
	RBACReconciler        *rbac.RBACReconciler
	AuthReconciler        *auth.AuthReconciler
	StatefulSetReconciler *statefulset.StatefulSetReconciler
	ServiceReconciler     *service.ServiceReconciler

	SuspendEnabled bool

	RequeueInterval time.Duration
	LogMaxScale     bool
}

MaxScaleReconciler reconciles a MaxScale object

func (*MaxScaleReconciler) Reconcile added in v0.0.25 

func (r *MaxScaleReconciler) 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 (*MaxScaleReconciler) SetupWithManager added in v0.0.25 

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

SetupWithManager sets up the controller with the Manager.

type PodController 

type PodController struct {
	client.Client
	// contains filtered or unexported fields
}

PodController reconciles a Pod object

func NewPodController 

func NewPodController(client client.Client, refResolver *refresolver.RefResolver, podReadinessController PodReadinessController,
	podAnnotations []string) *PodController

func (*PodController) Reconcile 

func (r *PodController) 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 (*PodController) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type PodGaleraController 

type PodGaleraController struct {
	client.Client
	// contains filtered or unexported fields
}

PodGaleraController reconciles a Pod object

func (*PodGaleraController) ReconcilePodNotReady 

func (r *PodGaleraController) ReconcilePodNotReady(ctx context.Context, pod corev1.Pod, mariadb *mariadbv1alpha1.MariaDB) error

func (*PodGaleraController) ReconcilePodReady 

func (r *PodGaleraController) ReconcilePodReady(ctx context.Context, pod corev1.Pod, mariadb *mariadbv1alpha1.MariaDB) error

type PodReadinessController 

type PodReadinessController interface {
	ReconcilePodReady(context.Context, corev1.Pod, *mariadbv1alpha1.MariaDB) error
	ReconcilePodNotReady(context.Context, corev1.Pod, *mariadbv1alpha1.MariaDB) error
}

func NewPodGaleraController 

func NewPodGaleraController(client client.Client, recorder record.EventRecorder) PodReadinessController

func NewPodReplicationController 

func NewPodReplicationController(client client.Client, recorder record.EventRecorder, builder *builder.Builder,
	refResolver *refresolver.RefResolver, replConfig *replication.ReplicationConfig) PodReadinessController

type PodReplicationController 

type PodReplicationController struct {
	client.Client
	// contains filtered or unexported fields
}

PodReplicationController reconciles a Pod object

func (*PodReplicationController) ReconcilePodNotReady 

func (r *PodReplicationController) ReconcilePodNotReady(ctx context.Context, pod corev1.Pod, mariadb *mariadbv1alpha1.MariaDB) error

func (*PodReplicationController) ReconcilePodReady 

func (r *PodReplicationController) ReconcilePodReady(ctx context.Context, pod corev1.Pod, mariadb *mariadbv1alpha1.MariaDB) error

type RestoreReconciler 

type RestoreReconciler struct {
	client.Client
	Scheme            *runtime.Scheme
	Builder           *builder.Builder
	RefResolver       *refresolver.RefResolver
	ConditionComplete *condition.Complete
	RBACReconciler    *rbac.RBACReconciler
	BatchReconciler   *batch.BatchReconciler
}

RestoreReconciler reconciles a restore object

func (*RestoreReconciler) Reconcile 

func (r *RestoreReconciler) 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 (*RestoreReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type SqlJobReconciler 

type SqlJobReconciler struct {
	client.Client
	Scheme              *runtime.Scheme
	Builder             *builder.Builder
	RefResolver         *refresolver.RefResolver
	ConditionComplete   *condition.Complete
	ConfigMapReconciler *configmap.ConfigMapReconciler
	RBACReconciler      *rbac.RBACReconciler
	RequeueInterval     time.Duration
}

SqlJobReconciler reconciles a SqlJob object

func (*SqlJobReconciler) Reconcile 

func (r *SqlJobReconciler) 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 (*SqlJobReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type StatefulSetGaleraReconciler 

type StatefulSetGaleraReconciler struct {
	client.Client
	Recorder    record.EventRecorder
	RefResolver *refresolver.RefResolver
}

func (*StatefulSetGaleraReconciler) Reconcile 

func (r *StatefulSetGaleraReconciler) 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 (*StatefulSetGaleraReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type UserReconciler 

type UserReconciler struct {
	client.Client
	RefResolver     *refresolver.RefResolver
	ConditionReady  *condition.Ready
	RequeueInterval time.Duration
}

UserReconciler reconciles a User object

func NewUserReconciler added in v0.0.24 

func NewUserReconciler(client client.Client, refResolver *refresolver.RefResolver, conditionReady *condition.Ready,
	requeueInterval time.Duration) *UserReconciler

func (*UserReconciler) Reconcile 

func (r *UserReconciler) 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 (*UserReconciler) SetupWithManager 

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

SetupWithManager sets up the controller with the Manager.

type WebhookConfigReconciler added in v0.0.23 

type WebhookConfigReconciler struct {
	client.Client
	// contains filtered or unexported fields
}

func NewWebhookConfigReconciler added in v0.0.23 

func NewWebhookConfigReconciler(client client.Client, scheme *runtime.Scheme, recorder record.EventRecorder, leaderChan <-chan struct{},
	caSecretKey types.NamespacedName, caCommonName string, caValidity time.Duration,
	certSecretKey types.NamespacedName, certValidity time.Duration, lookaheadValidity time.Duration,
	serviceKey types.NamespacedName, requeueDuration time.Duration) *WebhookConfigReconciler

func (*WebhookConfigReconciler) ReadyHandler added in v0.0.23 

func (r *WebhookConfigReconciler) ReadyHandler(logger logr.Logger) func(_ *http.Request) error

func (*WebhookConfigReconciler) Reconcile added in v0.0.23 

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

func (*WebhookConfigReconciler) SetupWithManager added in v0.0.23 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.