MCPcopy Create free account
hub / github.com/apache/arrow / ListBucketsAsync

Method ListBucketsAsync

cpp/src/arrow/filesystem/s3fs.cc:3033–3040  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

3031 }
3032
3033 Future<std::vector<std::string>> ListBucketsAsync() {
3034 auto deferred =
3035 [self = shared_from_this()]() mutable -> Result<std::vector<std::string>> {
3036 ARROW_ASSIGN_OR_RAISE(auto client_lock, self->holder_->Lock());
3037 return self->ProcessListBuckets(client_lock.Move()->ListBuckets());
3038 };
3039 return DeferNotOk(SubmitIO(io_context_, std::move(deferred)));
3040 }
3041
3042 Result<std::shared_ptr<ObjectInputFile>> OpenInputFile(const std::string& s,
3043 S3FileSystem* fs) {

Callers

nothing calls this directly

Calls 5

ProcessListBucketsMethod · 0.95
DeferNotOkFunction · 0.85
SubmitIOFunction · 0.85
ListBucketsMethod · 0.80
MoveMethod · 0.45

Tested by

no test coverage detected