Version: v0.35.1 Latest Latest

This package is not in the latest version of its module.

Go to latest
Published: Nov 24, 2022 License: Apache-2.0 Imports: 44 Imported by: 5




This section is empty.


This section is empty.


func New added in v0.6.0

func New(_ context.Context, t Throttler, transport http.RoundTripper, usePassthroughLb bool, logger *zap.SugaredLogger, tlsEnabled bool) http.Handler

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

func NewContextHandler added in v0.12.0

func NewContextHandler(ctx context.Context, next http.Handler, store *activatorconfig.Store) http.Handler

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

func NewTracingHandler added in v0.22.0

func NewTracingHandler(next http.Handler) http.HandlerFunc

NewTracingHandler creates a wrapper around tracing.HTTPSpanMiddleware that completely bypasses said handler when tracing is disabled via the Activator's configuration.

func RevIDFrom added in v0.21.0

func RevIDFrom(ctx context.Context) types.NamespacedName

RevIDFrom retrieves the the revisionID from the context.

func RevisionFrom added in v0.22.0

func RevisionFrom(ctx context.Context) *v1.Revision

RevisionFrom retrieves the Revision object from the context.

func WithRevisionAndID added in v0.22.0

func WithRevisionAndID(ctx context.Context, rev *v1.Revision, revID types.NamespacedName) context.Context

WithRevisionAndID attaches the Revision and the ID to the context.


type ConcurrencyReporter added in v0.4.0

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, 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) Handler added in v0.17.0

func (cr *ConcurrencyReporter) Handler(next http.Handler) http.HandlerFunc

Handler returns a handler that records requests coming in/being finished in the stats machinery.

func (*ConcurrencyReporter) Run added in v0.4.0

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

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

type HealthHandler added in v0.5.0

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 added in v0.5.0

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

type MetricHandler added in v0.9.0

type MetricHandler struct {
	// contains filtered or unexported fields

MetricHandler is a handler that records request metrics.

func NewMetricHandler added in v0.9.0

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

NewMetricHandler creates a handler that collects and reports request metrics.

func (*MetricHandler) ServeHTTP added in v0.9.0

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

type ProbeHandler added in v0.4.0

type ProbeHandler struct {
	NextHandler http.Handler

ProbeHandler handles responding to Knative internal network probes.

func (*ProbeHandler) ServeHTTP added in v0.4.0

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

type Throttler added in v0.10.0

type Throttler interface {
	Try(ctx context.Context, revID types.NamespacedName, fn func(string) error) error

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

Jump to

Keyboard shortcuts

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