in pkg/download/blobwithmsitoken.go [33:53]
func (self *blobWithMsiToken) GetRequest() (*http.Request, error) {
msi, err := self.msiProvider()
if err != nil {
return nil, err
}
if msi.AccessToken == "" {
return nil, errors.New("MSI token is empty")
}
request, err := http.NewRequest(http.MethodGet, self.url, nil)
if err != nil {
return nil, err
}
request.Header.Set(xMsClientRequestIdHeaderName, uuid.New().String())
if IsAzureStorageBlobUri(self.url) {
request.Header.Set("Authorization", fmt.Sprintf("Bearer %s", msi.AccessToken))
request.Header.Set(xMsVersionHeaderName, xMsVersionValue)
}
return request, nil
}