- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 88 for responses (0.11 sec)
-
pkg/test/echo/responses.go
package echo import ( "fmt" ) // Responses is an ordered list of parsed response objects. type Responses []Response func (r Responses) IsEmpty() bool { return len(r) == 0 } // Len returns the length of the parsed responses. func (r Responses) Len() int { return len(r) } // Count occurrences of the given text within the bodies of all responses. func (r Responses) Count(text string) int { count := 0
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 23 22:25:46 UTC 2022 - 1.4K bytes - Viewed (0) -
pilot/pkg/xds/deltaadstest.go
} return } select { case a.responses <- resp: case <-a.context.Done(): return } } } // DrainResponses reads all responses, but does nothing to them func (a *DeltaAdsTest) DrainResponses() { a.t.Helper() for { select { case <-a.context.Done(): return case r := <-a.responses: log.Infof("drained response %v", r.TypeUrl) } } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Feb 04 03:39:42 UTC 2024 - 6.9K bytes - Viewed (0) -
pkg/test/echo/parse.go
) func ParseResponses(req *proto.ForwardEchoRequest, resp *proto.ForwardEchoResponse) Responses { responses := make([]Response, len(resp.Output)) for i, output := range resp.Output { responses[i] = parseResponse(output) responses[i].RequestURL = req.Url } return responses } func parseResponse(output string) Response { out := Response{ RawContent: output, RequestHeaders: make(http.Header),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 23 22:25:46 UTC 2022 - 4.3K bytes - Viewed (0) -
pilot/pkg/xds/adstest.go
} return } select { case a.responses <- resp: case <-a.context.Done(): return } } } // DrainResponses reads all responses, but does nothing to them func (a *AdsTest) DrainResponses() { for { select { case <-a.context.Done(): return case r := <-a.responses: log.Infof("drained response %v", r.TypeUrl) } } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Feb 04 03:39:42 UTC 2024 - 6K bytes - Viewed (0) -
pkg/test/framework/components/echo/common/call.go
err = fmt.Errorf("unexpected number of responses: expected %d, received %d", opts.Count, len(responses)) } // Convert to a CallResult. result := echo.CallResult{ From: from, Opts: opts, Responses: responses, } // Return the results from the validator. err = opts.Check(result, err) if err != nil { err = fmt.Errorf("call failed from %s to %s (using %s): %v",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Oct 08 09:39:20 UTC 2023 - 6.7K bytes - Viewed (0) -
pkg/istio-agent/metrics/metrics.go
) // TODO: Add type url as type for requeasts and responses if needed. // XdsProxyRequests records total number of downstream requests. XdsProxyRequests = monitoring.NewSum( "xds_proxy_requests", "The total number of Xds Proxy Requests", ) // XdsProxyResponses records total number of upstream responses. XdsProxyResponses = monitoring.NewSum( "xds_proxy_responses",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jul 17 20:25:52 UTC 2023 - 2.2K bytes - Viewed (0) -
pkg/test/framework/components/echo/check/visitor.go
type Visitor func(echoClient.Response) error // Visit is a utility method that just invokes this Visitor function on the given response. func (v Visitor) Visit(r echoClient.Response) error { return v(r) } // And returns a Visitor that performs a logical AND of this Visitor and the one provided. func (v Visitor) And(o Visitor) Visitor { return func(r echoClient.Response) error { if err := v(r); err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jun 28 23:06:21 UTC 2022 - 2K bytes - Viewed (0) -
tests/integration/security/util/cert/cert.go
Name: port, }, Scheme: scheme.TLS, TLS: echo.TLS{ Alpn: []string{"istio"}, }, Check: check.NoError(), }) if result.Responses.Len() != 1 { t.Fatalf("dump cert failed, no responses") } var certs []string for _, rr := range result.Responses[0].Body() { var s string if err := json.Unmarshal([]byte(rr), &s); err != nil { t.Fatalf("failed to unmarshal: %v", err) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Dec 15 16:44:37 UTC 2023 - 6.2K bytes - Viewed (0) -
istioctl/pkg/writer/compare/comparator.go
err := json.Unmarshal(resp, istiodDump) if err != nil { continue } c.istiod = istiodDump break } if c.istiod == nil { return nil, fmt.Errorf("unable to find config dump in Istiod responses") } envoyDump := &configdump.Wrapper{} err := json.Unmarshal(envoyResponse, envoyDump) if err != nil { return nil, err } c.envoy = envoyDump c.w = w c.context = 7
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Apr 21 17:42:54 UTC 2024 - 3.7K bytes - Viewed (0) -
pilot/pkg/features/xds.go
"If true, Pilot will cache XDS responses.").Get() // EnableCDSCaching determines if CDS caching is enabled. This is explicitly split out of ENABLE_XDS_CACHE, // so that in case there are issues with the CDS cache we can just disable the CDS cache. EnableCDSCaching = env.Register("PILOT_ENABLE_CDS_CACHE", true, "If true, Pilot will cache CDS responses. Note: this depends on PILOT_ENABLE_XDS_CACHE.").Get()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Feb 24 06:18:36 UTC 2024 - 3.4K bytes - Viewed (0)