Free APF seats for watches handled by an aggregated apiserver.

Kubernetes-commit: 1873915be6be40df20fe35a8e0c7e8e0a620111a
This commit is contained in:
Ben Luddy 2021-10-06 10:16:46 -04:00 committed by Kubernetes Publisher
parent 1e65a6af45
commit 7324607749
1 changed files with 11 additions and 0 deletions

View File

@ -52,6 +52,17 @@ func WatchInitialized(ctx context.Context) {
}
}
// RequestDelegated informs the priority and fairness dispatcher that
// a given request has been delegated to an aggregated API
// server. No-op when priority and fairness is disabled.
func RequestDelegated(ctx context.Context) {
// The watch initialization signal doesn't traverse request
// boundaries, so we generously fire it as soon as we know
// that the request won't be serviced locally. Safe to call
// for non-watch requests.
WatchInitialized(ctx)
}
// InitializationSignal is an interface that allows sending and handling
// initialization signals.
type InitializationSignal interface {