Documentation ¶
Index ¶
- func ConvertInternalEventToWatchEvent(in *watch.Event, out *meta.WatchEvent) error
- func CreateResource(s rest.Creater, scope *registry.RequestScope) restful.RouteFunction
- func DeleteResource(s rest.Deleter, scope *registry.RequestScope) restful.RouteFunction
- func GetResource(s rest.Getter, scope *registry.RequestScope) restful.RouteFunction
- func IgnoreReceives(ws *websocket.Conn, timeout time.Duration)
- func IsWebSocketRequest(req *http.Request) bool
- func ListResource(s rest.Lister, scope *registry.RequestScope) restful.RouteFunction
- func PatchResource(s rest.Patcher, scope *registry.RequestScope) restful.RouteFunction
- func UpdateResource(s rest.Updater, scope *registry.RequestScope) restful.RouteFunction
- func WatchListResource(s rest.Watcher, scope *registry.RequestScope) restful.RouteFunction
- func WatchResource(s rest.Watcher, scope *registry.RequestScope) restful.RouteFunction
- type TimeoutFactory
- type WatchServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConvertInternalEventToWatchEvent ¶
func ConvertInternalEventToWatchEvent(in *watch.Event, out *meta.WatchEvent) error
func CreateResource ¶
func CreateResource(s rest.Creater, scope *registry.RequestScope) restful.RouteFunction
func DeleteResource ¶
func DeleteResource(s rest.Deleter, scope *registry.RequestScope) restful.RouteFunction
func GetResource ¶
func GetResource(s rest.Getter, scope *registry.RequestScope) restful.RouteFunction
func IsWebSocketRequest ¶
func ListResource ¶
func ListResource(s rest.Lister, scope *registry.RequestScope) restful.RouteFunction
func PatchResource ¶
func PatchResource(s rest.Patcher, scope *registry.RequestScope) restful.RouteFunction
func UpdateResource ¶
func UpdateResource(s rest.Updater, scope *registry.RequestScope) restful.RouteFunction
func WatchListResource ¶
func WatchListResource(s rest.Watcher, scope *registry.RequestScope) restful.RouteFunction
func WatchResource ¶
func WatchResource(s rest.Watcher, scope *registry.RequestScope) restful.RouteFunction
Types ¶
type TimeoutFactory ¶
TimeoutFactory abstracts watch timeout logic for testing
type WatchServer ¶
type WatchServer struct { Watching watch.Interface Scope *registry.RequestScope MediaType string Framer runtime.Framer Encoder runtime.Encoder EmbeddedEncoder runtime.Encoder Fixup func(runtime.Object) runtime.Object TimeoutFactory TimeoutFactory }
func (*WatchServer) ServeHTTP ¶
func (s *WatchServer) ServeHTTP(w http.ResponseWriter, req *http.Request)
Click to show internal directories.
Click to hide internal directories.