in pkg/handlers/eks_credential_handler.go [48:64]
func NewEksCredentialHandler(opts EksCredentialHandlerOpts) *EksCredentialHandler {
credentialsRetriever := eksauth.NewService(opts.Cfg)
if opts.CredentialRenewal != 0 && opts.MaxCacheSize != 0 {
credentialsRetriever = credsretriever.NewCachedCredentialRetriever(credsretriever.CachedCredentialRetrieverOpts{
Delegate: credentialsRetriever,
CredentialsRenewalTtl: opts.CredentialRenewal,
MaxCacheSize: opts.MaxCacheSize,
RefreshQPS: opts.RefreshQPS,
})
}
return &EksCredentialHandler{
RequestValidator: validation.DefaultCredentialValidator{},
ClusterName: opts.ClusterName,
CredentialRetriever: credentialsRetriever,
}
}