Current section

Files

Jump to
faktory_worker lib faktory_worker socket.ex
Raw

lib/faktory_worker/socket.ex

defmodule FaktoryWorker.Socket do
@moduledoc false
alias FaktoryWorker.Connection
@callback connect(host :: String.t(), port :: pos_integer(), opts :: keyword()) ::
{:ok, Connection.t()} | {:error, term()}
@callback send(connection :: Connection.t(), payload :: String.t()) ::
:ok | {:error, term()}
@callback recv(connection :: Connection.t()) :: {:ok, String.t()} | {:error, term()}
@callback recv(connection :: Connection.t(), length :: pos_integer()) ::
{:ok, String.t()} | {:error, term()}
end