Documentation
¶
Index ¶
Constants ¶
const ( RayJobDefaultRequeueDuration = 3 * time.Second PythonUnbufferedEnvVarName = "PYTHONUNBUFFERED" DefaultSubmitterFinishedTimeout = 30 * time.Second )
const ( ServiceDefaultRequeueDuration = 2 * time.Second RayClusterDeletionDelayDuration = 60 * time.Second ENABLE_ZERO_DOWNTIME = "ENABLE_ZERO_DOWNTIME" )
const (
RayCronJobDefaultRequeueDuration = 3 * time.Second
)
Variables ¶
var (
DefaultRequeueDuration = 2 * time.Second
)
Functions ¶
This section is empty.
Types ¶
type RayClusterReconciler ¶
type RayClusterReconciler struct {
client.Client
Scheme *k8sruntime.Scheme
Recorder record.EventRecorder
// contains filtered or unexported fields
}
RayClusterReconciler reconciles a RayCluster object
func NewReconciler ¶
func NewReconciler(ctx context.Context, mgr manager.Manager, options RayClusterReconcilerOptions) *RayClusterReconciler
NewReconciler returns a new reconcile.Reconciler
func (*RayClusterReconciler) Reconcile ¶
func (r *RayClusterReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)
Reconcile used to bridge the desired state with the current state
func (*RayClusterReconciler) SetupWithManager ¶
func (r *RayClusterReconciler) SetupWithManager(mgr ctrl.Manager, reconcileConcurrency int) error
SetupWithManager builds the reconciler.
type RayClusterReconcilerOptions ¶ added in v1.1.0
type RayClusterReconcilerOptions struct {
RayClusterMetricsManager *metrics.RayClusterMetricsManager
BatchSchedulerManager *batchscheduler.SchedulerManager
HeadSidecarContainers []corev1.Container
WorkerSidecarContainers []corev1.Container
DefaultContainerEnvs []corev1.EnvVar
IsOpenShift bool
}
type RayCronJobReconciler ¶ added in v1.6.0
type RayCronJobReconciler struct {
client.Client
Scheme *runtime.Scheme
Recorder record.EventRecorder
// contains filtered or unexported fields
}
RayCronJobReconciler reconciles a RayCronJob object
func NewRayCronJobReconciler ¶ added in v1.6.0
func NewRayCronJobReconciler(mgr ctrl.Manager) *RayCronJobReconciler
NewRayCronJobReconciler returns a new RayCronJobReconciler
func (*RayCronJobReconciler) Reconcile ¶ added in v1.6.0
func (r *RayCronJobReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)
[WARNING]: There MUST be a newline after kubebuilder markers. Reconcile reads that state of a RayCronJob object and makes changes based on it and what is in the RayCronJob.Spec Automatically generate RBAC rules to allow the Controller to read and write workloads Reconcile used to bridge the desired state with the current state
func (*RayCronJobReconciler) SetupWithManager ¶ added in v1.6.0
func (r *RayCronJobReconciler) SetupWithManager(mgr ctrl.Manager, reconcileConcurrency int) error
SetupWithManager sets up the controller with the Manager.
type RayJobReconciler ¶
type RayJobReconciler struct {
client.Client
Recorder record.EventRecorder
Scheme *runtime.Scheme
// contains filtered or unexported fields
}
RayJobReconciler reconciles a RayJob object
func NewRayJobReconciler ¶
func NewRayJobReconciler(ctx context.Context, mgr manager.Manager, options RayJobReconcilerOptions, provider utils.ClientProvider) *RayJobReconciler
NewRayJobReconciler returns a new reconcile.Reconciler
func (*RayJobReconciler) Reconcile ¶
func (r *RayJobReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)
[WARNING]: There MUST be a newline after kubebuilder markers. Reconcile reads that state of a RayJob object and makes changes based on it and what is in the RayJob.Spec Automatically generate RBAC rules to allow the Controller to read and write workloads Reconcile used to bridge the desired state with the current state
func (*RayJobReconciler) SetupWithManager ¶
func (r *RayJobReconciler) SetupWithManager(mgr ctrl.Manager, reconcileConcurrency int) error
SetupWithManager sets up the controller with the Manager.
type RayJobReconcilerOptions ¶ added in v1.4.0
type RayJobReconcilerOptions struct {
RayJobMetricsManager *metrics.RayJobMetricsManager
BatchSchedulerManager *batchscheduler.SchedulerManager
}
type RayServiceReconciler ¶
type RayServiceReconciler struct {
client.Client
Scheme *runtime.Scheme
Recorder record.EventRecorder
// Currently, the Ray dashboard doesn't cache the Serve application config.
// To avoid reapplying the same config repeatedly, cache the config in this map.
// Cache key is the combination of RayService namespace and name.
// Cache value is map of RayCluster name to Serve application config.
ServeConfigs *lru.Cache
RayClusterDeletionTimestamps cmap.ConcurrentMap[string, time.Time]
// contains filtered or unexported fields
}
RayServiceReconciler reconciles a RayService object
func NewRayServiceReconciler ¶
func NewRayServiceReconciler(ctx context.Context, mgr manager.Manager, provider utils.ClientProvider) *RayServiceReconciler
NewRayServiceReconciler returns a new reconcile.Reconciler
func (*RayServiceReconciler) Reconcile ¶
func (r *RayServiceReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)
[WARNING]: There MUST be a newline after kubebuilder markers. Reconcile is part of the main kubernetes reconciliation loop which aims to move the current state of the cluster closer to the desired state.
This the top level reconciliation flow for RayService.
For more details, check Reconcile and its Result here: - https://pkg.go.dev/sigs.k8s.io/controller-runtime@v0.11.2/pkg/reconcile
func (*RayServiceReconciler) SetupWithManager ¶
func (r *RayServiceReconciler) SetupWithManager(mgr ctrl.Manager, reconcileConcurrency int) error
SetupWithManager sets up the controller with the Manager.
Source Files
Directories