numaflowcontroller

Dec 18, 2024

Changes in this version

+ const ControllerNumaflowController

+ const DefaultNumaflowControllerImageName

+ const NumaflowControllerDeploymentName

+ func SplitYAMLToString(yamlData []byte) ([]string, error)

+ type NumaflowControllerReconciler struct

+ func NewNumaflowControllerReconciler(client client.Client, scheme *runtime.Scheme, rawConfig *rest.Config, ...) (*NumaflowControllerReconciler, error)

+ func (r *NumaflowControllerReconciler) ErrorHandler(numaflowController *apiv1.NumaflowController, err error, reason, msg string)

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

+ func (r *NumaflowControllerReconciler) SetupWithManager(mgr ctrl.Manager) error