- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for CreateAndStartServer (0.14 sec)
-
pilot/cmd/pilot-agent/status/ready/probe_test.go
server.Close() server = testserver.CreateAndStartServer(liveServerStats) probe.AdminPort = uint16(server.Listener.Addr().(*net.TCPAddr).Port) err = probe.Check() g.Expect(err).NotTo(HaveOccurred()) g.Expect(probe.atleastOnceReady).Should(BeTrue()) server.Close() server = testserver.CreateAndStartServer(noServerStats) probe.AdminPort = uint16(server.Listener.Addr().(*net.TCPAddr).Port)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 5.9K bytes - Viewed (0) -
pilot/cmd/pilot-agent/status/testserver/server.go
// limitations under the License. package testserver import ( "net" "net/http" "net/http/httptest" ) // CreateAndStartServer starts a server and returns the response passed. func CreateAndStartServer(response string) *httptest.Server { return createHTTPServer(createDefaultFuncMap(response)) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jan 26 17:53:14 UTC 2022 - 1.7K bytes - Viewed (0) -
pkg/envoy/agent_test.go
19, }, { "zero active connections", downstreamCxZeroAcStats, 0, }, } for _, tt := range cases { t.Run(tt.name, func(t *testing.T) { server := testserver.CreateAndStartServer(tt.stats) defer server.Close() agent := NewAgent(TestProxy{}, 0, 0, "localhost", server.Listener.Addr().(*net.TCPAddr).Port, 15021, 15009, true) if ac, _ := agent.activeProxyConnections(); ac != tt.expected {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Oct 19 20:22:09 UTC 2023 - 4.3K bytes - Viewed (0)