Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 33 for nodeResources (0.66 sec)

  1. pkg/kubelet/cm/dra/plugin/noderesources.go

    Oksana Baranova <******@****.***> 1716840773 +0300
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 27 20:12:53 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/registry.go

    		nodeunschedulable.Name:               nodeunschedulable.New,
    		noderesources.Name:                   runtime.FactoryAdapter(fts, noderesources.NewFit),
    		noderesources.BalancedAllocationName: runtime.FactoryAdapter(fts, noderesources.NewBalancedAllocation),
    		volumebinding.Name:                   runtime.FactoryAdapter(fts, volumebinding.New),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 5K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/noderesources/most_allocated.go

    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    See the License for the specific language governing permissions and
    limitations under the License.
    */
    
    package noderesources
    
    import (
    	"k8s.io/kubernetes/pkg/scheduler/apis/config"
    	"k8s.io/kubernetes/pkg/scheduler/framework"
    )
    
    // mostResourceScorer favors nodes with most requested resources.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Dec 21 15:23:47 UTC 2022
    - 2.2K bytes
    - Viewed (0)
  4. pkg/registry/registrytest/node.go

    	sync.Mutex
    }
    
    // MakeNodeList constructs api.NodeList from list of node names and a NodeResource.
    func MakeNodeList(nodes []string, nodeResources api.ResourceList) *api.NodeList {
    	list := api.NodeList{
    		Items: make([]api.Node, len(nodes)),
    	}
    	for i := range nodes {
    		list.Items[i].Name = nodes[i]
    		list.Items[i].Status.Capacity = nodeResources
    	}
    	return &list
    }
    
    func (r *NodeRegistry) SetError(err error) {
    	r.Lock()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 01 23:13:50 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/dynamicresources/structuredparameters.go

    }
    
    func (c claimController) nodeIsSuitable(ctx context.Context, nodeName string, resources resources) (bool, error) {
    	nodeResources := resources[nodeName]
    	for driverName, perDriver := range c.namedresources {
    		okay, err := perDriver.controller.NodeIsSuitable(ctx, nodeResources[driverName].NamedResources)
    		if err != nil {
    			// This is an error in the CEL expression which needs
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Mar 22 09:03:22 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go

    	"k8s.io/kubernetes/pkg/scheduler/framework/plugins/interpodaffinity"
    	"k8s.io/kubernetes/pkg/scheduler/framework/plugins/names"
    	"k8s.io/kubernetes/pkg/scheduler/framework/plugins/noderesources"
    	"k8s.io/kubernetes/pkg/scheduler/framework/plugins/podtopologyspread"
    	"k8s.io/kubernetes/pkg/scheduler/framework/plugins/queuesort"
    	"k8s.io/kubernetes/pkg/scheduler/framework/plugins/tainttoleration"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 82.8K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/plugins/noderesources/test_util.go

    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    See the License for the specific language governing permissions and
    limitations under the License.
    */
    
    package noderesources
    
    import (
    	"github.com/google/go-cmp/cmp/cmpopts"
    	v1 "k8s.io/api/core/v1"
    	"k8s.io/apimachinery/pkg/api/resource"
    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    	"k8s.io/apimachinery/pkg/util/validation/field"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Nov 03 01:07:28 UTC 2022
    - 1.9K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/plugins/noderesources/least_allocated.go

    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    See the License for the specific language governing permissions and
    limitations under the License.
    */
    
    package noderesources
    
    import (
    	"k8s.io/kubernetes/pkg/scheduler/apis/config"
    	"k8s.io/kubernetes/pkg/scheduler/framework"
    )
    
    // leastResourceScorer favors nodes with fewer requested resources.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Mar 12 01:50:09 UTC 2023
    - 2K bytes
    - Viewed (0)
  9. pkg/scheduler/framework/plugins/noderesources/requested_to_capacity_ratio.go

    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    See the License for the specific language governing permissions and
    limitations under the License.
    */
    
    package noderesources
    
    import (
    	"math"
    
    	"k8s.io/kubernetes/pkg/scheduler/apis/config"
    	"k8s.io/kubernetes/pkg/scheduler/framework"
    	"k8s.io/kubernetes/pkg/scheduler/framework/plugins/helper"
    )
    
    const maxUtilization = 100
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Dec 21 15:23:47 UTC 2022
    - 2.6K bytes
    - Viewed (0)
  10. pkg/scheduler/eventhandlers.go

    	"k8s.io/kubernetes/pkg/scheduler/framework/plugins/nodename"
    	"k8s.io/kubernetes/pkg/scheduler/framework/plugins/nodeports"
    	"k8s.io/kubernetes/pkg/scheduler/framework/plugins/noderesources"
    	"k8s.io/kubernetes/pkg/scheduler/internal/queue"
    	"k8s.io/kubernetes/pkg/scheduler/profile"
    )
    
    func (sched *Scheduler) onStorageClassAdd(obj interface{}) {
    	logger := sched.logger
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:21:04 UTC 2024
    - 24K bytes
    - Viewed (0)
Back to top