in pkg/controller/core/indexer/indexer.go [114:134]
func Setup(ctx context.Context, indexer client.FieldIndexer) error {
if err := indexer.IndexField(ctx, &kueue.Workload{}, WorkloadQueueKey, IndexWorkloadQueue); err != nil {
return fmt.Errorf("setting index on queue for Workload: %w", err)
}
if err := indexer.IndexField(ctx, &kueue.Workload{}, WorkloadClusterQueueKey, IndexWorkloadClusterQueue); err != nil {
return fmt.Errorf("setting index on clusterQueue for Workload: %w", err)
}
if err := indexer.IndexField(ctx, &kueue.Workload{}, WorkloadAdmittedKey, IndexWorkloadAdmitted); err != nil {
return fmt.Errorf("setting index on admitted for Workload: %w", err)
}
if err := indexer.IndexField(ctx, &kueue.Workload{}, WorkloadRuntimeClassKey, IndexWorkloadRuntimeClass); err != nil {
return fmt.Errorf("setting index on runtimeClass for Workload: %w", err)
}
if err := indexer.IndexField(ctx, &kueue.LocalQueue{}, QueueClusterQueueKey, IndexQueueClusterQueue); err != nil {
return fmt.Errorf("setting index on clusterQueue for localQueue: %w", err)
}
if err := indexer.IndexField(ctx, &corev1.LimitRange{}, LimitRangeHasContainerType, IndexLimitRangeHasContainerType); err != nil {
return fmt.Errorf("setting index on hasContainerType for limitRange: %w", err)
}
return nil
}