Merge pull request #2 from fterrag/kube2iam-workaround

fterrag · May 17, 2018 · e8e4f90 · e8e4f90
2 parents ca5f1c6 + bde6c18
commit e8e4f90
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/cmd/simplesqsd/simplesqsd.go b/cmd/simplesqsd/simplesqsd.go
@@ -4,6 +4,7 @@ import (
 	"net/http"
 	"os"
 	"strconv"
+	"time"
 
 	"github.com/aws/aws-sdk-go/aws"
 	"github.com/aws/aws-sdk-go/aws/session"
@@ -70,6 +71,14 @@ func main() {
 		WithRegion(c.QueueRegion).
 		WithHTTPClient(httpClient)
 
+	// To workaround a kube2iam issue, expire credentials every minute.
+	go func() {
+		for {
+			sqsConfig.Credentials.Expire()
+			time.Sleep(time.Minute)
+		}
+	}()
+
 	sqsSvc := sqs.New(awsSess, sqsConfig)
 
 	wConf := supervisor.WorkerConfig{