- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for activeProxyConnections (0.24 sec)
-
pkg/envoy/agent.go
log.Infof("Checking for active connections...") ticker := time.NewTicker(activeConnectionCheckDelay) defer ticker.Stop() retryCount := 0 graceful_loop: for range ticker.C { ac, err := a.activeProxyConnections() select { case status := <-a.statusCh: log.Infof("Envoy exited with status %v", status.err) log.Infof("Graceful termination logic ended prematurely, envoy process terminated early") return
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 24 16:04:22 UTC 2024 - 9K bytes - Viewed (0) -
pkg/envoy/agent_test.go
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 { t.Errorf("unexpected active proxy connections. expected: %d got: %d", tt.expected, ac) } }) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Oct 19 20:22:09 UTC 2023 - 4.3K bytes - Viewed (0)