worker

type Error struct {
	Err    error
	Entity interface{}
}

type Processor func(interface{}, context.Context) error

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