Function Inspect

pkg/cmd/network/inspect.go:37–111

(ctx context.Context, client *containerd.Client, options types.NetworkInspectOptions)

)

func Inspect(ctx context.Context, client *containerd.Client, options types.NetworkInspectOptions) error {
	if options.Mode != "native" && options.Mode != "dockercompat" {
		return fmt.Errorf("unknown mode %q", options.Mode)
	}

	cniEnv, err := netutil.NewCNIEnv(options.GOptions.CNIPath, options.GOptions.CNINetConfPath, netutil.WithNamespace(options.GOptions.Namespace))
	if err != nil {
		return err
	}

	var result []interface{}
	netLists, errs := cniEnv.ListNetworksMatch(options.Networks, true)

	for req, netList := range netLists {
		if len(netList) > 1 {
			errs = append(errs, fmt.Errorf("multiple IDs found with provided prefix: %s", req))
			continue
		}
		if len(netList) == 0 {
			errs = append(errs, fmt.Errorf("no network found matching: %s", req))
			continue
		}

		network := netList[0]

		var filters = []string{fmt.Sprintf(`labels.%q~="\\\"%s\\\""`, labels.Networks, network.Name)}
		filteredContainers, err := client.Containers(ctx, filters...)
		if err != nil {
			return err
		}

		var containers []*native.Container
		for _, container := range filteredContainers {
			nativeContainer, err := containerinspector.Inspect(ctx, container)
			if err != nil {
				continue
			}
			if nativeContainer.Process == nil || nativeContainer.Process.Status.Status != containerd.Running {
				continue
			}

			containers = append(containers, nativeContainer)
		}

		r := &native.Network{
			CNI:           json.RawMessage(network.Bytes),
			NerdctlID:     network.NerdctlID,
			NerdctlLabels: network.NerdctlLabels,
			File:          network.File,
			Containers:    containers,
		}
		switch options.Mode {
		case "native":
			result = append(result, r)
		case "dockercompat":
			compat, err := dockercompat.NetworkFromNative(r)
			if err != nil {
				return err