Function TestRunReturnsError

server/server_test.go:488–544

(t *testing.T)

}

func TestRunReturnsError(t *testing.T) {
	testCases := []struct {
		protocol string
	}{
		{
			protocol: "http",
		},
		{
			protocol: "grpc",
		},
	}
	for _, tc := range testCases {
		for _, network := range []string{"default", "tcpV4"} {
			t.Run(network, func(t *testing.T) {
				var level log.Level
				require.NoError(t, level.Set("info"))
				cfg := Config{
					Registerer:       prometheus.NewPedanticRegistry(),
					LogLevel:         level,
					MetricsNamespace: fmt.Sprintf("testing_%s", tc.protocol),
				}
				switch network {
				case "default":
					setAutoAssignedPorts(DefaultNetwork, &cfg)
				case "tcpV4":
					setAutoAssignedPorts(NetworkTCPV4, &cfg)
				default:
					require.Fail(t, "unrecognized network %q", network)
				}
				srv, err := New(cfg)
				require.NoError(t, err)

				errChan := make(chan error, 1)
				var wg sync.WaitGroup
				t.Cleanup(wg.Wait)
				wg.Add(1)
				go func() {
					defer wg.Done()
					errChan <- srv.Run()
				}()

				switch tc.protocol {
				case "http":
					require.NoError(t, srv.httpListener.Close())
				case "grpc":
					require.NoError(t, srv.grpcListener.Close())
				default:
					require.Fail(t, fmt.Sprintf("unrecognized protocol %q", tc.protocol))
				}
				require.NotNil(t, <-errChan)

				// So that address is freed for further tests.
				srv.GRPC.Stop()
			})
		}
	}
}