Method CreateFile

pkg/cluster/node.go:188–214

(ctx context.Context, args *fs.StatelessCreateFileService)

}

func (b *masterNode) CreateFile(ctx context.Context, args *fs.StatelessCreateFileService) error {
	reqBody, err := json.Marshal(args)
	if err != nil {
		return fmt.Errorf("failed to marshal request body: %w", err)
	}

	requestDst := routes.MasterStatelessUrl(MasterSiteUrlFromContext(ctx), "create")
	resp, err := b.client.Request(
		"POST",
		requestDst.String(),
		bytes.NewReader(reqBody),
		request.WithContext(ctx),
		request.WithSlaveMeta(NodeIdFromContext(ctx)),
		request.WithLogger(logging.FromContext(ctx)),
	).CheckHTTPResponse(200).DecodeResponse()
	if err != nil {
		return err
	}

	// 处理列取结果
	if resp.Code != 0 {
		return serializer.NewErrorFromResponse(resp)
	}

	return nil

}

func (b *masterNode) CreateDownloader(ctx context.Context, c request.Client, settings setting.Provider) (downloader.Downloader, error) {
	return NewDownloader(ctx, c, settings, b.Settings(ctx))