)
func NewPriorityAssigner(nsRegistry namespace.Registry, currentClusterName string) PriorityAssigner {
priority_assigner.go
return &priorityAssignerImpl{
nsRegistry: nsRegistry,
currentClusterName: currentClusterName,
}
}
func (a *priorityAssignerImpl) Assign(executable Executable) tasks.Priority {