gsh-digital-services/seaweedFS
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

s3tables test: expose pagination parameters in client list methods

Browse Source
This commit is contained in:
Chris Lu
2026-01-28 12:46:21 -08:00
parent 5c43f1e6a4
commit 783fe25eac
1 changed files with 15 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
test/s3tables/client.go
View File

@@ -85,9 +85,11 @@ func (c *S3TablesClient) GetTableBucket(arn string) (*s3tables.GetTableBucketRes
return &result, nil 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{ req := &s3tables.ListTableBucketsRequest{
Prefix: prefix, Prefix: prefix,
ContinuationToken: continuationToken,
MaxBuckets: maxBuckets,
} }
var result s3tables.ListTableBucketsResponse var result s3tables.ListTableBucketsResponse
if err := c.doRequestAndDecode("ListTableBuckets", req, &result); err != nil { 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 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{ req := &s3tables.ListNamespacesRequest{
TableBucketARN: bucketARN, TableBucketARN: bucketARN,
Prefix: prefix, Prefix: prefix,
ContinuationToken: continuationToken,
MaxNamespaces: maxNamespaces,
} }
var result s3tables.ListNamespacesResponse var result s3tables.ListNamespacesResponse
if err := c.doRequestAndDecode("ListNamespaces", req, &result); err != nil { 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 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{ req := &s3tables.ListTablesRequest{
TableBucketARN: bucketARN, TableBucketARN: bucketARN,
Namespace: namespace, Namespace: namespace,
Prefix: prefix, Prefix: prefix,
ContinuationToken: continuationToken,
MaxTables: maxTables,
} }
var result s3tables.ListTablesResponse var result s3tables.ListTablesResponse
if err := c.doRequestAndDecode("ListTables", req, &result); err != nil { if err := c.doRequestAndDecode("ListTables", req, &result); err != nil {