classifier

Documentation

Index

• Variables
• type Classifier
• type MissingHashesError
  • func (e MissingHashesError) Error() string
• type Params
• type Resolver
• type Result
  • func New(p Params) Result
• type SubResolver
• type SubResolverConfig

Variables

var (
	ErrNoMatch = errors.New("no match")
)

Types

type Classifier

type Classifier interface {
	Classify(ctx context.Context, infoHashes ...protocol.ID) error
}

type MissingHashesError

type MissingHashesError struct {
	InfoHashes []protocol.ID
}

func (MissingHashesError) Error

func (e MissingHashesError) Error() string

type Params

type Params struct {
	fx.In
	Search       search.Search
	SubResolvers []SubResolver `group:"content_resolvers"`
	Dao          *dao.Query
	Logger       *zap.SugaredLogger
}

type Resolver

type Resolver interface {
	Resolve(ctx context.Context, content model.TorrentContent) (model.TorrentContent, error)
}

type Result

type Result struct {
	fx.Out
	Classifier   Classifier
	Duration     prometheus.Collector `group:"prometheus_collectors"`
	SuccessTotal prometheus.Collector `group:"prometheus_collectors"`
	NoMatchTotal prometheus.Collector `group:"prometheus_collectors"`
	ErrorTotal   prometheus.Collector `group:"prometheus_collectors"`
}

func New

func New(p Params) Result

type SubResolver

type SubResolver interface {
	Config() SubResolverConfig
	PreEnrich(content model.TorrentContent) (model.TorrentContent, error)
	Resolver
}

type SubResolverConfig

type SubResolverConfig struct {
	Key      string
	Priority int
}