Skip to content
This repository was archived by the owner on Mar 5, 2024. It is now read-only.

Commit d999e61

Browse files
derrickburnsJoseph-Irving
authored andcommitted
Support inferring arn prefix. (#276)
1 parent 02f63bc commit d999e61

File tree

1 file changed

+4
-3
lines changed

1 file changed

+4
-3
lines changed

pkg/server/server.go

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,7 @@ import (
3333
pb "github.com/uswitch/kiam/proto"
3434
"google.golang.org/grpc"
3535
"google.golang.org/grpc/credentials"
36-
"k8s.io/api/core/v1"
36+
"k8s.io/api/core/v1"
3737
"k8s.io/apimachinery/pkg/runtime"
3838
"k8s.io/client-go/kubernetes"
3939
"k8s.io/client-go/kubernetes/scheme"
@@ -233,15 +233,16 @@ func NewServer(config *Config) (*KiamServer, error) {
233233
server.namespaces = k8s.NewNamespaceCache(k8s.NewListWatch(client, k8s.ResourceNamespaces), time.Minute)
234234
server.eventRecorder = eventRecorder(client)
235235

236-
stsGateway, err := sts.DefaultGateway(config.AssumeRoleArn, config.Region)
236+
arnResolver, err := newRoleARNResolver(config)
237237
if err != nil {
238238
return nil, err
239239
}
240240

241-
arnResolver, err := newRoleARNResolver(config)
241+
stsGateway, err := sts.DefaultGateway(arnResolver.Resolve(config.AssumeRoleArn), config.Region)
242242
if err != nil {
243243
return nil, err
244244
}
245+
245246
credentialsCache := sts.DefaultCache(
246247
stsGateway, config.SessionName,
247248
config.SessionDuration,

0 commit comments

Comments
 (0)