Function startLocalRegistry

integration/docker_test.go:1074–1115

(t *testing.T, ctx context.Context)

}

func startLocalRegistry(t *testing.T, ctx context.Context) string {
	t.Helper()
	c, err := client.NewClientWithOpts(client.FromEnv, client.WithAPIVersionNegotiation())
	require.NoError(t, err)
	defer c.Close()

	reader, err := c.ImagePull(ctx, "registry:2", image.PullOptions{})
	require.NoError(t, err)
	io.Copy(io.Discard, reader)
	reader.Close()

	port := getFreePort(t)
	portStr := strconv.Itoa(port)

	resp, err := c.ContainerCreate(ctx,
		&container.Config{Image: "registry:2"},
		&container.HostConfig{
			PortBindings: nat.PortMap{
				"5000/tcp": []nat.PortBinding{{HostPort: portStr}},
			},
		},
		nil, nil, fmt.Sprintf("test-registry-%s", portStr),
	)
	require.NoError(t, err)
	t.Cleanup(func() {
		c.ContainerRemove(context.Background(), resp.ID, container.RemoveOptions{Force: true})
	})

	require.NoError(t, c.ContainerStart(ctx, resp.ID, container.StartOptions{}))

	registryURL := fmt.Sprintf("localhost:%d", port)
	require.Eventually(t, func() bool {
		resp, err := http.Get("http://" + registryURL + "/v2/")
		if err != nil {
			return false
		}
		resp.Body.Close()
		return resp.StatusCode == http.StatusOK
	}, 10*time.Second, 200*time.Millisecond, "registry did not become ready")

	return registryURL
}

func buildHookImage(t *testing.T, ctx context.Context, registryURL, name, hookScript string) string {
	t.Helper()