Versions in this module Expand all Collapse all v0 v0.2.2 Dec 10, 2023 v0.2.1 Oct 15, 2023 Changes in this version + const DefaultBufferSize + var FilePool = sync.Pool + type Config struct + Capacity int + Concurrency int + type File struct + CompressedData *bytes.Buffer + Compressor *flate.Writer + Header *zip.FileHeader + Info fs.FileInfo + Overflow *os.File + Path string + func NewFile(path string, info fs.FileInfo, relativeTo string) (*File, error) + func (f *File) Overflowed() bool + func (f *File) Reset(path string, info fs.FileInfo, relativeTo string) error + func (f *File) Write(p []byte) (n int, err error) + func (f *File) Written() int64 + type FileWorkerPool struct + func NewFileWorkerPool(executor func(f *T) error, config *Config) (*FileWorkerPool[T], error) + func (f *FileWorkerPool[T]) Close() error + func (f *FileWorkerPool[T]) Enqueue(file *T) + func (f *FileWorkerPool[T]) Start(ctx context.Context) + func (f FileWorkerPool[T]) PendingFiles() int + type WorkerPool interface + Close func() error + Enqueue func(v *T) + Start func(ctx context.Context)