309
prefix string,
310
keyFilter func(key string) bool,
312
>
ctx, cancel := ensureContextTimeout(ctx)
313
>
defer cancel()
314
>
315
>
var token *string
316
>
317
>
if request.nextPageToken != nil {
318
token = deserializeQueryVisibilityToken(request.nextPageToken)
319
}
321
>
Bucket: aws.String(uri.Hostname()),
322
>
Prefix: aws.String(prefix),
323
>
MaxKeys: aws.Int32(int32(request.pageSize)),
324
>
ContinuationToken: token,
325
>
})
326
>
if err != nil {
327
if isRetryableError(err) {
328
return nil, serviceerror.NewUnavailable(err.Error())