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() {}