@RegisterExtension
  val clientTestRule = OkHttpClientTestRule()
  private val eventRecorder = EventRecorder()
  private val listener = EventSourceRecorder()
  private var client =
    clientTestRule
      .newClientBuilder()
      .eventListenerFactory(clientTestRule.wrap(eventRecorder))
      .build()

  @AfterEach
  fun after() {
    listener.assertExhausted()
  }

  @Test

  val handshakeCertificates = platform.localhostHandshakeCertificates()

  private lateinit var server: MockWebServer
  private lateinit var client: OkHttpClient

  val eventRecorder = EventRecorder()

  @BeforeEach
  fun setUp() {
    if (connectionType == H2) {
      platform.assumeHttp2Support()
    }

    response.use {
      assertEquals(200, response.code)
    }
  }

  @Test
  fun testEventListener() {
    val eventRecorder = EventRecorder()

    enableTls()

    client =
      client
        .newBuilder()
        .eventListenerFactory(clientTestRule.wrap(eventRecorder))
        .build()

    server.enqueue(MockResponse(body = "abc1"))
    server.enqueue(MockResponse(body = "abc2"))

  }

  fun wrap(eventListener: EventListener) =
    EventListener.Factory {
      ClientRuleEventListener(::addEvent) + eventListener
    }

  fun wrap(eventRecorder: EventRecorder) = wrap(eventRecorder.eventListener)

  fun wrap(eventListenerFactory: EventListener.Factory) =
    EventListener.Factory { call ->
      ClientRuleEventListener(::addEvent) + eventListenerFactory.create(call)
    }

        .validityInterval(1, 2)
        .build()
    var client = buildClient(clientCert, clientIntermediateCa.certificate)
    val eventRecorder = EventRecorder()
    client =
      client
        .newBuilder()
        .eventListener(eventRecorder.eventListener)
        .build()
    val socketFactory = buildServerSslSocketFactory()
    server.useHttps(socketFactory)
    server.requireClientAuth()

    serverListener.assertClosed(1000, "goodbye")
  }

  @Test
  fun webSocketsDontTriggerEventListener() {
    val eventRecorder = EventRecorder()
    client =
      client
        .newBuilder()
        .eventListenerFactory(clientTestRule.wrap(eventRecorder))
        .build()
    webServer.enqueue(
      MockResponse
        .Builder()
        .webSocketUpgrade(serverListener)

  @StartStop
  private val server = MockWebServer()

  private var eventRecorder = EventRecorder()
  private val handshakeCertificates = platform.localhostHandshakeCertificates()
  private var client =
    clientTestRule
      .newClientBuilder()
      .eventListenerFactory(clientTestRule.wrap(eventRecorder))
      .build()
  private val executorService = Executors.newScheduledThreadPool(1)

  @BeforeEach

    eventRecorder.removeUpToEvent(ConnectionAcquired::class.java)
    eventRecorder.removeUpToEvent(ResponseFailed::class.java)
    eventRecorder.removeUpToEvent(ConnectionReleased::class.java)
    eventRecorder.removeUpToEvent(ConnectionAcquired::class.java)
    eventRecorder.removeUpToEvent(ConnectionReleased::class.java)
    eventRecorder.removeUpToEvent(CallEnd::class.java)
  }

  @Test

- The EventRecorder from k8s.io/client-go/tools/events will now create events in the default namespace (instead of kube-system) when the related object does not have it set. ([#88815](https://github.com/kubernetes/kubernetes/pull/88815), [@enj](https://github.com/enj))...

- Weight of PodTopologySpread scheduling Score is doubled. ([#91258](https://github.com/kubernetes/kubernetes/pull/91258), [@alculquicondor](https://github.com/alculquicondor)) [SIG Scheduling]