Skip to content

Commit 9d74b77

Browse files
8naama8naama
authored
v0.3.7
Change shutdown drain to be synchronous
2 parents 7f55be0 + 9d5429d commit 9d74b77

File tree

4 files changed

+42
-54
lines changed

4 files changed

+42
-54
lines changed

‎logzio-lambda-extensions-logs/README.md

+36-34
Original file line numberDiff line numberDiff line change
@@ -227,44 +227,44 @@ foo: bar
227227
228228
| Region Name | Region Code | AWS ARN |
229229
|---------------------------|------------------|---------------------------------------------------------------------------------|
230-
| US East (N. Virginia) | `us-east-1` | `arn:aws:lambda:us-east-1:486140753397:layer:LogzioLambdaExtensionLogs:15` |
231-
| US East (Ohio) | `us-east-2` | `arn:aws:lambda:us-east-2:486140753397:layer:LogzioLambdaExtensionLogs:15` |
232-
| US West (N. California) | `us-west-1` | `arn:aws:lambda:us-west-1:486140753397:layer:LogzioLambdaExtensionLogs:15` |
233-
| US West (Oregon) | `us-west-2` | `arn:aws:lambda:us-west-2:486140753397:layer:LogzioLambdaExtensionLogs:14` |
234-
| Europe (Frankfurt) | `eu-central-1` | `arn:aws:lambda:eu-central-1:486140753397:layer:LogzioLambdaExtensionLogs:16` |
235-
| Europe (Ireland) | `eu-west-1` | `arn:aws:lambda:eu-west-1:486140753397:layer:LogzioLambdaExtensionLogs:14` |
236-
| Europe (Stockholm) | `eu-north-1` | `arn:aws:lambda:eu-north-1:486140753397:layer:LogzioLambdaExtensionLogs:15` |
237-
| Asia Pacific (Sydney) | `ap-southeast-2` | `arn:aws:lambda:ap-southeast-2:486140753397:layer:LogzioLambdaExtensionLogs:15` |
238-
| Canada (Central) | `ca-central-1` | `arn:aws:lambda:ca-central-1:486140753397:layer:LogzioLambdaExtensionLogs:16` |
239-
| South America (São Paulo) | `sa-east-1` | `arn:aws:lambda:sa-east-1:486140753397:layer:LogzioLambdaExtensionLogs:17` |
240-
| Asia Pacific (Tokyo) | `ap-northeast-1` | `arn:aws:lambda:ap-northeast-1:486140753397:layer:LogzioLambdaExtensionLogs:11` |
241-
| Asia Pacific (Singapore) | `ap-southeast-1` | `arn:aws:lambda:ap-southeast-1:486140753397:layer:LogzioLambdaExtensionLogs:12` |
242-
| Asia Pacific (Mumbai) | `ap-south-1` | `arn:aws:lambda:ap-south-1:486140753397:layer:LogzioLambdaExtensionLogs:11` |
243-
| Asia Pacific (Osaka) | `ap-northeast-3` | `arn:aws:lambda:ap-northeast-3:486140753397:layer:LogzioLambdaExtensionLogs:12` |
244-
| Asia Pacific (Seoul) | `ap-northeast-2` | `arn:aws:lambda:ap-northeast-2:486140753397:layer:LogzioLambdaExtensionLogs:12` |
245-
| Europe (London) | `eu-west-2` | `arn:aws:lambda:eu-west-2:486140753397:layer:LogzioLambdaExtensionLogs:13` |
246-
| Europe (Paris) | `eu-west-3` | `arn:aws:lambda:eu-west-3:486140753397:layer:LogzioLambdaExtensionLogs:12` |
230+
| US East (N. Virginia) | `us-east-1` | `arn:aws:lambda:us-east-1:486140753397:layer:LogzioLambdaExtensionLogs:16` |
231+
| US East (Ohio) | `us-east-2` | `arn:aws:lambda:us-east-2:486140753397:layer:LogzioLambdaExtensionLogs:16` |
232+
| US West (N. California) | `us-west-1` | `arn:aws:lambda:us-west-1:486140753397:layer:LogzioLambdaExtensionLogs:16` |
233+
| US West (Oregon) | `us-west-2` | `arn:aws:lambda:us-west-2:486140753397:layer:LogzioLambdaExtensionLogs:15` |
234+
| Europe (Frankfurt) | `eu-central-1` | `arn:aws:lambda:eu-central-1:486140753397:layer:LogzioLambdaExtensionLogs:17` |
235+
| Europe (Ireland) | `eu-west-1` | `arn:aws:lambda:eu-west-1:486140753397:layer:LogzioLambdaExtensionLogs:15` |
236+
| Europe (Stockholm) | `eu-north-1` | `arn:aws:lambda:eu-north-1:486140753397:layer:LogzioLambdaExtensionLogs:16` |
237+
| Asia Pacific (Sydney) | `ap-southeast-2` | `arn:aws:lambda:ap-southeast-2:486140753397:layer:LogzioLambdaExtensionLogs:16` |
238+
| Canada (Central) | `ca-central-1` | `arn:aws:lambda:ca-central-1:486140753397:layer:LogzioLambdaExtensionLogs:17` |
239+
| South America (São Paulo) | `sa-east-1` | `arn:aws:lambda:sa-east-1:486140753397:layer:LogzioLambdaExtensionLogs:18` |
240+
| Asia Pacific (Tokyo) | `ap-northeast-1` | `arn:aws:lambda:ap-northeast-1:486140753397:layer:LogzioLambdaExtensionLogs:12` |
241+
| Asia Pacific (Singapore) | `ap-southeast-1` | `arn:aws:lambda:ap-southeast-1:486140753397:layer:LogzioLambdaExtensionLogs:13` |
242+
| Asia Pacific (Mumbai) | `ap-south-1` | `arn:aws:lambda:ap-south-1:486140753397:layer:LogzioLambdaExtensionLogs:12` |
243+
| Asia Pacific (Osaka) | `ap-northeast-3` | `arn:aws:lambda:ap-northeast-3:486140753397:layer:LogzioLambdaExtensionLogs:13` |
244+
| Asia Pacific (Seoul) | `ap-northeast-2` | `arn:aws:lambda:ap-northeast-2:486140753397:layer:LogzioLambdaExtensionLogs:13` |
245+
| Europe (London) | `eu-west-2` | `arn:aws:lambda:eu-west-2:486140753397:layer:LogzioLambdaExtensionLogs:14` |
246+
| Europe (Paris) | `eu-west-3` | `arn:aws:lambda:eu-west-3:486140753397:layer:LogzioLambdaExtensionLogs:13` |
247247
248248
## ARM64 Architecture
249249
| Region Name | Region Code | AWS ARN |
250250
|---------------------------|------------------|-----------------------------------------------------------------------------------|
251-
| US East (N. Virginia) | `us-east-1` | `arn:aws:lambda:us-east-1:486140753397:layer:LogzioLambdaExtensionLogsArm:7` |
252-
| US East (Ohio) | `us-east-2` | `arn:aws:lambda:us-east-2:486140753397:layer:LogzioLambdaExtensionLogsArm:7` |
253-
| US West (N. California) | `us-west-1` | `arn:aws:lambda:us-west-1:486140753397:layer:LogzioLambdaExtensionLogsArm:7` |
254-
| US West (Oregon) | `us-west-2` | `arn:aws:lambda:us-west-2:486140753397:layer:LogzioLambdaExtensionLogsArm:6` |
255-
| Europe (Frankfurt) | `eu-central-1` | `arn:aws:lambda:eu-central-1:486140753397:layer:LogzioLambdaExtensionLogsArm:6` |
256-
| Europe (Ireland) | `eu-west-1` | `arn:aws:lambda:eu-west-1:486140753397:layer:LogzioLambdaExtensionLogsArm:7` |
257-
| Europe (Stockholm) | `eu-north-1` | `arn:aws:lambda:eu-north-1:486140753397:layer:LogzioLambdaExtensionLogsArm:7` |
258-
| Asia Pacific (Sydney) | `ap-southeast-2` | `arn:aws:lambda:ap-southeast-2:486140753397:layer:LogzioLambdaExtensionLogsArm:6` |
259-
| Canada (Central) | `ca-central-1` | `arn:aws:lambda:ca-central-1:486140753397:layer:LogzioLambdaExtensionLogsArm:6` |
260-
| South America (São Paulo) | `sa-east-1` | `arn:aws:lambda:sa-east-1:486140753397:layer:LogzioLambdaExtensionLogsArm:7` |
261-
| Asia Pacific (Tokyo) | `ap-northeast-1` | `arn:aws:lambda:ap-northeast-1:486140753397:layer:LogzioLambdaExtensionLogsArm:7` |
262-
| Asia Pacific (Singapore) | `ap-southeast-1` | `arn:aws:lambda:ap-southeast-1:486140753397:layer:LogzioLambdaExtensionLogsArm:7` |
263-
| Asia Pacific (Mumbai) | `ap-south-1` | `arn:aws:lambda:ap-south-1:486140753397:layer:LogzioLambdaExtensionLogsArm:6` |
264-
| Asia Pacific (Osaka) | `ap-northeast-3` | `arn:aws:lambda:ap-northeast-3:486140753397:layer:LogzioLambdaExtensionLogsArm:7` |
265-
| Asia Pacific (Seoul) | `ap-northeast-2` | `arn:aws:lambda:ap-northeast-2:486140753397:layer:LogzioLambdaExtensionLogsArm:7` |
266-
| Europe (London) | `eu-west-2` | `arn:aws:lambda:eu-west-2:486140753397:layer:LogzioLambdaExtensionLogsArm:6` |
267-
| Europe (Paris) | `eu-west-3` | `arn:aws:lambda:eu-west-3:486140753397:layer:LogzioLambdaExtensionLogsArm:7` |
251+
| US East (N. Virginia) | `us-east-1` | `arn:aws:lambda:us-east-1:486140753397:layer:LogzioLambdaExtensionLogsArm:8` |
252+
| US East (Ohio) | `us-east-2` | `arn:aws:lambda:us-east-2:486140753397:layer:LogzioLambdaExtensionLogsArm:8` |
253+
| US West (N. California) | `us-west-1` | `arn:aws:lambda:us-west-1:486140753397:layer:LogzioLambdaExtensionLogsArm:8` |
254+
| US West (Oregon) | `us-west-2` | `arn:aws:lambda:us-west-2:486140753397:layer:LogzioLambdaExtensionLogsArm:7` |
255+
| Europe (Frankfurt) | `eu-central-1` | `arn:aws:lambda:eu-central-1:486140753397:layer:LogzioLambdaExtensionLogsArm:7` |
256+
| Europe (Ireland) | `eu-west-1` | `arn:aws:lambda:eu-west-1:486140753397:layer:LogzioLambdaExtensionLogsArm:8` |
257+
| Europe (Stockholm) | `eu-north-1` | `arn:aws:lambda:eu-north-1:486140753397:layer:LogzioLambdaExtensionLogsArm:8` |
258+
| Asia Pacific (Sydney) | `ap-southeast-2` | `arn:aws:lambda:ap-southeast-2:486140753397:layer:LogzioLambdaExtensionLogsArm:7` |
259+
| Canada (Central) | `ca-central-1` | `arn:aws:lambda:ca-central-1:486140753397:layer:LogzioLambdaExtensionLogsArm:7` |
260+
| South America (São Paulo) | `sa-east-1` | `arn:aws:lambda:sa-east-1:486140753397:layer:LogzioLambdaExtensionLogsArm:8` |
261+
| Asia Pacific (Tokyo) | `ap-northeast-1` | `arn:aws:lambda:ap-northeast-1:486140753397:layer:LogzioLambdaExtensionLogsArm:8` |
262+
| Asia Pacific (Singapore) | `ap-southeast-1` | `arn:aws:lambda:ap-southeast-1:486140753397:layer:LogzioLambdaExtensionLogsArm:8` |
263+
| Asia Pacific (Mumbai) | `ap-south-1` | `arn:aws:lambda:ap-south-1:486140753397:layer:LogzioLambdaExtensionLogsArm:7` |
264+
| Asia Pacific (Osaka) | `ap-northeast-3` | `arn:aws:lambda:ap-northeast-3:486140753397:layer:LogzioLambdaExtensionLogsArm:8` |
265+
| Asia Pacific (Seoul) | `ap-northeast-2` | `arn:aws:lambda:ap-northeast-2:486140753397:layer:LogzioLambdaExtensionLogsArm:8` |
266+
| Europe (London) | `eu-west-2` | `arn:aws:lambda:eu-west-2:486140753397:layer:LogzioLambdaExtensionLogsArm:7` |
267+
| Europe (Paris) | `eu-west-3` | `arn:aws:lambda:eu-west-3:486140753397:layer:LogzioLambdaExtensionLogsArm:8` |
268268
269269
### Lambda extension versions
270270
@@ -279,6 +279,8 @@ foo: bar
279279
**NOTE:** If your AWS region is not in the list, please reach out to Logz.io's support or open an issue in this repo.
280280
281281
### Changelog:
282+
- **0.3.7**:
283+
- Change `SHUTDOWN` event flush to synchronous.
282284
- **0.3.6**:
283285
- Drain queue upon shutdown event.
284286
- **0.3.5**:

‎logzio-lambda-extensions-logs/go.mod

+1-1
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ go 1.22
44

55
require (
66
github.com/golang-collections/go-datastructures v0.0.0-20150211160725-59788d5eb259
7-
github.com/logzio/logzio-go v1.0.7
7+
github.com/logzio/logzio-go v1.0.8
88
github.com/pkg/errors v0.9.1
99
github.com/sirupsen/logrus v1.9.3
1010
github.com/stretchr/testify v1.9.0

‎logzio-lambda-extensions-logs/go.sum

+2-17
Original file line numberDiff line numberDiff line change
@@ -13,13 +13,10 @@ github.com/golang/protobuf v1.2.0/go.mod h1:6lQm79b+lXiMfvg/cZm0SGofjICqVBUtrP5y
1313
github.com/golang/snappy v0.0.0-20180518054509-2e65f85255db/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=
1414
github.com/golang/snappy v0.0.4 h1:yAGX7huGHXlcLOEtBnF4w7FQwA26wojNCwOYAEhLjQM=
1515
github.com/golang/snappy v0.0.4/go.mod h1:/XxbfmMg8lxefKM7IXC3fBNl/7bRcc72aCRzEWrmP2Q=
16-
github.com/google/go-cmp v0.5.6/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
17-
github.com/google/go-cmp v0.5.7/go.mod h1:n+brtR0CgQNWTVd5ZUFpTBC8YFBDLK/h/bpaJ8/DtOE=
1816
github.com/hpcloud/tail v1.0.0 h1:nfCOvKYfkgYP8hkirhJocXT2+zOD8yUNjXaWfTlyFKI=
1917
github.com/hpcloud/tail v1.0.0/go.mod h1:ab1qPbhIpdTxEkNHXyeSf5vhxWSCs/tWer42PpOxQnU=
20-
github.com/logzio/logzio-go v1.0.7 h1:aKGuKSkvnkY5okCKsQE50ICOGn4BN1MFG2y1jQG47XY=
21-
github.com/logzio/logzio-go v1.0.7/go.mod h1:ljlI3Zfi3hntJiHqCqWSUPT9cZP6yvDHUzDl5ZLGYRE=
22-
github.com/lufia/plan9stats v0.0.0-20211012122336-39d0f177ccd0/go.mod h1:zJYVVT2jmtg6P3p1VtQj7WsuWi/y4VnjVBn7F8KPB3I=
18+
github.com/logzio/logzio-go v1.0.8 h1:wT9TAdTR/WVb2Gy6VYorPsJ2AhhTxp3FqB7Cic76C7A=
19+
github.com/logzio/logzio-go v1.0.8/go.mod h1:j7HsB56omyQR05Gm/mr8jxaO8MIaOL1Lb/uRTqfe9nc=
2320
github.com/onsi/ginkgo v1.6.0/go.mod h1:lLunBs/Ym6LB5Z9jYTR76FiuTmxDTDusOGeTQH+WWjE=
2421
github.com/onsi/ginkgo v1.7.0 h1:WSHQ+IS43OoUrWtD1/bbclrwK8TTH5hzp+umCiuxHgs=
2522
github.com/onsi/ginkgo v1.7.0/go.mod h1:lLunBs/Ym6LB5Z9jYTR76FiuTmxDTDusOGeTQH+WWjE=
@@ -29,30 +26,22 @@ github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4=
2926
github.com/pkg/errors v0.9.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
3027
github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=
3128
github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=
32-
github.com/power-devops/perfstat v0.0.0-20210106213030-5aafc221ea8c/go.mod h1:OmDBASR4679mdNQnz2pUhc2G8CO2JrUAVFDRBDP/hJE=
3329
github.com/power-devops/perfstat v0.0.0-20240221224432-82ca36839d55 h1:o4JXh1EVt9k/+g42oCprj/FisM4qX9L3sZB3upGN2ZU=
3430
github.com/power-devops/perfstat v0.0.0-20240221224432-82ca36839d55/go.mod h1:OmDBASR4679mdNQnz2pUhc2G8CO2JrUAVFDRBDP/hJE=
35-
github.com/shirou/gopsutil/v3 v3.22.3/go.mod h1:D01hZJ4pVHPpCTZ3m3T2+wDF2YAGfd+H4ifUguaQzHM=
3631
github.com/shirou/gopsutil/v3 v3.24.5 h1:i0t8kL+kQTvpAYToeuiVk3TgDeKOFioZO3Ztz/iZ9pI=
3732
github.com/shirou/gopsutil/v3 v3.24.5/go.mod h1:bsoOS1aStSs9ErQ1WWfxllSeS1K5D+U30r2NfcubMVk=
3833
github.com/sirupsen/logrus v1.9.3 h1:dueUQJ1C2q9oE3F7wvmSGAaVtTmUizReu6fjN8uqzbQ=
3934
github.com/sirupsen/logrus v1.9.3/go.mod h1:naHLuLoDiP4jHNo9R0sCBMtWGeIprob74mVsIT4qYEQ=
4035
github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
41-
github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
4236
github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
43-
github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
4437
github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg=
4538
github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
4639
github.com/syndtr/goleveldb v1.0.0 h1:fBdIW9lB4Iz0n9khmH8w27SJ3QEJ7+IgjPEwGSZiFdE=
4740
github.com/syndtr/goleveldb v1.0.0/go.mod h1:ZVVdQEZoIme9iO1Ch2Jdy24qqXrMMOU6lpPAyBWyWuQ=
48-
github.com/tklauser/go-sysconf v0.3.10/go.mod h1:C8XykCvCb+Gn0oNCWPIlcb0RuglQTYaQ2hGm7jmxEFk=
49-
github.com/tklauser/numcpus v0.4.0/go.mod h1:1+UI3pD8NW14VMwdgJNJ1ESk2UnwhAnz5hMwiKKqXCQ=
5041
github.com/vjeantet/grok v1.0.1 h1:2rhIR7J4gThTgcZ1m2JY4TrJZNgjn985U28kT2wQrJ4=
5142
github.com/vjeantet/grok v1.0.1/go.mod h1:ax1aAchzC6/QMXMcyzHQGZWaW1l195+uMYIkCWPCNIo=
52-
github.com/yusufpapurcu/wmi v1.2.2/go.mod h1:SBZ9tNy3G9/m5Oi98Zks0QjeHVDvuK0qfxQmPyzfmi0=
5343
github.com/yusufpapurcu/wmi v1.2.4 h1:zFUKzehAFReQwLys1b/iSMl+JQGSCSjtVqQn9bBrPo0=
5444
github.com/yusufpapurcu/wmi v1.2.4/go.mod h1:SBZ9tNy3G9/m5Oi98Zks0QjeHVDvuK0qfxQmPyzfmi0=
55-
go.uber.org/atomic v1.9.0/go.mod h1:fEN4uk6kAWBTFdckzkM89CLk9XfWZrxpCo0nPH17wJc=
5645
go.uber.org/atomic v1.11.0 h1:ZvwS0R+56ePWxUNi+Atn9dWONBPp/AUETXlHW0DxSjE=
5746
go.uber.org/atomic v1.11.0/go.mod h1:LUxbIzbOniOlMKjJjyPfpl4v+PKK2cNJn91OQbhoJI0=
5847
golang.org/x/net v0.0.0-20180906233101-161cd47e91fd h1:nTDtHvHSdCn1m6ITfMRqtOd/9+7a3s8RBNOZ3eYZzJA=
@@ -61,16 +50,12 @@ golang.org/x/sync v0.0.0-20180314180146-1d60e4601c6f/go.mod h1:RxMgew5VJxzue5/jJ
6150
golang.org/x/sys v0.0.0-20180909124046-d0be0721c37e/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=
6251
golang.org/x/sys v0.0.0-20190916202348-b4ddaad3f8a3/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
6352
golang.org/x/sys v0.0.0-20201204225414-ed752295db88/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
64-
golang.org/x/sys v0.0.0-20220128215802-99c3d69c2c27/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
6553
golang.org/x/sys v0.0.0-20220715151400-c0bba94af5f8/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
6654
golang.org/x/sys v0.1.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
67-
golang.org/x/sys v0.20.0 h1:Od9JTbYCk261bKm4M/mw7AklTlFYIa0bIp9BgSm1S8Y=
68-
golang.org/x/sys v0.20.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
6955
golang.org/x/sys v0.25.0 h1:r+8e+loiHxRqhXVl6ML1nO3l1+oFoWbnlu2Ehimmi34=
7056
golang.org/x/sys v0.25.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
7157
golang.org/x/text v0.3.0 h1:g61tztE5qeGQ89tm6NTjjM9VPIm088od1l6aSorWRWg=
7258
golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=
73-
golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
7459
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405 h1:yhCVgyC4o1eVCa2tZl7eS0r+SDo693bJlVdllGtEeKM=
7560
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
7661
gopkg.in/fsnotify.v1 v1.4.7 h1:xOHLXZwVvI9hhs+cLKq5+I5onOuwQLhQwiu63xxlHs4=

‎logzio-lambda-extensions-logs/main.go

+3-2
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@ import (
1616
"path"
1717
"strings"
1818
"syscall"
19+
"time"
1920
)
2021

2122
// INITIAL_QUEUE_SIZE is the initial size set for the synchronous logQueue
@@ -122,13 +123,13 @@ func main() {
122123
select {
123124
case <-ctx.Done():
124125
logger.Info(printPrefix, "Received context done event")
125-
logsApiLogger.Drain()
126+
logsApiLogger.AwaitDrain(time.Millisecond * 1800)
126127
logsApiAgent.Shutdown()
127128
logger.Info(printPrefix, "Exiting")
128129
return
129130
case <-eventChannel:
130131
logger.Info(printPrefix, "Received SHUTDOWN event")
131-
logsApiLogger.Drain()
132+
logsApiLogger.AwaitDrain(time.Millisecond * 1800)
132133
logsApiAgent.Shutdown()
133134
logger.Info(printPrefix, "Exiting")
134135
return

0 commit comments

Comments
 (0)