handlers

package

v0.0.0-...-a134451 Latest Latest Go to latest Published: Feb 28, 2024 License: MIT Imports: 24 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/tsundata/flowline

Links

Open Source Insights

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
- func (s *WatchServer) ServeHTTP(w http.ResponseWriter, req *http.Request)

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 IgnoreReceives ¶

func IgnoreReceives(ws *websocket.Conn, timeout time.Duration)

func IsWebSocketRequest ¶

func IsWebSocketRequest(req *http.Request) bool

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 ¶

type TimeoutFactory interface {
	TimeoutCh() (<-chan time.Time, func() bool)
}

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)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL