func()

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
}