Skip to content

Commit 51a9acd

Browse files
committed
feat(storage): Add region tags in fastbyte samples
1 parent b4bf27b commit 51a9acd

1 file changed

Lines changed: 10 additions & 0 deletions

File tree

google/cloud/storage/examples/storage_async_samples.cc

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -160,6 +160,7 @@ void OpenObjectSingleRangedRead(
160160
google::cloud::storage_experimental::AsyncClient& client,
161161
std::vector<std::string> const& argv) {
162162
//! [open-object-single-ranged-read]
163+
// [START storage_read_appendable_object_single_range]
163164
namespace gcs_ex = google::cloud::storage_experimental;
164165

165166
// Helper coroutine to count newlines returned by an AsyncReader.
@@ -192,6 +193,7 @@ void OpenObjectSingleRangedRead(
192193
co_return co_await count_newlines(std::move(reader), std::move(token));
193194
};
194195
//! [open-object-single-ranged-read]
196+
// [END storage_read_appendable_object_single_range]
195197

196198
// The example is easier to test if we call the coroutine and block
197199
// until it completes.
@@ -203,6 +205,7 @@ void OpenObjectMultipleRangedRead(
203205
google::cloud::storage_experimental::AsyncClient& client,
204206
std::vector<std::string> const& argv) {
205207
//! [open-object-multiple-ranged-read]
208+
// [START storage_read_appendable_object_multiple_ranges]
206209
namespace gcs_ex = google::cloud::storage_experimental;
207210
// Helper coroutine, count lines returned by a AsyncReader
208211
auto count_newlines =
@@ -236,6 +239,7 @@ void OpenObjectMultipleRangedRead(
236239
co_return (co_await std::move(c1)) + (co_await std::move(c2));
237240
};
238241
//! [open-object-multiple-ranged-read]
242+
// [END storage_read_appendable_object_mulitple_ranges]
239243
// The example is easier to test and run if we call the coroutine and block
240244
// until it completes.
241245
auto const count = coro(client, argv.at(0), argv.at(1)).get();
@@ -246,6 +250,7 @@ void OpenObjectReadFullObject(
246250
google::cloud::storage_experimental::AsyncClient& client,
247251
std::vector<std::string> const& argv) {
248252
//! [open-object-read-full-object]
253+
// [START storage_read_appendable_object_full]
249254
namespace gcs_ex = google::cloud::storage_experimental;
250255

251256
// Helper coroutine to count newlines returned by an AsyncReader.
@@ -278,6 +283,7 @@ void OpenObjectReadFullObject(
278283
co_return co_await count_newlines(std::move(reader), std::move(token));
279284
};
280285
//! [open-object-read-full-object]
286+
// [END storage_read_appendable_object_full]
281287

282288
// The example is easier to test if we call the coroutine and block
283289
// until it completes.
@@ -627,6 +633,7 @@ void StartAppendableObjectUpload(
627633
google::cloud::storage_experimental::AsyncClient& client,
628634
std::vector<std::string> const& argv) {
629635
//! [start-appendable-object-upload]
636+
// [START storage_start_appendable_object_upload]
630637
namespace gcs = google::cloud::storage;
631638
namespace gcs_ex = google::cloud::storage_experimental;
632639
auto coro = [](gcs_ex::AsyncClient& client, std::string bucket_name,
@@ -645,6 +652,7 @@ void StartAppendableObjectUpload(
645652
co_return (co_await writer.Finalize(std::move(token))).value();
646653
};
647654
//! [start-appendable-object-upload]
655+
// [END storage_start_appendable_object_upload]
648656
// The example is easier to test and run if we call the coroutine and block
649657
// until it completes..
650658
auto const object = coro(client, argv.at(0), argv.at(1)).get();
@@ -655,6 +663,7 @@ void ResumeAppendableObjectUpload(
655663
google::cloud::storage_experimental::AsyncClient& client,
656664
std::vector<std::string> const& argv) {
657665
//! [resume-appendable-object-upload]
666+
// [START storage_resume_appendable_object_upload]
658667
namespace gcs = google::cloud::storage;
659668
namespace gcs_ex = google::cloud::storage_experimental;
660669
auto coro = [](gcs_ex::AsyncClient& client, std::string bucket_name,
@@ -706,6 +715,7 @@ void ResumeAppendableObjectUpload(
706715
co_return (co_await writer.Finalize(std::move(token))).value();
707716
};
708717
//! [resume-appendable-object-upload]
718+
// [END storage_resume_appendable_object_upload]
709719

710720
// The example is easier to test and run if we call the coroutine and block
711721
// until it completes.

0 commit comments

Comments
 (0)