kubernetes/staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_context.go

type priorityAndFairnessKeyType …

const priorityAndFairnessInitializationSignalKey …

// WithInitializationSignal creates a copy of parent context with
// priority and fairness initialization signal value.
func WithInitializationSignal(ctx context.Context, signal InitializationSignal) context.Context { … }

// initializationSignalFrom returns an initialization signal function
// which when called signals that watch initialization has already finished
// to priority and fairness dispatcher.
func initializationSignalFrom(ctx context.Context) (InitializationSignal, bool) { … }

// WatchInitialized sends a signal to priority and fairness dispatcher
// that a given watch request has already been initialized.
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) { … }

type InitializationSignal …

type initializationSignal …

func NewInitializationSignal() InitializationSignal { … }

func (i *initializationSignal) Signal() { … }

func (i *initializationSignal) Wait() { … }