depidx

Documentation

Index

• type Deps
  • func NewDeps(cfg gocfg.ICfg) *Deps
  • func (deps *Deps) FS() fs.ISimpleFS
  • func (deps *Deps) FileInfos() fileinfostore.IFileInfoStore
  • 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) SetFS(filesystem fs.ISimpleFS)
  • func (deps *Deps) SetFileInfos(fileInfos fileinfostore.IFileInfoStore)
  • 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) SetUsers(users userstore.IUserStore)
  • func (deps *Deps) SetWorkers(workers worker.IWorkerPool)
  • func (deps *Deps) Token() cryptoutil.ITokenEncDec
  • func (deps *Deps) Users() userstore.IUserStore
  • 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) FS

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

func (*Deps) FileInfos

func (deps *Deps) FileInfos() fileinfostore.IFileInfoStore

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) SetFS

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

func (*Deps) SetFileInfos

func (deps *Deps) SetFileInfos(fileInfos fileinfostore.IFileInfoStore)

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) SetUsers

func (deps *Deps) SetUsers(users userstore.IUserStore)

func (*Deps) SetWorkers

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

func (*Deps) Token

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

func (*Deps) Users

func (deps *Deps) Users() userstore.IUserStore

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
}