controller/

Sep 3, 2024

Changes in this version

+ const ControllerMonoVertexRollout

+ type MonoVertexRolloutReconciler struct

+ func NewMonoVertexRolloutReconciler(client client.Client, s *runtime.Scheme, restConfig *rest.Config, ...) *MonoVertexRolloutReconciler

+ func (r *MonoVertexRolloutReconciler) ErrorHandler(monoVertexRollout *apiv1.MonoVertexRollout, err error, reason, msg string)

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

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

Aug 14, 2024

Changes in this version

+ const DefaultNumaflowControllerImageName

type ISBServiceRolloutReconciler

+ func (r *ISBServiceRolloutReconciler) ErrorHandler(isbServiceRollout *apiv1.ISBServiceRollout, err error, reason, msg string)

type NumaflowControllerRolloutReconciler

+ func (r *NumaflowControllerRolloutReconciler) ErrorHandler(numaflowControllerRollout *apiv1.NumaflowControllerRollout, err error, ...)

+ type PauseModule struct

+ func GetPauseModule() *PauseModule

+ type PauseRequester interface

type PipelineRolloutReconciler

+ func (r *PipelineRolloutReconciler) ErrorHandler(pipelineRollout *apiv1.PipelineRollout, err error, reason, msg string)

+ type PipelineSpec struct

+ InterStepBufferServiceName string

+ Lifecycle lifecycle

Jul 16, 2024

Changes in this version

type PipelineRolloutReconciler

+ func (r *PipelineRolloutReconciler) Shutdown(ctx context.Context)

Jun 25, 2024

Changes in this version

+ const ControllerISBSVCRollout

+ const ControllerNumaflowControllerRollout

+ const ControllerPipelineRollout

+ const NumaflowControllerDeploymentName

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

+ type ISBServiceRolloutReconciler struct

+ func NewISBServiceRolloutReconciler(client client.Client, s *runtime.Scheme, restConfig *rest.Config) *ISBServiceRolloutReconciler

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

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

+ type NumaflowControllerRolloutReconciler struct

+ func NewNumaflowControllerRolloutReconciler(client client.Client, s *runtime.Scheme, rawConfig *rest.Config, ...) (*NumaflowControllerRolloutReconciler, error)

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

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

+ type PipelineRolloutReconciler struct

+ func NewPipelineRolloutReconciler(client client.Client, s *runtime.Scheme, restConfig *rest.Config) *PipelineRolloutReconciler

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

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