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

Set the extension name inside the extension

Browse Source
This commit is contained in:
M. Mert Yildiran 2021-08-17 09:10:50 +03:00
parent 5c0a7d907a
commit 5ce85f4162
No known key found for this signature in database
GPG Key ID: D42ADB236521BF7A
4 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -14,7 +14,7 @@ func init() {
type dissecting string
func (g dissecting) Register(extension *api.Extension) {
fmt.Printf("extension: %v\n", extension)
extension.Name = "amqp"
extension.Ports = []string{"5671", "5672"}
}

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

@ -14,7 +14,7 @@ func init() {
type dissecting string
func (g dissecting) Register(extension *api.Extension) {
fmt.Printf("extension: %v\n", extension)
extension.Name = "http"
extension.Ports = []string{"80", "8080", "443"}
}

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

@ -14,7 +14,7 @@ func init() {
type dissecting string
func (g dissecting) Register(extension *api.Extension) {
fmt.Printf("extension: %v\n", extension)
extension.Name = "kafka"
extension.Ports = []string{"9092"}
}

3
tap/passive_tapper.go
View File

@ -254,7 +254,6 @@ func loadExtensions() {
filename := file.Name()
log.Printf("Loading extension: %s\n", filename)
extension := &api.Extension{
Name: strings.TrimSuffix(filename, filepath.Ext(filename)),
Path: path.Join(extensionsDir, filename),
}
plug, _ := plugin.Open(extension.Path)
@ -265,7 +264,7 @@ func loadExtensions() {
dissector, _ = symDissector.(api.Dissector)
dissector.Register(extension)
extension.Dissector = dissector
fmt.Printf("returned extension: %v\n", extension)
log.Printf("Extension Properties: %+v\n", extension)
extensions[i] = extension
}
}