@@ -17,8 +17,8 @@ import (
1717 "github.com/golang-collections/go-datastructures/queue"
1818)
1919
20- // DefaulHttpListenerPort is used to set the URL where the logs will be sent by Logs API
21- const DefaulHttpListenerPort = "1234"
20+ // DefaultHttpListenerPort is used to set the URL where the logs will be sent by Logs API
21+ const DefaultHttpListenerPort = "1234"
2222
2323// LogsApiHttpListener is used to listen to the Logs API using HTTP
2424type LogsApiHttpListener struct {
@@ -36,12 +36,22 @@ func NewLogsApiHttpListener(lq *queue.Queue) (*LogsApiHttpListener, error) {
3636 }, nil
3737}
3838
39+ func ListenOnAddress () string {
40+ env_aws_local , ok := os .LookupEnv ("AWS_SAM_LOCAL" )
41+ if ok && "true" == env_aws_local {
42+ return ":" + DefaultHttpListenerPort
43+ }
44+
45+ return "sandbox:" + DefaultHttpListenerPort
46+ }
47+
3948// Start initiates the server in a goroutine where the logs will be sent
4049func (s * LogsApiHttpListener ) Start () (bool , error ) {
41- s .httpServer = & http.Server {Addr : ":" + DefaulHttpListenerPort }
50+ address := ListenOnAddress ()
51+ s .httpServer = & http.Server {Addr : address }
4252 http .HandleFunc ("/" , s .http_handler )
4353 go func () {
44- logger .Infof ("Serving agent on %s" , ":" + DefaulHttpListenerPort )
54+ logger .Infof ("Serving agent on %s" , address )
4555 err := s .httpServer .ListenAndServe ()
4656 if err != http .ErrServerClosed {
4757 logger .Errorf ("Unexpected stop on Http Server: %v" , err )
@@ -138,7 +148,7 @@ func (a HttpAgent) Init(agentID string) error {
138148 }
139149 destination := logsapi.Destination {
140150 Protocol : logsapi .HttpProto ,
141- URI : logsapi .URI (fmt .Sprintf ("http://sandbox:%s" , DefaulHttpListenerPort )),
151+ URI : logsapi .URI (fmt .Sprintf ("http://sandbox:%s" , DefaultHttpListenerPort )),
142152 HttpMethod : logsapi .HttpPost ,
143153 Encoding : logsapi .JSON ,
144154 }
0 commit comments