Current section
Files
Jump to
Current section
Files
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