- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for Insert (0.15 sec)
-
cni/pkg/iptables/iptables.go
inpodTproxyMark := fmt.Sprintf("0x%x", InpodTProxyMark) + "/" + fmt.Sprintf("0x%x", InpodTProxyMask) iptablesBuilder := builder.NewIptablesRuleBuilder(ipbuildConfig(cfg.cfg)) // Insert jumps to our custom chains // This is mostly just for visual tidiness and cleanup, as we can delete the secondary chains and jumps // without polluting the main table too much. // -t mangle -A PREROUTING -j ISTIO_PRERT
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue May 07 19:54:50 GMT 2024 - 19.7K bytes - Viewed (0) -
cni/pkg/log/uds_test.go
// Ideally we would fail if the UDS part fails but the error library makes it kind of tricky _ = log.Sync() // Restore os stdout. os.Stdout = stdout assert.NoError(t, log.Configure(loggingOptions)) assert.NoError(t, w.Close()) out, err := io.ReadAll(r) assert.NoError(t, err) // For each level, there should be two lines, one from direct log, // the other one from UDS server
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Mar 16 00:20:01 GMT 2024 - 2.5K bytes - Viewed (0) -
cni/pkg/nodeagent/podcgroupns_test.go
podUID, containerID, err := getPodUIDAndContainerIDFromCGroups(makeCGroups(tt.cgroupPaths)) if tt.expectMsg != "" { assert.Equal(t, tt.expectMsg, err.Error()) return } assert.Equal(t, tt.expectPodUID, podUID) assert.Equal(t, tt.expectContainerID, containerID) }) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 4.6K bytes - Viewed (0) -
istioctl/pkg/workload/workload_test.go
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "istio.io/istio/istioctl/pkg/cli" "istio.io/istio/pilot/test/util" "istio.io/istio/pkg/config/constants" "istio.io/istio/pkg/kube" "istio.io/istio/pkg/test/util/assert" ) var fakeCACert = []byte("fake-CA-cert") var ( defaultYAML = `apiVersion: networking.istio.io/v1alpha3 kind: WorkloadGroup metadata: name: foo namespace: bar spec: metadata: {}
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Mar 27 16:59:05 GMT 2024 - 14.6K bytes - Viewed (0) -
cni/pkg/nodeagent/informers_test.go
types.MergePatchType, labelsPatch, metav1.PatchOptions{}) assert.NoError(t, err) // wait until at least one add event happens mt.Assert(EventTotals.Name(), map[string]string{"type": "add"}, monitortest.AtLeast(1)) assertPodNotAnnotated(t, client, pod) // Assert expected calls (not) actually made fs.AssertExpectations(t) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 15.8K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
err := netServer.RemovePodFromMesh(ctx, pod) assert.NoError(t, err) assert.Equal(t, ztunnelServer.deletedPods.Load(), 1) assert.Equal(t, nlDeps.DelInpodMarkIPRuleCnt.Load(), 1) assert.Equal(t, nlDeps.DelLoopbackRoutesCnt.Load(), 1) // make sure the uid was taken from cache and netns closed netns := fixture.podNsMap.Take(string(pod.UID)) assert.Equal(t, nil, netns) // run gc to clean up ns:
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 16.4K bytes - Viewed (0) -
cni/pkg/plugin/plugin_test.go
"k8s.io/apimachinery/pkg/runtime" "istio.io/api/annotation" "istio.io/api/label" "istio.io/istio/pkg/config/constants" "istio.io/istio/pkg/kube" "istio.io/istio/pkg/test/util/assert" ) const ( testPodName = "testPod" testNSName = "testNS" testSandboxDirectory = "/tmp" invalidVersion = "0.1.0" preVersion = "0.2.0" ) var mockConfTmpl = `{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 15:58:51 GMT 2024 - 17.5K bytes - Viewed (0) -
istioctl/pkg/precheck/precheck.go
} } return msgs, nil } func extractCRDVersions(r *crd.CustomResourceDefinition) sets.String { res := sets.New[string]() for _, v := range r.Spec.Versions { if v.Served { res.Insert(v.Name) } } return res } func checkInstallPermissions(cli kube.CLIClient, istioNamespace string) diag.Messages { Resources := []struct { namespace string group string
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 02:57:30 GMT 2024 - 19.3K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver_test.go
mt.Assert(ztunnelConnected.Name(), nil, monitortest.Exactly(1)) // we should get the fd to dev null. note that we can't assert the fd number // as the kernel may have given us a different number that refers to the same file. assert.Equal(t, len(fds), 1) // in theory we should close the fd, but it's just a test.. assert.Equal(t, m.Payload.(*zdsapi.WorkloadRequest_Add).Add.Uid, uid)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 8.6K bytes - Viewed (0) -
cni/pkg/util/podutil_test.go
"istio.io/istio/pkg/test/util/assert" ) func TestGetPodIPIfPodIPPresent(t *testing.T) { pod := &corev1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "test", Namespace: "test", }, Spec: corev1.PodSpec{ NodeName: "derp", }, Status: corev1.PodStatus{ PodIP: "11.1.1.12", }, } podIPs := GetPodIPsIfPresent(pod) assert.Equal(t, len(podIPs), 1) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 4.9K bytes - Viewed (0)