Skip to content

Commit a9236a2

Browse files
gauravaktogauravakto
committed
Add pod informer to resolve pod ips
Initialize pod informer in main and resolve labels remove unused imports rename file Remove close channel
1 parent 67c0d9d commit a9236a2

File tree

7 files changed

+657
-32
lines changed

7 files changed

+657
-32
lines changed

‎ebpf/go.mod

Lines changed: 48 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,13 +1,56 @@
11
module github.com/akto-api-security/mirroring-api-logging/ebpf
22

3-
go 1.21
3+
go 1.24.0
4+
5+
toolchain go1.24.2
46

57
require (
68
github.com/akto-api-security/mirroring-api-logging/trafficUtil v0.0.0-00010101000000-000000000000
9+
github.com/google/uuid v1.6.0
710
github.com/iovisor/gobpf v0.2.1-0.20221005153822-16120a1bf4d4
811
github.com/shirou/gopsutil v3.21.11+incompatible
912
)
1013

14+
require (
15+
github.com/davecgh/go-spew v1.1.1 // indirect
16+
github.com/emicklei/go-restful/v3 v3.11.0 // indirect
17+
github.com/fxamacker/cbor/v2 v2.7.0 // indirect
18+
github.com/go-logr/logr v1.4.2 // indirect
19+
github.com/go-openapi/jsonpointer v0.21.0 // indirect
20+
github.com/go-openapi/jsonreference v0.20.2 // indirect
21+
github.com/go-openapi/swag v0.23.0 // indirect
22+
github.com/gogo/protobuf v1.3.2 // indirect
23+
github.com/google/gnostic-models v0.6.9 // indirect
24+
github.com/google/go-cmp v0.7.0 // indirect
25+
github.com/josharian/intern v1.0.0 // indirect
26+
github.com/json-iterator/go v1.1.12 // indirect
27+
github.com/mailru/easyjson v0.7.7 // indirect
28+
github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
29+
github.com/modern-go/reflect2 v1.0.2 // indirect
30+
github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 // indirect
31+
github.com/pkg/errors v0.9.1 // indirect
32+
github.com/spf13/pflag v1.0.5 // indirect
33+
github.com/x448/float16 v0.8.4 // indirect
34+
golang.org/x/net v0.38.0 // indirect
35+
golang.org/x/oauth2 v0.27.0 // indirect
36+
golang.org/x/term v0.30.0 // indirect
37+
golang.org/x/time v0.9.0 // indirect
38+
google.golang.org/protobuf v1.36.6 // indirect
39+
gopkg.in/evanphx/json-patch.v4 v4.12.0 // indirect
40+
gopkg.in/inf.v0 v0.9.1 // indirect
41+
gopkg.in/yaml.v3 v3.0.1 // indirect
42+
k8s.io/api v0.33.0 // indirect
43+
k8s.io/apimachinery v0.33.0 // indirect
44+
k8s.io/client-go v0.33.0 // indirect
45+
k8s.io/klog/v2 v2.130.1 // indirect
46+
k8s.io/kube-openapi v0.0.0-20250318190949-c8a335a9a2ff // indirect
47+
k8s.io/utils v0.0.0-20241104100929-3ea5e8cea738 // indirect
48+
sigs.k8s.io/json v0.0.0-20241010143419-9aa6b5e7a4b3 // indirect
49+
sigs.k8s.io/randfill v1.0.0 // indirect
50+
sigs.k8s.io/structured-merge-diff/v4 v4.6.0 // indirect
51+
sigs.k8s.io/yaml v1.4.0 // indirect
52+
)
53+
1154
require (
1255
github.com/go-ole/go-ole v1.2.6 // indirect
1356
github.com/golang/snappy v0.0.4 // indirect
@@ -24,10 +67,10 @@ require (
2467
github.com/yusufpapurcu/wmi v1.2.4 // indirect
2568
go.mongodb.org/mongo-driver v1.14.0 // indirect
2669
golang.org/x/arch v0.7.0
27-
golang.org/x/crypto v0.31.0 // indirect
28-
golang.org/x/sync v0.10.0 // indirect
29-
golang.org/x/sys v0.28.0 // indirect
30-
golang.org/x/text v0.21.0 // indirect
70+
golang.org/x/crypto v0.36.0 // indirect
71+
golang.org/x/sync v0.12.0 // indirect
72+
golang.org/x/sys v0.31.0 // indirect
73+
golang.org/x/text v0.23.0 // indirect
3174
)
3275

3376
replace github.com/akto-api-security/mirroring-api-logging/trafficUtil => ../trafficUtil

‎ebpf/go.sum

Lines changed: 134 additions & 14 deletions
Large diffs are not rendered by default.

‎ebpf/main.go

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@ import (
2727
"github.com/akto-api-security/mirroring-api-logging/trafficUtil/kafkaUtil"
2828
"github.com/akto-api-security/mirroring-api-logging/trafficUtil/trafficMetrics"
2929
trafficUtils "github.com/akto-api-security/mirroring-api-logging/trafficUtil/utils"
30+
podutils "github.com/akto-api-security/mirroring-api-logging/trafficUtil"
3031
)
3132

3233
var source string = ""
@@ -210,8 +211,14 @@ func run() {
210211

211212
sig := make(chan os.Signal, 1)
212213
signal.Notify(sig, syscall.SIGHUP, syscall.SIGINT, syscall.SIGQUIT, syscall.SIGTERM)
214+
stopCh, err := podutils.SetupPodInformer()
215+
if err != nil {
216+
slog.Error("Failed to setup pod watcher", "error", err)
217+
}
213218
slog.Info("sniffer is ready")
214219
<-sig
220+
close(stopCh)
221+
215222
slog.Info("signaled to terminate")
216223
}
217224

‎trafficUtil/go.mod

Lines changed: 41 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,26 +1,63 @@
11
module github.com/akto-api-security/mirroring-api-logging/trafficUtil
22

3-
go 1.22
3+
go 1.24.0
44

55
toolchain go1.24.2
66

77
require (
88
github.com/segmentio/kafka-go v0.4.25
99
go.mongodb.org/mongo-driver v1.11.3
1010
google.golang.org/protobuf v1.36.6
11+
k8s.io/api v0.33.0
12+
k8s.io/apimachinery v0.33.0
13+
k8s.io/client-go v0.33.0
1114
)
1215

1316
require (
17+
github.com/davecgh/go-spew v1.1.1 // indirect
18+
github.com/emicklei/go-restful/v3 v3.11.0 // indirect
19+
github.com/fxamacker/cbor/v2 v2.7.0 // indirect
20+
github.com/go-logr/logr v1.4.2 // indirect
21+
github.com/go-openapi/jsonpointer v0.21.0 // indirect
22+
github.com/go-openapi/jsonreference v0.20.2 // indirect
23+
github.com/go-openapi/swag v0.23.0 // indirect
24+
github.com/gogo/protobuf v1.3.2 // indirect
1425
github.com/golang/snappy v0.0.1 // indirect
26+
github.com/google/gnostic-models v0.6.9 // indirect
27+
github.com/google/go-cmp v0.7.0 // indirect
28+
github.com/google/uuid v1.6.0 // indirect
29+
github.com/josharian/intern v1.0.0 // indirect
30+
github.com/json-iterator/go v1.1.12 // indirect
1531
github.com/klauspost/compress v1.13.6 // indirect
32+
github.com/mailru/easyjson v0.7.7 // indirect
33+
github.com/modern-go/concurrent v0.0.0-20180306012644-bacd9c7ef1dd // indirect
34+
github.com/modern-go/reflect2 v1.0.2 // indirect
1635
github.com/montanaflynn/stats v0.0.0-20171201202039-1bf9dbcd8cbe // indirect
36+
github.com/munnerz/goautoneg v0.0.0-20191010083416-a7dc8b61c822 // indirect
1737
github.com/pierrec/lz4 v2.6.0+incompatible // indirect
1838
github.com/pkg/errors v0.9.1 // indirect
39+
github.com/spf13/pflag v1.0.5 // indirect
40+
github.com/x448/float16 v0.8.4 // indirect
1941
github.com/xdg-go/pbkdf2 v1.0.0 // indirect
2042
github.com/xdg-go/scram v1.1.1 // indirect
2143
github.com/xdg-go/stringprep v1.0.3 // indirect
2244
github.com/youmark/pkcs8 v0.0.0-20181117223130-1be2e3e5546d // indirect
23-
golang.org/x/crypto v0.0.0-20220622213112-05595931fe9d // indirect
24-
golang.org/x/sync v0.0.0-20210220032951-036812b2e83c // indirect
25-
golang.org/x/text v0.3.7 // indirect
45+
golang.org/x/crypto v0.36.0 // indirect
46+
golang.org/x/net v0.38.0 // indirect
47+
golang.org/x/oauth2 v0.27.0 // indirect
48+
golang.org/x/sync v0.12.0 // indirect
49+
golang.org/x/sys v0.31.0 // indirect
50+
golang.org/x/term v0.30.0 // indirect
51+
golang.org/x/text v0.23.0 // indirect
52+
golang.org/x/time v0.9.0 // indirect
53+
gopkg.in/evanphx/json-patch.v4 v4.12.0 // indirect
54+
gopkg.in/inf.v0 v0.9.1 // indirect
55+
gopkg.in/yaml.v3 v3.0.1 // indirect
56+
k8s.io/klog/v2 v2.130.1 // indirect
57+
k8s.io/kube-openapi v0.0.0-20250318190949-c8a335a9a2ff // indirect
58+
k8s.io/utils v0.0.0-20241104100929-3ea5e8cea738 // indirect
59+
sigs.k8s.io/json v0.0.0-20241010143419-9aa6b5e7a4b3 // indirect
60+
sigs.k8s.io/randfill v1.0.0 // indirect
61+
sigs.k8s.io/structured-merge-diff/v4 v4.6.0 // indirect
62+
sigs.k8s.io/yaml v1.4.0 // indirect
2663
)

0 commit comments

Comments
 (0)