kubernetes: github.com/erimatnor/kubernetes/pkg/registry/generic/rest Index | Files

package rest

import "github.com/erimatnor/kubernetes/pkg/registry/generic/rest"

Package rest has generic implementations of resources used for REST responses


Package Files

doc.go proxy.go streamer.go

type LocationStreamer Uses

type LocationStreamer struct {
    Location    *url.URL
    Transport   http.RoundTripper
    ContentType string
    Flush       bool

LocationStreamer is a resource that streams the contents of a particular location URL

func (*LocationStreamer) InputStream Uses

func (s *LocationStreamer) InputStream(apiVersion, acceptHeader string) (stream io.ReadCloser, flush bool, contentType string, err error)

InputStream returns a stream with the contents of the URL location. If no location is provided, a null stream is returned.

func (*LocationStreamer) IsAnAPIObject Uses

func (*LocationStreamer) IsAnAPIObject()

IsAnAPIObject marks this object as a runtime.Object

type UpgradeAwareProxyHandler Uses

type UpgradeAwareProxyHandler struct {
    UpgradeRequired bool
    Location        *url.URL
    Transport       http.RoundTripper
    FlushInterval   time.Duration
    // contains filtered or unexported fields

UpgradeAwareProxyHandler is a handler for proxy requests that may require an upgrade

func NewUpgradeAwareProxyHandler Uses

func NewUpgradeAwareProxyHandler(location *url.URL, transport http.RoundTripper, upgradeRequired bool) *UpgradeAwareProxyHandler

NewUpgradeAwareProxyHandler creates a new proxy handler with a default flush interval

func (*UpgradeAwareProxyHandler) RequestError Uses

func (h *UpgradeAwareProxyHandler) RequestError() error

RequestError returns an error that occurred while handling request

func (*UpgradeAwareProxyHandler) ServeHTTP Uses

func (h *UpgradeAwareProxyHandler) ServeHTTP(w http.ResponseWriter, req *http.Request)

ServeHTTP handles the proxy request

Package rest imports 16 packages (graph). Updated 2017-05-11. Refresh now. Tools for package owners.