uploads

Documentation

Index

• type File
• type Upload
  • func New(log *slog.Logger, uploadCh chan<- *repos.File) *Upload
  • func (u *Upload) Add(ctx context.Context, file *File) (packId string, err error)
  • func (u *Upload) Flush(ctx context.Context) error

Types

type File

type File struct {
	io.Reader
	Path    string
	Hash    string
	Mode    fs.FileMode
	Size    int64
	ModTime time.Time
}

type Upload

type Upload struct {
	MaxPackSize  int
	MinChunkSize int
	MaxChunkSize int
	Limiter      rate.Limiter
	Concurrency  int
	// contains filtered or unexported fields
}

func New

func New(log *slog.Logger, uploadCh chan<- *repos.File) *Upload

func (*Upload) Add

func (u *Upload) Add(ctx context.Context, file *File) (packId string, err error)

func (*Upload) Flush

func (u *Upload) Flush(ctx context.Context) error