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 {}