kubernetes/staging/src/k8s.io/apiserver/pkg/authentication/request/headerrequest/requestheader_controller.go

const authenticationRoleName

type RequestHeaderAuthRequestProvider

var _

type requestHeaderBundle

type RequestHeaderAuthRequestController

// NewRequestHeaderAuthRequestController creates a new controller that implements RequestHeaderAuthRequestController
func NewRequestHeaderAuthRequestController(
	cmName string,
	cmNamespace string,
	client kubernetes.Interface,
	usernameHeadersKey, uidHeadersKey, groupHeadersKey, extraHeaderPrefixesKey, allowedClientNamesKey string) *RequestHeaderAuthRequestController {}

func (c *RequestHeaderAuthRequestController) UsernameHeaders() []string {}

func (c *RequestHeaderAuthRequestController) UIDHeaders() []string {}

func (c *RequestHeaderAuthRequestController) GroupHeaders() []string {}

func (c *RequestHeaderAuthRequestController) ExtraHeaderPrefixes() []string {}

func (c *RequestHeaderAuthRequestController) AllowedClientNames() []string {}

// Run starts RequestHeaderAuthRequestController controller and blocks until stopCh is closed.
func (c *RequestHeaderAuthRequestController) Run(ctx context.Context, workers int) {}

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

func (c *RequestHeaderAuthRequestController) runWorker() {}

func (c *RequestHeaderAuthRequestController) processNextWorkItem() bool {}

// sync reads the config and propagates the changes to exportedRequestHeaderBundle
// which is exposed by the set of methods that are used to fill RequestHeaderConfig struct
func (c *RequestHeaderAuthRequestController) sync() error {}

func (c *RequestHeaderAuthRequestController) syncConfigMap(configMap *corev1.ConfigMap) error {}

func (c *RequestHeaderAuthRequestController) hasRequestHeaderBundleChanged(cm *corev1.ConfigMap) (bool, *requestHeaderBundle, error) {}

func (c *RequestHeaderAuthRequestController) getRequestHeaderBundleFromConfigMap(cm *corev1.ConfigMap) (*requestHeaderBundle, error) {}

func (c *RequestHeaderAuthRequestController) loadRequestHeaderFor(key string) []string {}

func (c *RequestHeaderAuthRequestController) keyFn() string {}

func deserializeStrings(in string) ([]string, error) {}