Documentation
¶
Index ¶
- func GetDefaultDeploymentSpec(config common.KaiwoConfigContext, dangerous bool) appsv1.DeploymentSpec
- func GetDefaultRayServiceSpec(config common.KaiwoConfigContext, dangerous bool) rayv1.RayServiceSpec
- func NewKaiwoServiceHandler(scheme *runtime.Scheme, kaiwoService *kaiwo.KaiwoService) common.WorkloadHandler
- type DeploymentHandler
- func (handler *DeploymentHandler) BuildDesired(ctx context.Context, clusterCtx common.ClusterContext) (client.Object, error)
- func (handler *DeploymentHandler) GetActual(ctx context.Context, k8sClient client.Client) (client.Object, error)
- func (handler *DeploymentHandler) GetCommonSpec() kaiwo.CommonMetaSpec
- func (handler *DeploymentHandler) GetCommonStatusSpec() *kaiwo.CommonStatusSpec
- func (handler *DeploymentHandler) GetInitializedObject() client.Object
- func (handler *DeploymentHandler) GetKaiwoWorkloadObject() client.Object
- func (handler *DeploymentHandler) GetKueueWorkloads(ctx context.Context, k8sClient client.Client) ([]kueuev1beta1.Workload, error)
- func (handler *DeploymentHandler) MutateActual(ctx context.Context, clusterCtx common.ClusterContext, actual client.Object) error
- func (handler *DeploymentHandler) ObserveStatus(ctx context.Context, k8sClient client.Client, obj client.Object, ...) (*kaiwo.WorkloadStatus, []metav1.Condition, error)
- type RayServiceHandler
- func (handler *RayServiceHandler) BuildDesired(ctx context.Context, clusterCtx common.ClusterContext) (client.Object, error)
- func (handler *RayServiceHandler) GetCommonSpec() kaiwo.CommonMetaSpec
- func (handler *RayServiceHandler) GetCommonStatusSpec() *kaiwo.CommonStatusSpec
- func (handler *RayServiceHandler) GetInitializedObject() client.Object
- func (handler *RayServiceHandler) GetKaiwoWorkloadObject() client.Object
- func (handler *RayServiceHandler) GetKueueWorkloads(ctx context.Context, k8sClient client.Client) ([]kueuev1beta1.Workload, error)
- func (handler *RayServiceHandler) HandleStatusChange(ctx context.Context, k8sClient client.Client, obj client.Object, ...) error
- func (handler *RayServiceHandler) MutateActual(ctx context.Context, clusterCtx common.ClusterContext, actual client.Object) error
- func (handler *RayServiceHandler) ObserveStatus(ctx context.Context, k8sClient client.Client, obj client.Object, ...) (*kaiwo.WorkloadStatus, []metav1.Condition, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetDefaultDeploymentSpec ¶
func GetDefaultDeploymentSpec(config common.KaiwoConfigContext, dangerous bool) appsv1.DeploymentSpec
func GetDefaultRayServiceSpec ¶
func GetDefaultRayServiceSpec(config common.KaiwoConfigContext, dangerous bool) rayv1.RayServiceSpec
func NewKaiwoServiceHandler ¶ added in v0.1.6
func NewKaiwoServiceHandler(scheme *runtime.Scheme, kaiwoService *kaiwo.KaiwoService) common.WorkloadHandler
Types ¶
type DeploymentHandler ¶ added in v0.1.6
type DeploymentHandler struct {
KaiwoService *kaiwo.KaiwoService
Scheme *runtime.Scheme
}
func (*DeploymentHandler) BuildDesired ¶ added in v0.1.6
func (handler *DeploymentHandler) BuildDesired(ctx context.Context, clusterCtx common.ClusterContext) (client.Object, error)
func (*DeploymentHandler) GetCommonSpec ¶ added in v0.1.6
func (handler *DeploymentHandler) GetCommonSpec() kaiwo.CommonMetaSpec
func (*DeploymentHandler) GetCommonStatusSpec ¶ added in v0.1.6
func (handler *DeploymentHandler) GetCommonStatusSpec() *kaiwo.CommonStatusSpec
func (*DeploymentHandler) GetInitializedObject ¶ added in v0.1.6
func (handler *DeploymentHandler) GetInitializedObject() client.Object
func (*DeploymentHandler) GetKaiwoWorkloadObject ¶ added in v0.1.6
func (handler *DeploymentHandler) GetKaiwoWorkloadObject() client.Object
func (*DeploymentHandler) GetKueueWorkloads ¶ added in v0.1.6
func (handler *DeploymentHandler) GetKueueWorkloads(ctx context.Context, k8sClient client.Client) ([]kueuev1beta1.Workload, error)
func (*DeploymentHandler) MutateActual ¶ added in v0.1.6
func (handler *DeploymentHandler) MutateActual(ctx context.Context, clusterCtx common.ClusterContext, actual client.Object) error
func (*DeploymentHandler) ObserveStatus ¶ added in v0.1.6
func (handler *DeploymentHandler) ObserveStatus(ctx context.Context, k8sClient client.Client, obj client.Object, previousStatus kaiwo.WorkloadStatus) (*kaiwo.WorkloadStatus, []metav1.Condition, error)
type RayServiceHandler ¶ added in v0.1.6
type RayServiceHandler struct {
KaiwoService *kaiwo.KaiwoService
Scheme *runtime.Scheme
}
func (*RayServiceHandler) BuildDesired ¶ added in v0.1.6
func (handler *RayServiceHandler) BuildDesired(ctx context.Context, clusterCtx common.ClusterContext) (client.Object, error)
func (*RayServiceHandler) GetCommonSpec ¶ added in v0.1.6
func (handler *RayServiceHandler) GetCommonSpec() kaiwo.CommonMetaSpec
func (*RayServiceHandler) GetCommonStatusSpec ¶ added in v0.1.6
func (handler *RayServiceHandler) GetCommonStatusSpec() *kaiwo.CommonStatusSpec
func (*RayServiceHandler) GetInitializedObject ¶ added in v0.1.6
func (handler *RayServiceHandler) GetInitializedObject() client.Object
func (*RayServiceHandler) GetKaiwoWorkloadObject ¶ added in v0.1.6
func (handler *RayServiceHandler) GetKaiwoWorkloadObject() client.Object
func (*RayServiceHandler) GetKueueWorkloads ¶ added in v0.1.6
func (handler *RayServiceHandler) GetKueueWorkloads(ctx context.Context, k8sClient client.Client) ([]kueuev1beta1.Workload, error)
func (*RayServiceHandler) HandleStatusChange ¶ added in v0.1.6
func (handler *RayServiceHandler) HandleStatusChange(ctx context.Context, k8sClient client.Client, obj client.Object, newStatus kaiwo.WorkloadStatus) error
func (*RayServiceHandler) MutateActual ¶ added in v0.1.6
func (handler *RayServiceHandler) MutateActual(ctx context.Context, clusterCtx common.ClusterContext, actual client.Object) error
func (*RayServiceHandler) ObserveStatus ¶ added in v0.1.6
func (handler *RayServiceHandler) ObserveStatus(ctx context.Context, k8sClient client.Client, obj client.Object, previousStatus kaiwo.WorkloadStatus) (*kaiwo.WorkloadStatus, []metav1.Condition, error)
Source Files
Click to show internal directories.
Click to hide internal directories.