func()

in internal/credsretriever/refreshing_cache.go [223:236]


func (r *cachedCredentialRetriever) fetchCredentialsFromDelegate(ctx context.Context,
	request *credentials.EksCredentialsRequest) (cacheEntry, error) {
	iamCredentials, metadata, err := r.delegate.GetIamCredentials(ctx, request)
	if err != nil {
		return cacheEntry{}, err
	}
	requestLogCtx := logger.ContextWithField(logger.CloneToNewIfPresent(ctx, context.Background()),
		"association-id", metadata.AssociationId())
	return cacheEntry{
		originatingRequest: request,
		requestLogCtx:      requestLogCtx,
		credentials:        iamCredentials,
	}, nil
}