Search Options

Results per page
Sort
Preferred Languages
Advance

Results 101 - 110 of 135 for SetMode (3.02 sec)

  1. pkg/scheduler/extender.go

    			}
    		}
    	} else if result.Nodes != nil {
    		nodeResult = make([]*framework.NodeInfo, len(result.Nodes.Items))
    		for i := range result.Nodes.Items {
    			nodeResult[i] = framework.NewNodeInfo()
    			nodeResult[i].SetNode(&result.Nodes.Items[i])
    		}
    	}
    
    	return nodeResult, result.FailedNodes, result.FailedAndUnresolvableNodes, nil
    }
    
    // Prioritize based on extender implemented priority functions. Weight*priority is added
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 19:07:19 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  2. platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/DefaultCacheCoordinator.java

            Consumer<FileLock> onFileLockAcquireAction = this::afterLockAcquire;
            Consumer<FileLock> onFileLockReleaseAction = this::beforeLockRelease;
    
            switch (lockOptions.getMode()) {
                case Shared:
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed May 01 12:21:15 UTC 2024
    - 20.5K bytes
    - Viewed (0)
  3. internal/bucket/object/lock/lock_test.go

    	"reflect"
    	"strings"
    	"testing"
    	"time"
    
    	xhttp "github.com/minio/minio/internal/http"
    )
    
    func TestParseMode(t *testing.T) {
    	testCases := []struct {
    		value        string
    		expectedMode RetMode
    	}{
    		{
    			value:        "governance",
    			expectedMode: RetGovernance,
    		},
    		{
    			value:        "complIAnce",
    			expectedMode: RetCompliance,
    		},
    		{
    			value:        "gce",
    			expectedMode: "",
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Feb 22 06:26:06 UTC 2024
    - 17.1K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/types.go

    			n.PVCRefCounts[key] += 1
    		} else {
    			n.PVCRefCounts[key] -= 1
    			if n.PVCRefCounts[key] <= 0 {
    				delete(n.PVCRefCounts, key)
    			}
    		}
    	}
    }
    
    // SetNode sets the overall node information.
    func (n *NodeInfo) SetNode(node *v1.Node) {
    	n.node = node
    	n.Allocatable = NewResource(node.Status.Allocatable)
    	n.Generation = nextGeneration()
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 19:28:17 UTC 2024
    - 36.7K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/preemption/preemption_test.go

    		},
    	}
    
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			var nodeInfos []*framework.NodeInfo
    			for _, name := range nodeNames {
    				ni := framework.NewNodeInfo()
    				ni.SetNode(st.MakeNode().Name(name).Obj())
    				nodeInfos = append(nodeInfos, ni)
    			}
    			nodes, _ := nodesWherePreemptionMightHelp(nodeInfos, tt.nodesStatuses)
    			if len(tt.expected) != len(nodes) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/tainttoleration/taint_toleration_test.go

    		},
    	}
    	for _, test := range tests {
    		t.Run(test.name, func(t *testing.T) {
    			_, ctx := ktesting.NewTestContext(t)
    			nodeInfo := framework.NewNodeInfo()
    			nodeInfo.SetNode(test.node)
    			p, err := New(ctx, nil, nil, feature.Features{})
    			if err != nil {
    				t.Fatalf("creating plugin: %v", err)
    			}
    			gotStatus := p.(framework.FilterPlugin).Filter(ctx, nil, test.pod, nodeInfo)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 17.5K bytes
    - Viewed (0)
  7. pilot/pkg/model/telemetry.go

    			for _, o := range m.Overrides {
    				// if we disable all metrics, we should drop the entire filter
    				if isAllMetrics(o.GetMatch()) && o.Disabled.GetValue() {
    					for _, mode := range getModes(o.GetMatch().GetMode()) {
    						key := metricProviderModeKey(provider, mode)
    						disabledAllMetricsProviders.Insert(key)
    					}
    
    					continue
    				}
    
    				metricsNames := getMatches(o.GetMatch())
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 15 18:14:09 UTC 2024
    - 35.2K bytes
    - Viewed (0)
  8. pilot/pkg/networking/core/cluster_traffic_policy.go

    func shouldH2Upgrade(clusterName string, port *model.Port, mesh *meshconfig.MeshConfig,
    	connectionPool *networking.ConnectionPoolSettings,
    ) bool {
    	// TODO (mjog)
    	// Upgrade if tls.GetMode() == networking.TLSSettings_ISTIO_MUTUAL
    	if connectionPool != nil && connectionPool.Http != nil {
    		override := connectionPool.Http.H2UpgradePolicy
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 23 05:38:57 UTC 2024
    - 20K bytes
    - Viewed (0)
  9. docs/de/docs/advanced/settings.md

        Hello Wade Wilson
        ```
    
        </div>
    
    ### Umgebungsvariablen mit Python auslesen
    
    Sie können Umgebungsvariablen auch außerhalb von Python im Terminal (oder mit einer anderen Methode) erstellen und diese dann mit Python auslesen.
    
    Sie könnten zum Beispiel eine Datei `main.py` haben mit:
    
    ```Python hl_lines="3"
    import os
    
    name = os.getenv("MY_NAME", "World")
    print(f"Hello {name} from Python")
    Registered: Mon Jun 17 08:32:26 UTC 2024
    - Last Modified: Sat Mar 30 20:17:14 UTC 2024
    - 17.8K bytes
    - Viewed (0)
  10. pkg/serviceaccount/claims_test.go

    	if f.secret == nil {
    		return nil, apierrors.NewNotFound(schema.GroupResource{Group: "", Resource: "secrets"}, name)
    	}
    	return f.secret, nil
    }
    func (f fakeGetter) GetNode(name string) (*v1.Node, error) {
    	if f.node == nil {
    		return nil, apierrors.NewNotFound(schema.GroupResource{Group: "", Resource: "nodes"}, name)
    	}
    	return f.node, nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 17.9K bytes
    - Viewed (0)
Back to top