Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for from (5.22 sec)

  1. cni/pkg/iptables/iptables.go

    		"-j", "CONNMARK",
    		"--set-xmark", inpodTproxyMark)
    
    	// Handle healthcheck probes from the host node. In the host netns, before the packet enters the pod, we SNAT
    	// the healthcheck packet to a fixed IP if the packet is coming from a node-local process with a socket.
    	//
    	// We do this so we can exempt this traffic from ztunnel capture/proxy - otherwise both kube-proxy (legit)
    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)
  2. cni/pkg/plugin/plugin_test.go

    	ns.ObjectMeta.Labels = map[string]string{constants.DataplaneModeLabel: constants.DataplaneModeAmbient}
    
    	testDoAddRun(t, cniConf, testNSName, pod, ns)
    
    	wasCalled := serverClose()
    	// Pod has sidecar annotation from injector, should not be added to mesh
    	assert.Equal(t, wasCalled, false)
    }
    
    func TestCmdAddPodWithGenericSidecar(t *testing.T) {
    	url, serverClose := setupCNIEventClientWithMockServer(false)
    
    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)
  3. cni/pkg/nodeagent/informers.go

    	if matchAmbient {
    		log.Infof("Namespace %s is enabled in ambient mesh", namespace)
    	} else {
    		log.Infof("Namespace %s is disabled from ambient mesh", namespace)
    	}
    	for _, pod := range s.pods.List(namespace, klabels.Everything()) {
    		// ztunnel pods are never "added to/removed from the mesh", so do not fire
    		// spurious events for them to avoid triggering extra
    		// ztunnel node reconciliation checks.
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri May 03 19:29:42 GMT 2024
    - 9.6K bytes
    - Viewed (0)
  4. operator/cmd/mesh/install.go

    			if revision != util.DefaultRevisionName {
    				revisionWarning = ""
    			}
    			if icpTag < tag {
    				p.Printf("%s Istio is being upgraded from %s to %s.\n"+revisionWarning+check,
    					warnMarker, icpTag, tag)
    			} else {
    				p.Printf("%s Istio is being downgraded from %s to %s.\n"+revisionWarning+check,
    					warnMarker, icpTag, tag)
    			}
    		}
    	}
    	return nil
    }
    
    // GetTagVersion returns istio tag version
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu May 02 14:30:43 GMT 2024
    - 15.5K bytes
    - Viewed (1)
  5. istioctl/pkg/waypoint/waypoint.go

    	waypointDeleteCmd := &cobra.Command{
    		Use:   "delete",
    		Short: "Delete a waypoint configuration",
    		Long:  "Delete a waypoint configuration from the cluster",
    		Example: `  # Delete a waypoint from the default namespace
      istioctl x waypoint delete
    
      # Delete a waypoint by name, which can obtain from istioctl x waypoint list
      istioctl x waypoint delete waypoint-name --namespace default
    
      # Delete several waypoints by name
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed May 08 19:45:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  6. cni/pkg/plugin/plugin.go

    	K8S_POD_INFRA_CONTAINER_ID types.UnmarshallableString // nolint: revive, stylecheck
    }
    
    // parseConfig parses the supplied configuration (and prevResult) from stdin.
    func parseConfig(stdin []byte) (*Config, error) {
    	conf := Config{}
    
    	if err := json.Unmarshal(stdin, &conf); err != nil {
    		return nil, fmt.Errorf("failed to parse network configuration: %v", err)
    	}
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed May 08 15:58:51 GMT 2024
    - 10.5K bytes
    - Viewed (0)
Back to top