Function ExampleBucket_List

blob/example_test.go:192–257

()

}

func ExampleBucket_List() {
	// Connect to a bucket when your program starts up.
	// This example uses the file-based implementation.
	dir, cleanup := newTempDir()
	defer cleanup()

	// Create the file-based bucket.
	bucket, err := fileblob.OpenBucket(dir, nil)
	if err != nil {
		log.Fatal(err)
	}
	defer bucket.Close()

	// Create some blob objects for listing: "foo[0..4].txt".
	ctx := context.Background()
	for i := range 5 {
		if err := bucket.WriteAll(ctx, fmt.Sprintf("foo%d.txt", i), []byte("Go Cloud Development Kit"), nil); err != nil {
			log.Fatal(err)
		}
	}

	// Iterate over them.
	// This will list the blobs created above because fileblob is strongly
	// consistent, but is not guaranteed to work on all services.
	li := bucket.List(nil)
	for {
		obj, err := li.Next(ctx)
		if err == io.EOF {
			break
		}
		if err != nil {
			log.Fatal(err)
		}
		fmt.Println(obj.Key)
	}

	// Alternatively, use All to iterate (and optionally download):
	fmt.Println()
	fmt.Println("Now, using an iterator:")
	li = bucket.List(nil)
	iter, errFn := li.All(ctx)
	for obj, download := range iter {
		var buf bytes.Buffer
		if err := download(&buf, nil /* default ReaderOptions */); err != nil {
			log.Fatalf("download of %q failed: %v", obj.Key, err)
		}
		fmt.Printf("%s: %s\n", obj.Key, string(buf.Bytes()))
	}
	if err := errFn(); err != nil {
		log.Fatalf("iteration failed: %v", err)
	}

	// Output:
	// foo0.txt
	// foo1.txt
	// foo2.txt
	// foo3.txt
	// foo4.txt