kubernetes/staging/src/k8s.io/controller-manager/pkg/clientbuilder/client_builder_dynamic.go

var defaultExpirationSeconds …

var defaultLeewayPercent …

type DynamicControllerClientBuilder …

// NewDynamicClientBuilder returns client builder which uses TokenRequest feature and refresh service account token periodically
func NewDynamicClientBuilder(clientConfig *restclient.Config, coreClient v1core.CoreV1Interface, ns string) ControllerClientBuilder { … }

// this function only for test purpose, don't call it
func NewTestDynamicClientBuilder(clientConfig *restclient.Config, coreClient v1core.CoreV1Interface, ns string, expirationSeconds int64, leewayPercent int) ControllerClientBuilder { … }

func (t *DynamicControllerClientBuilder) Config(saName string) (*restclient.Config, error) { … }

func (t *DynamicControllerClientBuilder) ConfigOrDie(name string) *restclient.Config { … }

func (t *DynamicControllerClientBuilder) Client(name string) (clientset.Interface, error) { … }

func (t *DynamicControllerClientBuilder) ClientOrDie(name string) clientset.Interface { … }

func (t *DynamicControllerClientBuilder) DiscoveryClient(name string) (discovery.DiscoveryInterface, error) { … }

func (t *DynamicControllerClientBuilder) DiscoveryClientOrDie(name string) discovery.DiscoveryInterface { … }

type tokenSourceImpl …

func (ts *tokenSourceImpl) Token() (*oauth2.Token, error) { … }

func constructClient(saNamespace, saName string, config *restclient.Config) restclient.Config { … }

func getOrCreateServiceAccount(coreClient v1core.CoreV1Interface, namespace, name string) (*v1.ServiceAccount, error) { … }