chore: refactoring

Signed-off-by: thediveo <[email protected]>

decorator/dockernet/dockernet.go

@@ -8,7 +8,6 @@ import (
 	"context"
 	"fmt"
 	"strings"
-	"time"
 
 	"github.com/siemens/ghostwire/v2/decorator"
 	"github.com/siemens/ghostwire/v2/network"
@@ -70,7 +69,6 @@ type dockerNetworks struct {
 func makeDockerNetworks(ctx context.Context, engine *model.ContainerEngine, allnetns network.NetworkNamespaces) (
 	docknets dockerNetworks,
 ) {
-	start := time.Now()
 	dockerclient, err := client.NewClientWithOpts(
 		client.WithHost(engine.API),
 		client.WithAPIVersionNegotiation())
@@ -81,8 +79,6 @@ func makeDockerNetworks(ctx context.Context, engine *model.ContainerEngine, alln
 	}
 	networks, _ := dockerclient.NetworkList(ctx, types.NetworkListOptions{})
 	_ = dockerclient.Close()
-	span := time.Since(start)
-	log.Debugf("docker(%d) network ls took %s", engine.PID, span)
 	netnsid, _ := ops.NamespacePath(fmt.Sprintf("/proc/%d/ns/net", engine.PID)).ID()
 	docknets.networks = networks
 	docknets.engine = engine

decorator/podmannet/libpodclient.go

@@ -121,6 +121,13 @@ func ensureReaderClosed(resp *http.Response) {
 	resp.Body.Close()
 }
 
+// ping the /_ping API endpoint (which is unversioned) and return the value of
+// the “Libpod-Api-Version” header that came back from this endpoint, or an
+// empty string. The libpod API version is in semver format, without any “v”
+// prefix.
+//
+// Use the returned API version to set Client.libpodVersion so that following
+// libpod endpoint calls are properly versioned.
 func (c *Client) ping(ctx context.Context) (libpodAPIVersion string) {
 	resp, err := c.get(ctx, "/_ping")
 	defer ensureReaderClosed(resp)

decorator/podmannet/podmannet.go

@@ -7,7 +7,6 @@ package podmannet
 import (
 	"context"
 	"fmt"
-	"time"
 
 	"github.com/siemens/ghostwire/v2/decorator"
 	"github.com/siemens/ghostwire/v2/decorator/dockernet"
@@ -48,7 +47,6 @@ type podmanNetworks struct {
 func makePodmanNetworks(ctx context.Context, engine *model.ContainerEngine, allnetns network.NetworkNamespaces) (
 	podmannets podmanNetworks,
 ) {
-	start := time.Now()
 	libpodclient, err := newLibpodClient(engine.API)
 	if err != nil {
 		log.Warnf("cannot discover podman-managed networks from API %s, reason: %s",
@@ -58,8 +56,6 @@ func makePodmanNetworks(ctx context.Context, engine *model.ContainerEngine, alln
 	libpodclient.libpodVersion = libpodclient.ping(ctx)
 	networks, _ := libpodclient.networkList(ctx)
 	_ = libpodclient.Close()
-	span := time.Since(start)
-	log.Debugf("podman(%d) network ls took %s", engine.PID, span)
 	netnsid, _ := ops.NamespacePath(fmt.Sprintf("/proc/%d/ns/net", engine.PID)).ID()
 	podmannets.networks = networks
 	podmannets.engine = engine