github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-04 01:40:07 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #124824 from seans3/export-poke-udp

Browse Source 
Export PokeUDP helper function
This commit is contained in:
Kubernetes Prow Robot 2024-05-16 20:13:01 -07:00 committed by GitHub
commit 5ceb99dc6b
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
test/e2e/network/service.go
View File

@ -474,7 +474,7 @@ const (
// Any time we add new errors, we should audit all callers of this. // Any time we add new errors, we should audit all callers of this.
) )
// pokeUDP tries to connect to a host on a port and send the given request. Callers // PokeUDP tries to connect to a host on a port and send the given request. Callers
// can specify additional success parameters, if desired. // can specify additional success parameters, if desired.
// //
// The result status will be characterized as precisely as possible, given the // The result status will be characterized as precisely as possible, given the
@ -484,7 +484,7 @@ const (
// //
// The result response will be populated if the UDP transaction was completed, even // The result response will be populated if the UDP transaction was completed, even
// if the other test params make this a failure). // if the other test params make this a failure).
func pokeUDP(host string, port int, request string, params *UDPPokeParams) UDPPokeResult { func PokeUDP(host string, port int, request string, params *UDPPokeParams) UDPPokeResult {
hostPort := net.JoinHostPort(host, strconv.Itoa(port)) hostPort := net.JoinHostPort(host, strconv.Itoa(port))
url := fmt.Sprintf("udp://%s", hostPort) url := fmt.Sprintf("udp://%s", hostPort)
@ -577,7 +577,7 @@ func pokeUDP(host string, port int, request string, params *UDPPokeParams) UDPPo
// testReachableUDP tests that the given host serves UDP on the given port. // testReachableUDP tests that the given host serves UDP on the given port.
func testReachableUDP(ctx context.Context, host string, port int, timeout time.Duration) { func testReachableUDP(ctx context.Context, host string, port int, timeout time.Duration) {
pollfn := func(ctx context.Context) (bool, error) { pollfn := func(ctx context.Context) (bool, error) {
result := pokeUDP(host, port, "echo hello", &UDPPokeParams{ result := PokeUDP(host, port, "echo hello", &UDPPokeParams{
Timeout: 3 * time.Second, Timeout: 3 * time.Second,
Response: "hello", Response: "hello",
}) })
@ -595,7 +595,7 @@ func testReachableUDP(ctx context.Context, host string, port int, timeout time.D
// testNotReachableUDP tests that the given host doesn't serve UDP on the given port. // testNotReachableUDP tests that the given host doesn't serve UDP on the given port.
func testNotReachableUDP(ctx context.Context, host string, port int, timeout time.Duration) { func testNotReachableUDP(ctx context.Context, host string, port int, timeout time.Duration) {
pollfn := func(ctx context.Context) (bool, error) { pollfn := func(ctx context.Context) (bool, error) {
result := pokeUDP(host, port, "echo hello", &UDPPokeParams{Timeout: 3 * time.Second}) result := PokeUDP(host, port, "echo hello", &UDPPokeParams{Timeout: 3 * time.Second})
if result.Status != UDPSuccess && result.Status != UDPError { if result.Status != UDPSuccess && result.Status != UDPError {
return true, nil return true, nil
} }