worker

type Job struct {
	ID      string          // unique identifier for the job.
	Ack     func(err error) // acknowledge callback when message is processed.
	Time    time.Time       // time at which this job was created.
	Error   error           // error during processing if any.
	Payload interface{}     // payload of the message.
}

type Option func(ws *workerSession) error

type Proc interface {
	Exec(ctx context.Context, job Job) error
}

type ProcFn func(ctx context.Context, job Job) error

type Stream func(ctx context.Context) (<-chan Job, error)