diff --git a/sdk/storage/azblob/pageblob/examples_test.go b/sdk/storage/azblob/pageblob/examples_test.go index 3a69cb5ef72d..29bf08797e0d 100644 --- a/sdk/storage/azblob/pageblob/examples_test.go +++ b/sdk/storage/azblob/pageblob/examples_test.go @@ -11,6 +11,7 @@ import ( "context" "fmt" "log" + "math/rand" "os" "github.com/Azure/azure-sdk-for-go/sdk/azcore/streaming" @@ -45,42 +46,17 @@ func Example_pageblob_Client() { _, err = pageBlobClient.Create(context.TODO(), pageblob.PageBytes*4, nil) handleError(err) - page := make([]byte, pageblob.PageBytes) - copy(page, "Page 0") - _, err = pageBlobClient.UploadPages(context.TODO(), streaming.NopCloser(bytes.NewReader(page)), blob.HTTPRange{ - Offset: 0, - Count: 0, - }, nil) - handleError(err) - - copy(page, "Page 1") - _, err = pageBlobClient.UploadPages( - context.TODO(), - streaming.NopCloser(bytes.NewReader(page)), blob.HTTPRange{ - Count: int64(2 * pageblob.PageBytes), - }, nil) - handleError(err) - - pager := pageBlobClient.NewGetPageRangesPager(&pageblob.GetPageRangesOptions{ - Range: blob.HTTPRange{ - Count: int64(10 * pageblob.PageBytes), - }, - }) - - for pager.More() { - resp, err := pager.NextPage(context.TODO()) - if err != nil { - log.Fatal(err) - } - for _, pr := range resp.PageList.PageRange { - fmt.Printf("Start=%d, End=%d\n", pr.Start, pr.End) - } + // Upload 5 pages to the page blob + for i := 0; i < 5; i++ { + count := int64(1024) + page := make([]byte, 2*pageblob.PageBytes) + rand.Read(page) + _, err = pageBlobClient.UploadPages(context.Background(), streaming.NopCloser(bytes.NewReader(page)), + blob.HTTPRange{Offset: int64(i) * count, Count: count}, nil) + handleError(err) } - _, err = pageBlobClient.ClearPages(context.TODO(), blob.HTTPRange{Count: 1 * pageblob.PageBytes}, nil) - handleError(err) - - pager = pageBlobClient.NewGetPageRangesPager(&pageblob.GetPageRangesOptions{ + pager := pageBlobClient.NewGetPageRangesPager(&pageblob.GetPageRangesOptions{ Range: blob.HTTPRange{ Count: int64(10 * pageblob.PageBytes), },