workermw

Documentation

Index

• func WithJobProcessorInstrumentation() func(worker.JobProcessor) worker.JobProcessor
• type JobProcessorInstrumentation
  • func (mw JobProcessorInstrumentation) Enqueue(ctx context.Context, jobs ...worker.Job) (err error)
  • func (mw JobProcessorInstrumentation) GetSyncJobsByService(ctx context.Context, service string) ([]worker.Job, error)
  • func (mw JobProcessorInstrumentation) Process(ctx context.Context, types []string, fn worker.JobExecutorFunc) (err error)
  • func (mw JobProcessorInstrumentation) Stats(ctx context.Context) ([]worker.JobTypeStats, error)

Functions

func WithJobProcessorInstrumentation

func WithJobProcessorInstrumentation() func(worker.JobProcessor) worker.JobProcessor

Types

type JobProcessorInstrumentation

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

func (JobProcessorInstrumentation) Enqueue

func (mw JobProcessorInstrumentation) Enqueue(ctx context.Context, jobs ...worker.Job) (err error)

func (JobProcessorInstrumentation) GetSyncJobsByService

func (mw JobProcessorInstrumentation) GetSyncJobsByService(ctx context.Context, service string) ([]worker.Job, error)

func (JobProcessorInstrumentation) Process

func (mw JobProcessorInstrumentation) Process(ctx context.Context, types []string, fn worker.JobExecutorFunc) (err error)

func (JobProcessorInstrumentation) Stats

func (mw JobProcessorInstrumentation) Stats(ctx context.Context) ([]worker.JobTypeStats, error)