driver

package
v1.0.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 28, 2023 License: MIT Imports: 27 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetDriverProps added in v1.0.0

func GetDriverProps() map[string]DriveConfigProp

func RegsiterDriver

func RegsiterDriver(name string, showName string, driver Driver, driveConfig DriveConfig)

Types

type ConflictBehaviorType

type ConflictBehaviorType string
const (
	Rename  ConflictBehaviorType = "rename"
	Fail    ConflictBehaviorType = "fail"
	Replace ConflictBehaviorType = "replace"
)

type DownloadUrl

type DownloadUrl struct {
	Title       string `json:"title"`
	DownloadUrl string `json:"downloadUrl"`
}

type DriveConfig added in v1.0.0

type DriveConfig interface {
}

type DriveConfigProp added in v1.0.0

type DriveConfigProp struct {
	Name       string     `json:"name"`
	ShowName   string     `json:"showname"`
	Properties []Property `json:"properties"`
}

type Driver

type Driver interface {
	Check() error

	InitDriver(e *echo.Group, db *gorm.DB) error

	PreUploadUrl(key string) (string, error)

	WalkDir(key string) (*File, error)

	PreDeleteUrl(key string) (string, error)

	DownloadUrl(key string) ([]*DownloadUrl, error)
	// contains filtered or unexported methods
}

func GetDriver

func GetDriver(name string, config map[string]interface{}) (Driver, error)

type File

type File struct {
	Name         string
	IsDir        bool
	Childrens    []*File
	Size         int64
	AbsolutePath string
}

type FileDriver

type FileDriver struct {
	// contains filtered or unexported fields
}

func (*FileDriver) Check added in v1.0.0

func (d *FileDriver) Check() error

func (*FileDriver) DownloadUrl

func (d *FileDriver) DownloadUrl(path string) ([]*DownloadUrl, error)

func (*FileDriver) InitDriver

func (d *FileDriver) InitDriver(e *echo.Group, db *gorm.DB) error

func (*FileDriver) PreDeleteUrl

func (d *FileDriver) PreDeleteUrl(path string) (string, error)

func (*FileDriver) PreUploadUrl

func (d *FileDriver) PreUploadUrl(path string) (string, error)

func (*FileDriver) WalkDir

func (d *FileDriver) WalkDir(key string) (*File, error)

type FileDriverConfig

type FileDriverConfig struct {
	Path string `arg:"path;路径;文件存储路径;required" json:"path"`
	Key  string `arg:"key;签名key;部分接口所需要使用的签名key,随意填写;required" json:"key"`
	Host string `arg:"host;服务地址;NextList服务地址,需要外网能够访问;required" json:"host"`
}

type Json

type Json map[string]interface{}

type ODFile

type ODFile struct {
	Name  string
	Size  int
	IsDir bool
}

type ODListFileResp

type ODListFileResp struct {
	Value []*Json `json:""`
}

type ODWalkFunc

type ODWalkFunc func(path string, file *ODFile) error

type OneDriver

type OneDriver struct {
	AccessToken string
	// contains filtered or unexported fields
}

func (*OneDriver) Check added in v1.0.0

func (d *OneDriver) Check() error

func (*OneDriver) Delete

func (d *OneDriver) Delete(path string) error

func (*OneDriver) DownloadUrl

func (d *OneDriver) DownloadUrl(path string) ([]*DownloadUrl, error)

func (*OneDriver) InitDriver

func (d *OneDriver) InitDriver(e *echo.Group, db *gorm.DB) error
func (d *OneDriver) Link(path string) (string, error)

func (*OneDriver) PreDeleteUrl

func (d *OneDriver) PreDeleteUrl(path string) (string, error)

func (*OneDriver) PreUploadUrl

func (d *OneDriver) PreUploadUrl(path string) (string, error)

func (*OneDriver) Upload

func (d *OneDriver) Upload(file UploaderFileStream) error

func (*OneDriver) Walk

func (d *OneDriver) Walk(path string, fn ODWalkFunc) error

func (*OneDriver) WalkDir

func (d *OneDriver) WalkDir(key string) (*File, error)

type OneDriverConfig

type OneDriverConfig struct {
	RefreshToken string `arg:"refreshToken;刷新Token;OneDriver所使用的刷新Token;required" json:"refreshToken"`
	ClientID     string `arg:"clientID;应用ID;注册的应用的ID;required" json:"clientID"`
	ClientSecret string `arg:"clientSecret;应用密钥;应用密钥;required" json:"clientSecret"`
	RedirectUrl  string `arg:"refirectUrl;跳转地址;暂时固定为https://tool.nn.ci/onedrive/callback;required" json:"refirectUrl"`
	Path         string `arg:"path;目录;要作为列表的onedriver的目录;required" json:"path"`
	Key          string `arg:"key;签名key;部分接口所需要使用的签名key,随意填写;required" json:"key"`
	Host         string `arg:"host;服务地址;NextList服务地址,需要外网能够访问;required" json:"host"`
}

type OnedriveErrorResp

type OnedriveErrorResp struct {
	Error Json `json:"error"`
}

type OnedriverTokenResp

type OnedriverTokenResp struct {
	TokenType    string `json:"token_type"`
	ExpiresIn    int    `json:"expires_in"`
	Scope        string `json:"scope"`
	AccessToken  string `json:"access_token"`
	RefreshToken string `json:"refresh_token"`
}

type PropType added in v1.0.0

type PropType string
const (
	Int     PropType = "int"
	String  PropType = "string"
	Boolean PropType = "boolean"
)

type Property added in v1.0.0

type Property struct {
	Name     string   `json:"name"`
	Label    string   `json:"label"`
	PropType PropType `json:"type"`
	Required bool     `json:"required"`
	Usage    string   `json:"usage"`
}

func GetNameAndUsages added in v1.0.0

func GetNameAndUsages(otype reflect.Type, i int) Property

type S3Driver

type S3Driver struct {
	Bucket string
	// contains filtered or unexported fields
}

func (*S3Driver) Check added in v1.0.0

func (d *S3Driver) Check() error

func (*S3Driver) DownloadUrl

func (d *S3Driver) DownloadUrl(path string) ([]*DownloadUrl, error)

func (*S3Driver) InitDriver

func (d *S3Driver) InitDriver(e *echo.Group, db *gorm.DB) error

func (*S3Driver) PreDeleteUrl

func (d *S3Driver) PreDeleteUrl(key string) (string, error)

func (*S3Driver) PreUploadUrl

func (d *S3Driver) PreUploadUrl(key string) (string, error)

func (*S3Driver) WalkDir

func (d *S3Driver) WalkDir(prefix string) (*File, error)

type S3DriverConfig

type S3DriverConfig struct {
	SecretID    string `arg:"secretID;SecretID;对象存储的密钥ID;required" json:"secretID"`
	SecretKey   string `arg:"secretKey;SecretKey;对象存储的密钥Key;required" json:"secretKey"`
	Region      string `arg:"region;区域;对象存储所在区域;required" json:"region"`
	Endpoint    string `arg:"endpoint;Endpoint;endpoint地址;required" json:"endpoint"`
	Bucket      string `arg:"bucket;Bucket;bucket名称;required" json:"bucket"`
	ForceS3Path bool   `` /* 129-byte string literal not displayed */
	Key         string `arg:"key;签名key;部分接口所需要使用的签名key,随意填写;required" json:"key"`
	Host        string `arg:"host;服务地址;NextList服务地址,需要外网能够访问;required" json:"host"`
}

type UploadSessionItem

type UploadSessionItem struct {
	ConflictBehavior ConflictBehaviorType `json:"@microsoft.graph.conflictBehavior"`
}

type UploadSessionOption

type UploadSessionOption struct {
	Item UploadSessionItem `json:"item"`
}

type UploadSessionResp

type UploadSessionResp struct {
	UploadUrl          string `json:"uploadUrl"`
	ExpirationDateTime string `json:"expirationDateTime"`
}

type UploaderFileStream

type UploaderFileStream struct {
	Name string

	DataLength int
	// contains filtered or unexported fields
}

func (UploaderFileStream) Read

func (r UploaderFileStream) Read(p []byte) (n int, err error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL