Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for parsing (0.18 sec)

  1. cni/pkg/nodeagent/server.go

    	pods := s.handlers.GetAmbientPods()
    	err := s.dataplane.ConstructInitialSnapshot(pods)
    	if err != nil {
    		log.Warnf("failed to construct initial snapshot: %v", err)
    	}
    
    	log.Info("CNI ambient server marking ready")
    	s.Ready()
    	s.dataplane.Start(s.ctx)
    	s.handlers.Start()
    }
    
    func (s *Server) Stop() {
    	log.Info("CNI ambient server terminating, cleaning up node net rules")
    
    	s.cniServerStopFunc()
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 7.2K bytes
    - Viewed (0)
  2. istioctl/pkg/tag/tag.go

    		// if we have a conflict, we will fail. If --skip-confirmation is set, we will continue with a
    		// warning; when actually applying we will also confirm to ensure the user does not see the
    		// warning *after* it has applied
    		if !skipConfirmation {
    			_, _ = stderr.Write([]byte(err.Error()))
    			if !generate {
    				if !util.Confirm("Apply anyways? [y/N]", w) {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 02 08:32:06 GMT 2024
    - 16.3K bytes
    - Viewed (0)
  3. cni/pkg/plugin/plugin.go

    		conf.RawPrevResult = nil
    		conf.PrevResult, err = cniv1.NewResultFromResult(res)
    		if err != nil {
    			return nil, fmt.Errorf("could not convert result to current version: %v", err)
    		}
    	}
    	// End previous result parsing
    
    	return &conf, nil
    }
    
    func getLogLevel(logLevel string) log.Level {
    	switch logLevel {
    	case "debug":
    		return log.DebugLevel
    	case "warn":
    		return log.WarnLevel
    	case "error":
    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)
  4. istioctl/pkg/precheck/precheck.go

    		}
    		meshData := make(map[string]interface{})
    		if data, exists := configMap.Data["mesh"]; exists {
    			if err := yaml.Unmarshal([]byte(data), &meshData); err != nil {
    				fmt.Printf("Error parsing meshConfig: %v\n", err)
    				return err
    			}
    		}
    		if scopingImpacted = meshData["discoverySelectors"] != nil; !scopingImpacted {
    			continue
    		}
    		// Check if mitigation is already in place
    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)
  5. cni/pkg/iptables/iptables_linux.go

    	if cfg.EnableIPv6 {
    		families = append(families, unix.AF_INET6)
    	}
    	for _, family := range families {
    		// Equiv:
    		// ip rule add fwmark 0x111/0xfff pref 32764 lookup 100
    		//
    		// Adds in-pod rules for marking packets with the istio-specific TPROXY mark.
    		// A very similar mechanism is used for sidecar TPROXY.
    		//
    		// TODO largely identical/copied from tools/istio-iptables/pkg/capture/run_linux.go
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 30 22:24:38 GMT 2024
    - 3.3K bytes
    - Viewed (0)
  6. istioctl/pkg/describe/describe.go

    						mismatchNotes = append(mismatchNotes, fmt.Sprintf("Warning: Route to subset %s but NO DESTINATION RULE defining subsets!", dest.Destination.Subset))
    					} else {
    						// Don't bother giving the match conditions, the problem is that there are unknowns in the VirtualService
    						mismatchNotes = append(mismatchNotes,
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Apr 13 05:23:38 GMT 2024
    - 50.4K bytes
    - Viewed (0)
Back to top