From fa477238a756ebee9b6a0b846aae7321e0f46bd5 Mon Sep 17 00:00:00 2001 From: Frank Terragna Date: Thu, 17 May 2018 14:06:50 -0400 Subject: [PATCH] Use sqsSvc to expire credentials --- cmd/simplesqsd/simplesqsd.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/cmd/simplesqsd/simplesqsd.go b/cmd/simplesqsd/simplesqsd.go index a22cd0f..73aa570 100644 --- a/cmd/simplesqsd/simplesqsd.go +++ b/cmd/simplesqsd/simplesqsd.go @@ -71,16 +71,16 @@ func main() { WithRegion(c.QueueRegion). WithHTTPClient(httpClient) + sqsSvc := sqs.New(awsSess, sqsConfig) + // To workaround a kube2iam issue, expire credentials every minute. go func() { for { - sqsConfig.Credentials.Expire() + sqsSvc.Config.Credentials.Expire() time.Sleep(time.Minute) } }() - sqsSvc := sqs.New(awsSess, sqsConfig) - wConf := supervisor.WorkerConfig{ QueueURL: c.QueueURL, QueueMaxMessages: c.QueueMaxMessages,