controller

Documentation

Index

• func RolloutModel(oldPipeline numaflowV1alpha1.Pipeline, client client.Client)
• type MLInferenceOperatorContext
  • func NewMLInferenceOperateContext(ctx context.Context, logger logr.Logger, client client.Client, ...) *MLInferenceOperatorContext
  • func (mlictx *MLInferenceOperatorContext) Process() error
  • func (mlictx *MLInferenceOperatorContext) Reconcile() error
  • func (mlictx *MLInferenceOperatorContext) Validate() bool
• type MLInferenceReconciler
  • func (r *MLInferenceReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
  • func (r *MLInferenceReconciler) SetupWithManager(mgr ctrl.Manager) error

Functions

func RolloutModel

func RolloutModel(oldPipeline numaflowV1alpha1.Pipeline, client client.Client)

Types

type MLInferenceOperatorContext

type MLInferenceOperatorContext struct {
	// contains filtered or unexported fields
}

func NewMLInferenceOperateContext

func NewMLInferenceOperateContext(ctx context.Context, logger logr.Logger, client client.Client, obj *v1alpha1.MLInference) *MLInferenceOperatorContext

func (*MLInferenceOperatorContext) Process

func (mlictx *MLInferenceOperatorContext) Process() error

func (*MLInferenceOperatorContext) Reconcile

func (mlictx *MLInferenceOperatorContext) Reconcile() error

func (*MLInferenceOperatorContext) Validate

func (mlictx *MLInferenceOperatorContext) Validate() bool

validate if MLInference spec meets requirements

type MLInferenceReconciler

type MLInferenceReconciler struct {
	client.Client
	Scheme     *runtime.Scheme
	Cache      cache.Cache
	RESTMapper meta.RESTMapper
}

MLInferenceReconciler reconciles a MLInference object

func (*MLInferenceReconciler) Reconcile

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

func (*MLInferenceReconciler) SetupWithManager

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

SetupWithManager sets up the controller with the Manager.