github/kubeshark
1
0
Fork 0
mirror of https://github.com/kubeshark/kubeshark.git synced 2025-06-23 23:08:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

fixed general stats (#293)

Browse Source
This commit is contained in:
RoyUP9 2021-09-22 10:52:53 +03:00 committed by GitHub
parent 1841798646
commit 02bd7883cb
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
agent/pkg/api/main.go
View File

@ -7,6 +7,7 @@ import (
"fmt" "fmt"
"mizuserver/pkg/database" "mizuserver/pkg/database"
"mizuserver/pkg/holder" "mizuserver/pkg/holder"
"mizuserver/pkg/providers"
"net/url" "net/url"
"os" "os"
"path" "path"
@ -110,6 +111,8 @@ func startReadingChannel(outputItems <-chan *tapApi.OutputChannelItem, extension
} }
for item := range outputItems { for item := range outputItems {
providers.EntryAdded()
extension := extensionsMap[item.Protocol.Name] extension := extensionsMap[item.Protocol.Name]
resolvedSource, resolvedDestionation := resolveIP(item.ConnectionInfo) resolvedSource, resolvedDestionation := resolveIP(item.ConnectionInfo)
mizuEntry := extension.Dissector.Analyze(item, primitive.NewObjectID().Hex(), resolvedSource, resolvedDestionation) mizuEntry := extension.Dissector.Analyze(item, primitive.NewObjectID().Hex(), resolvedSource, resolvedDestionation)