mirror of
https://github.com/kubeshark/kubeshark.git
synced 2025-09-17 15:21:54 +00:00
adding service map edges from mizu entries
This commit is contained in:
@@ -105,6 +105,7 @@ func startReadingChannel(outputItems <-chan *tapApi.OutputChannelItem, extension
|
|||||||
}
|
}
|
||||||
connection.InsertMode()
|
connection.InsertMode()
|
||||||
|
|
||||||
|
serviceMap := GetServiceMapInstance()
|
||||||
disableOASValidation := false
|
disableOASValidation := false
|
||||||
ctx := context.Background()
|
ctx := context.Background()
|
||||||
doc, contractContent, router, err := loadOAS(ctx)
|
doc, contractContent, router, err := loadOAS(ctx)
|
||||||
@@ -146,6 +147,9 @@ func startReadingChannel(outputItems <-chan *tapApi.OutputChannelItem, extension
|
|||||||
panic(err)
|
panic(err)
|
||||||
}
|
}
|
||||||
connection.SendText(string(data))
|
connection.SendText(string(data))
|
||||||
|
|
||||||
|
serviceMap.AddEdge(id(mizuEntry.Source.Name), id(mizuEntry.Destination.Name), extension.Protocol.Name)
|
||||||
|
serviceMap.PrintAdjacentEdges()
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
Reference in New Issue
Block a user