update s3 session cache key (#6923)
This commit is contained in:
@@ -31,7 +31,8 @@ func createSession(awsAccessKeyId, awsSecretAccessKey, region, endpoint string,
|
|||||||
sessionsLock.Lock()
|
sessionsLock.Lock()
|
||||||
defer sessionsLock.Unlock()
|
defer sessionsLock.Unlock()
|
||||||
|
|
||||||
if t, found := s3Sessions[region]; found {
|
cacheKey := fmt.Sprintf("%s|%s", region, endpoint)
|
||||||
|
if t, found := s3Sessions[cacheKey]; found {
|
||||||
return t, nil
|
return t, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user