github/kubeshark
1
0
Fork 0
mirror of https://github.com/kubeshark/kubeshark.git synced 2025-07-06 12:59:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

Don't omit the Latency field in BaseEntryDetails (#302)

Browse Source
This commit is contained in:
M. Mert Yıldıran 2021-09-23 14:58:20 +03:00 committed by GitHub
parent f164e54fee
commit 8ba96acf05
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
5 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -115,7 +115,6 @@ func startReadingChannel(outputItems <-chan *tapApi.OutputChannelItem, extension
if err == nil { if err == nil {
rules, _ := models.RunValidationRulesState(*harEntry, mizuEntry.Service) rules, _ := models.RunValidationRulesState(*harEntry, mizuEntry.Service)
baseEntry.Rules = rules baseEntry.Rules = rules
baseEntry.Latency = mizuEntry.ElapsedTime
} }
} }

3
tap/api/api.go
View File

@ -156,7 +156,7 @@ type BaseEntryDetails struct {
SourcePort string `json:"sourcePort,omitempty"` SourcePort string `json:"sourcePort,omitempty"`
DestinationPort string `json:"destinationPort,omitempty"` DestinationPort string `json:"destinationPort,omitempty"`
IsOutgoing bool `json:"isOutgoing,omitempty"` IsOutgoing bool `json:"isOutgoing,omitempty"`
Latency int64 `json:"latency,omitempty"` Latency int64 `json:"latency"`
Rules ApplicableRules `json:"rules,omitempty"` Rules ApplicableRules `json:"rules,omitempty"`
} }
@ -190,6 +190,7 @@ func (bed *BaseEntryDetails) UnmarshalData(entry *MizuEntry) error {
bed.Timestamp = entry.Timestamp bed.Timestamp = entry.Timestamp
bed.RequestSenderIp = entry.RequestSenderIp bed.RequestSenderIp = entry.RequestSenderIp
bed.IsOutgoing = entry.IsOutgoing bed.IsOutgoing = entry.IsOutgoing
bed.Latency = entry.ElapsedTime
return nil return nil
} }

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

@ -312,7 +312,7 @@ func (d dissecting) Summarize(entry *api.MizuEntry) *api.BaseEntryDetails {
SourcePort: entry.SourcePort, SourcePort: entry.SourcePort,
DestinationPort: entry.DestinationPort, DestinationPort: entry.DestinationPort,
IsOutgoing: entry.IsOutgoing, IsOutgoing: entry.IsOutgoing,
Latency: 0, Latency: entry.ElapsedTime,
Rules: api.ApplicableRules{ Rules: api.ApplicableRules{
Latency: 0, Latency: 0,
Status: false, Status: false,

2
tap/extensions/http/main.go
View File

@ -223,7 +223,7 @@ func (d dissecting) Summarize(entry *api.MizuEntry) *api.BaseEntryDetails {
SourcePort: entry.SourcePort, SourcePort: entry.SourcePort,
DestinationPort: entry.DestinationPort, DestinationPort: entry.DestinationPort,
IsOutgoing: entry.IsOutgoing, IsOutgoing: entry.IsOutgoing,
Latency: 0, Latency: entry.ElapsedTime,
Rules: api.ApplicableRules{ Rules: api.ApplicableRules{
Latency: 0, Latency: 0,
Status: false, Status: false,

2
tap/extensions/kafka/main.go
View File

@ -186,7 +186,7 @@ func (d dissecting) Summarize(entry *api.MizuEntry) *api.BaseEntryDetails {
SourcePort: entry.SourcePort, SourcePort: entry.SourcePort,
DestinationPort: entry.DestinationPort, DestinationPort: entry.DestinationPort,
IsOutgoing: entry.IsOutgoing, IsOutgoing: entry.IsOutgoing,
Latency: 0, Latency: entry.ElapsedTime,
Rules: api.ApplicableRules{ Rules: api.ApplicableRules{
Latency: 0, Latency: 0,
Status: false, Status: false,