feat:Add a new resource to support CacheTask

- Added a new resource: standardcache, which is used to support CacheTask.
- Added RPC calls for DownloadCacheTask.
- Added a function to create CacheTask ID based on URL.

Signed-off-by: fu220 <2863318196@qq.com>

Author: fu220

pkg/idgen/task_id.go

@@ -191,3 +191,19 @@ func TaskIDV2ByContent(content string) string {
 func PersistentCacheTaskIDByContent(content string) string {
 	return pkgdigest.SHA256FromStrings(content)
 }
+
+// CacheTaskIDV2ByURLBased generates v2 version of cache task id by url based.
+func CacheTaskIDV2ByURLBased(url string, pieceLength *uint64, tag, application string, filteredQueryParams []string) string {
+	url, err := neturl.FilterQueryParams(url, filteredQueryParams)
+	if err != nil {
+		url = ""
+	}
+
+	params := []string{url, tag, application}
+	if pieceLength != nil {
+		params = append(params, strconv.FormatUint(*pieceLength, 10))
+	}
+
+	params = append(params, commonv2.TaskType_CACHE.String())
+	return pkgdigest.SHA256FromStrings(params...)
+}

pkg/rpc/dfdaemon/client/client_v2.go

@@ -104,6 +104,9 @@ type V2 interface {
 	// DeletePersistentCacheTask deletes persistent cache task from p2p network.
 	DeletePersistentCacheTask(context.Context, *dfdaemonv2.DeletePersistentCacheTaskRequest, ...grpc.CallOption) error
 
+	// DownloadCacheTask downloads cache task from p2p network.
+	DownloadCacheTask(context.Context, string, *dfdaemonv2.DownloadCacheTaskRequest, ...grpc.CallOption) (dfdaemonv2.DfdaemonUpload_DownloadCacheTaskClient, error)
+
 	// Close tears down the ClientConn and all underlying connections.
 	Close() error
 }
@@ -196,6 +199,15 @@ func (v *v2) DeletePersistentCacheTask(ctx context.Context, req *dfdaemonv2.Dele
 	return err
 }
 
+// DownloadCacheTask downloads cache task from p2p network.
+func (v *v2) DownloadCacheTask(ctx context.Context, taskID string, req *dfdaemonv2.DownloadCacheTaskRequest, opts ...grpc.CallOption) (dfdaemonv2.DfdaemonUpload_DownloadCacheTaskClient, error) {
+	return v.DfdaemonUploadClient.DownloadCacheTask(
+		context.WithValue(ctx, pkgbalancer.ContextKey, taskID),
+		req,
+		opts...,
+	)
+}
+
 // ListTaskEntries lists task entries from p2p network.
 func (v *v2) ListTaskEntries(ctx context.Context, req *dfdaemonv2.ListTaskEntriesRequest, opts ...grpc.CallOption) (*dfdaemonv2.ListTaskEntriesResponse, error) {
 	ctx, cancel := context.WithTimeout(ctx, contextTimeout)