Skip to content

Commit 78f9ca2

Browse files
committed
add buffers to eventsChannel, lambdaResponseChannel and RecordsChannel in proxy server
1 parent 0d6b19d commit 78f9ca2

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

proxy/proxy.go

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -36,9 +36,9 @@ func NewProxyServer() (*ProxyServer, error) {
3636
ps := &ProxyServer{
3737
runtimeEndpoint: os.Getenv("AWS_LAMBDA_RUNTIME_API"),
3838
port: port,
39-
eventsChannel: make(chan *http.Response),
40-
lambdaResponseChannel: make(chan *http.Request),
41-
RecordsChannel: make(chan firetail.Record),
39+
eventsChannel: make(chan *http.Response, 1),
40+
lambdaResponseChannel: make(chan *http.Request, 1),
41+
RecordsChannel: make(chan firetail.Record, 100),
4242
}
4343

4444
r := chi.NewRouter()

0 commit comments

Comments
 (0)