kubernetes/staging/src/k8s.io/apiserver/pkg/server/dynamiccertificates/configmap_cafile_content.go

type ConfigMapCAController …

var _ …

var _ …

// NewDynamicCAFromConfigMapController returns a CAContentProvider based on a configmap that automatically reloads content.
// It is near-realtime via an informer.
func NewDynamicCAFromConfigMapController(purpose, namespace, name, key string, kubeClient kubernetes.Interface) (*ConfigMapCAController, error) { … }

func (c *ConfigMapCAController) keyFn() string { … }

// AddListener adds a listener to be notified when the CA content changes.
func (c *ConfigMapCAController) AddListener(listener Listener) { … }

// loadCABundle determines the next set of content for the file.
func (c *ConfigMapCAController) loadCABundle() error { … }

// hasCAChanged returns true if the caBundle is different than the current.
func (c *ConfigMapCAController) hasCAChanged(caBundle []byte) bool { … }

// RunOnce runs a single sync loop
func (c *ConfigMapCAController) RunOnce(ctx context.Context) error { … }

// Run starts the kube-apiserver and blocks until stopCh is closed.
func (c *ConfigMapCAController) Run(ctx context.Context, workers int) { … }

func (c *ConfigMapCAController) runWorker() { … }

func (c *ConfigMapCAController) processNextWorkItem() bool { … }

// Name is just an identifier
func (c *ConfigMapCAController) Name() string { … }

// CurrentCABundleContent provides ca bundle byte content
func (c *ConfigMapCAController) CurrentCABundleContent() []byte { … }

// VerifyOptions provides verifyoptions compatible with authenticators
func (c *ConfigMapCAController) VerifyOptions() (x509.VerifyOptions, bool) { … }