Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for scanner (0.19 sec)

  1. cni/pkg/nodeagent/podcgroupns.go

    func GetCgroups(procCgroupData bytes.Buffer) ([]Cgroup, error) {
    	reader := bytes.NewReader(procCgroupData.Bytes())
    	var cgroups []Cgroup
    	scanner := bufio.NewScanner(reader)
    
    	for scanner.Scan() {
    		token := scanner.Text()
    		substrings := strings.SplitN(token, ":", 3)
    		if len(substrings) < 3 {
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Fri Apr 12 21:47:31 GMT 2024
    - 11K bytes
    - Viewed (0)
  2. istioctl/pkg/describe/describe_test.go

    )
    
    // execAndK8sConfigTestCase lets a test case hold some Envoy, Istio, and Kubernetes configuration
    type execAndK8sConfigTestCase struct {
    	k8sConfigs     []runtime.Object // Canned K8s configuration
    	istioConfigs   []runtime.Object // Canned Istio configuration
    	configDumps    map[string][]byte
    	namespace      string
    	istioNamespace string
    
    	args []string
    
    	// Typically use one of the three
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Thu Mar 28 09:54:01 GMT 2024
    - 30.4K bytes
    - Viewed (0)
  3. istioctl/pkg/metrics/metrics_test.go

    }
    
    func (client mockPromAPI) Query(ctx context.Context, query string, ts time.Time, opts ...promv1.Option) (prometheus_model.Value, promv1.Warnings, error) {
    	canned, ok := client.cannedResponse[query]
    	if !ok {
    		return prometheus_model.Vector{}, nil, nil
    	}
    	return canned, nil, nil
    }
    
    func (client mockPromAPI) TSDB(ctx context.Context) (promv1.TSDBResult, error) {
    	return promv1.TSDBResult{}, nil
    }
    
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Wed Oct 25 02:07:44 GMT 2023
    - 7.9K bytes
    - Viewed (0)
Back to top