- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 613 for endpoint (0.18 sec)
-
istioctl/pkg/writer/envoy/configdump/endpoint.go
return false } return true } func retrieveEndpointStatus(ep *endpoint.LbEndpoint) core.HealthStatus { return ep.GetHealthStatus() } func retrieveEndpointPort(ep *endpoint.LbEndpoint) uint32 { return ep.GetEndpoint().GetAddress().GetSocketAddress().GetPortValue() } func retrieveEndpointAddress(ep *endpoint.LbEndpoint) string { addr := ep.GetEndpoint().GetAddress()
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Sun Apr 21 17:42:54 GMT 2024 - 5.6K bytes - Viewed (0) -
istioctl/pkg/util/configdump/endpoint.go
) // GetEndpointsConfigDump retrieves the listener config dump from the ConfigDump func (w *Wrapper) GetEndpointsConfigDump() (*admin.EndpointsConfigDump, error) { endpointsDumpAny, err := w.getSection(endpoints) if err != nil { return nil, nil } endpointsDump := &admin.EndpointsConfigDump{} err = endpointsDumpAny.UnmarshalTo(endpointsDump) if err != nil { return nil, err } return endpointsDump, nil
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Tue Oct 24 14:14:42 GMT 2023 - 1.1K bytes - Viewed (0) -
cmd/endpoint.go
GridHost string } // Endpoint - any type of endpoint. type Endpoint struct { *url.URL IsLocal bool PoolIdx, SetIdx, DiskIdx int } // Equal returns true if endpoint == ep func (endpoint Endpoint) Equal(ep Endpoint) bool { if endpoint.IsLocal == ep.IsLocal && endpoint.PoolIdx == ep.PoolIdx && endpoint.SetIdx == ep.SetIdx && endpoint.DiskIdx == ep.DiskIdx { if endpoint.Path == ep.Path && endpoint.Host == ep.Host {
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sun Apr 21 11:43:18 GMT 2024 - 34.1K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/endpoint_test.go
t.Run(tt.name, func(t *testing.T) { gotOut := &bytes.Buffer{} cw := &ConfigWriter{Stdout: gotOut} cd, _ := os.ReadFile("testdata/endpoint/configdump.json") cw.Prime(cd) err := cw.PrintEndpointsSummary(tt.filter) assert.NoError(t, err) wantOutputFile := path.Join("testdata/endpoint", fmt.Sprintf("%s_output.txt", tt.name)) util.CompareContent(t, gotOut.Bytes(), wantOutputFile) }) } }
Go - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Tue Jul 12 02:25:59 GMT 2022 - 2.4K bytes - Viewed (0) -
cmd/endpoint-ellipses.go
} // Returns all the expanded endpoints, each argument is expanded separately. func (s *endpointSet) getEndpoints() (endpoints []string) { if len(s.endpoints) != 0 { return s.endpoints } for _, argPattern := range s.argPatterns { for _, lbls := range argPattern.Expand() { endpoints = append(endpoints, strings.Join(lbls, "")) } } s.endpoints = endpoints return endpoints }
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Apr 11 21:22:47 GMT 2024 - 14.8K bytes - Viewed (0) -
cmd/endpoint_test.go
{SlashSeparator, Endpoint{}, -1, fmt.Errorf("empty or root endpoint is not supported")}, {`\`, Endpoint{}, -1, fmt.Errorf("empty or root endpoint is not supported")}, {"c://foo", Endpoint{}, -1, fmt.Errorf("invalid URL endpoint format")}, {"ftp://foo", Endpoint{}, -1, fmt.Errorf("invalid URL endpoint format")}, {"http://server/path?location", Endpoint{}, -1, fmt.Errorf("invalid URL endpoint format")},
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Sat Jan 13 07:53:03 GMT 2024 - 18.9K bytes - Viewed (1) -
tests/test_callable_endpoint.py
from fastapi import FastAPI from fastapi.testclient import TestClient def main(some_arg, q: Optional[str] = None): return {"some_arg": some_arg, "q": q} endpoint = partial(main, "foo") app = FastAPI() app.get("/")(endpoint) client = TestClient(app) def test_partial(): response = client.get("/?q=bar") data = response.json()
Python - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Sun Jun 28 18:13:30 GMT 2020 - 457 bytes - Viewed (0) -
cmd/endpoint-ellipses_test.go
if paddinglen == 0 { seq = append(seq, fmt.Sprintf("%d", i)) } else { seq = append(seq, fmt.Sprintf(fmt.Sprintf("%%0%dd", paddinglen), i)) } } return seq } // Test tests parses endpoint ellipses input pattern. func TestParseEndpointSet(t *testing.T) { testCases := []struct { arg string es endpointSet success bool }{ // Tests invalid inputs. { "...",
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Thu Dec 07 09:33:56 GMT 2023 - 15.2K bytes - Viewed (0) -
cmd/endpoint_contrib_test.go
globalMinioPort = tempGlobalMinioPort }() globalMinioPort = "9000" tempGlobalDomainIPs := globalDomainIPs defer func() { globalDomainIPs = tempGlobalDomainIPs }() ipv4TestCases := []struct { endPoints set.StringSet expectedResult set.StringSet }{ {set.NewStringSet(), set.NewStringSet()}, {set.CreateStringSet("localhost"), set.NewStringSet()},
Go - Registered: Sun Apr 21 19:28:08 GMT 2024 - Last Modified: Fri Apr 30 15:50:39 GMT 2021 - 2.2K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/testdata/endpoint/configdump.json
} ], "dynamic_endpoint_configs": [ { "endpoint_config": { "@type": "type.googleapis.com/envoy.config.endpoint.v3.ClusterLoadAssignment", "cluster_name": "outbound|9080||reviews.default.svc.cluster.local", "endpoints": [ {
Json - Registered: Wed Apr 24 22:53:08 GMT 2024 - Last Modified: Tue Jul 12 02:25:59 GMT 2022 - 66K bytes - Viewed (0)