in server/server.go [231:248]
func (s *CSIDriverProviderServer) getAwsSessions(nameSpace, svcAcct string, ctx context.Context, lookupRegionList []string, usePodIdentity bool, podName string, preferredAddressType string) (response []*session.Session, err error) {
// Get the pod's AWS creds for each lookup region.
var awsSessionsList []*session.Session
for _, region := range lookupRegionList {
awsAuth, err := auth.NewAuth(ctx, region, nameSpace, svcAcct, podName, preferredAddressType, usePodIdentity, s.k8sClient)
if err != nil {
return nil, fmt.Errorf("%s: %s", region, err)
}
awsSession, err := awsAuth.GetAWSSession()
if err != nil {
return nil, fmt.Errorf("%s: %s", region, err)
}
awsSessionsList = append(awsSessionsList, awsSession)
}
return awsSessionsList, nil
}