github/kubeshark
1
0
Fork 0
mirror of https://github.com/kubeshark/kubeshark.git synced 2025-06-22 14:32:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

🔨 Fix the /pods/* HTTP endpoint paths of Hub

Browse Source
This commit is contained in:
M. Mert Yildiran 2022-12-14 00:39:54 +03:00
parent 8b9b3c2fc2
commit 442f638f2b
No known key found for this signature in database
GPG Key ID: DA5D6DCBB758A461
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
internal/connect/hub.go
View File

@ -63,12 +63,12 @@ func (connector *Connector) isReachable(path string) (bool, error) {
}
func (connector *Connector) PostWorkerPodToHub(pod *v1.Pod) error {
setWorkerUrl := fmt.Sprintf("%s/pods/set-worker", connector.url)
postWorkerUrl := fmt.Sprintf("%s/pods/worker", connector.url)
if podMarshalled, err := json.Marshal(pod); err != nil {
return fmt.Errorf("Failed to marshal the Worker pod: %w", err)
} else {
if _, err := utils.Post(setWorkerUrl, "application/json", bytes.NewBuffer(podMarshalled), connector.client); err != nil {
if _, err := utils.Post(postWorkerUrl, "application/json", bytes.NewBuffer(podMarshalled), connector.client); err != nil {
return fmt.Errorf("Failed sending the Worker pod to Hub: %w", err)
} else {
log.Debug().Interface("worker-pod", pod).Msg("Reported worker pod to Hub:")
@ -78,12 +78,12 @@ func (connector *Connector) PostWorkerPodToHub(pod *v1.Pod) error {
}
func (connector *Connector) PostTargettedPodsToHub(pods []core.Pod) error {
setTargettedUrl := fmt.Sprintf("%s/pods/set-targetted", connector.url)
postTargettedUrl := fmt.Sprintf("%s/pods/targetted", connector.url)
if podsMarshalled, err := json.Marshal(pods); err != nil {
return fmt.Errorf("Failed to marshal the targetted pods: %w", err)
} else {
if _, err := utils.Post(setTargettedUrl, "application/json", bytes.NewBuffer(podsMarshalled), connector.client); err != nil {
if _, err := utils.Post(postTargettedUrl, "application/json", bytes.NewBuffer(podsMarshalled), connector.client); err != nil {
return fmt.Errorf("Failed sending the targetted pods to Hub: %w", err)
} else {
log.Debug().Int("pod-count", len(pods)).Msg("Reported targetted pods to Hub:")