mirror of
https://github.com/bitmagnet-io/bitmagnet.git
synced 2026-07-29 23:43:43 -04:00
28 lines
771 B
Go
28 lines
771 B
Go
package processor
|
|
|
|
import (
|
|
"github.com/bitmagnet-io/bitmagnet/internal/blocker"
|
|
"github.com/bitmagnet-io/bitmagnet/internal/classifier"
|
|
"github.com/bitmagnet-io/bitmagnet/internal/database/search"
|
|
"github.com/bitmagnet-io/bitmagnet/internal/persister"
|
|
"github.com/bitmagnet-io/bitmagnet/internal/queue"
|
|
)
|
|
|
|
func New(
|
|
defaultWorkflow classifier.Workflow,
|
|
searchClient search.Search,
|
|
blockerBlocker blocker.Blocker,
|
|
runner classifier.Runner,
|
|
queueJobProvider queue.JobProvider[MessageParams],
|
|
persister persister.Adder,
|
|
) Processor {
|
|
return processor{
|
|
searchClient: searchClient,
|
|
blocker: blockerBlocker,
|
|
runner: runner,
|
|
defaultWorkflow: defaultWorkflow,
|
|
queueJobProvider: queueJobProvider,
|
|
persister: persister,
|
|
}
|
|
}
|