tasks

Documentation

Index

• func SkipFB2Binaries(next xmlparse.TokenHandler) xmlparse.TokenHandler
• func SkipFB2Cover(next xmlparse.TokenHandler) xmlparse.TokenHandler
• func SkipFB2CustomInfo(next xmlparse.TokenHandler) xmlparse.TokenHandler
• func SkipFB2DocInfo(next xmlparse.TokenHandler) xmlparse.TokenHandler
• type DefineItemTask
  • func NewDefineItemTask(item string, lib entities.Library, repoMarks *repos.LibMarks, bar *mpb.Bar, ...) *DefineItemTask
  • func (t *DefineItemTask) Do() error
  • func (t *DefineItemTask) ID() string
• type DoReadZipTask
• type ErrAlreadyIndexed
  • func (e ErrAlreadyIndexed) Error() string
• type ErrSkipRule
  • func (e ErrSkipRule) Error() string
• type IndexTaskFactory
• type ParseFB2Task
  • func NewParseFB2Task(data io.Reader, book entities.Book, rules entities.IndexRules, ...) *ParseFB2Task
  • func (t *ParseFB2Task) Do() error
  • func (t *ParseFB2Task) ID() string
• type PushParseTask
• type PushReadTask
• type ReadTask
  • func NewReadTask(src string, lib string, reader io.ReadCloser, doParseTask PushParseTask) *ReadTask
  • func (t *ReadTask) Do() error
  • func (t *ReadTask) ID() string
• type ReadZipTask
  • func NewReadZipTask(num int, total int, path string, item fs.FileInfo, lib entities.Library, ...) *ReadZipTask
  • func (t *ReadZipTask) Do() error
  • func (t *ReadZipTask) ID() string

Functions

func SkipFB2Binaries

func SkipFB2Binaries(next xmlparse.TokenHandler) xmlparse.TokenHandler

func SkipFB2Cover

func SkipFB2Cover(next xmlparse.TokenHandler) xmlparse.TokenHandler

func SkipFB2CustomInfo

func SkipFB2CustomInfo(next xmlparse.TokenHandler) xmlparse.TokenHandler

func SkipFB2DocInfo

func SkipFB2DocInfo(next xmlparse.TokenHandler) xmlparse.TokenHandler

Types

type DefineItemTask

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

func NewDefineItemTask

func NewDefineItemTask(
	item string,
	lib entities.Library,
	repoMarks *repos.LibMarks,
	bar *mpb.Bar,
	doFB2Task PushReadTask,
	doZIPTask DoReadZipTask,
) *DefineItemTask

func (*DefineItemTask) Do

func (t *DefineItemTask) Do() error

func (*DefineItemTask) ID

func (t *DefineItemTask) ID() string

type DoReadZipTask

type DoReadZipTask func(fs.FileInfo) error

type ErrAlreadyIndexed

type ErrAlreadyIndexed struct{}

func (ErrAlreadyIndexed) Error

func (e ErrAlreadyIndexed) Error() string

type ErrSkipRule

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

func (ErrSkipRule) Error

func (e ErrSkipRule) Error() string

type IndexTaskFactory

type IndexTaskFactory func(io.Reader, entities.Book, zerolog.Logger) pipeline.Task

type ParseFB2Task

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

func NewParseFB2Task

func NewParseFB2Task(
	data io.Reader,
	book entities.Book,
	rules entities.IndexRules,
	encoder entities.LibEncodeType,
	repo *repos.BooksLevelBleve,
	bar *mpb.Bar,
) *ParseFB2Task

func (*ParseFB2Task) Do

func (t *ParseFB2Task) Do() error

func (*ParseFB2Task) ID

func (t *ParseFB2Task) ID() string

type PushParseTask

type PushParseTask func(io.Reader) error

type PushReadTask

type PushReadTask func(io.ReadCloser, entities.Book) error

type ReadTask

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

func NewReadTask

func NewReadTask(
	src string,
	lib string,
	reader io.ReadCloser,
	doParseTask PushParseTask,
) *ReadTask

func (*ReadTask) Do

func (t *ReadTask) Do() error

func (*ReadTask) ID

func (t *ReadTask) ID() string

type ReadZipTask

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

func NewReadZipTask

func NewReadZipTask(
	num int,
	total int,
	path string,
	item fs.FileInfo,
	lib entities.Library,
	bars *mpb.Progress,
	doReaderTask PushReadTask,
) *ReadZipTask

func (*ReadZipTask) Do

func (t *ReadZipTask) Do() error

func (*ReadZipTask) ID

func (t *ReadZipTask) ID() string