controller

Documentation

Index

• type AirflowClusterReconciler
  • func (r *AirflowClusterReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *AirflowClusterReconciler) SetupWithManager(mgr ctrl.Manager) error
• type ClusterReconciler
  • func NewClusterReconciler(client *client.Client, clusterInfo reconciler.ClusterInfo, ...) *ClusterReconciler
  • func (r *ClusterReconciler) GetImage() *util.Image
  • func (r *ClusterReconciler) RegisterResource(ctx context.Context) error

Types

type AirflowClusterReconciler

type AirflowClusterReconciler struct {
	ctrlclient.Client
	Scheme *runtime.Scheme
}

AirflowClusterReconciler reconciles a AirflowCluster object

func (*AirflowClusterReconciler) Reconcile

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

func (*AirflowClusterReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.

type ClusterReconciler

type ClusterReconciler struct {
	reconciler.BaseCluster[*airflowv1alpha1.AirflowClusterSpec]
	ClusterConfig *airflowv1alpha1.ClusterConfigSpec
}

func NewClusterReconciler

func NewClusterReconciler(
	client *client.Client,
	clusterInfo reconciler.ClusterInfo,
	spec *airflowv1alpha1.AirflowClusterSpec,
) *ClusterReconciler

func (*ClusterReconciler) GetImage

func (r *ClusterReconciler) GetImage() *util.Image

func (*ClusterReconciler) RegisterResource

func (r *ClusterReconciler) RegisterResource(ctx context.Context) error