depidx

Documentation

Index

• type Deps
  • func NewDeps(cfg gocfg.ICfg) *Deps
  • func (deps *Deps) Cron() cron.ICron
  • func (deps *Deps) DB() db.IDBQuickshare
  • func (deps *Deps) FS() fs.ISimpleFS
  • func (deps *Deps) FileIndex() fileindex.IFileIndex
  • func (deps *Deps) FileInfos() db.IFilesFunctions
  • func (deps *Deps) ID() idgen.IIDGen
  • func (deps *Deps) KV() kvstore.IKVStore
  • func (deps *Deps) Limiter() iolimiter.ILimiter
  • func (deps *Deps) Log() *zap.SugaredLogger
  • func (deps *Deps) SetCron(cronImp cron.ICron)
  • func (deps *Deps) SetDB(rdb db.IDBQuickshare)
  • func (deps *Deps) SetFS(filesystem fs.ISimpleFS)
  • func (deps *Deps) SetFileIndex(index fileindex.IFileIndex)
  • func (deps *Deps) SetID(ider idgen.IIDGen)
  • func (deps *Deps) SetKV(kvstore kvstore.IKVStore)
  • func (deps *Deps) SetLimiter(limiter iolimiter.ILimiter)
  • func (deps *Deps) SetLog(logger *zap.SugaredLogger)
  • func (deps *Deps) SetToken(tokenMaker cryptoutil.ITokenEncDec)
  • func (deps *Deps) SetWorkers(workers worker.IWorkerPool)
  • func (deps *Deps) SiteStore() db.IConfigDB
  • func (deps *Deps) Token() cryptoutil.ITokenEncDec
  • func (deps *Deps) Users() db.IUserDB
  • func (deps *Deps) Workers() worker.IWorkerPool
• type IUploader

Types

type Deps

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

func NewDeps

func NewDeps(cfg gocfg.ICfg) *Deps

func (*Deps) Cron

func (deps *Deps) Cron() cron.ICron

func (*Deps) DB

func (deps *Deps) DB() db.IDBQuickshare

func (*Deps) FS

func (deps *Deps) FS() fs.ISimpleFS

func (*Deps) FileIndex

func (deps *Deps) FileIndex() fileindex.IFileIndex

func (*Deps) FileInfos

func (deps *Deps) FileInfos() db.IFilesFunctions

func (*Deps) ID

func (deps *Deps) ID() idgen.IIDGen

func (*Deps) KV

func (deps *Deps) KV() kvstore.IKVStore

func (*Deps) Limiter

func (deps *Deps) Limiter() iolimiter.ILimiter

func (*Deps) Log

func (deps *Deps) Log() *zap.SugaredLogger

func (*Deps) SetCron

func (deps *Deps) SetCron(cronImp cron.ICron)

func (*Deps) SetDB

func (deps *Deps) SetDB(rdb db.IDBQuickshare)

func (*Deps) SetFS

func (deps *Deps) SetFS(filesystem fs.ISimpleFS)

func (*Deps) SetFileIndex

func (deps *Deps) SetFileIndex(index fileindex.IFileIndex)

func (*Deps) SetID

func (deps *Deps) SetID(ider idgen.IIDGen)

func (*Deps) SetKV

func (deps *Deps) SetKV(kvstore kvstore.IKVStore)

func (*Deps) SetLimiter

func (deps *Deps) SetLimiter(limiter iolimiter.ILimiter)

func (*Deps) SetLog

func (deps *Deps) SetLog(logger *zap.SugaredLogger)

func (*Deps) SetToken

func (deps *Deps) SetToken(tokenMaker cryptoutil.ITokenEncDec)

func (*Deps) SetWorkers

func (deps *Deps) SetWorkers(workers worker.IWorkerPool)

func (*Deps) SiteStore

func (deps *Deps) SiteStore() db.IConfigDB

func (*Deps) Token

func (deps *Deps) Token() cryptoutil.ITokenEncDec

func (*Deps) Users

func (deps *Deps) Users() db.IUserDB

func (*Deps) Workers

func (deps *Deps) Workers() worker.IWorkerPool

type IUploader

type IUploader interface {
	Create(filePath string, size int64) error
	WriteChunk(filePath string, chunk []byte, off int64) (int, error)
	Status(filePath string) (int64, bool, error)
	Close() error
	Sync() error
}