kubernetes/staging/src/k8s.io/apiserver/pkg/admission/configuration/configuration_manager.go

const defaultInterval …

const defaultFailureThreshold …

const defaultBootstrapRetries …

const defaultBootstrapGraceperiod …

var ErrNotReady …

var ErrDisabled …

type getFunc …

type poller …

func newPoller(get getFunc) *poller { … }

func (a *poller) lastError(err error) { … }

func (a *poller) notReady() { … }

func (a *poller) bootstrapping() { … }

// If the poller is not bootstrapped yet, the configuration() gets a few chances
// to retry. This hides transient failures during system startup.
func (a *poller) configuration() (runtime.Object, error) { … }

func (a *poller) setConfigurationAndReady(value runtime.Object) { … }

func (a *poller) Run(stopCh <-chan struct{ … }

func (a *poller) sync() { … }