processor

Documentation

Index

• Constants
• type MessageParams
• type MissingHashesError
  • func (e MissingHashesError) Error() string
• type Params
• type Processor
• type Result
  • func New(p Params) Result

Constants

const MessageName = "process_torrent"

Types

type MessageParams

type MessageParams struct {
	Rematch    bool
	InfoHashes []protocol.ID
}

type MissingHashesError

type MissingHashesError struct {
	InfoHashes []protocol.ID
}

func (MissingHashesError) Error

func (e MissingHashesError) Error() string

type Params

type Params struct {
	fx.In
	Search     lazy.Lazy[search.Search]
	Classifier lazy.Lazy[classifier.Classifier]
	Dao        lazy.Lazy[*dao.Query]
	Logger     *zap.SugaredLogger
}

type Processor

type Processor interface {
	Process(ctx context.Context, params MessageParams) error
}

type Result

type Result struct {
	fx.Out
	Processor lazy.Lazy[Processor]
}

func New

func New(p Params) Result