Function TestWriteIndex_Progress

pkg/v1/remote/progress_test.go:167–194

(t *testing.T)

}

func TestWriteIndex_Progress(t *testing.T) {
	idx, err := random.Index(1000, 3, 3)
	if err != nil {
		t.Fatal(err)
	}
	c := make(chan v1.Update, 200)

	// Set up a fake registry.
	s := httptest.NewServer(registry.New())
	defer s.Close()
	u, err := url.Parse(s.URL)
	if err != nil {
		t.Fatal(err)
	}
	dst := fmt.Sprintf("%s/test/progress/upload", u.Host)
	ref, err := name.ParseReference(dst)
	if err != nil {
		t.Fatal(err)
	}

	if err := WriteIndex(ref, idx, WithProgress(c)); err != nil {
		t.Fatalf("WriteIndex: %v", err)
	}

	if err := checkUpdates(c); err != nil {
		t.Fatal(err)
	}
}

func TestMultiWrite_Progress(t *testing.T) {
	idx, err := random.Index(1000, 3, 3)