Chimeway.Digests.Emission (chimeway v1.0.0)

Copy Markdown View Source

Transactional digest emission for due buckets with durable membership resolution.

Summary

Types

emit_result()

Functions

emit_bucket(bucket_or_id, opts \\ [])

Types

emit_result()

@type emit_result() :: %{
  bucket: Chimeway.Digests.DigestBucket.t(),
  digest_delivery: Chimeway.Delivery.t(),
  immediate_deliveries: [Chimeway.Delivery.t()]
}

Functions

emit_bucket(bucket_or_id, opts \\ [])

@spec emit_bucket(
  binary() | Chimeway.Digests.DigestBucket.t(),
  keyword()
) :: {:ok, emit_result()} | {:error, term()}