Skip to content

Commit 609f18c

Browse files
committed
feat: update api version for client
Signed-off-by: Gaius <gaius.qi@gmail.com>
1 parent 9eb1f08 commit 609f18c

File tree

4 files changed

+9
-8
lines changed

4 files changed

+9
-8
lines changed

go.mod

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ module d7y.io/dragonfly/v2
33
go 1.21
44

55
require (
6-
d7y.io/api/v2 v2.0.142
6+
d7y.io/api/v2 v2.0.147
77
github.com/MysteriousPotato/go-lockable v1.0.0
88
github.com/RichardKnop/machinery v1.10.8
99
github.com/Showmax/go-fqdn v1.0.0
@@ -129,7 +129,7 @@ require (
129129
github.com/distribution/reference v0.5.0 // indirect
130130
github.com/docker/go-metrics v0.0.1 // indirect
131131
github.com/docker/libtrust v0.0.0-20150114040149-fa567046d9b1 // indirect
132-
github.com/envoyproxy/protoc-gen-validate v1.0.4 // indirect
132+
github.com/envoyproxy/protoc-gen-validate v1.1.0 // indirect
133133
github.com/felixge/httpsnoop v1.0.4 // indirect
134134
github.com/fsnotify/fsnotify v1.7.0 // indirect
135135
github.com/gabriel-vasile/mimetype v1.4.4 // indirect

go.sum

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -53,8 +53,8 @@ cloud.google.com/go/storage v1.5.0/go.mod h1:tpKbwo567HUNpVclU5sGELwQWBDZ8gh0Zeo
5353
cloud.google.com/go/storage v1.6.0/go.mod h1:N7U0C8pVQ/+NIKOBQyamJIeKQKkZ+mxpohlUTyfDhBk=
5454
cloud.google.com/go/storage v1.8.0/go.mod h1:Wv1Oy7z6Yz3DshWRJFhqM/UCfaWIRTdp0RXyy7KQOVs=
5555
cloud.google.com/go/storage v1.10.0/go.mod h1:FLPqc6j+Ki4BU591ie1oL6qBQGu2Bl/tZ9ullr3+Kg0=
56-
d7y.io/api/v2 v2.0.142 h1:u1gQZwCKJODdJB883J9e5SRK9VmOTmApX13FX/bR0Vk=
57-
d7y.io/api/v2 v2.0.142/go.mod h1:IakrltEphFvcLIQs3NVeb9PAe66MGDnd2/HMs9DKYu8=
56+
d7y.io/api/v2 v2.0.147 h1:5Cwt5EheJ+VjR4digdoTzRFBlNSOM1/wTg48U9vrimQ=
57+
d7y.io/api/v2 v2.0.147/go.mod h1:hyEaaIglThVWRHODk2yHN/tpa1L+/nPgdQFwPsL6fNc=
5858
dmitri.shuralyov.com/gpu/mtl v0.0.0-20190408044501-666a987793e9/go.mod h1:H6x//7gZCb22OMCxBHrMx7a5I7Hp++hsVxbQ4BYO7hU=
5959
github.com/Azure/azure-sdk-for-go v16.2.1+incompatible/go.mod h1:9XXNKU+eRnpl9moKnB4QOLf1HestfXbmab5FXxiDBjc=
6060
github.com/Azure/azure-sdk-for-go/sdk/azcore v1.0.0/go.mod h1:uGG2W01BaETf0Ozp+QxxKJdMBNRWPdstHG0Fmdwn1/U=
@@ -434,8 +434,8 @@ github.com/envoyproxy/go-control-plane v0.9.7/go.mod h1:cwu0lG7PUMfa9snN8LXBig5y
434434
github.com/envoyproxy/go-control-plane v0.9.9-0.20201210154907-fd9021fe5dad/go.mod h1:cXg6YxExXjJnVBQHBLXeUAgxn2UodCpnH306RInaBQk=
435435
github.com/envoyproxy/go-control-plane v0.9.9-0.20210512163311-63b5d3c536b0/go.mod h1:hliV/p42l8fGbc6Y9bQ70uLwIvmJyVE5k4iMKlh8wCQ=
436436
github.com/envoyproxy/protoc-gen-validate v0.1.0/go.mod h1:iSmxcyjqTsJpI2R4NaDN7+kN2VEUnK/pcBlmesArF7c=
437-
github.com/envoyproxy/protoc-gen-validate v1.0.4 h1:gVPz/FMfvh57HdSJQyvBtF00j8JU4zdyUgIUNhlgg0A=
438-
github.com/envoyproxy/protoc-gen-validate v1.0.4/go.mod h1:qys6tmnRsYrQqIhm2bvKZH4Blx/1gTIZ2UKVY1M+Yew=
437+
github.com/envoyproxy/protoc-gen-validate v1.1.0 h1:tntQDh69XqOCOZsDz0lVJQez/2L6Uu2PdjCQwWCJ3bM=
438+
github.com/envoyproxy/protoc-gen-validate v1.1.0/go.mod h1:sXRDRVmzEbkM7CVcM06s9shE/m23dg3wzjl0UWqJ2q4=
439439
github.com/evanphx/json-patch v4.9.0+incompatible/go.mod h1:50XU6AFN0ol/bzJsmQLiYLvXMP4fmwYFNcr97nuDLSk=
440440
github.com/fatih/color v1.7.0/go.mod h1:Zm6kSWBoL9eyXnKyktHP6abPY2pDugNf5KwzbycvMj4=
441441
github.com/fatih/structs v1.1.0/go.mod h1:9NiDSp5zOcgEDl+j00MP/WkGVPOlPRLejGD8Ga6PJ7M=

scheduler/job/job.go

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -249,6 +249,7 @@ func (j *job) preheatV2(ctx context.Context, req *internaljob.PreheatRequest) er
249249
log.Infof("preheat(v2) %s tag: %s, filtered query params: %s, digest: %s, headers: %#v",
250250
req.URL, req.Tag, req.FilteredQueryParams, req.Digest, req.Headers)
251251

252+
pieceLength := uint64(req.PieceLength)
252253
stream, err := j.resource.SeedPeer().Client().DownloadTask(ctx, taskID, &dfdaemonv2.DownloadTaskRequest{
253254
Download: &commonv2.Download{
254255
Url: req.URL,
@@ -259,7 +260,7 @@ func (j *job) preheatV2(ctx context.Context, req *internaljob.PreheatRequest) er
259260
Priority: commonv2.Priority(req.Priority),
260261
FilteredQueryParams: filteredQueryParams,
261262
RequestHeader: req.Headers,
262-
PieceLength: uint64(req.PieceLength),
263+
PieceLength: &pieceLength,
263264
}})
264265
if err != nil {
265266
logger.Errorf("preheat(v2) %s failed: %s", req.URL, err.Error())

0 commit comments

Comments
 (0)