Merge pull request #3 from k8spacket/ebpf-k8spacket-version

Ebpf k8spacket version

Author: k8spacket

go.mod

@@ -1,5 +1,3 @@
-module github.com/k8spacket/plugin-api
+module github.com/k8spacket/plugin-api/v2
 
 go 1.21
-
-retract v1.0.0 // Published accidentally.

plugin_interface.go

@@ -1,35 +1,49 @@
 package plugin_api
 
-import "net/http"
+import (
+	"net/http"
+)
 
-type ReassembledStream struct {
-	StreamId      uint32
-	Src           string
-	SrcPort       string
-	SrcName       string
-	SrcNamespace  string
-	Dst           string
-	DstPort       string
-	DstName       string
-	DstNamespace  string
-	Closed        bool
-	BytesSent     float64
-	BytesReceived float64
-	Duration      float64
+type Address struct {
+	Addr      string
+	Port      uint16
+	Name      string
+	Namespace string
+}
+type TCPEvent struct {
+	Client  Address
+	Server  Address
+	TxB     uint64
+	RxB     uint64
+	DeltaUs uint64
 }
 
-type TCPPacketPayload struct {
-	StreamId uint32
-	Payload  []byte
+type TLSEvent struct {
+	Client         Address
+	Server         Address
+	TlsVersions    []uint16
+	Ciphers        []uint16
+	ServerName     string
+	UsedTlsVersion uint16
+	UsedCipher     uint16
 }
 
-type StreamPlugin interface {
+type ConsumerPlugin interface {
 	InitPlugin(manager PluginManager)
-	DistributeReassembledStream(stream ReassembledStream)
-	DistributeTCPPacketPayload(tcpPacket TCPPacketPayload)
+}
+
+type TCPConsumerPlugin interface {
+	ConsumerPlugin
+	DistributeTCPEvent(tcpEvent TCPEvent)
+}
+
+type TLSConsumerPlugin interface {
+	ConsumerPlugin
+	DistributeTLSEvent(tlsEvent TLSEvent)
 }
 
 type PluginManager interface {
-	RegisterPlugin(plugin StreamPlugin)
+	RegisterTCPPlugin(plugin TCPConsumerPlugin)
+	RegisterTLSPlugin(plugin TLSConsumerPlugin)
 	RegisterHttpHandler(pattern string, handler func(http.ResponseWriter, *http.Request))
 }