Skip to content

Commit f47df5f

Browse files
authored
feat(115_open): support custom pagesize (#1822)
1 parent ff3c4b8 commit f47df5f

File tree

2 files changed

+8
-1
lines changed

2 files changed

+8
-1
lines changed

drivers/115_open/driver.go

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -53,6 +53,12 @@ func (d *Open115) Init(ctx context.Context) error {
5353
if d.Addition.LimitRate > 0 {
5454
d.limiter = rate.NewLimiter(rate.Limit(d.Addition.LimitRate), 1)
5555
}
56+
if d.PageSize <= 0 {
57+
d.PageSize = 200
58+
} else if d.PageSize > 1150 {
59+
d.PageSize = 1150
60+
}
61+
5662
return nil
5763
}
5864

@@ -69,7 +75,7 @@ func (d *Open115) Drop(ctx context.Context) error {
6975

7076
func (d *Open115) List(ctx context.Context, dir model.Obj, args model.ListArgs) ([]model.Obj, error) {
7177
var res []model.Obj
72-
pageSize := int64(200)
78+
pageSize := int64(d.PageSize)
7379
offset := int64(0)
7480
for {
7581
if err := d.WaitLimit(ctx); err != nil {

drivers/115_open/meta.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@ type Addition struct {
1212
OrderBy string `json:"order_by" type:"select" options:"file_name,file_size,user_utime,file_type"`
1313
OrderDirection string `json:"order_direction" type:"select" options:"asc,desc"`
1414
LimitRate float64 `json:"limit_rate" type:"float" default:"1" help:"limit all api request rate ([limit]r/1s)"`
15+
PageSize int64 `json:"page_size" type:"number" default:"200" help:"list api per page size of 115open driver"`
1516
AccessToken string `json:"access_token" required:"true"`
1617
RefreshToken string `json:"refresh_token" required:"true"`
1718
}

0 commit comments

Comments
 (0)