tasks

Documentation

Index

• func SkipFB2Binaries(next fb2parse.TokenHandler) fb2parse.TokenHandler
• func SkipFB2Cover(next fb2parse.TokenHandler) fb2parse.TokenHandler
• func SkipFB2CustomInfo(next fb2parse.TokenHandler) fb2parse.TokenHandler
• func SkipFB2DocInfo(next fb2parse.TokenHandler) fb2parse.TokenHandler
• type HandleLibItemTask
  • func NewHandleLibItemTask(num, total int, item string, lib entities.Library, logger zerolog.Logger, ...) *HandleLibItemTask
  • func (t *HandleLibItemTask) Do()
  • func (t *HandleLibItemTask) GetID() string
• type IndexFB2DataTask
  • func NewIndexFB2DataTask(data io.Reader, book entities.BookInfo, encoder entities.LibEncodeType, ...) *IndexFB2DataTask
  • func (t *IndexFB2DataTask) Do()
  • func (t *IndexFB2DataTask) GetID() string
• type IndexTaskFactory
• type ReadZipTask
  • func NewReadZipTask(num, total int, path string, item fs.FileInfo, lib entities.Library, ...) *ReadZipTask
  • func (t *ReadZipTask) Do()
  • func (t *ReadZipTask) GetID() string
• type ReaderTask
  • func NewReaderTask(reader io.ReadCloser, book entities.BookInfo, wg *sync.WaitGroup, ...) *ReaderTask
  • func (t *ReaderTask) Do()
  • func (t *ReaderTask) GetID() string

Functions

func SkipFB2Binaries

func SkipFB2Binaries(next fb2parse.TokenHandler) fb2parse.TokenHandler

func SkipFB2Cover

func SkipFB2Cover(next fb2parse.TokenHandler) fb2parse.TokenHandler

func SkipFB2CustomInfo

func SkipFB2CustomInfo(next fb2parse.TokenHandler) fb2parse.TokenHandler

func SkipFB2DocInfo

func SkipFB2DocInfo(next fb2parse.TokenHandler) fb2parse.TokenHandler

Types

type HandleLibItemTask

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

func NewHandleLibItemTask

func NewHandleLibItemTask(
	num, total int,
	item string,
	lib entities.Library,
	logger zerolog.Logger,
	readPool interfaces.Pool,
	indexPool interfaces.Pool,
	wg *sync.WaitGroup,
	repoMarks entities.ILibMarksRepo,
	counter *entities.CntAtomic32,
	bars *mpb.Progress,
	taskIndex IndexTaskFactory,
) *HandleLibItemTask

func (*HandleLibItemTask) Do

func (t *HandleLibItemTask) Do()

func (*HandleLibItemTask) GetID

func (t *HandleLibItemTask) GetID() string

type IndexFB2DataTask

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

func NewIndexFB2DataTask

func NewIndexFB2DataTask(
	data io.Reader,
	book entities.BookInfo,
	encoder entities.LibEncodeType,
	repo entities.IBooksInfoRepo,
	logger zerolog.Logger,
	wg *sync.WaitGroup,
	counter *entities.CntAtomic32,
	bar *mpb.Bar,
) *IndexFB2DataTask

func (*IndexFB2DataTask) Do

func (t *IndexFB2DataTask) Do()

func (*IndexFB2DataTask) GetID

func (t *IndexFB2DataTask) GetID() string

type IndexTaskFactory

type IndexTaskFactory func(io.Reader, entities.BookInfo, zerolog.Logger) interfaces.Task

type ReadZipTask

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

func NewReadZipTask

func NewReadZipTask(
	num, total int,
	path string,
	item fs.FileInfo,
	lib entities.Library,
	repoMarks entities.ILibMarksRepo,
	logger zerolog.Logger,
	readPool interfaces.Pool,
	indexPool interfaces.Pool,
	wg *sync.WaitGroup,
	counter *entities.CntAtomic32,
	bars *mpb.Progress,
	taskIndex IndexTaskFactory,
) *ReadZipTask

func (*ReadZipTask) Do

func (t *ReadZipTask) Do()

func (*ReadZipTask) GetID

func (t *ReadZipTask) GetID() string

type ReaderTask

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

func NewReaderTask

func NewReaderTask(
	reader io.ReadCloser,
	book entities.BookInfo,
	wg *sync.WaitGroup,
	logger zerolog.Logger,
	indexPool interfaces.Pool,
	taskIndex IndexTaskFactory,
) *ReaderTask

func (*ReaderTask) Do

func (t *ReaderTask) Do()

func (*ReaderTask) GetID

func (t *ReaderTask) GetID() string