Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for Parts (0.37 sec)

  1. cni/pkg/nodeagent/pod_cache.go

    	return maps.Clone(p.currentPodCache)
    }
    
    // Remove and return the Netns for the given uid
    // No need to return NetnsCloser here it will be closed automatically on GC.
    // (it may be used in parallel by other parts of the code, so we want it to be used only when not used)
    func (p *podNetnsCache) Take(uid string) Netns {
    	// lock current pod map
    	p.mu.Lock()
    	defer p.mu.Unlock()
    	if ns, ok := p.currentPodCache[uid]; ok {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 4.5K bytes
    - Viewed (0)
  2. istioctl/pkg/authz/listener.go

    }
    
    func extractName(name string) (string, string) {
    	// parts[1] is the namespace, parts[2] is the policy name, parts[3] is the rule index.
    	parts := re.FindStringSubmatch(name)
    	if len(parts) != 4 {
    		log.Errorf("failed to parse policy name: %s", name)
    		return "", ""
    	}
    	return fmt.Sprintf("%s.%s", parts[2], parts[1]), parts[3]
    }
    
    // Print prints the AuthorizationPolicy in the listener.
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Mon Sep 11 15:29:30 GMT 2023
    - 6K bytes
    - Viewed (0)
  3. istioctl/pkg/analyze/analyze.go

    			for _, s := range suppress {
    				parts := strings.Split(s, "=")
    				if len(parts) != 2 {
    					return fmt.Errorf("%s is not a valid suppression value. See istioctl analyze --help", s)
    				}
    				// Check to see if the supplied code is valid. If not, emit a
    				// warning but continue.
    				codeIsValid := false
    				for _, at := range msg.All() {
    					if at.Code() == parts[0] {
    						codeIsValid = true
    						break
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue Apr 02 08:32:06 GMT 2024
    - 17K bytes
    - Viewed (0)
  4. istioctl/pkg/metrics/metrics.go

    	}
    	return promv1.NewAPI(promClient), nil
    }
    
    func metrics(promAPI promv1.API, workload string, duration time.Duration) (workloadMetrics, error) {
    	parts := strings.Split(workload, ".")
    	wname := parts[0]
    	wns := ""
    	if len(parts) > 1 {
    		wns = parts[1]
    	}
    
    	rpsQuery := fmt.Sprintf(`sum(rate(%s{%s=~"%s.*", %s=~"%s.*",reporter="destination"}[%s]))`,
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Apr 13 05:23:38 GMT 2024
    - 8.4K bytes
    - Viewed (0)
  5. cni/pkg/plugin/plugin_dryrun_test.go

    			}
    		})
    	}
    }
    
    func getRules(b []byte) map[string]string {
    	// Separate content with "COMMIT"
    	parts := strings.Split(string(b), "COMMIT")
    	tables := make(map[string]string)
    	for _, table := range parts {
    		// If table is not empty, get table name from the first line
    		lines := strings.Split(strings.Trim(table, "\n"), "\n")
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Sat Feb 10 00:31:55 GMT 2024
    - 8.4K bytes
    - Viewed (0)
  6. istioctl/pkg/describe/describe.go

    								continue
    							}
    							// parse gateway
    							gns := vsNamespace
    							parts := strings.SplitN(gatewayName, "/", 2)
    							if len(parts) == 2 {
    								gatewayName = parts[1]
    								gns = parts[0]
    							}
    							// todo: check istiod env `PILOT_SCOPE_GATEWAY_TO_NAMESPACE`, if true, need to match gateway namespace
    
    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