Documentation
¶
Index ¶
- Constants
- func ResourceExists(client kubernetes.Interface, groupVersion string, kind string) (bool, error)
- type LWSController
- type ModelServingController
- func (c *ModelServingController) CreatePodsByRole(ctx context.Context, role workloadv1alpha1.Role, ...) error
- func (c *ModelServingController) CreatePodsForServingGroup(ctx context.Context, ms *workloadv1alpha1.ModelServing, servingGroupIndex int, ...) error
- func (c *ModelServingController) DeleteRole(ctx context.Context, ms *workloadv1alpha1.ModelServing, ...)
- func (c *ModelServingController) Run(ctx context.Context, workers int)
- func (c *ModelServingController) UpdateModelServingStatus(ms *workloadv1alpha1.ModelServing, revision string) error
- type RoleWithScore
- type ServingGroupWithScore
Constants ¶
View Source
const ( PodDeletionCostAnnotation = corev1.PodDeletionCost // Status priority constants: lower number = higher deletion priority (delete first) // Priority levels: // 0: Highest deletion priority - unhealthy or terminating states // 1: Lowest deletion priority - healthy running state // // ServingGroup priorities: PriorityServingGroupCreating = 0 PriorityServingGroupDeleting = 0 PriorityServingGroupScaling = 0 PriorityServingGroupNotFound = 0 PriorityServingGroupRunning = 1 // Role priorities: PriorityRoleCreating = 0 PriorityRoleDeleting = 0 PriorityRoleNotFound = 0 PriorityRoleRunning = 1 )
View Source
const ( GroupNameKey = "GroupName" RoleIDKey = "RoleID" )
Variables ¶
This section is empty.
Functions ¶
func ResourceExists ¶ added in v0.3.0
Types ¶
type LWSController ¶ added in v0.3.0
type LWSController struct {
// contains filtered or unexported fields
}
LWSController reconciles a LeaderWorkerSet object
func InitializeLWSController ¶ added in v0.3.0
func InitializeLWSController( cfg *rest.Config, kubeClient kubernetes.Interface, kthenaClient kthenaclientset.Interface, ) (*LWSController, error)
func NewLWSController ¶ added in v0.3.0
func NewLWSController( kubeClient kubernetes.Interface, kthenaClient kthenaclientset.Interface, lwsClient lwsclientset.Interface, lwsInformer lwsinformers.SharedInformerFactory, kthenaInformer kthenainformers.SharedInformerFactory, ) (*LWSController, error)
type ModelServingController ¶
type ModelServingController struct {
// contains filtered or unexported fields
}
func NewModelServingController ¶
func NewModelServingController(kubeClientSet kubernetes.Interface, modelServingClient clientset.Interface, volcanoClient volcano.Interface, apiextClient apiextClientSet.Interface) (*ModelServingController, error)
func (*ModelServingController) CreatePodsByRole ¶ added in v0.3.0
func (c *ModelServingController) CreatePodsByRole(ctx context.Context, role workloadv1alpha1.Role, ms *workloadv1alpha1.ModelServing, roleIndex int, servingGroupOrdinal int, revision string) error
func (*ModelServingController) CreatePodsForServingGroup ¶
func (c *ModelServingController) CreatePodsForServingGroup(ctx context.Context, ms *workloadv1alpha1.ModelServing, servingGroupIndex int, revision string, roles []workloadv1alpha1.Role) error
func (*ModelServingController) DeleteRole ¶
func (c *ModelServingController) DeleteRole(ctx context.Context, ms *workloadv1alpha1.ModelServing, groupName, roleName, roleID string)
func (*ModelServingController) Run ¶
func (c *ModelServingController) Run(ctx context.Context, workers int)
func (*ModelServingController) UpdateModelServingStatus ¶
func (c *ModelServingController) UpdateModelServingStatus(ms *workloadv1alpha1.ModelServing, revision string) error
UpdateModelServingStatus update replicas in modelServing status.
type RoleWithScore ¶ added in v0.2.0
type RoleWithScore struct {
Name string
Priority int // Status priority from getRoleStatusPriority()
DeletionCost int // Higher cost = more protected (lower deletion priority)
Index int
}
RoleWithScore stores role deletion priority information Priority order: Status (primary) > Deletion cost (secondary) > Index (tertiary)
type ServingGroupWithScore ¶ added in v0.2.0
type ServingGroupWithScore struct {
Name string
Priority int // Status priority from getServingGroupStatusPriority()
DeletionCost int // Higher cost = more protected (lower deletion priority)
Index int
}
ServingGroupWithScore stores serving group deletion priority information Priority order: Status (primary) > Deletion cost (secondary) > Index (tertiary)
Source Files
Click to show internal directories.
Click to hide internal directories.