From 783fe25eace50cbc3f349bd09202a741f274ea89 Mon Sep 17 00:00:00 2001 From: Chris Lu Date: Wed, 28 Jan 2026 12:46:21 -0800 Subject: [PATCH] s3tables test: expose pagination parameters in client list methods --- test/s3tables/client.go | 24 +++++++++++++++--------- 1 file changed, 15 insertions(+), 9 deletions(-) diff --git a/test/s3tables/client.go b/test/s3tables/client.go index 5806ee33c..638682b5d 100644 --- a/test/s3tables/client.go +++ b/test/s3tables/client.go @@ -85,9 +85,11 @@ func (c *S3TablesClient) GetTableBucket(arn string) (*s3tables.GetTableBucketRes return &result, nil } -func (c *S3TablesClient) ListTableBuckets(prefix string) (*s3tables.ListTableBucketsResponse, error) { +func (c *S3TablesClient) ListTableBuckets(prefix, continuationToken string, maxBuckets int) (*s3tables.ListTableBucketsResponse, error) { req := &s3tables.ListTableBucketsRequest{ - Prefix: prefix, + Prefix: prefix, + ContinuationToken: continuationToken, + MaxBuckets: maxBuckets, } var result s3tables.ListTableBucketsResponse if err := c.doRequestAndDecode("ListTableBuckets", req, &result); err != nil { @@ -129,10 +131,12 @@ func (c *S3TablesClient) GetNamespace(bucketARN string, namespace []string) (*s3 return &result, nil } -func (c *S3TablesClient) ListNamespaces(bucketARN, prefix string) (*s3tables.ListNamespacesResponse, error) { +func (c *S3TablesClient) ListNamespaces(bucketARN, prefix, continuationToken string, maxNamespaces int) (*s3tables.ListNamespacesResponse, error) { req := &s3tables.ListNamespacesRequest{ - TableBucketARN: bucketARN, - Prefix: prefix, + TableBucketARN: bucketARN, + Prefix: prefix, + ContinuationToken: continuationToken, + MaxNamespaces: maxNamespaces, } var result s3tables.ListNamespacesResponse if err := c.doRequestAndDecode("ListNamespaces", req, &result); err != nil { @@ -180,11 +184,13 @@ func (c *S3TablesClient) GetTable(bucketARN string, namespace []string, name str return &result, nil } -func (c *S3TablesClient) ListTables(bucketARN string, namespace []string, prefix string) (*s3tables.ListTablesResponse, error) { +func (c *S3TablesClient) ListTables(bucketARN string, namespace []string, prefix, continuationToken string, maxTables int) (*s3tables.ListTablesResponse, error) { req := &s3tables.ListTablesRequest{ - TableBucketARN: bucketARN, - Namespace: namespace, - Prefix: prefix, + TableBucketARN: bucketARN, + Namespace: namespace, + Prefix: prefix, + ContinuationToken: continuationToken, + MaxTables: maxTables, } var result s3tables.ListTablesResponse if err := c.doRequestAndDecode("ListTables", req, &result); err != nil {