ebpf/containers/crio.go

package containers

import (
	"context"
	"encoding/json"
	"errors"
	"fmt"
	"net"
	"net/http"
	"os"
	"time"

	"github.com/coroot/coroot-node-agent/common"
	"github.com/coroot/coroot-node-agent/proc"
	"github.com/coroot/logparser"
	klog "github.com/sirupsen/logrus"
)

const crioTimeout = 30 * time.Second

var (
	crioClient *http.Client
	crioSocket = proc.HostPath("/var/run/crio/crio.sock")
)

type CrioContainerInfo struct {
	Name            string            `json:"name"`
	Image           string            `json:"image"`
	Labels          map[string]string `json:"labels"`
	LogPath         string            `json:"log_path"`
	CrioAnnotations map[string]string `json:"crio_annotations"`
}

type CrioVolume struct {
	ContainerPath string `json:"container_path"`
	HostPath      string `json:"host_path"`
}

func CrioInit() error {
	if _, err := os.Stat(crioSocket); err != nil {
		return err
	}
	klog.Infoln("cri-o socket:", crioSocket)

	crioClient = &http.Client{
		Transport: &http.Transport{
			DialContext: func(ctx context.Context, network, addr string) (net.Conn, error) {
				return net.DialTimeout("unix", crioSocket, crioTimeout)
			},
			DisableCompression: true,
		},
	}
	return nil
}

func CrioInspect(containerID string) (*ContainerMetadata, error) {
	if crioClient == nil {
		return nil, fmt.Errorf("cri-o client is not initialized")
	}
	resp, err := crioClient.Get("http://localhost/containers/" + containerID)
	if err != nil {
		return nil, err
	}
	defer resp.Body.Close()

	if resp.StatusCode != http.StatusOK {
		return nil, errors.New(resp.Status)
	}

	i := &CrioContainerInfo{}
	if err = json.NewDecoder(resp.Body).Decode(i); err != nil {
		return nil, err
	}

	res := &ContainerMetadata{
		name:       i.Name,
		labels:     i.Labels,
		volumes:    map[string]string{},
		logPath:    i.LogPath,
		image:      i.Image,
		logDecoder: logparser.CriDecoder{},
	}

	var volumes []CrioVolume

	if err := json.Unmarshal([]byte(i.CrioAnnotations["io.kubernetes.cri-o.Volumes"]), &volumes); err != nil {
		klog.Warningln(err)
	} else {
		for _, v := range volumes {
			res.volumes[v.ContainerPath] = common.ParseKubernetesVolumeSource(v.HostPath)
		}
	}
	return res, nil
}