mirror of
https://github.com/kubeshark/kubeshark.git
synced 2025-06-22 06:18:51 +00:00
parent
a69eb38663
commit
2433d867af
@ -307,7 +307,7 @@ func startTlsTapper(extension *api.Extension, outputItems chan *api.OutputChanne
|
|||||||
OutputChannel: outputItems,
|
OutputChannel: outputItems,
|
||||||
}
|
}
|
||||||
|
|
||||||
// go tls.PollForLogging()
|
go tls.PollForLogging()
|
||||||
go tls.Poll(emitter, options, streamsMap)
|
go tls.Poll(emitter, options, streamsMap)
|
||||||
|
|
||||||
return &tls
|
return &tls
|
||||||
|
@ -61,7 +61,7 @@ func (t *TlsTapper) Init(chunksBufferSize int, logBufferSize int, procfs string,
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (t *TlsTapper) Poll(emitter api.Emitter, options *api.TrafficFilteringOptions, streamsMap api.TcpStreamMap) {
|
func (t *TlsTapper) Poll(emitter api.Emitter, options *api.TrafficFilteringOptions, streamsMap api.TcpStreamMap) {
|
||||||
// t.poller.pollSsllib(emitter, options, streamsMap)
|
t.poller.pollSsllib(emitter, options, streamsMap)
|
||||||
t.poller.pollGolang(emitter, options, streamsMap)
|
t.poller.pollGolang(emitter, options, streamsMap)
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -172,7 +172,6 @@ func setupRLimit() error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (t *TlsTapper) tapSsllibPid(pid uint32, sslLibrary string, namespace string) error {
|
func (t *TlsTapper) tapSsllibPid(pid uint32, sslLibrary string, namespace string) error {
|
||||||
return nil
|
|
||||||
logger.Log.Infof("Tapping TLS (pid: %v) (sslLibrary: %v)", pid, sslLibrary)
|
logger.Log.Infof("Tapping TLS (pid: %v) (sslLibrary: %v)", pid, sslLibrary)
|
||||||
|
|
||||||
newSsl := sslHooks{}
|
newSsl := sslHooks{}
|
||||||
|
Loading…
Reference in New Issue
Block a user