framework

var (
	KnownGoroutineLeaks = []goleak.Option{

		goleak.IgnoreTopFunction("context.(*cancelCtx).propagateCancel.func2"),

		goleak.IgnoreTopFunction("google.golang.org/grpc.(*addrConn).resetTransportAndUnlock"),

		goleak.IgnoreTopFunction("google.golang.org/grpc.(*pickerWrapper).pick"),

		goleak.IgnoreTopFunction("google.golang.org/grpc/internal/grpcsync.(*CallbackSerializer).run"),

		goleak.IgnoreTopFunction("google.golang.org/grpc.newClientStreamWithParams.func4"),

		goleak.IgnoreTopFunction("google.golang.org/grpc/internal/transport.(*serverHandlerTransport).HandleStreams.func1"),

		goleak.IgnoreTopFunction("google.golang.org/grpc.newClientStreamWithParams.func4"),

		goleak.IgnoreTopFunction("google.golang.org/grpc/internal/transport.(*controlBuffer).get"),

		goleak.IgnoreTopFunction("google.golang.org/grpc/internal/transport.(*http2Client).keepalive"),

		goleak.IgnoreTopFunction("google.golang.org/grpc/internal/transport.(*recvBufferReader).readMessageHeader"),

		goleak.IgnoreTopFunction("google.golang.org/grpc/internal/transport.(*recvBufferReader).readMessageHeaderClient"),

		goleak.IgnoreTopFunction("google.golang.org/grpc/internal/transport.(*serverHandlerTransport).HandleStreams.func1"),

		goleak.IgnoreTopFunction("google.golang.org/grpc/internal/transport.(*serverHandlerTransport).runStream"),

		goleak.IgnoreTopFunction("internal/poll.runtime_pollWait"),

		goleak.IgnoreTopFunction("sync.runtime_notifyListWait"),

		goleak.IgnoreTopFunction("go.etcd.io/etcd/client/v3.(*watchGrpcStream).waitCancelSubstreams.func1.1"),

		goleak.IgnoreTopFunction("go.etcd.io/etcd/client/v3.(*watchGrpcStream).serveSubstream.func1"),

		goleak.IgnoreTopFunction("k8s.io/apimachinery/pkg/util/wait.BackoffUntil"),

		goleak.IgnoreTopFunction("github.com/kcp-dev/kcp/pkg/informer.NewGenericDiscoveringDynamicSharedInformerFactory[...].func3"),

		goleak.IgnoreTopFunction("k8s.io/apiserver/pkg/storage/storagebackend/factory.newETCD3Check.func2"),

		goleak.IgnoreTopFunction("k8s.io/client-go/util/workqueue.(*delayingType[...]).waitingLoop"),

		goleak.IgnoreTopFunction("k8s.io/client-go/util/workqueue.(*Typed[...]).updateUnfinishedWorkLoop"),

		goleak.IgnoreTopFunction("github.com/kcp-dev/apimachinery/v2/third_party/informers.newScopedSharedIndexInformerWithContext.func1"),

		goleak.IgnoreTopFunction("net/http.(*persistConn).writeLoop"),

		goleak.IgnoreTopFunction("golang.org/x/net/http2.(*serverConn).serve"),

		goleak.IgnoreTopFunction("gopkg.in/natefinch/lumberjack%2ev2.(*Logger).millRun"),

		goleak.IgnoreTopFunction("internal/poll.runtime_pollWait"),
	}

	// 14s as etcd sets a client request timeout of up to 7 seconds when
	// shutting down the server and then starts shutting down everything
	// else.
	// A shorter timespan d would lead to false positives in the tests.
	WaitTime = 14 * time.Second
)

var ContextRunInProcess kcptestingserver.KcpRunner = func(ctx context.Context, t kcptestingserver.TestingT, cfg kcptestingserver.Config) (<-chan struct{}, error) {
	s := NewInProcessServer(t)
	s.Config = cfg
	s.Start(ctx, t)
	s.Wait(t)
	return s.StopCh, nil
}