github/kubeshark
1
0
Fork 0
mirror of https://github.com/kubeshark/kubeshark.git synced 2025-07-18 10:21:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

⚡ Use Prefix field of ListObjectsV2Input instead of strings.HasPrefix check

Browse Source
This commit is contained in:
M. Mert Yildiran 2023-06-29 16:06:52 +03:00
parent bf3285cb8b
commit 98738cb5a6
No known key found for this signature in database
GPG Key ID: DA5D6DCBB758A461
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
cmd/tapPcapRunner.go
View File

@ -301,6 +301,7 @@ func downloadTarFromS3(s3Url string) (tarPath string, err error) {
var listObjectsOutput *s3.ListObjectsV2Output var listObjectsOutput *s3.ListObjectsV2Output
listObjectsOutput, err = client.ListObjectsV2(context.TODO(), &s3.ListObjectsV2Input{ listObjectsOutput, err = client.ListObjectsV2(context.TODO(), &s3.ListObjectsV2Input{
Bucket: aws.String(bucket), Bucket: aws.String(bucket),
Prefix: aws.String(key),
}) })
if err != nil { if err != nil {
return return
@ -331,9 +332,6 @@ func downloadTarFromS3(s3Url string) (tarPath string, err error) {
for _, object := range listObjectsOutput.Contents { for _, object := range listObjectsOutput.Contents {
objectKey := *object.Key objectKey := *object.Key
if !strings.HasPrefix(objectKey, key) {
continue
}
fullPath := filepath.Join(tempDirPath, objectKey) fullPath := filepath.Join(tempDirPath, objectKey)
err = os.MkdirAll(filepath.Dir(fullPath), os.ModePerm) err = os.MkdirAll(filepath.Dir(fullPath), os.ModePerm)