in auth/auth.go [40:72]
func NewAuth(
ctx context.Context,
region, nameSpace, svcAcc, podName, preferredAddressType string,
usePodIdentity bool,
k8sClient k8sv1.CoreV1Interface,
) (auth *Auth, e error) {
var stsClient stsiface.STSAPI
if !usePodIdentity {
// Get an initial session to use for STS calls when using IRSA
sess, err := session.NewSession(aws.NewConfig().
WithSTSRegionalEndpoint(endpoints.RegionalSTSEndpoint).
WithRegion(region),
)
if err != nil {
return nil, err
}
stsClient = sts.New(sess)
}
return &Auth{
region: region,
nameSpace: nameSpace,
svcAcc: svcAcc,
podName: podName,
preferredAddressType: preferredAddressType,
usePodIdentity: usePodIdentity,
k8sClient: k8sClient,
stsClient: stsClient,
ctx: ctx,
}, nil
}