- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 159 for responses (0.09 sec)
-
pkg/http/get.go
} for k, v := range headers { req.Header.Set(k, v) } response, err := httpClient.Do(req) if err != nil { return nil, err } defer response.Body.Close() if response.StatusCode != http.StatusOK { return nil, fmt.Errorf("unexpected status %d", response.StatusCode) } var b bytes.Buffer if _, err := io.Copy(&b, response.Body); err != nil { return nil, err } return &b, nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Aug 09 03:52:10 UTC 2023 - 1.9K bytes - Viewed (0) -
pkg/kube/krt/recomputetrigger_test.go
rt := krt.NewRecomputeTrigger() col1 := krt.NewStatic(ptr.Of("foo")).AsCollection() response := "foo" col2 := krt.NewCollection(col1, func(ctx krt.HandlerContext, i string) *string { rt.MarkDependant(ctx) return ptr.Of(response) }) tt := assert.NewTracker[string](t) col2.Register(TrackerHandler[string](tt)) tt.WaitOrdered("add/foo") response = "bar" rt.TriggerRecomputation() tt.WaitUnordered("delete/foo", "add/bar")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 07 05:51:56 UTC 2024 - 1.3K bytes - Viewed (0) -
istioctl/pkg/util/common.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 15 15:02:17 UTC 2023 - 1.6K bytes - Viewed (0) -
pilot/pkg/model/telemetry_logging_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:30 UTC 2024 - 54K bytes - Viewed (0) -
pkg/webhooks/validation/server/server_test.go
if err := json.Unmarshal(gotBody, &gotReview); err != nil { t.Fatalf("%v: could not decode response body: %v", c.name, err) } if gotReview.Response.Allowed != c.wantAllowed { t.Fatalf("%v: AdmissionReview.Response.Allowed is wrong : got %v want %v", c.name, gotReview.Response.Allowed, c.wantAllowed) } }) } } // scenario is a common struct used by many tests in this context.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 01 01:34:15 UTC 2023 - 9.6K bytes - Viewed (0) -
pilot/pkg/credentials/kube/secrets.go
func (s *CredentialsController) insertCache(user string, response error) { s.mu.Lock() defer s.mu.Unlock() key := authorizationKey(user) expDelta := cacheTTL if response == nil { // Cache success a bit longer, there is no need to quickly revoke access expDelta *= 5 } log.Debugf("cached authorization for user %s: %v", user, response) s.authorizationCache[key] = authorizationResponse{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 19:18:21 UTC 2024 - 10K bytes - Viewed (0) -
pkg/kube/inject/webhook.go
reviewResponse = wh.inject(ar, path) } } response := kube.AdmissionReview{} response.Response = reviewResponse var responseKube runtime.Object var apiVersion string if ar != nil { apiVersion = ar.APIVersion response.TypeMeta = ar.TypeMeta if response.Response != nil { if ar.Request != nil { response.Response.UID = ar.Request.UID } } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:59:39 UTC 2024 - 42.2K bytes - Viewed (0) -
pilot/pkg/xds/deltatest.go
) var knownOptimizationGaps = sets.New( "BlackHoleCluster", "InboundPassthroughCluster", "PassthroughCluster", ) // compareDiff compares a Delta and SotW XDS response. This allows checking that the Delta XDS // response returned the optimal result. Checks include correctness checks (e.g. if a config changed, // we must include it) and possible optimizations (e.g. we sent a config, but it was not changed).
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 5.7K bytes - Viewed (0) -
pkg/webhooks/validation/server/server.go
} else { reviewResponse = admit(ar.Request) } } response := kube.AdmissionReview{} response.Response = reviewResponse var responseKube runtime.Object var apiVersion string if ar != nil { apiVersion = ar.APIVersion response.TypeMeta = ar.TypeMeta if response.Response != nil { if ar.Request != nil { response.Response.UID = ar.Request.UID } } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat May 04 06:13:56 UTC 2024 - 9.3K bytes - Viewed (0) -
samples/tcp-echo/src/main_test.go
t.Fatalf("couldn't send request: %v", err) } else { reader := bufio.NewReader(conn) if response, err := reader.ReadBytes(byte('\n')); err != nil { t.Fatalf("couldn't read server response: %v", err) } else if !strings.HasPrefix(string(response), want) { t.Errorf("output doesn't match, wanted: %s, got: %s", want, response) } } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Mar 06 09:12:44 UTC 2023 - 1.7K bytes - Viewed (0)