local

Documentation

Index

• func GetSnapshot(videoPath string, frameNum int) (imgData *bytes.Buffer, err error)
• type Addition
• type Local
  • func (d *Local) Config() driver.Config
  • func (d *Local) Copy(_ context.Context, srcObj, dstDir model.Obj) error
  • func (d *Local) Drop(ctx context.Context) error
  • func (d *Local) FileInfoToObj(f fs.FileInfo, reqPath string, fullPath string) model.Obj
  • func (d *Local) Get(ctx context.Context, path string) (model.Obj, error)
  • func (d *Local) GetAddition() driver.Additional
  • func (d *Local) GetMeta(ctx context.Context, path string) (model.Obj, error)
  • func (d *Local) Init(ctx context.Context) error
  • func (d *Local) Link(ctx context.Context, file model.Obj, args model.LinkArgs) (*model.Link, error)
  • func (d *Local) List(ctx context.Context, dir model.Obj, args model.ListArgs) ([]model.Obj, error)
  • func (d *Local) MakeDir(ctx context.Context, parentDir model.Obj, dirName string) error
  • func (d *Local) Move(ctx context.Context, srcObj, dstDir model.Obj) error
  • func (d *Local) Put(ctx context.Context, dstDir model.Obj, stream model.FileStreamer, ...) error
  • func (d *Local) Remove(ctx context.Context, obj model.Obj) error
  • func (d *Local) Rename(ctx context.Context, srcObj model.Obj, newName string) error
• type NopTokenBucket
  • func NewNopTokenBucket() NopTokenBucket
  • func (b NopTokenBucket) Do(_ context.Context, f func() error) error
  • func (b NopTokenBucket) Put()
  • func (b NopTokenBucket) Take() <-chan struct{}
• type StaticTokenBucket
  • func NewStaticTokenBucket(size int) StaticTokenBucket
  • func NewStaticTokenBucketWithMigration(oldBucket TokenBucket, size int) StaticTokenBucket
  • func (b StaticTokenBucket) Do(ctx context.Context, f func() error) error
  • func (b StaticTokenBucket) Put()
  • func (b StaticTokenBucket) Take() <-chan struct{}
• type TokenBucket

Functions

func GetSnapshot

func GetSnapshot(videoPath string, frameNum int) (imgData *bytes.Buffer, err error)

Types

type Addition

type Addition struct {
	driver.RootPath
	Thumbnail        bool   `json:"thumbnail" required:"true" help:"enable thumbnail"`
	ThumbCacheFolder string `json:"thumb_cache_folder"`
	ThumbConcurrency string `` /* 179-byte string literal not displayed */
	ShowHidden       bool   `json:"show_hidden" default:"true" required:"false" help:"show hidden directories and files"`
	MkdirPerm        string `json:"mkdir_perm" default:"777"`
	RecycleBinPath   string `` /* 137-byte string literal not displayed */
}

type Local

type Local struct {
	model.Storage
	Addition
	// contains filtered or unexported fields
}

func (*Local) Config

func (d *Local) Config() driver.Config

func (*Local) Copy

func (d *Local) Copy(_ context.Context, srcObj, dstDir model.Obj) error

func (*Local) Drop

func (d *Local) Drop(ctx context.Context) error

func (*Local) FileInfoToObj

func (d *Local) FileInfoToObj(f fs.FileInfo, reqPath string, fullPath string) model.Obj

func (*Local) Get

func (d *Local) Get(ctx context.Context, path string) (model.Obj, error)

func (*Local) GetAddition

func (d *Local) GetAddition() driver.Additional

func (*Local) GetMeta

func (d *Local) GetMeta(ctx context.Context, path string) (model.Obj, error)

func (*Local) Init

func (d *Local) Init(ctx context.Context) error

func (*Local) Link

func (d *Local) Link(ctx context.Context, file model.Obj, args model.LinkArgs) (*model.Link, error)

func (*Local) List

func (d *Local) List(ctx context.Context, dir model.Obj, args model.ListArgs) ([]model.Obj, error)

func (*Local) MakeDir

func (d *Local) MakeDir(ctx context.Context, parentDir model.Obj, dirName string) error

func (*Local) Move

func (d *Local) Move(ctx context.Context, srcObj, dstDir model.Obj) error

func (*Local) Put

func (d *Local) Put(ctx context.Context, dstDir model.Obj, stream model.FileStreamer, up driver.UpdateProgress) error

func (*Local) Remove

func (d *Local) Remove(ctx context.Context, obj model.Obj) error

func (*Local) Rename

func (d *Local) Rename(ctx context.Context, srcObj model.Obj, newName string) error

type NopTokenBucket

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

NopTokenBucket all function calls to this bucket will success immediately

func NewNopTokenBucket

func NewNopTokenBucket() NopTokenBucket

func (NopTokenBucket) Do

func (b NopTokenBucket) Do(_ context.Context, f func() error) error

func (NopTokenBucket) Put

func (b NopTokenBucket) Put()

func (NopTokenBucket) Take

func (b NopTokenBucket) Take() <-chan struct{}

type StaticTokenBucket

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

StaticTokenBucket is a bucket with a fixed number of tokens, where the retrieval and return of tokens are manually controlled. In the initial state, the bucket is full.

func NewStaticTokenBucket

func NewStaticTokenBucket(size int) StaticTokenBucket

func NewStaticTokenBucketWithMigration

func NewStaticTokenBucketWithMigration(oldBucket TokenBucket, size int) StaticTokenBucket

func (StaticTokenBucket) Do

func (b StaticTokenBucket) Do(ctx context.Context, f func() error) error

func (StaticTokenBucket) Put

func (b StaticTokenBucket) Put()

func (StaticTokenBucket) Take

func (b StaticTokenBucket) Take() <-chan struct{}

Take channel maybe closed when local driver is modified. don't call Put method after the channel is closed.

type TokenBucket

type TokenBucket interface {
	Take() <-chan struct{}
	Put()
	Do(context.Context, func() error) error
}