2 Star 0 Fork 0

TeamsHub/backend-gopkg

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
文件
domain
infrastructure
config
connector
pkg
aes
aria2
auth
authn
balancer
browser
cache
cluster
code
color
conf
crontab
database
ddm
email
env
errno
errors
file
filesystem
callBack
chunk
driver
cos
ecm
local
onedrive
oss
qiniu
remote
s3
shadow
masterinslave
errors.go
handler.go
slaveinmaster
upyun
handler.go
fsctx
response
tests
archive.go
archive_test.go
errors.go
file.go
file_test.go
filesystem.go
filesystem_test.go
hooks.go
hooks_test.go
image.go
image_test.go
manage.go
manage_test.go
path.go
path_test.go
upload.go
upload_test.go
validator.go
validator_test.go
gin
grpclient
hash
hashid
hcode
httpclient
ifc
img
jwt
koala
live
log
mail
md5
mocks
models
mongo
mq
notify
ocr
opensearch_industry
oss
pdf2imag
recaptcha
request
rsa
serializer
shutdown
signature
slsLog
sms
task
thumb
time_parse
token
tool
toolfunc
trace
urltable
util
validator
webdav
wxwork
xml
filesystem.zip
third/gismag
.gitignore
LICENSE
Makefile
README.en.md
README.md
go.mod
go.sum
plugin.go
zoneinfo.zip
克隆/下载
handler.go 1.92 KB
一键复制 编辑 原始数据 按行查看 历史
HCY 提交于 9个月前 . edit pkg
package masterinslave
import (
"context"
"gitee.com/wuzheng0709/backend-gopkg/infrastructure/pkg/cluster"
"gitee.com/wuzheng0709/backend-gopkg/infrastructure/pkg/filesystem/driver"
"gitee.com/wuzheng0709/backend-gopkg/infrastructure/pkg/filesystem/fsctx"
"gitee.com/wuzheng0709/backend-gopkg/infrastructure/pkg/filesystem/response"
model "gitee.com/wuzheng0709/backend-gopkg/infrastructure/pkg/models"
"gitee.com/wuzheng0709/backend-gopkg/infrastructure/pkg/serializer"
"net/url"
)
// Driver 影子存储策略,用于在从机端上传文件
type Driver struct {
master cluster.Node
handler driver.Handler
policy *model.Policy
}
// NewDriver 返回新的处理器
func NewDriver(master cluster.Node, handler driver.Handler, policy *model.Policy) driver.Handler {
return &Driver{
master: master,
handler: handler,
policy: policy,
}
}
func (d *Driver) Put(ctx context.Context, file fsctx.FileHeader) error {
return d.handler.Put(ctx, file)
}
func (d *Driver) Delete(ctx context.Context, files []string) ([]string, error) {
return d.handler.Delete(ctx, files)
}
func (d *Driver) Get(ctx context.Context, path string) (response.RSCloser, error) {
return nil, ErrNotImplemented
}
func (d *Driver) Thumb(ctx context.Context, path string) (*response.ContentResponse, error) {
return nil, ErrNotImplemented
}
func (d *Driver) Source(ctx context.Context, path string, url url.URL, ttl int64, isDownload bool, speed int) (string, error) {
return "", ErrNotImplemented
}
func (d *Driver) Token(ctx context.Context, ttl int64, uploadSession *serializer.UploadSession, file fsctx.FileHeader) (*serializer.UploadCredential, error) {
return nil, ErrNotImplemented
}
func (d *Driver) List(ctx context.Context, path string, recursive bool) ([]response.Object, error) {
return nil, ErrNotImplemented
}
// 取消上传凭证
func (handler Driver) CancelToken(ctx context.Context, uploadSession *serializer.UploadSession) error {
return nil
}
Loading...
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
1
https://gitee.com/wuzheng0709/backend-gopkg.git
git@gitee.com:wuzheng0709/backend-gopkg.git
wuzheng0709
backend-gopkg
backend-gopkg
v1.6.17

搜索帮助