- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 53 for CoreV1 (0.14 sec)
-
cni/pkg/plugin/plugin_dryrun_test.go
if err != nil { t.Fatalf("failed with error: %v", err) } } func buildFakeDryRunPod() *corev1.Pod { app := corev1.Container{Name: "test"} proxy := corev1.Container{Name: "istio-proxy"} validate := corev1.Container{Name: "istio-validate"} fakePod := &corev1.Pod{ TypeMeta: metav1.TypeMeta{ APIVersion: "core/v1", Kind: "Pod", }, ObjectMeta: metav1.ObjectMeta{
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Tue Aug 27 16:44:45 UTC 2024 - 8.5K bytes - Viewed (0) -
cni/pkg/repair/repaircontroller.go
UID: &pod.UID, ResourceVersion: &pod.ResourceVersion, } err := c.client.Kube().CoreV1().Pods(pod.Namespace).Delete(context.Background(), pod.Name, metav1.DeleteOptions{ Preconditions: preconditions, }) if err != nil { c.events.Write(pod, corev1.EventTypeWarning, ReasonDeleteBrokenPod, "pod detected as broken, but failed to delete: %v", err) m.With(resultLabel.Value(resultFail)).Increment()
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Sat Feb 10 00:31:55 UTC 2024 - 10.4K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 16:05:45 UTC 2024 - 22.1K bytes - Viewed (0) -
istioctl/pkg/checkinject/checkinject_test.go
admitv1 "k8s.io/api/admissionregistration/v1" corev1 "k8s.io/api/core/v1" metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "sigs.k8s.io/yaml" "istio.io/api/annotation" "istio.io/api/label" "istio.io/istio/pkg/test/util/assert" ) func Test_analyzeRunningWebhooks(t *testing.T) { cases := []struct { name string pod *corev1.Pod ns *corev1.Namespace expectedMessages []webhookAnalysis
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Jun 15 15:02:17 UTC 2023 - 10.6K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
s.ztunnelServer.Close() } func (s *NetServer) rescanPod(pod *corev1.Pod) error { // this can happen if the pod was dynamically added to the mesh after it was created. // in that case, try finding the netns using procfs. filter := map[types.UID]*corev1.Pod{ pod.UID: pod, } return s.scanProcForPodsAndCache(filter) } func (s *NetServer) getOrOpenNetns(pod *corev1.Pod, netNs string) (Netns, error) { if netNs == "" {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Oct 21 16:48:55 UTC 2024 - 9.1K bytes - Viewed (0) -
istioctl/pkg/completion/completion.go
} } return nsNameList, nil } func getNamespaces(ctx context.Context, client kube.CLIClient) ([]corev1.Namespace, error) { nslist, err := client.Kube().CoreV1().Namespaces().List(ctx, metav1.ListOptions{}) if err != nil { return []corev1.Namespace{}, err } return nslist.Items, nil }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Sat Apr 13 05:23:38 UTC 2024 - 4.9K bytes - Viewed (0) -
istioctl/pkg/tag/tag_test.go
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 16:05:45 UTC 2024 - 8.5K bytes - Viewed (0) -
cni/pkg/nodeagent/server_test.go
fakeIPSetDeps.On("clearEntriesWithIP", "foo-v4", netip.MustParseAddr("6.6.6.6"), ).Return(nil) err := m.syncHostIPSets([]*corev1.Pod{pod}) assert.NoError(t, err) fakeIPSetDeps.AssertExpectations(t) } func podWithAnnotation() *corev1.Pod { return &corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "test", Namespace: "test", UID: types.UID("test"),
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 16:05:45 UTC 2024 - 18.7K bytes - Viewed (0) -
istioctl/pkg/util/handlers/handlers_test.go
} } func attachPod(ns string) *corev1.Pod { return &corev1.Pod{ ObjectMeta: metav1.ObjectMeta{Name: "foo-abc", Namespace: ns, ResourceVersion: "10"}, Spec: corev1.PodSpec{ RestartPolicy: corev1.RestartPolicyAlways, DNSPolicy: corev1.DNSClusterFirst, Containers: []corev1.Container{ { Name: "bar", }, }, InitContainers: []corev1.Container{ { Name: "initfoo",
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Jun 09 18:17:49 UTC 2023 - 6.6K bytes - Viewed (0) -
cni/pkg/plugin/plugin_test.go
"eth0", testSandboxDirectory, "", // unused here ambientEnabled, "mock", ) } func buildFakePodAndNSForClient() (*corev1.Pod, *corev1.Namespace) { proxy := corev1.Container{Name: "mockContainer"} app := corev1.Container{Name: "foo-init"} fakePod := &corev1.Pod{ TypeMeta: metav1.TypeMeta{ APIVersion: "core/v1", Kind: "Pod", }, ObjectMeta: metav1.ObjectMeta{
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 16:05:45 UTC 2024 - 17.3K bytes - Viewed (0)