Skip to content

Commit

Permalink
maint: Clean up probes manager (#83)
Browse files Browse the repository at this point in the history
## Which problem is this PR solving?
Removes some unused things in probe/manager.go

## Short description of the changes
- Removes unused funcs and a const
  • Loading branch information
MikeGoldsmith committed Aug 18, 2023
1 parent ff8e804 commit d7ab7d0
Showing 1 changed file with 0 additions and 47 deletions.
47 changes: 0 additions & 47 deletions bpf/probes/manager.go
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,6 @@ package probes

import (
"bytes"
"context"
"encoding/binary"
"errors"
"net"
Expand All @@ -14,16 +13,11 @@ import (
"github.com/honeycombio/libhoney-go"
"github.com/rs/zerolog/log"
semconv "go.opentelemetry.io/otel/semconv/v1.20.0"
v1 "k8s.io/api/core/v1"
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
"k8s.io/apimachinery/pkg/labels"
"k8s.io/client-go/kubernetes"
)

//go:generate go run github.com/cilium/ebpf/cmd/bpf2go -target amd64,arm64 -cc clang -cflags $CFLAGS bpf source/tcp_probe.c

const mapKey uint32 = 0

type manager struct {
bpfObjects bpfObjects
probes []link.Link
Expand Down Expand Up @@ -100,47 +94,6 @@ func (m *manager) Stop() {
m.reader.Close()
}

func getPodByIPAddr(client *kubernetes.Clientset, ipAddr string) v1.Pod {
pods, _ := client.CoreV1().Pods(v1.NamespaceAll).List(context.TODO(), metav1.ListOptions{})

var matchedPod v1.Pod

for _, pod := range pods.Items {
if ipAddr == pod.Status.PodIP {
matchedPod = pod
}
}

return matchedPod
}

func getServiceForPod(client *kubernetes.Clientset, inputPod v1.Pod) v1.Service {
// get list of services
services, _ := client.CoreV1().Services(v1.NamespaceAll).List(context.TODO(), metav1.ListOptions{})
var matchedService v1.Service
// loop over services
for _, service := range services.Items {
set := labels.Set(service.Spec.Selector)
listOptions := metav1.ListOptions{LabelSelector: set.AsSelector().String()}
pods, err := client.CoreV1().Pods(v1.NamespaceAll).List(context.TODO(), listOptions)
if err != nil {
log.Error().Err(err).Msg("Error getting pods")
}
for _, pod := range pods.Items {
if pod.Name == inputPod.Name {
matchedService = service
}
}
}

return matchedService
}

func getNodeByPod(client *kubernetes.Clientset, pod v1.Pod) *v1.Node {
node, _ := client.CoreV1().Nodes().Get(context.TODO(), pod.Spec.NodeName, metav1.GetOptions{})
return node
}

// Send event to Honeycomb
func sendEvent(event bpfTcpEvent, client *kubernetes.Clientset) {

Expand Down

0 comments on commit d7ab7d0

Please sign in to comment.