Honeydew.EctoPollQueue (honeydew v1.5.0) View Source

The following arguments can be provided when selecting the Ecto Poll Queue module:

You must provide:

  • repo: is your Ecto.Repo module
  • schema: is your Ecto.Schema module

You may provide:

  • poll_interval: is how often Honeydew will poll your database when the queue is silent, in seconds (default: 10)
  • stale_timeout: is the amount of time a job can take before it risks retry, in seconds (default: 300)

For example:

Honeydew.start_queue(:classify_photos, {Honeydew.EctoPollQueue,
                                        repo: MyApp.Repo,
                                        schema: MyApp.Photo})
Honeydew.start_queue(:classify_photos, {Honeydew.EctoPollQueue,
                                        repo: MyApp.Repo,
                                        schema: MyApp.Photo},
                                       failure_mode: {Honeydew.Retry,
                                                      times: 3})

Link to this section Summary

Link to this section Types

Link to this type

ecto_poll_queue_spec_opt()

View Source

Specs

ecto_poll_queue_spec_opt() ::
  Honeydew.queue_spec_opt()
  | {:schema, module()}
  | {:repo, module()}
  | {:poll_interval, pos_integer()}
  | {:stale_timeout, pos_integer()}

Specs

queue_name() :: Honeydew.queue_name()

Link to this section Functions