- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 215 for resps (0.14 sec)
-
cmd/erasure-common.go
func readMultipleFiles(ctx context.Context, disks []StorageAPI, req ReadMultipleReq, readQuorum int) ([]ReadMultipleResp, error) { resps := make([]chan ReadMultipleResp, len(disks)) for i := range resps { resps[i] = make(chan ReadMultipleResp, len(req.Files)) } g := errgroup.WithNErrs(len(disks)) // Read files in parallel across disks. for index := range disks { index := index
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.6K bytes - Viewed (0) -
pkg/kubelet/cm/devicemanager/manager_test.go
}) resp.Mounts = append(resp.Mounts, &pluginapi.Mount{ ContainerPath: "/container_dir1/file2", HostPath: "host_dir1/file2", ReadOnly: true, }) resp.Envs["key1"] = "val1" } } resps := new(pluginapi.AllocateResponse) resps.ContainerResponses = append(resps.ContainerResponses, resp) return resps, nil } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 65K bytes - Viewed (0) -
pkg/kubelet/apis/podresources/server_v1_test.go
return false } return reflect.DeepEqual(a, b) } func equalAllocatableResourcesResponse(respA, respB *podresourcesapi.AllocatableResourcesResponse) bool { if !equalInt64s(respA.CpuIds, respB.CpuIds) { return false } return equalContainerDevices(respA.Devices, respB.Devices) } func equalGetResponse(ResA, ResB *podresourcesapi.GetPodResourcesResponse) bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 45.9K bytes - Viewed (0) -
pilot/pkg/xds/ads_test.go
ads := s.ConnectADS().WithType(v3.ClusterType) resp1 := ads.RequestResponseAck(t, nil) fullPush(s) resp2 := ads.ExpectResponse(t) if !(resp1.VersionInfo < resp2.VersionInfo) { t.Fatalf("version should be incrementing: %v -> %v", resp1.VersionInfo, resp2.VersionInfo) } if resp1.Nonce == resp2.Nonce { t.Fatalf("nonce should change %v -> %v", resp1.Nonce, resp2.Nonce) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 30 17:25:17 UTC 2024 - 30.3K bytes - Viewed (0) -
internal/grid/handlers.go
if r != h.nilResp { h.respPool.Put(r) } } // NewResponse creates a new response. // Handlers can use this to create a reusable response. func (h *StreamTypeHandler[Payload, Req, Resp]) NewResponse() Resp { return h.respPool.Get().(Resp) } func newStreamHandler[Payload, Req, Resp RoundTripper](h HandlerID) *StreamTypeHandler[Payload, Req, Resp] {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 27.1K bytes - Viewed (0) -
pkg/istio-agent/xds_proxy_delta.go
forward(resp) } func forwardDeltaToEnvoy(con *ProxyConnection, resp *discovery.DeltaDiscoveryResponse) { if !model.IsEnvoyType(resp.TypeUrl) && resp.TypeUrl != model.WorkloadType { proxyLog.Errorf("Skipping forwarding type url %s to Envoy as is not a valid Envoy type", resp.TypeUrl) return }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 04 20:29:08 UTC 2024 - 11.7K bytes - Viewed (0) -
pilot/pkg/xds/delta_test.go
ResourceNamesSubscribe: []string{"outbound|80||test-1.default"}, }) resp := ads.ExpectResponse() if len(resp.Resources) != 1 || resp.Resources[0].Name != "outbound|80||test-1.default" { t.Fatalf("received unexpected eds resource %v", resp.Resources) } if len(resp.RemovedResources) != 0 { t.Fatalf("received unexpected removed eds resource %v", resp.RemovedResources) } ads.Request(&discovery.DeltaDiscoveryRequest{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 15.2K bytes - Viewed (0) -
internal/grid/grid_test.go
}() var n int err = stream.Results(func(resp *testResponse) error { // t.Logf("got resp: %+v", *resp.Msg) const wantString = testPayload + testPayload if resp.OrgString != testPayload+testPayload { t.Errorf("want %q, got %q", wantString, resp.OrgString) } if resp.OrgNum != n+1 { t.Errorf("want %d, got %d", n+1, resp.OrgNum) } handler.PutResponse(resp) n++ return nil })
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri Jun 07 15:51:52 UTC 2024 - 36.4K bytes - Viewed (0) -
pkg/kubelet/server/server_test.go
func assertHealthIsOk(t *testing.T, httpURL string) { resp, err := http.Get(httpURL) if err != nil { t.Fatalf("Got error GETing: %v", err) } defer resp.Body.Close() if resp.StatusCode != http.StatusOK { t.Errorf("expected status code %d, got %d", http.StatusOK, resp.StatusCode) } body, readErr := io.ReadAll(resp.Body) if readErr != nil { // copying the response body did not work
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 51.5K bytes - Viewed (0) -
pilot/pkg/xds/deltaadstest.go
select { case <-time.After(a.timeout): a.t.Fatalf("did not get response in time") case resp := <-a.responses: if resp == nil { a.t.Fatalf("expected response") } if resp != nil && (len(resp.RemovedResources) > 0 || len(resp.Resources) > 0) { a.t.Fatalf("expected empty response. received %v", resp) } return resp case err := <-a.error: a.t.Fatalf("got error: %v", err) } return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Feb 04 03:39:42 UTC 2024 - 6.9K bytes - Viewed (0)