github/kubeshark
1
0
Fork 0
mirror of https://github.com/kubeshark/kubeshark.git synced 2025-07-29 15:37:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix an issue in ConnectionStart

Browse Source
This commit is contained in:
M. Mert Yildiran 2021-08-21 17:10:38 +03:00
parent 2a68271238
commit 172683fe21
No known key found for this signature in database
GPG Key ID: D42ADB236521BF7A
2 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tap/extensions/amqp/helpers.go
View File

@ -559,7 +559,7 @@ func emitConnectionStart(event ConnectionStart, connectionInfo *api.ConnectionIn
Type: "connection_start",
Data: &AMQPWrapper{
Method: connectionMethodMap[10],
Url: fmt.Sprintf("%s.%s", string(event.VersionMajor), string(event.VersionMinor)),
Url: fmt.Sprintf("%d.%d", event.VersionMajor, event.VersionMinor),
Details: event,
},
},

7
tap/extensions/amqp/main.go
View File

@ -6,6 +6,7 @@ import (
"fmt"
"io"
"log"
"strconv"
"github.com/up9inc/mizu/tap/api"
)
@ -223,7 +224,11 @@ func (d dissecting) Analyze(item *api.OutputChannelItem, entryId string, resolve
summary = reqDetails["Queue"].(string)
break
case connectionMethodMap[10]:
summary = fmt.Sprintf("%g.%g", reqDetails["VersionMajor"].(float64), reqDetails["VersionMinor"].(float64))
summary = fmt.Sprintf(
"%s.%s",
strconv.Itoa(int(reqDetails["VersionMajor"].(float64))),
strconv.Itoa(int(reqDetails["VersionMinor"].(float64))),
)
break
case connectionMethodMap[50]:
summary = reqDetails["ReplyText"].(string)