Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NewAgent (0.18 sec)

  1. pkg/envoy/agent_test.go

    	return nil
    }
    
    // TestStartExit starts a proxy and ensures the agent exits once the proxy exits
    func TestStartExit(t *testing.T) {
    	ctx := context.Background()
    	done := make(chan struct{})
    	a := NewAgent(TestProxy{}, 0, 0, "", 0, 0, 0, true)
    	go func() {
    		a.Run(ctx)
    		done <- struct{}{}
    	}()
    	<-done
    }
    
    // TestStartTwiceStop applies three configs and validates that cleanups are called in order
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Oct 19 20:22:09 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  2. pkg/envoy/agent.go

    )
    
    var errAbort = errors.New("proxy aborted")
    
    const errOutOfMemory = "signal: killed"
    
    var activeConnectionCheckDelay = 1 * time.Second
    
    // NewAgent creates a new proxy agent for the proxy start-up and clean-up functions.
    func NewAgent(proxy Proxy, terminationDrainDuration, minDrainDuration time.Duration, localhost string,
    	adminPort, statusPort, prometheusPort int, exitOnZeroActiveConnections bool,
    ) *Agent {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 24 16:04:22 UTC 2024
    - 9K bytes
    - Viewed (0)
Back to top