View Source GRPC.Server.Adapter behaviour (grpc v0.9.0)

HTTP server adapter for GRPC.

Summary

Types

state()

Callbacks

send_headers(state, headers)

send_reply(state, content, opts)

start(atom, map, port, opts)

stop(atom, map)

Types

state()

@type state() :: %{
  pid: pid(),
  handling_timer: reference() | nil,
  resp_trailers: map(),
  compressor: atom() | nil,
  pending_reader: nil
}

Callbacks

send_headers(state, headers)

@callback send_headers(state(), headers :: map()) :: any()

send_reply(state, content, opts)

@callback send_reply(state(), content :: binary(), opts :: keyword()) :: any()

start(atom, map, port, opts)

@callback start(
  atom(),
  %{required(String.t()) => [module()]},
  port :: non_neg_integer(),
  opts :: keyword()
) :: {atom(), any(), non_neg_integer()}

stop(atom, map)

@callback stop(atom(), %{required(String.t()) => [module()]}) ::
  :ok | {:error, :not_found}