Packages

lepus

0.1.6
0.1.6 0.1.5 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0

Opinionated library for RabbitMQ with exponential backoff retries and RPC.

HexDocs

Current section

Files

Jump to
Readme
7 Versions
4 Dependencies
Dependants
Files
Activity
lepus lib lepus client.ex
Raw

lib/lepus/client.ex 

defmodule Lepus.Client do

  @moduledoc """

  Client behaviour used in `Lepus`.

  """



  @type exchange :: String.t()

  @type routing_key :: String.t()

  @type binary_payload :: binary()

  @type payload :: term()

  @type opts :: keyword()

  @type response() :: :ok | {:ok, any()} | {:error, any()}



  @callback publish(Supervisor.supervisor(), exchange, routing_key, binary_payload, opts) ::

              response()



  @callback publish_json(Supervisor.supervisor(), exchange, routing_key, payload, opts) ::

              response()

end