Scrypath.Oban (scrypath v0.3.1)

Copy Markdown View Source

Narrow Oban helpers for composing Scrypath sync jobs into Ecto.Multi.

Summary

Functions

enqueue_delete(multi, name, schema_module, document_ids, opts)
enqueue_upsert(multi, name, schema_module, records, opts)

Functions

enqueue_delete(multi, name, schema_module, document_ids, opts)

@spec enqueue_delete(Ecto.Multi.t(), Ecto.Multi.name(), module(), [term()], keyword()) ::
  Ecto.Multi.t()

enqueue_upsert(multi, name, schema_module, records, opts)

@spec enqueue_upsert(
  Ecto.Multi.t(),
  Ecto.Multi.name(),
  module(),
  [struct() | map()],
  keyword()
) ::
  Ecto.Multi.t()