Documentation
¶
Index ¶
- Constants
- type ModelServingController
- func (c *ModelServingController) CreatePodByRole(ctx context.Context, role workloadv1alpha1.Role, ...) error
- func (c *ModelServingController) CreatePodsForServingGroup(ctx context.Context, mi *workloadv1alpha1.ModelServing, groupIndex int, ...) error
- func (c *ModelServingController) DeleteRole(ctx context.Context, mi *workloadv1alpha1.ModelServing, ...)
- func (c *ModelServingController) DeleteServingGroup(mi *workloadv1alpha1.ModelServing, groupname string)
- func (c *ModelServingController) Run(ctx context.Context, workers int)
- func (c *ModelServingController) UpdateModelServingConditionsStatus(mi *workloadv1alpha1.ModelServing, condition metav1.Condition) error
- func (c *ModelServingController) UpdateModelServingStatus(mi *workloadv1alpha1.ModelServing, revision string) error
Constants ¶
View Source
const ( GroupNameKey = "GroupName" RoleIDKey = "RoleID" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ModelServingController ¶
type ModelServingController struct {
// contains filtered or unexported fields
}
func NewModelServingController ¶
func NewModelServingController(kubeClientSet kubernetes.Interface, modelServingClient clientset.Interface, volcanoClient volcano.Interface) (*ModelServingController, error)
func (*ModelServingController) CreatePodByRole ¶
func (c *ModelServingController) CreatePodByRole(ctx context.Context, role workloadv1alpha1.Role, mi *workloadv1alpha1.ModelServing, roleIndex, groupIndex int, newHash string) error
func (*ModelServingController) CreatePodsForServingGroup ¶
func (c *ModelServingController) CreatePodsForServingGroup(ctx context.Context, mi *workloadv1alpha1.ModelServing, groupIndex int, newHash string) error
func (*ModelServingController) DeleteRole ¶
func (c *ModelServingController) DeleteRole(ctx context.Context, mi *workloadv1alpha1.ModelServing, groupName, roleName, roleID string)
func (*ModelServingController) DeleteServingGroup ¶
func (c *ModelServingController) DeleteServingGroup(mi *workloadv1alpha1.ModelServing, groupname string)
func (*ModelServingController) Run ¶
func (c *ModelServingController) Run(ctx context.Context, workers int)
func (*ModelServingController) UpdateModelServingConditionsStatus ¶
func (c *ModelServingController) UpdateModelServingConditionsStatus(mi *workloadv1alpha1.ModelServing, condition metav1.Condition) error
UpdateModelServingConditionsStatus update conditions ModelServing status.
func (*ModelServingController) UpdateModelServingStatus ¶
func (c *ModelServingController) UpdateModelServingStatus(mi *workloadv1alpha1.ModelServing, revision string) error
UpdateModelServingStatus update replicas in modelServing status.
Source Files
Click to show internal directories.
Click to hide internal directories.