- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for NewAgent (0.18 sec)
-
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) -
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)