rayclusterreplicaset

Documentation

Index

• func Add(mgr manager.Manager, runtimeConfig config.RuntimeConfig) error
• func GetCondition(status orchestrationv1alpha1.RayClusterReplicaSetStatus, condType string) *metav1.Condition
• func NewCondition(condType string, status metav1.ConditionStatus, reason, msg string) metav1.Condition
• func RemoveCondition(status *orchestrationv1alpha1.RayClusterReplicaSetStatus, condType string)
• func SetCondition(status *orchestrationv1alpha1.RayClusterReplicaSetStatus, ...)
• type RayClusterReplicaSetReconciler
  • func (r *RayClusterReplicaSetReconciler) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

Functions

func Add

func Add(mgr manager.Manager, runtimeConfig config.RuntimeConfig) error

Add creates a new RayClusterReplicaSet Controller and adds it to the Manager with default RBAC. The Manager will set fields on the Controller and Start it when the Manager is Started.

func GetCondition

func GetCondition(status orchestrationv1alpha1.RayClusterReplicaSetStatus, condType string) *metav1.Condition

GetCondition returns a replicaset condition with the provided type if it exists.

func NewCondition

func NewCondition(condType string, status metav1.ConditionStatus, reason, msg string) metav1.Condition

NewCondition creates a new replicaset condition.

func RemoveCondition

func RemoveCondition(status *orchestrationv1alpha1.RayClusterReplicaSetStatus, condType string)

RemoveCondition removes the condition with the provided type from the replicaset status.

func SetCondition

func SetCondition(status *orchestrationv1alpha1.RayClusterReplicaSetStatus, condition metav1.Condition)

SetCondition adds/replaces the given condition in the replicaset status. If the condition that we are about to add already exists and has the same status and reason then we are not going to update.

Types

type RayClusterReplicaSetReconciler

type RayClusterReplicaSetReconciler struct {
	client.Client
	Scheme   *runtime.Scheme
	Recorder record.EventRecorder
	// A cache raycluster creates/deletes each raycluster replicaset to see
	// We use replicaset namespace/name as an expectation key
	// For example, there is a RayClusterReplicaSet with namespace "aibrix", name "llama7b" and replica 3,
	// We will create the expectation:
	// - "aibrix/llama7b", expects 3 adds.
	Expectations  expectation.ControllerExpectationsInterface
	RuntimeConfig config.RuntimeConfig
}

RayClusterReplicaSetReconciler reconciles a RayClusterReplicaSet object

func (*RayClusterReplicaSetReconciler) Reconcile

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

Reconcile method moves the RayClusterReplicaSet to desired State