- Sort Score
- Result 10 results
- Languages All
Results 111 - 120 of 185 for node_id (0.1 sec)
-
staging/src/k8s.io/apiserver/pkg/authentication/serviceaccount/util_test.go
"authentication.kubernetes.io/pod-uid": {"uid"}, }, }, }, "extracts node name/uid": { info: ServiceAccountInfo{Name: "name", Namespace: "ns", NodeName: "test", NodeUID: "uid"}, expectedUserInfo: &user.DefaultInfo{ Name: "system:serviceaccount:ns:name", Groups: []string{"system:serviceaccounts", "system:serviceaccounts:ns"}, Extra: map[string][]string{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 21:15:10 UTC 2023 - 7.7K bytes - Viewed (0) -
maven-model-builder/src/main/java/org/apache/maven/model/superpom/DefaultSuperPomProvider.java
options.put("xml:" + version, "xml:" + version); String modelId = "org.apache.maven:maven-model-builder:" + version + "-" + this.getClass().getPackage().getImplementationVersion() + ":super-pom"; InputSource inputSource = new InputSource( modelId, getClass().getResource(resource).toExternalForm());
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Sep 26 05:17:52 UTC 2023 - 3.2K bytes - Viewed (0) -
pkg/volume/csi/csi_client.go
}, nil } func (c *csiDriverClient) NodeGetInfo(ctx context.Context) ( nodeID string, maxVolumePerNode int64, accessibleTopology map[string]string, err error) { klog.V(4).InfoS(log("calling NodeGetInfo rpc")) var getNodeInfoError error nodeID, maxVolumePerNode, accessibleTopology, getNodeInfoError = c.nodeGetInfoV1(ctx) if getNodeInfoError != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 20 10:15:36 UTC 2022 - 22.1K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/utils/xla_sharding_util.cc
} return mlir::success(); } namespace { bool IsAssignedToLogicalDevice(const int core_id, const xla::OpSharding& sharding) { return sharding.type() == xla::OpSharding::MAXIMAL && sharding.tile_assignment_devices(0) == core_id; } // Returns the index of the return value of region in // `tf_device.parallel_execute` that represents cluster func output at
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed May 22 21:28:13 UTC 2024 - 34K bytes - Viewed (0) -
pkg/bootstrap/option/instances.go
return newDurationOption("connect_timeout", value) } func Cluster(value string) Instance { return newOption("cluster", value) } func NodeID(value string) Instance { return newOption("nodeID", value) } func NodeType(value string) Instance { ntype := strings.Split(value, "~")[0] return newOption("nodeType", ntype) } func XdsType(value string) Instance {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:02:38 UTC 2024 - 9K bytes - Viewed (0) -
tests/testdata/bootstrap_tmpl.json
{ "node": { "id": "{{ .EnvoyConfigOpt.NodeID }}", "cluster": "mycluster", "locality": { "zone": "testzone" }, "metadata": { {{ .EnvoyConfigOpt.meta_json_str }} } }, "stats_config": { "use_all_default_tags": false }, "admin": { "access_log_path": "{{.AccessLogPath}}", "address": { "socket_address": { "address": "0.0.0.0",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jan 13 02:10:15 UTC 2021 - 9.5K bytes - Viewed (0) -
platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/ivyservice/resolveengine/graph/builder/NodeStateTest.groovy
} private EdgeState edge(NodeState from, boolean strict = true, String name = null, NodeState to = nextNode(), endorsing = false) { String moduleName = name ? name : "${from.nodeId}-${to.nodeId}" EdgeState edgeState = Mock() DependencyState dependencyState = Mock() DependencyMetadata dependencyMetadata = Mock() ModuleComponentSelector selector = Mock()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 14:19:34 UTC 2024 - 10.9K bytes - Viewed (0) -
pkg/volume/csi/nodeinfomanager/nodeinfomanager.go
"k8s.io/kubernetes/pkg/volume" "k8s.io/kubernetes/pkg/volume/util" ) const ( // Name of node annotation that contains JSON map of driver names to node annotationKeyNodeID = "csi.volume.kubernetes.io/nodeid" ) var ( nodeKind = v1.SchemeGroupVersion.WithKind("Node") updateBackoff = wait.Backoff{ Steps: 4, Duration: 10 * time.Millisecond, Factor: 5.0, Jitter: 0.1, } )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 11 09:02:45 UTC 2024 - 20.1K bytes - Viewed (0) -
pkg/adsc/adsc.go
// xds client used to create a stream client discovery.AggregatedDiscoveryServiceClient conn *grpc.ClientConn // Indicates if the ADSC client is closed closed bool // NodeID is the node identity sent to Pilot. nodeID string watchTime time.Time // initialLoad tracks the time to receive the initial configuration. initialLoad time.Duration // indicates if the initial LDS request is sent
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Feb 05 22:18:49 UTC 2024 - 35K bytes - Viewed (0) -
pilot/pkg/model/context_test.go
}, PodPorts: []model.PodPort{ {Name: "http", ContainerPort: 8080, Protocol: "TCP"}, {Name: "grpc", ContainerPort: 8079, Protocol: "TCP"}, }, }, }, }, } nodeID := "sidecar~1.1.1.1~id~domain" for _, tt := range cases { t.Run(tt.name, func(t *testing.T) { meta, err := mapToStruct(tt.metadata) if err != nil { t.Fatalf("failed to setup metadata: %v", err)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 05 23:51:52 UTC 2024 - 11.2K bytes - Viewed (0)