View Source Mobilizon.Federation.ActivityPub.Federator (Mobilizon v5.0.0-beta.1)

Handle federated activities

Summary

Returns a specification to start this module under a supervisor.

init(args)

Callback implementation for GenServer.init/1.

queue_pop(list)

start_link(_)

Returns a specification to start this module under a supervisor.

@spec enqueue(atom(), map(), pos_integer()) :: :ok | {:ok, any()} | {:error, any()}

@spec enqueue_sorted(any(), any(), pos_integer()) :: any()

@spec handle(:publish | :publish_single_ap | atom(), Activity.t() | map()) ::
  :ok | {:ok, Activity.t()} | Tesla.Env.result() | {:error, String.t()}

@spec init(any()) :: {:ok, any()}

Callback implementation for GenServer.init/1.

@spec maybe_start_job(any(), any()) :: {any(), any()}

@spec queue_pop([any()]) :: {any(), [any()]}

@spec start_link(any()) :: GenServer.on_start()