Search Options

Results per page
Sort
Preferred Languages
Advance

Results 81 - 90 of 128 for respCh (0.13 sec)

  1. istioctl/pkg/writer/envoy/configdump/listener.go

    	fChains := getFilterChains(l)
    	resp := make([]filterchain, 0, len(fChains))
    	for _, filterChain := range fChains {
    		fc := filterchain{
    			destination: getFilterType(filterChain.GetFilters()),
    			match:       getMatches(filterChain.FilterChainMatch),
    		}
    		resp = append(resp, fc)
    	}
    	return resp
    }
    
    func getMatches(f *listener.FilterChainMatch) string {
    	match := f
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Nov 29 12:37:14 UTC 2023
    - 18.1K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/helper/IndexingHelper.java

                                    final BulkItemResponse resp = items[i];
                                    if (resp.isFailed() && resp.getFailure() != null) {
                                        final Map<String, Object> req = docList.get(i);
                                        final Failure failure = resp.getFailure();
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:11:58 UTC 2024
    - 16.8K bytes
    - Viewed (0)
  3. cmd/perf-tests.go

    		result.Error = err.Error()
    		return
    	}
    	client := &http.Client{
    		Transport: globalRemoteTargetTransport,
    	}
    	resp, err := client.Do(req)
    	if err != nil {
    		result.Error = err.Error()
    		return
    	}
    	defer xhttp.DrainBody(resp.Body)
    	err = gob.NewDecoder(resp.Body).Decode(&result)
    	// endpoint have been overwritten
    	result.Endpoint = rp.String()
    	if err != nil {
    		result.Error = err.Error()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.8K bytes
    - Viewed (0)
  4. istioctl/pkg/cli/mock_test.go

    		tf := cmdtesting.NewTestFactory()
    		_, _, codec := cmdtesting.NewExternalScheme()
    		tf.UnstructuredClient = &fake.RESTClient{
    			NegotiatedSerializer: resource.UnstructuredPlusDefaultContentConfig().NegotiatedSerializer,
    			Resp: &http.Response{
    				StatusCode: http.StatusOK,
    				Header:     cmdtesting.DefaultHeader(),
    				Body: cmdtesting.ObjBody(codec,
    					cmdtesting.NewInternalType("", "", "foo")),
    			},
    		}
    		return tf
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Jun 15 15:02:17 UTC 2023
    - 1.3K bytes
    - Viewed (0)
  5. cmd/xl-storage.go

    				}
    			}
    		}
    		if osErrToFileErr(err) == errFileNotFound {
    			resp = checkPartFileNotFound
    		}
    		return
    	}
    	if st.Mode().IsDir() {
    		resp = checkPartFileNotFound
    		return
    	}
    	// Check if shard is truncated.
    	if st.Size() < expectedSize {
    		resp = checkPartFileCorrupt
    		return
    	}
    	return checkPartSuccess
    }
    
    // CheckParts check if path has necessary parts available.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  6. cmd/admin-handlers_test.go

    	}
    
    	rec := httptest.NewRecorder()
    	adminTestBed.router.ServeHTTP(rec, req)
    
    	resp, _ := io.ReadAll(rec.Body)
    	if rec.Code != http.StatusOK {
    		t.Errorf("Expected to receive %d status code but received %d. Body (%s)",
    			http.StatusOK, rec.Code, string(resp))
    	}
    
    	result := &serviceResult{}
    	if err := json.Unmarshal(resp, result); err != nil {
    		t.Error(err)
    	}
    	_ = result
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  7. istioctl/pkg/kubeinject/kubeinject.go

    		},
    		Response: nil,
    	}
    	revBytes, err := json.Marshal(rev)
    	if err != nil {
    		return nil, err
    	}
    	resp, err := client.Post(address, "application/json", bytes.NewBuffer(revBytes))
    	if err != nil {
    		return nil, err
    	}
    	defer resp.Body.Close()
    	body, err := io.ReadAll(resp.Body)
    	if err != nil {
    		return nil, err
    	}
    	var obj runtime.Object
    	var ar *kube.AdmissionReview
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Thu Aug 15 16:31:46 UTC 2024
    - 21K bytes
    - Viewed (0)
  8. cmd/prepare-storage.go

    	if err != nil {
    		return err
    	}
    	// Indicate that the liveness check for a peer call
    	req.Header.Set(xhttp.MinIOPeerCall, "true")
    
    	resp, err := httpClient.Do(req)
    	if err != nil {
    		return err
    	}
    	xhttp.DrainBody(resp.Body)
    
    	return nil
    }
    
    // connect to list of endpoints and load all Erasure disk formats, validate the formats are correct
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 11.1K bytes
    - Viewed (1)
  9. istioctl/pkg/precheck/precheck_test.go

    		tf := cmdtesting.NewTestFactory()
    		_, _, codec := cmdtesting.NewExternalScheme()
    		tf.UnstructuredClient = &fake.RESTClient{
    			NegotiatedSerializer: resource.UnstructuredPlusDefaultContentConfig().NegotiatedSerializer,
    			Resp: &http.Response{
    				StatusCode: http.StatusOK,
    				Header:     cmdtesting.DefaultHeader(),
    				Body: cmdtesting.ObjBody(codec,
    					cmdtesting.NewInternalType("", "", "foo")),
    			},
    		}
    		return tf
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Tue Jul 09 12:01:22 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  10. istioctl/pkg/internaldebug/internal-debug_test.go

    		tf := cmdtesting.NewTestFactory()
    		_, _, codec := cmdtesting.NewExternalScheme()
    		tf.UnstructuredClient = &fake.RESTClient{
    			NegotiatedSerializer: resource.UnstructuredPlusDefaultContentConfig().NegotiatedSerializer,
    			Resp: &http.Response{
    				StatusCode: http.StatusOK,
    				Header:     cmdtesting.DefaultHeader(),
    				Body: cmdtesting.ObjBody(codec,
    					cmdtesting.NewInternalType("", "", "foo")),
    			},
    		}
    		return tf
    	}
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Mar 15 08:28:50 UTC 2024
    - 4.5K bytes
    - Viewed (0)
Back to top