queue

type Executor interface {
	Run(ctx *task.Context, param task.Param)
}

type InProcessQueue struct {
	Database       *appdb.Handle
	CaptureContext task.CaptureTaskContext
	Executor       Executor
	// contains filtered or unexported fields
}