1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
|
package s3
import (
"context"
"fmt"
)
// ListObjectVersionsAPIClient is a client that implements the ListObjectVersions
// operation
type ListObjectVersionsAPIClient interface {
ListObjectVersions(context.Context, *ListObjectVersionsInput, ...func(*Options)) (*ListObjectVersionsOutput, error)
}
var _ ListObjectVersionsAPIClient = (*Client)(nil)
// ListObjectVersionsPaginatorOptions is the paginator options for ListObjectVersions
type ListObjectVersionsPaginatorOptions struct {
// (Optional) The maximum number of Object Versions that you want Amazon S3 to
// return.
Limit int32
// Set to true if pagination should stop if the service returns a pagination token
// that matches the most recent token provided to the service.
StopOnDuplicateToken bool
}
// ListObjectVersionsPaginator is a paginator for ListObjectVersions
type ListObjectVersionsPaginator struct {
options ListObjectVersionsPaginatorOptions
client ListObjectVersionsAPIClient
params *ListObjectVersionsInput
firstPage bool
keyMarker *string
versionIDMarker *string
isTruncated bool
}
// NewListObjectVersionsPaginator returns a new ListObjectVersionsPaginator
func NewListObjectVersionsPaginator(client ListObjectVersionsAPIClient, params *ListObjectVersionsInput, optFns ...func(*ListObjectVersionsPaginatorOptions)) *ListObjectVersionsPaginator {
if params == nil {
params = &ListObjectVersionsInput{}
}
options := ListObjectVersionsPaginatorOptions{}
options.Limit = params.MaxKeys
for _, fn := range optFns {
fn(&options)
}
return &ListObjectVersionsPaginator{
options: options,
client: client,
params: params,
firstPage: true,
keyMarker: params.KeyMarker,
versionIDMarker: params.VersionIdMarker,
}
}
// HasMorePages returns a boolean indicating whether more pages are available
func (p *ListObjectVersionsPaginator) HasMorePages() bool {
return p.firstPage || p.isTruncated
}
// NextPage retrieves the next ListObjectVersions page.
func (p *ListObjectVersionsPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*ListObjectVersionsOutput, error) {
if !p.HasMorePages() {
return nil, fmt.Errorf("no more pages available")
}
params := *p.params
params.KeyMarker = p.keyMarker
params.VersionIdMarker = p.versionIDMarker
var limit int32
if p.options.Limit > 0 {
limit = p.options.Limit
}
params.MaxKeys = limit
result, err := p.client.ListObjectVersions(ctx, ¶ms, optFns...)
if err != nil {
return nil, err
}
p.firstPage = false
prevToken := p.keyMarker
p.isTruncated = result.IsTruncated
p.keyMarker = nil
p.versionIDMarker = nil
if result.IsTruncated {
p.keyMarker = result.NextKeyMarker
p.versionIDMarker = result.NextVersionIdMarker
}
if p.options.StopOnDuplicateToken &&
prevToken != nil &&
p.keyMarker != nil &&
*prevToken == *p.keyMarker {
p.isTruncated = false
}
return result, nil
}
// ListMultipartUploadsAPIClient is a client that implements the ListMultipartUploads
// operation
type ListMultipartUploadsAPIClient interface {
ListMultipartUploads(context.Context, *ListMultipartUploadsInput, ...func(*Options)) (*ListMultipartUploadsOutput, error)
}
var _ ListMultipartUploadsAPIClient = (*Client)(nil)
// ListMultipartUploadsPaginatorOptions is the paginator options for ListMultipartUploads
type ListMultipartUploadsPaginatorOptions struct {
// (Optional) The maximum number of Multipart Uploads that you want Amazon S3 to
// return.
Limit int32
// Set to true if pagination should stop if the service returns a pagination token
// that matches the most recent token provided to the service.
StopOnDuplicateToken bool
}
// ListMultipartUploadsPaginator is a paginator for ListMultipartUploads
type ListMultipartUploadsPaginator struct {
options ListMultipartUploadsPaginatorOptions
client ListMultipartUploadsAPIClient
params *ListMultipartUploadsInput
firstPage bool
keyMarker *string
uploadIDMarker *string
isTruncated bool
}
// NewListMultipartUploadsPaginator returns a new ListMultipartUploadsPaginator
func NewListMultipartUploadsPaginator(client ListMultipartUploadsAPIClient, params *ListMultipartUploadsInput, optFns ...func(*ListMultipartUploadsPaginatorOptions)) *ListMultipartUploadsPaginator {
if params == nil {
params = &ListMultipartUploadsInput{}
}
options := ListMultipartUploadsPaginatorOptions{}
options.Limit = params.MaxUploads
for _, fn := range optFns {
fn(&options)
}
return &ListMultipartUploadsPaginator{
options: options,
client: client,
params: params,
firstPage: true,
keyMarker: params.KeyMarker,
uploadIDMarker: params.UploadIdMarker,
}
}
// HasMorePages returns a boolean indicating whether more pages are available
func (p *ListMultipartUploadsPaginator) HasMorePages() bool {
return p.firstPage || p.isTruncated
}
// NextPage retrieves the next ListMultipartUploads page.
func (p *ListMultipartUploadsPaginator) NextPage(ctx context.Context, optFns ...func(*Options)) (*ListMultipartUploadsOutput, error) {
if !p.HasMorePages() {
return nil, fmt.Errorf("no more pages available")
}
params := *p.params
params.KeyMarker = p.keyMarker
params.UploadIdMarker = p.uploadIDMarker
var limit int32
if p.options.Limit > 0 {
limit = p.options.Limit
}
params.MaxUploads = limit
result, err := p.client.ListMultipartUploads(ctx, ¶ms, optFns...)
if err != nil {
return nil, err
}
p.firstPage = false
prevToken := p.keyMarker
p.isTruncated = result.IsTruncated
p.keyMarker = nil
p.uploadIDMarker = nil
if result.IsTruncated {
p.keyMarker = result.NextKeyMarker
p.uploadIDMarker = result.NextUploadIdMarker
}
if p.options.StopOnDuplicateToken &&
prevToken != nil &&
p.keyMarker != nil &&
*prevToken == *p.keyMarker {
p.isTruncated = false
}
return result, nil
}
|
