- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 42 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/plugin/kubernetes.go
Containers: sets.New[string](), Labels: pod.Labels, Annotations: pod.Annotations, ProxyEnvironments: make(map[string]string), } for _, c := range containers(pod) { pi.Containers.Insert(c.Name) if c.Name == ISTIOPROXY { // don't include ports from istio-proxy in the redirect ports // Get proxy container env variable, and extract out ProxyConfig from it. for _, e := range c.Env {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 3.6K bytes - Viewed (0) -
cni/pkg/nodeagent/server_test.go
kubeClient: fakeClientSet, netServer: server, } err := m.AddPodToMesh(fakeCtx, pod, podIPs, "") assert.NoError(t, err) pod, err = fakeClientSet.CoreV1().Pods("test").Get(fakeCtx, "test", metav1.GetOptions{}) assert.NoError(t, err) assert.Equal(t, len(pod.Annotations), 1) assert.Equal(t, pod.Annotations[constants.AmbientRedirection], constants.AmbientRedirectionEnabled) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 7.8K 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/util/handlers/handlers_test.go
corev1client "k8s.io/client-go/kubernetes/typed/core/v1" "k8s.io/client-go/rest/fake" cmdtesting "k8s.io/kubectl/pkg/cmd/testing" "k8s.io/kubectl/pkg/scheme" "istio.io/istio/pkg/test/util/assert" ) func TestInferPodInfo(t *testing.T) { tests := []struct { proxyName string namespace string wantPodName string wantNamespace string }{ {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jun 09 18:17:49 GMT 2023 - 6.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) -
operator/cmd/mesh/manifest_shared_test.go
var interceptorFunc = interceptor.Funcs{Patch: func( ctx context.Context, clnt client.WithWatch, obj client.Object, patch client.Patch, opts ...client.PatchOption, ) error { // Apply patches are supposed to upsert, but fake client fails if the object doesn't exist, // if an apply patch occurs for an object that doesn't yet exist, create it. if patch.Type() != types.ApplyPatchType { return clnt.Patch(ctx, obj, patch, opts...) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Feb 20 22:39:28 GMT 2024 - 11.7K bytes - Viewed (1) -
cni/pkg/install/binaries.go
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Dec 11 19:10:54 GMT 2023 - 1.5K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/route.go
stripFull := strings.TrimSuffix(h, ".svc.cluster.local") if unique.Contains(stripFull) && stripFull != h { shouldDelete.Insert(h) } stripPartial := strings.TrimSuffix(h, ".svc") if unique.Contains(stripPartial) && stripPartial != h { shouldDelete.Insert(h) } } // Filter from original list to keep original order ret := make([]string, 0, len(domains)) for _, h := range domains {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 11 05:38:17 GMT 2023 - 7.2K bytes - Viewed (0)