MPP.Subscription.Store behaviour (mpp v0.14.0)

Behaviour and dispatch helpers for recurring-subscription persistence.

Updates must be atomic so concurrent renewal attempts cannot charge the same billing period twice. MPP.Subscription.ETSStore is the single-node default.

Summary

Types

store_ref()

update_fun()

Callbacks

delete(t)

get(t)

put(t)

update(t, update_fun)

Functions

default_store()

Return the application-started subscription store.

delete(store, id)

Delete a subscription through a store reference.

get(store, id)

Look up a subscription through a store reference.

put(store, record)

Persist a subscription through a store reference.

update(store, id, fun)

Atomically update a subscription through a store reference.

Types

store_ref()

@type store_ref() :: module() | {module(), keyword()}

update_fun()

@type update_fun() :: (MPP.Subscription.Record.t() | :not_found ->
                   {:ok, MPP.Subscription.Record.t()} | {:error, term()})

Callbacks

delete(t)

@callback delete(String.t()) :: :ok | {:error, term()}

get(t)

@callback get(String.t()) ::
  {:ok, MPP.Subscription.Record.t()} | :not_found | {:error, term()}

put(t)

@callback put(MPP.Subscription.Record.t()) :: :ok | {:error, term()}

update(t, update_fun)

@callback update(String.t(), update_fun()) ::
  {:ok, MPP.Subscription.Record.t()} | {:error, term()}

Functions

default_store()

@spec default_store() :: module()

Return the application-started subscription store.

delete(store, id)

@spec delete(store_ref(), String.t()) :: :ok | {:error, term()}

Delete a subscription through a store reference.

get(store, id)

@spec get(store_ref(), String.t()) ::
  {:ok, MPP.Subscription.Record.t()} | :not_found | {:error, term()}

Look up a subscription through a store reference.

put(store, record)

@spec put(store_ref(), MPP.Subscription.Record.t()) :: :ok | {:error, term()}

Persist a subscription through a store reference.

update(store, id, fun)

@spec update(store_ref(), String.t(), update_fun()) ::
  {:ok, MPP.Subscription.Record.t()} | {:error, term()}

Atomically update a subscription through a store reference.