- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 103 for responses (0.17 sec)
-
tests/integration/security/fuzz/fuzz_test.go
if !strings.Contains(stdout, "Prescan: original token Response Code: 200") { t.Fatalf("could not find prescan check, please make sure the jwt_tool.py completed successfully") } errCases := []string{} scanStarted := false for _, line := range strings.Split(stdout, "\n") { if scanStarted { // First check the response is a valid test case.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 12.9K bytes - Viewed (0) -
pilot/pkg/bootstrap/server.go
} // initRegistryEventHandlers sets up event handlers for config and service updates func (s *Server) initRegistryEventHandlers() { log.Info("initializing registry event handlers") // Flush cached discovery responses whenever services configuration change. serviceHandler := func(prev, curr *model.Service, event model.Event) { pushReq := &model.PushRequest{ Full: true,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 46.3K bytes - Viewed (0) -
pkg/adsc/adsc.go
// Retrieved configurations can be stored using the common istio model interface. Store model.ConfigStore // Retrieved endpoints can be stored in the memory registry. This is used for CDS and EDS responses. Registry *memory.ServiceDiscovery // LocalCacheDir is set to a base name used to save fetched resources. // If set, each update will be saved.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Feb 05 22:18:49 UTC 2024 - 35K bytes - Viewed (0) -
tests/integration/pilot/common/routing.go
Check: check.And( check.OK(), ConsistentHostChecker, ), PropagateResponse: func(req *http.Request, res *http.Response) { scopes.Framework.Infof("invoking propagate response") if res == nil { scopes.Framework.Infof("no response") return } if res.Cookies() == nil { scopes.Framework.Infof("no cookies") return }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 21:52:51 UTC 2024 - 135.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) -
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) -
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)