|
|
@ -28,7 +28,7 @@ var awsCredentialCache = make(map[string]cache) |
|
|
|
var credentialCacheLock sync.RWMutex |
|
|
|
var credentialCacheLock sync.RWMutex |
|
|
|
|
|
|
|
|
|
|
|
func GetCredentials(dsInfo *DatasourceInfo) (*credentials.Credentials, error) { |
|
|
|
func GetCredentials(dsInfo *DatasourceInfo) (*credentials.Credentials, error) { |
|
|
|
cacheKey := dsInfo.AccessKey + ":" + dsInfo.Profile + ":" + dsInfo.AssumeRoleArn |
|
|
|
cacheKey := fmt.Sprintf("%s:%s:%s:%s", dsInfo.AuthType, dsInfo.AccessKey, dsInfo.Profile, dsInfo.AssumeRoleArn) |
|
|
|
credentialCacheLock.RLock() |
|
|
|
credentialCacheLock.RLock() |
|
|
|
if _, ok := awsCredentialCache[cacheKey]; ok { |
|
|
|
if _, ok := awsCredentialCache[cacheKey]; ok { |
|
|
|
if awsCredentialCache[cacheKey].expiration != nil && |
|
|
|
if awsCredentialCache[cacheKey].expiration != nil && |
|
|
|