Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Option ¶
type Option func(*Worker)
Option is used to set worker creation options in New.
func OmittingFuserIDInOutDir ¶
func OmittingFuserIDInOutDir() Option
OmittingFuserIDInOutDir causes the fanout worker to *not* add the analytic ID to output directories specified in input tasks.
type Worker ¶
Worker is a worker that takes a task from one queue and creates multiple tasks in different output queues based on analytic IDs.
func New ¶
New creates a new runnable fanout worker, given an EntroQ client, a PostgreSQL database, an inbox name, and an output task queue format string with a single "%s" specifier. The analytic ID in a request will be inserted in that point in the format string, after applying url.PathEscape to it.
func (*Worker) FuserInbox ¶
FuserInbox returns the inbox name for a given analytic ID.