Skip to content

Commit

Permalink
Move the private code package of Dragonfly to internal package (drago…
Browse files Browse the repository at this point in the history 
…nflyoss#346)

Signed-off-by: santong <[email protected]>
  • Loading branch information
@244372610
244372610 authored Jun 21, 2021
1 parent 2101a4b commit 650cc9c
Show file tree
Hide file tree
Showing 156 changed files with 381 additions and 375 deletions.
2 changes: 1 addition & 1 deletion cdnsystem/daemon/cdn/cache_data_mgr.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ import (
"d7y.io/dragonfly/v2/cdnsystem/daemon/cdn/storage"
"d7y.io/dragonfly/v2/cdnsystem/storedriver"
"d7y.io/dragonfly/v2/cdnsystem/types"
logger "d7y.io/dragonfly/v2/pkg/dflog"
logger "d7y.io/dragonfly/v2/internal/dflog"
"d7y.io/dragonfly/v2/pkg/synclock"
"d7y.io/dragonfly/v2/pkg/util/digestutils"
"d7y.io/dragonfly/v2/pkg/util/stringutils"
Expand Down
2 changes: 1 addition & 1 deletion cdnsystem/daemon/cdn/cache_detector.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ import (
"d7y.io/dragonfly/v2/cdnsystem/daemon/cdn/storage"
cdnerrors "d7y.io/dragonfly/v2/cdnsystem/errors"
"d7y.io/dragonfly/v2/cdnsystem/types"
logger "d7y.io/dragonfly/v2/pkg/dflog"
logger "d7y.io/dragonfly/v2/internal/dflog"
"d7y.io/dragonfly/v2/pkg/source"
"d7y.io/dragonfly/v2/pkg/util/digestutils"
"d7y.io/dragonfly/v2/pkg/util/stringutils"
Expand Down
2 changes: 1 addition & 1 deletion cdnsystem/daemon/cdn/cache_writer.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@ import (
"d7y.io/dragonfly/v2/cdnsystem/config"
"d7y.io/dragonfly/v2/cdnsystem/daemon/cdn/storage"
"d7y.io/dragonfly/v2/cdnsystem/types"
logger "d7y.io/dragonfly/v2/pkg/dflog"
logger "d7y.io/dragonfly/v2/internal/dflog"
"d7y.io/dragonfly/v2/pkg/util/digestutils"
"d7y.io/dragonfly/v2/pkg/util/rangeutils"
)
Expand Down
2 changes: 1 addition & 1 deletion cdnsystem/daemon/cdn/downloader.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ import (
"io"

"d7y.io/dragonfly/v2/cdnsystem/types"
logger "d7y.io/dragonfly/v2/pkg/dflog"
logger "d7y.io/dragonfly/v2/internal/dflog"
"d7y.io/dragonfly/v2/pkg/source"
"d7y.io/dragonfly/v2/pkg/structure/maputils"
"d7y.io/dragonfly/v2/pkg/util/rangeutils"
Expand Down
4 changes: 2 additions & 2 deletions cdnsystem/daemon/cdn/manager.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -26,14 +26,14 @@ import (
"d7y.io/dragonfly/v2/cdnsystem/daemon"
_ "d7y.io/dragonfly/v2/cdnsystem/daemon/cdn/storage/disk" // To register diskStorage
_ "d7y.io/dragonfly/v2/cdnsystem/daemon/cdn/storage/hybrid" // To register hybridStorage
"d7y.io/dragonfly/v2/pkg/rpc/cdnsystem/server"
"d7y.io/dragonfly/v2/internal/rpc/cdnsystem/server"
"d7y.io/dragonfly/v2/pkg/synclock"
"d7y.io/dragonfly/v2/pkg/util/timeutils"

"d7y.io/dragonfly/v2/cdnsystem/config"
"d7y.io/dragonfly/v2/cdnsystem/daemon/cdn/storage"
"d7y.io/dragonfly/v2/cdnsystem/types"
logger "d7y.io/dragonfly/v2/pkg/dflog"
logger "d7y.io/dragonfly/v2/internal/dflog"
"d7y.io/dragonfly/v2/pkg/ratelimiter/limitreader"
"d7y.io/dragonfly/v2/pkg/ratelimiter/ratelimiter"
"d7y.io/dragonfly/v2/pkg/util/stringutils"
Expand Down
4 changes: 2 additions & 2 deletions cdnsystem/daemon/cdn/manager_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -30,8 +30,8 @@ import (
"d7y.io/dragonfly/v2/cdnsystem/daemon/mock"
"d7y.io/dragonfly/v2/cdnsystem/plugins"
"d7y.io/dragonfly/v2/cdnsystem/types"
"d7y.io/dragonfly/v2/pkg/idgen"
"d7y.io/dragonfly/v2/pkg/rpc/base"
"d7y.io/dragonfly/v2/internal/idgen"
"d7y.io/dragonfly/v2/internal/rpc/base"
"d7y.io/dragonfly/v2/pkg/source"
sourceMock "d7y.io/dragonfly/v2/pkg/source/mock"
"d7y.io/dragonfly/v2/pkg/util/net/urlutils"
Expand Down
2 changes: 1 addition & 1 deletion cdnsystem/daemon/cdn/reporter.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ import (
"d7y.io/dragonfly/v2/cdnsystem/daemon"
"d7y.io/dragonfly/v2/cdnsystem/daemon/cdn/storage"
"d7y.io/dragonfly/v2/cdnsystem/types"
logger "d7y.io/dragonfly/v2/pkg/dflog"
logger "d7y.io/dragonfly/v2/internal/dflog"
"github.com/pkg/errors"
"go.uber.org/zap"
)
Expand Down
2 changes: 1 addition & 1 deletion cdnsystem/daemon/cdn/storage/disk/disk.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ import (
"d7y.io/dragonfly/v2/cdnsystem/storedriver"
"d7y.io/dragonfly/v2/cdnsystem/storedriver/local"
"d7y.io/dragonfly/v2/cdnsystem/types"
logger "d7y.io/dragonfly/v2/pkg/dflog"
logger "d7y.io/dragonfly/v2/internal/dflog"
"d7y.io/dragonfly/v2/pkg/synclock"
"d7y.io/dragonfly/v2/pkg/unit"
"d7y.io/dragonfly/v2/pkg/util/fileutils"
Expand Down
2 changes: 1 addition & 1 deletion cdnsystem/daemon/cdn/storage/hybrid/hybrid.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,7 @@ import (
"d7y.io/dragonfly/v2/cdnsystem/storedriver"
"d7y.io/dragonfly/v2/cdnsystem/storedriver/local"
"d7y.io/dragonfly/v2/cdnsystem/types"
logger "d7y.io/dragonfly/v2/pkg/dflog"
logger "d7y.io/dragonfly/v2/internal/dflog"
"d7y.io/dragonfly/v2/pkg/synclock"
"d7y.io/dragonfly/v2/pkg/unit"
"d7y.io/dragonfly/v2/pkg/util/fileutils"
Expand Down
2 changes: 1 addition & 1 deletion cdnsystem/daemon/cdn/storage/hybrid/shm_switch.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ package hybrid
import (
"regexp"

logger "d7y.io/dragonfly/v2/pkg/dflog"
logger "d7y.io/dragonfly/v2/internal/dflog"
"go.uber.org/atomic"
)

Expand Down
2 changes: 1 addition & 1 deletion cdnsystem/daemon/cdn/storage/storage_gc.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ import (
"d7y.io/dragonfly/v2/cdnsystem/daemon"
cdnerrors "d7y.io/dragonfly/v2/cdnsystem/errors"
"d7y.io/dragonfly/v2/cdnsystem/storedriver"
logger "d7y.io/dragonfly/v2/pkg/dflog"
logger "d7y.io/dragonfly/v2/internal/dflog"
"d7y.io/dragonfly/v2/pkg/util/timeutils"
"github.com/emirpasic/gods/maps/treemap"
godsutils "github.com/emirpasic/gods/utils"
Expand Down
2 changes: 1 addition & 1 deletion cdnsystem/daemon/gc/manager.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ import (
"sync"
"time"

logger "d7y.io/dragonfly/v2/pkg/dflog"
logger "d7y.io/dragonfly/v2/internal/dflog"
)

type Executor interface {
Expand Down
4 changes: 2 additions & 2 deletions cdnsystem/daemon/progress/manager.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -27,8 +27,8 @@ import (

"d7y.io/dragonfly/v2/cdnsystem/daemon"
"d7y.io/dragonfly/v2/cdnsystem/types"
"d7y.io/dragonfly/v2/pkg/dferrors"
logger "d7y.io/dragonfly/v2/pkg/dflog"
"d7y.io/dragonfly/v2/internal/dferrors"
logger "d7y.io/dragonfly/v2/internal/dflog"
"d7y.io/dragonfly/v2/pkg/structure/syncmap"
"d7y.io/dragonfly/v2/pkg/synclock"
"github.com/pkg/errors"
Expand Down
4 changes: 2 additions & 2 deletions cdnsystem/daemon/task/manager.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -26,8 +26,8 @@ import (
"d7y.io/dragonfly/v2/cdnsystem/daemon/gc"
cdnerrors "d7y.io/dragonfly/v2/cdnsystem/errors"
"d7y.io/dragonfly/v2/cdnsystem/types"
"d7y.io/dragonfly/v2/pkg/dferrors"
logger "d7y.io/dragonfly/v2/pkg/dflog"
"d7y.io/dragonfly/v2/internal/dferrors"
logger "d7y.io/dragonfly/v2/internal/dflog"
"d7y.io/dragonfly/v2/pkg/structure/syncmap"
"d7y.io/dragonfly/v2/pkg/synclock"
"d7y.io/dragonfly/v2/pkg/util/stringutils"
Expand Down
4 changes: 2 additions & 2 deletions cdnsystem/daemon/task/manager_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -23,8 +23,8 @@ import (
"d7y.io/dragonfly/v2/cdnsystem/config"
"d7y.io/dragonfly/v2/cdnsystem/daemon/mock"
"d7y.io/dragonfly/v2/cdnsystem/types"
"d7y.io/dragonfly/v2/pkg/idgen"
"d7y.io/dragonfly/v2/pkg/rpc/base"
"d7y.io/dragonfly/v2/internal/idgen"
"d7y.io/dragonfly/v2/internal/rpc/base"
"github.com/golang/mock/gomock"
"github.com/stretchr/testify/suite"
)
Expand Down
2 changes: 1 addition & 1 deletion cdnsystem/daemon/task/manager_util.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ import (
"d7y.io/dragonfly/v2/cdnsystem/config"
cdnerrors "d7y.io/dragonfly/v2/cdnsystem/errors"
"d7y.io/dragonfly/v2/cdnsystem/types"
logger "d7y.io/dragonfly/v2/pkg/dflog"
logger "d7y.io/dragonfly/v2/internal/dflog"
"d7y.io/dragonfly/v2/pkg/source"
"d7y.io/dragonfly/v2/pkg/synclock"
"d7y.io/dragonfly/v2/pkg/util/net/urlutils"
Expand Down
2 changes: 1 addition & 1 deletion cdnsystem/plugins/plugins.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ package plugins
import (
"fmt"

logger "d7y.io/dragonfly/v2/pkg/dflog"
logger "d7y.io/dragonfly/v2/internal/dflog"
)

var mgr = NewManager()
Expand Down
8 changes: 4 additions & 4 deletions cdnsystem/server/server.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -30,11 +30,11 @@ import (
"d7y.io/dragonfly/v2/cdnsystem/daemon/task"
"d7y.io/dragonfly/v2/cdnsystem/plugins"
"d7y.io/dragonfly/v2/cdnsystem/server/service"
"d7y.io/dragonfly/v2/internal/rpc"
"d7y.io/dragonfly/v2/internal/rpc/cdnsystem/server"
"d7y.io/dragonfly/v2/internal/rpc/manager"
configServer "d7y.io/dragonfly/v2/internal/rpc/manager/client"
"d7y.io/dragonfly/v2/pkg/basic/dfnet"
"d7y.io/dragonfly/v2/pkg/rpc"
"d7y.io/dragonfly/v2/pkg/rpc/cdnsystem/server"
"d7y.io/dragonfly/v2/pkg/rpc/manager"
configServer "d7y.io/dragonfly/v2/pkg/rpc/manager/client"
"d7y.io/dragonfly/v2/pkg/util/net/iputils"
"d7y.io/dragonfly/v2/pkg/util/stringutils"
"github.com/pkg/errors"
Expand Down
10 changes: 5 additions & 5 deletions cdnsystem/server/service/cdn_seed_server.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -26,11 +26,11 @@ import (
"d7y.io/dragonfly/v2/cdnsystem/daemon"
cdnerrors "d7y.io/dragonfly/v2/cdnsystem/errors"
"d7y.io/dragonfly/v2/cdnsystem/types"
"d7y.io/dragonfly/v2/pkg/dfcodes"
"d7y.io/dragonfly/v2/pkg/dferrors"
logger "d7y.io/dragonfly/v2/pkg/dflog"
"d7y.io/dragonfly/v2/pkg/rpc/base"
"d7y.io/dragonfly/v2/pkg/rpc/cdnsystem"
"d7y.io/dragonfly/v2/internal/dfcodes"
"d7y.io/dragonfly/v2/internal/dferrors"
logger "d7y.io/dragonfly/v2/internal/dflog"
"d7y.io/dragonfly/v2/internal/rpc/base"
"d7y.io/dragonfly/v2/internal/rpc/cdnsystem"
"d7y.io/dragonfly/v2/pkg/util/net/iputils"
"d7y.io/dragonfly/v2/pkg/util/net/urlutils"
"d7y.io/dragonfly/v2/pkg/util/stringutils"
Expand Down
4 changes: 2 additions & 2 deletions cdnsystem/server/service/cdn_seed_server_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -24,8 +24,8 @@ import (
"d7y.io/dragonfly/v2/cdnsystem/config"
"d7y.io/dragonfly/v2/cdnsystem/daemon"
"d7y.io/dragonfly/v2/cdnsystem/types"
"d7y.io/dragonfly/v2/pkg/rpc/base"
"d7y.io/dragonfly/v2/pkg/rpc/cdnsystem"
"d7y.io/dragonfly/v2/internal/rpc/base"
"d7y.io/dragonfly/v2/internal/rpc/cdnsystem"
)

func TestCdnSeedServer_GetPieceTasks(t *testing.T) {
Expand Down
2 changes: 1 addition & 1 deletion cdnsystem/storedriver/local/local_driver.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ import (

cdnerrors "d7y.io/dragonfly/v2/cdnsystem/errors"
"d7y.io/dragonfly/v2/cdnsystem/storedriver"
logger "d7y.io/dragonfly/v2/pkg/dflog"
logger "d7y.io/dragonfly/v2/internal/dflog"
"d7y.io/dragonfly/v2/pkg/synclock"
"d7y.io/dragonfly/v2/pkg/unit"
"d7y.io/dragonfly/v2/pkg/util/fileutils"
Expand Down
2 changes: 1 addition & 1 deletion client/clientutil/keepalive.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ package clientutil
import (
"time"

logger "d7y.io/dragonfly/v2/pkg/dflog"
logger "d7y.io/dragonfly/v2/internal/dflog"
)

type KeepAlive interface {
Expand Down
2 changes: 1 addition & 1 deletion client/clientutil/peer.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ import (

"github.com/pborman/uuid"

"d7y.io/dragonfly/v2/pkg/rpc/scheduler"
"d7y.io/dragonfly/v2/internal/rpc/scheduler"
)

func GenPeerID(peerHost *scheduler.PeerHost) string {
Expand Down
4 changes: 2 additions & 2 deletions client/config/dfget.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -28,13 +28,13 @@ import (
"time"

"d7y.io/dragonfly/v2/cmd/dependency/base"
logger "d7y.io/dragonfly/v2/pkg/dflog"
logger "d7y.io/dragonfly/v2/internal/dflog"
"d7y.io/dragonfly/v2/pkg/unit"
"github.com/pkg/errors"
"golang.org/x/time/rate"

"d7y.io/dragonfly/v2/internal/dferrors"
"d7y.io/dragonfly/v2/pkg/basic"
"d7y.io/dragonfly/v2/pkg/dferrors"
"d7y.io/dragonfly/v2/pkg/util/net/urlutils"
"d7y.io/dragonfly/v2/pkg/util/stringutils"
)
Expand Down
2 changes: 1 addition & 1 deletion client/daemon/gc/gc_manager.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ package gc
import (
"time"

logger "d7y.io/dragonfly/v2/pkg/dflog"
logger "d7y.io/dragonfly/v2/internal/dflog"
)

type GC interface {
Expand Down
14 changes: 7 additions & 7 deletions client/daemon/peer/peertask_base.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -34,13 +34,13 @@ import (

"d7y.io/dragonfly/v2/client/clientutil"
"d7y.io/dragonfly/v2/client/config"
"d7y.io/dragonfly/v2/pkg/dfcodes"
"d7y.io/dragonfly/v2/pkg/dferrors"
logger "d7y.io/dragonfly/v2/pkg/dflog"
"d7y.io/dragonfly/v2/pkg/rpc/base"
dfclient "d7y.io/dragonfly/v2/pkg/rpc/dfdaemon/client"
"d7y.io/dragonfly/v2/pkg/rpc/scheduler"
schedulerclient "d7y.io/dragonfly/v2/pkg/rpc/scheduler/client"
"d7y.io/dragonfly/v2/internal/dfcodes"
"d7y.io/dragonfly/v2/internal/dferrors"
logger "d7y.io/dragonfly/v2/internal/dflog"
"d7y.io/dragonfly/v2/internal/rpc/base"
dfclient "d7y.io/dragonfly/v2/internal/rpc/dfdaemon/client"
"d7y.io/dragonfly/v2/internal/rpc/scheduler"
schedulerclient "d7y.io/dragonfly/v2/internal/rpc/scheduler/client"
)

const (
Expand Down
12 changes: 6 additions & 6 deletions client/daemon/peer/peertask_file.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -20,19 +20,19 @@ import (
"context"
"sync"

"d7y.io/dragonfly/v2/pkg/dferrors"
"d7y.io/dragonfly/v2/internal/dferrors"
"github.com/pkg/errors"
"go.opentelemetry.io/otel/semconv"
"go.opentelemetry.io/otel/trace"
"go.uber.org/atomic"
"golang.org/x/time/rate"

"d7y.io/dragonfly/v2/client/config"
"d7y.io/dragonfly/v2/pkg/dfcodes"
logger "d7y.io/dragonfly/v2/pkg/dflog"
"d7y.io/dragonfly/v2/pkg/rpc/base"
"d7y.io/dragonfly/v2/pkg/rpc/scheduler"
schedulerclient "d7y.io/dragonfly/v2/pkg/rpc/scheduler/client"
"d7y.io/dragonfly/v2/internal/dfcodes"
logger "d7y.io/dragonfly/v2/internal/dflog"
"d7y.io/dragonfly/v2/internal/rpc/base"
"d7y.io/dragonfly/v2/internal/rpc/scheduler"
schedulerclient "d7y.io/dragonfly/v2/internal/rpc/scheduler/client"
)

type FilePeerTaskRequest struct {
Expand Down
6 changes: 3 additions & 3 deletions client/daemon/peer/peertask_file_callback.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -21,9 +21,9 @@ import (
"time"

"d7y.io/dragonfly/v2/client/daemon/storage"
"d7y.io/dragonfly/v2/pkg/dfcodes"
"d7y.io/dragonfly/v2/pkg/rpc/base"
"d7y.io/dragonfly/v2/pkg/rpc/scheduler"
"d7y.io/dragonfly/v2/internal/dfcodes"
"d7y.io/dragonfly/v2/internal/rpc/base"
"d7y.io/dragonfly/v2/internal/rpc/scheduler"
)

type filePeerTaskCallback struct {
Expand Down
2 changes: 1 addition & 1 deletion client/daemon/peer/peertask_file_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ import (
"d7y.io/dragonfly/v2/client/clientutil"
"d7y.io/dragonfly/v2/client/config"
"d7y.io/dragonfly/v2/client/daemon/test"
"d7y.io/dragonfly/v2/pkg/rpc/scheduler"
"d7y.io/dragonfly/v2/internal/rpc/scheduler"
"d7y.io/dragonfly/v2/pkg/source"
sourceMock "d7y.io/dragonfly/v2/pkg/source/mock"
"github.com/golang/mock/gomock"
Expand Down
8 changes: 4 additions & 4 deletions client/daemon/peer/peertask_manager.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -33,10 +33,10 @@ import (

"d7y.io/dragonfly/v2/client/config"
"d7y.io/dragonfly/v2/client/daemon/storage"
logger "d7y.io/dragonfly/v2/pkg/dflog"
"d7y.io/dragonfly/v2/pkg/rpc/base"
"d7y.io/dragonfly/v2/pkg/rpc/scheduler"
schedulerclient "d7y.io/dragonfly/v2/pkg/rpc/scheduler/client"
logger "d7y.io/dragonfly/v2/internal/dflog"
"d7y.io/dragonfly/v2/internal/rpc/base"
"d7y.io/dragonfly/v2/internal/rpc/scheduler"
schedulerclient "d7y.io/dragonfly/v2/internal/rpc/scheduler/client"
)

// TaskManager processes all peer tasks request
Expand Down
6 changes: 3 additions & 3 deletions client/daemon/peer/peertask_manager_mock_test.go
View file

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

12 changes: 6 additions & 6 deletions client/daemon/peer/peertask_manager_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -39,13 +39,13 @@ import (
"d7y.io/dragonfly/v2/client/daemon/test"
mock_daemon "d7y.io/dragonfly/v2/client/daemon/test/mock/daemon"
mock_scheduler "d7y.io/dragonfly/v2/client/daemon/test/mock/scheduler"
"d7y.io/dragonfly/v2/internal/dfcodes"
"d7y.io/dragonfly/v2/internal/rpc"
"d7y.io/dragonfly/v2/internal/rpc/base"
daemonserver "d7y.io/dragonfly/v2/internal/rpc/dfdaemon/server"
"d7y.io/dragonfly/v2/internal/rpc/scheduler"
schedulerclient "d7y.io/dragonfly/v2/internal/rpc/scheduler/client"
"d7y.io/dragonfly/v2/pkg/basic/dfnet"
"d7y.io/dragonfly/v2/pkg/dfcodes"
"d7y.io/dragonfly/v2/pkg/rpc"
"d7y.io/dragonfly/v2/pkg/rpc/base"
daemonserver "d7y.io/dragonfly/v2/pkg/rpc/dfdaemon/server"
"d7y.io/dragonfly/v2/pkg/rpc/scheduler"
schedulerclient "d7y.io/dragonfly/v2/pkg/rpc/scheduler/client"
)

var _ daemonserver.DaemonServer = mock_daemon.NewMockDaemonServer(nil)
Expand Down
8 changes: 4 additions & 4 deletions client/daemon/peer/peertask_reuse.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -24,10 +24,10 @@ import (

"d7y.io/dragonfly/v2/client/config"
"d7y.io/dragonfly/v2/client/daemon/storage"
"d7y.io/dragonfly/v2/pkg/dfcodes"
logger "d7y.io/dragonfly/v2/pkg/dflog"
"d7y.io/dragonfly/v2/pkg/idgen"
"d7y.io/dragonfly/v2/pkg/rpc/scheduler"
"d7y.io/dragonfly/v2/internal/dfcodes"
logger "d7y.io/dragonfly/v2/internal/dflog"
"d7y.io/dragonfly/v2/internal/idgen"
"d7y.io/dragonfly/v2/internal/rpc/scheduler"
"github.com/go-http-utils/headers"
"go.opentelemetry.io/otel/semconv"
"go.opentelemetry.io/otel/trace"
Expand Down
Loading

0 comments on commit 650cc9c

Please sign in to comment.