@@ -2,10 +2,11 @@ package server
22
33import (
44 "encoding/json"
5- "github.com/google/uuid"
65 "log"
76 "time"
87
8+ "github.com/google/uuid"
9+
910 "github.com/aws/aws-sdk-go/aws"
1011 "github.com/aws/aws-sdk-go/service/lambda"
1112 "github.com/pkg/errors"
@@ -38,7 +39,10 @@ func (l *lambdaExecutionManager) run() {
3839 setInvokeConfig = false
3940 }
4041 for region := range l .regions {
41- l .executeFunction (region , setInvokeConfig )
42+ err := l .executeFunction (region , setInvokeConfig )
43+ if err != nil {
44+ log .Println (err )
45+ }
4246 time .Sleep (l .frequency )
4347 }
4448 count ++
@@ -47,7 +51,7 @@ func (l *lambdaExecutionManager) run() {
4751
4852func (l * lambdaExecutionManager ) executeFunction (region int , setInvokeConfig bool ) error {
4953 log .Println ("Executing Lambda function in region" , l .regions [region ])
50- sess , err := getSessionAWS ()
54+ sess , err := GetSessionAWS ()
5155 if err != nil {
5256 return err
5357 }
@@ -111,7 +115,10 @@ func newLambdaExecutionManager(publicIP string, regions []string, frequency time
111115 for {
112116 <- onDemandExecution
113117 log .Println ("Starting new tunnel as existing tunnel failed" )
114- executionManager .executeFunction (0 , false )
118+ err := executionManager .executeFunction (0 , false )
119+ if err != nil {
120+ log .Println (err )
121+ }
115122 time .Sleep (time .Second * 5 )
116123 }
117124 }()
0 commit comments