Packages

honeydew

1.1.3
1.5.0 1.4.6 1.4.5 1.4.4 1.4.3 1.4.2 1.4.1 1.4.0 1.3.0 1.2.8 1.2.7 1.2.6 1.2.5 1.2.4 1.2.3 1.2.2 1.2.1 1.2.0 1.1.6 1.1.5 1.1.4 1.1.3 1.1.2 1.1.1 1.1.0 1.0.4 1.0.3 1.0.2 1.0.1 1.0.0 1.0.0-rc7 1.0.0-rc6 1.0.0-rc5 1.0.0-rc4 1.0.0-rc3 1.0.0-rc2 1.0.0-rc1 0.0.11 0.0.10 0.0.9 0.0.8 0.0.7 0.0.6 0.0.5 0.0.4 0.0.3 0.0.2 0.0.1

Pluggable local/clusterable job queue focused on safety.

HexDocs

Current section

Files

Jump to
Readme
48 Versions
1 Dependency
3 Dependants
Files
Activity
honeydew lib honeydew sources ecto state.ex
Raw

lib/honeydew/sources/ecto/state.ex 

defmodule Honeydew.EctoSource.State do

  defstruct [

    :schema,

    :repo,

    :sql,

    :table,

    :key_field,

    :lock_field,

    :private_field,

    :task_fn,

    :queue,

    :stale_timeout,

  ]



  @type stale_timeout :: pos_integer



  @type t :: %__MODULE__{schema: module,

                         repo: module,

                         sql: module,

                         table: String.t(),

                         key_field: String.t(),

                         lock_field: String.t(),

                         private_field: String.t(),

                         stale_timeout: stale_timeout,

                         task_fn: function(),

                         queue: Honeydew.queue_name()}

end