kubernetes/staging/src/k8s.io/apiserver/pkg/endpoints/handlers/watch.go

var neverExitWatch …

type TimeoutFactory …

type realTimeoutFactory …

// TimeoutCh returns a channel which will receive something when the watch times out,
// and a cleanup function to call when this happens.
func (w *realTimeoutFactory) TimeoutCh() (<-chan time.Time, func() bool) { … }

// serveWatchHandler returns a handle to serve a watch response.
// TODO: the functionality in this method and in WatchServer.Serve is not cleanly decoupled.
func serveWatchHandler(watcher watch.Interface, scope *RequestScope, mediaTypeOptions negotiation.MediaTypeOptions, req *http.Request, w http.ResponseWriter, timeout time.Duration, metricsScope string, initialEventsListBlueprint runtime.Object) (http.Handler, error) { … }

type WatchServer …

// HandleHTTP serves a series of encoded events via HTTP with Transfer-Encoding: chunked.
// or over a websocket connection.
func (s *WatchServer) HandleHTTP(w http.ResponseWriter, req *http.Request) { … }

// HandleWS serves a series of encoded events over a websocket connection.
func (s *WatchServer) HandleWS(ws *websocket.Conn) { … }

type websocketFramer …

func newWebsocketFramer(ws *websocket.Conn, useTextFraming bool) io.Writer { … }

func (w *websocketFramer) Write(p []byte) (int, error) { … }

var _ …

func shouldRecordWatchListLatency(event watch.Event) bool { … }