Function Inspect

pkg/containerinspector/containerinspector.go:30–73

(ctx context.Context, container containerd.Container)

)

func Inspect(ctx context.Context, container containerd.Container) (*native.Container, error) {
	info, err := container.Info(ctx)
	if err != nil {
		return nil, err
	}
	n := &native.Container{
		Container: info,
	}
	id := container.ID()

	n.Spec, err = typeurl.UnmarshalAny(info.Spec)
	if err != nil {
		log.G(ctx).WithError(err).WithField("id", id).Warnf("failed to inspect Spec")
		return n, nil
	}
	task, err := container.Task(ctx, nil)
	if err != nil {
		if !errdefs.IsNotFound(err) {
			log.G(ctx).WithError(err).WithField("id", id).Warnf("failed to inspect Task")
		}
		return n, nil
	}
	n.Process = &native.Process{
		Pid: int(task.Pid()),
	}
	st, err := task.Status(ctx)
	if err != nil {
		log.G(ctx).WithError(err).WithField("id", id).Warnf("failed to inspect Status")
		return n, nil
	}
	if st.Status == containerd.Stopped {
		n.Process.Pid = 0
	}
	n.Process.Status = st
	if st.Status == containerd.Running || st.Status == containerd.Paused {
		netNS, err := InspectNetNS(ctx, n.Process.Pid)
		if err != nil {
			log.G(ctx).WithError(err).WithField("id", id).Warnf("failed to inspect NetNS")
			return n, nil
		}
		n.Process.NetNS = netNS
	}
	return n, nil
}