- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 638 for nameslice (0.17 sec)
-
pilot/pkg/serviceregistry/kube/controller/ambient/workloads.go
w := &workloadapi.Workload{ Uid: a.generateWorkloadEntryUID(wle.Namespace, wle.Name), Name: wle.Name, Namespace: wle.Namespace, Network: network, ClusterId: string(a.ClusterID), ServiceAccount: wle.Spec.ServiceAccount,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 16:51:29 UTC 2024 - 20.9K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
defer cancel() pod := &corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "test", Namespace: "test", }, Spec: corev1.PodSpec{ NodeName: NodeName, }, Status: corev1.PodStatus{ PodIP: "11.1.1.12", }, } ns := &corev1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: "test"}} client := kube.NewFakeClient(ns, pod)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 22.2K bytes - Viewed (0) -
pilot/pkg/model/extensions.go
wasmPlugin.ImagePullSecret = toSecretResourceName(wasmPlugin.ImagePullSecret, plugin.Namespace) return &WasmPluginWrapper{ Name: plugin.Name, Namespace: plugin.Namespace, ResourceName: WasmPluginResourceNamePrefix + plugin.Namespace + "." + plugin.Name, WasmPlugin: wasmPlugin, ResourceVersion: plugin.ResourceVersion, } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 11K bytes - Viewed (0) -
pkg/kubelet/util/manager/watch_based_manager.go
defer c.lock.Unlock() item, exists := c.items[key] if !exists { item = c.newReflectorLocked(namespace, name) c.items[key] = item } item.refMap[referencedFrom]++ } func (c *objectCache) DeleteReference(namespace, name string, referencedFrom types.UID) { key := objectKey{namespace: namespace, name: name} c.lock.Lock() defer c.lock.Unlock() if item, ok := c.items[key]; ok {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 11.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/conversion_test.go
}, Resolution: networking.ServiceEntry_DNS_ROUND_ROBIN, }, } func createWorkloadEntry(name, namespace string, spec *networking.WorkloadEntry) *config.Config { return &config.Config{ Meta: config.Meta{ GroupVersionKind: gvk.WorkloadEntry, Name: name, Namespace: namespace, CreationTimestamp: GlobalTime, }, Spec: spec, } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 39K bytes - Viewed (0) -
pkg/wasm/cache_test.go
ResourceName: "namespace.resource", ResourceVersion: "0", RequestTimeout: time.Second * 10, }, wantCachedModules: map[moduleKey]*cacheEntry{ {name: ts.URL, checksum: cacheHitSum}: {modulePath: "test.wasm"}, }, wantCachedChecksums: map[string]*checksumEntry{ ts.URL: {checksum: cacheHitSum, resourceVersionByResource: map[string]string{"namespace.resource": "0"}}, },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 33.9K bytes - Viewed (0) -
pkg/test/framework/components/echo/echotest/filters_test.go
// simple pod with a different namespace a1Ns2 = &fakeInstance{Cluster: cls1, Namespace: echo2NS, Service: "a"} a2Ns2 = &fakeInstance{Cluster: cls2, Namespace: echo2NS, Service: "a"} // virtual machine vm1 = &fakeInstance{Cluster: cls1, Namespace: echo1NS, Service: "vm", DeployAsVM: true} vm2 = &fakeInstance{Cluster: cls2, Namespace: echo1NS, Service: "vm", DeployAsVM: true} // headless
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 13.1K bytes - Viewed (0) -
istioctl/pkg/workload/workload.go
} } else { wg, err = kubeClient.Istio().NetworkingV1alpha3().WorkloadGroups(namespace).Get(context.Background(), name, metav1.GetOptions{}) // errors if the requested workload group does not exist in the given namespace if err != nil { return fmt.Errorf("workloadgroup %s not found in namespace %s: %v", name, namespace, err) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 25.5K bytes - Viewed (0) -
pilot/pkg/autoregistration/controller_test.go
"missing ip": {Metadata: &model.NodeMetadata{Namespace: wgA.Namespace, AutoRegisterGroup: wgA.Name}}, "missing namespace": {IPAddresses: []string{"1.2.3.4"}, Metadata: &model.NodeMetadata{AutoRegisterGroup: wgA.Name}}, "non-existent group": {IPAddresses: []string{"1.2.3.4"}, Metadata: &model.NodeMetadata{Namespace: wgA.Namespace, AutoRegisterGroup: "dne"}}, }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 31.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/controller.go
// Insert all instances for this IP for services within the same namespace. This ensures we // match Kubernetes logic where Services do not cross namespace boundaries and avoids // possibility of other namespaces inserting service instances into namespaces they do not // control. if node.Metadata.Namespace == "" || i.Service.Attributes.Namespace == node.Metadata.Namespace { out = append(out, model.ServiceInstanceToTarget(i)) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 36.8K bytes - Viewed (0)