Method CreateContainer

agent/pkg/docker/docker.go:244–286

CreateContainer creates a container according to the given spec, returning a docker container ID to start it. It takes a caller-provided channel on which docker events are sent. Slow receivers will block the call.

(
	ctx context.Context,
	id cproto.ID,
	req cproto.RunSpec,
	p events.Publisher[Event],
)

// to start it. It takes a caller-provided channel on which docker events are sent. Slow receivers
// will block the call.
func (d *Client) CreateContainer(
	ctx context.Context,
	id cproto.ID,
	req cproto.RunSpec,
	p events.Publisher[Event],
) (string, error) {
	response, err := d.cl.ContainerCreate(
		ctx, &req.ContainerConfig, &req.HostConfig, &req.NetworkingConfig, nil, "")
	if err != nil {
		return "", fmt.Errorf("creating container: %w", err)
	}
	dockerID := response.ID
	for _, w := range response.Warnings {
		if err = p.Publish(ctx, NewLogEvent(model.LogLevelWarning, fmt.Sprintf(
			"warning when creating container: %s", w,
		))); err != nil {
			return "", err
		}
	}

	for _, copyArx := range req.Archives {
		if err = p.Publish(ctx, NewLogEvent(model.LogLevelInfo, fmt.Sprintf(
			"copying files to container: %s", copyArx.Path,
		))); err != nil {
			return "", err
		}

		files, cErr := archive.ToIOReader(copyArx.Archive)
		if cErr != nil {
			return "", fmt.Errorf("converting RunSpec Archive files to io.Reader: %w", cErr)
		}
		if err = d.cl.CopyToContainer(
			ctx,
			dockerID,
			copyArx.Path,
			files,
			copyArx.CopyOptions,
		); err != nil {
			return "", fmt.Errorf("copying files to container: %w", err)
		}
	}
	return dockerID, nil
}

// RunContainer runs a container by docker container ID. It takes a caller-provided channel on which
// docker events are sent. Slow receivers will block the call. RunContainer takes two contexts: one