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

Set isTapTarget to always true again since filterAuthorities implementation has problems

Browse Source
This commit is contained in:
M. Mert Yildiran 2021-08-27 05:06:01 +03:00
parent 510a68933f
commit b2abd7b990
No known key found for this signature in database
GPG Key ID: D42ADB236521BF7A
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tap/tcp_stream_factory.go
View File

@ -102,6 +102,8 @@ func (factory *tcpStreamFactory) WaitGoRoutines() {
func (factory *tcpStreamFactory) getStreamProps(srcIP string, dstIP string, dstPort string) *streamProps { func (factory *tcpStreamFactory) getStreamProps(srcIP string, dstIP string, dstPort string) *streamProps {
if hostMode { if hostMode {
// TODO: Fix `filterAuthorities` logic or value. Default `isTapTarget: true` causes;
// RabbitMQ server->client pushes to not show up for example. Where the client is the tapped pod.
if inArrayString(gSettings.filterAuthorities, fmt.Sprintf("%s:%s", dstIP, dstPort)) { if inArrayString(gSettings.filterAuthorities, fmt.Sprintf("%s:%s", dstIP, dstPort)) {
rlog.Debugf("getStreamProps %s", fmt.Sprintf("+ host1 %s:%s", dstIP, dstPort)) rlog.Debugf("getStreamProps %s", fmt.Sprintf("+ host1 %s:%s", dstIP, dstPort))
return &streamProps{isTapTarget: true, isOutgoing: false} return &streamProps{isTapTarget: true, isOutgoing: false}
@ -112,7 +114,7 @@ func (factory *tcpStreamFactory) getStreamProps(srcIP string, dstIP string, dstP
rlog.Debugf("getStreamProps %s", fmt.Sprintf("+ host3 %s", srcIP)) rlog.Debugf("getStreamProps %s", fmt.Sprintf("+ host3 %s", srcIP))
return &streamProps{isTapTarget: true, isOutgoing: true} return &streamProps{isTapTarget: true, isOutgoing: true}
} }
return &streamProps{isTapTarget: false} return &streamProps{isTapTarget: true, isOutgoing: false}
} else { } else {
isOutgoing := !inArrayString(ownIps, dstIP) isOutgoing := !inArrayString(ownIps, dstIP)