in internal/conn/storage/credcache.go [88:101]
func (c *credCache) get(ctx context.Context) (*service.UserDelegationCredential, error) {
cred := c.cred.Load()
if cred == nil {
return nil, errors.New("no credential")
}
if cred.expires.Before(c.now()) {
if cred.err != nil {
return nil, cred.err
}
return nil, errors.New("credential expired")
}
return cred.cred, nil
}