oxy: github.com/vulcand/oxy/stream Index | Files

package stream

import "github.com/vulcand/oxy/stream"

Package stream provides http.Handler middleware that passes-through the entire request

Stream works around several limitations caused by buffering implementations, but also introduces certain risks.

Workarounds for buffering limitations: 1. Streaming really large chunks of data (large file transfers, or streaming videos, etc.)

2. Streaming (chunking) sparse data. For example, an implementation might send a health check or a heart beat over a long-lived connection. This does not play well with buffering.

Risks: 1. Connections could survive for very long periods of time.

2. There is no easy way to enforce limits on size/time of a connection.

Examples of a streaming middleware:

// sample HTTP handler
handler := http.HandlerFunc(func(w http.ResponseWriter, req *http.Request) {
  w.Write([]byte("hello"))
})

// Stream will literally pass through to the next handler without ANY buffering
// or validation of the data.
stream.New(handler)

Index

Package Files

stream.go threshold.go

Constants

const (
    // DefaultMaxBodyBytes No limit by default
    DefaultMaxBodyBytes = -1
)

func IsValidExpression Uses

func IsValidExpression(expr string) bool

IsValidExpression check if it's a valid expression

func Logger Uses

func Logger(l *log.Logger) optSetter

Logger defines the logger the streamer will use.

It defaults to logrus.StandardLogger(), the global logger used by logrus.

type Stream Uses

type Stream struct {
    // contains filtered or unexported fields
}

Stream is responsible for buffering requests and responses It buffers large requests and responses to disk,

func New Uses

func New(next http.Handler, setters ...optSetter) (*Stream, error)

New returns a new streamer middleware. New() function supports optional functional arguments

func (*Stream) ServeHTTP Uses

func (s *Stream) ServeHTTP(w http.ResponseWriter, req *http.Request)

func (*Stream) Wrap Uses

func (s *Stream) Wrap(next http.Handler) error

Wrap sets the next handler to be called by stream handler.

Package stream imports 5 packages (graph) and is imported by 8 packages. Updated 2018-07-09. Refresh now. Tools for package owners.