reportwkr

Documentation

Index

• func Start(conf *appconfig.Config, deps WorkerDeps)
• type Worker
  • func (w *Worker) Consumer(ctx context.Context, ch chan error) error
• type WorkerDeps

Functions

func Start

func Start(conf *appconfig.Config, deps WorkerDeps)

Types

type Worker

type Worker struct {
	WorkerDeps
	// contains filtered or unexported fields
}

func (*Worker) Consumer

func (w *Worker) Consumer(ctx context.Context, ch chan error) error

type WorkerDeps

type WorkerDeps struct {
	fx.In
	DB                     *bun.DB
	Redis                  *redis.Client
	NatsJS                 nats.JetStreamContext
	StageService           *service.Stage
	DropReportRepo         *repo.DropReport
	DropPatternRepo        *repo.DropPattern
	DropReportExtraRepo    *repo.DropReportExtra
	DropPatternElementRepo *repo.DropPatternElement
	ReportVerifier         *reportverifs.ReportVerifiers
}