Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for activeProxyConnections (0.49 sec)

  1. 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)
  2. 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)
Back to top