handler

Documentation

Index

• func New(ctx context.Context, t Throttler) http.Handler
• func NewContextHandler(ctx context.Context, next http.Handler) http.Handler
• type ConcurrencyReporter
  • func NewConcurrencyReporter(ctx context.Context, podName string, reqCh chan network.ReqEvent, ...) *ConcurrencyReporter
  • func (cr *ConcurrencyReporter) Run(stopCh <-chan struct{})
• type HealthHandler
  • func (h *HealthHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type MetricHandler
  • func NewMetricHandler(podName string, next http.Handler) *MetricHandler
  • func (h *MetricHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type ProbeHandler
  • func (h *ProbeHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type RequestEventHandler
  • func NewRequestEventHandler(reqChan chan network.ReqEvent, next http.Handler) *RequestEventHandler
  • func (h *RequestEventHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)
• type Throttler

Functions

func New

func New(ctx context.Context, t Throttler) http.Handler

New constructs a new http.Handler that deals with revision activation.

func NewContextHandler

func NewContextHandler(ctx context.Context, next http.Handler) http.Handler

NewContextHandler creates a handler that extracts the necessary context from the request and makes it available on the request's context.

Types

type ConcurrencyReporter

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

ConcurrencyReporter reports stats based on incoming requests and ticks.

func NewConcurrencyReporter

func NewConcurrencyReporter(ctx context.Context, podName string,
	reqCh chan network.ReqEvent, statCh chan []asmetrics.StatMessage) *ConcurrencyReporter

NewConcurrencyReporter creates a ConcurrencyReporter which listens to incoming ReqEvents on reqCh and ticks on reportCh and reports stats on statCh.

func (*ConcurrencyReporter) Run

func (cr *ConcurrencyReporter) Run(stopCh <-chan struct{})

Run runs until stopCh is closed and processes events on all incoming channels.

type HealthHandler

type HealthHandler struct {
	HealthCheck func() error
	NextHandler http.Handler
	Logger      *zap.SugaredLogger
}

HealthHandler handles responding to kubelet probes with a provided health check.

func (*HealthHandler) ServeHTTP

func (h *HealthHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type MetricHandler

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

MetricHandler sends metrics via reporter

func NewMetricHandler

func NewMetricHandler(podName string, next http.Handler) *MetricHandler

NewMetricHandler creates a handler collects and reports request metrics

func (*MetricHandler) ServeHTTP

func (h *MetricHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type ProbeHandler

type ProbeHandler struct {
	NextHandler http.Handler
}

ProbeHandler handles responding to Knative internal network probes.

func (*ProbeHandler) ServeHTTP

func (h *ProbeHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type RequestEventHandler

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

RequestEventHandler sends events to the given channel.

func NewRequestEventHandler

func NewRequestEventHandler(reqChan chan network.ReqEvent, next http.Handler) *RequestEventHandler

NewRequestEventHandler creates a handler that sends events about incoming/closed http connections to the given channel.

func (*RequestEventHandler) ServeHTTP

func (h *RequestEventHandler) ServeHTTP(w http.ResponseWriter, r *http.Request)

type Throttler

type Throttler interface {
	Try(context.Context, func(string) error) error
}

Throttler is the interface that Handler calls to Try to proxy the user request.