grpc v0.5.0-beta.1 GRPC.Server View Source

A gRPC server which handles requests by calling user-defined functions.

You should pass a GRPC.Service in when use the module:

defmodule Greeter.Service do
  use GRPC.Service, name: "ping"

  rpc :SayHello, Request, Reply
  rpc :SayGoodbye, stream(Request), stream(Reply)
end

defmodule Greeter.Server do
  use GRPC.Server, service: Greeter.Service

  def say_hello(request, _stream) do
    Reply.new(message: "Hello")
  end

  def say_goodbye(request_enum, stream) do
    requests = Enum.map request_enum, &(&1)
    GRPC.Server.send_reply(stream, reply1)
    GRPC.Server.send_reply(stream, reply2)
  end
end

Your functions should accept a client request and a GRPC.Server.Stream. The request will be a Enumerable.t(created by Elixir's Stream) of requests if it's streaming. If a reply is streaming, you need to call send_reply/2 to send replies one by one instead of returning reply in the end.

Link to this section Summary

Types

rpc()

rpc_req()

rpc_return()

servers_list()

servers_map()

Functions

send_headers(stream, headers)

Send custom metadata(headers).

send_reply(stream, reply, opts \\ [])

Send streaming reply.

set_compressor(stream, compressor)

Set compressor to compress responses. An accepted compressor will be set if clients use one, even if set_compressor is not called. But this can be called to override the chosen.

set_headers(stream, headers)

Set custom metadata(headers).

set_trailers(stream, trailers)

Set custom trailers, which will be sent in the end.

stream_send(stream, reply) deprecated

DEPRECATED. Use send_reply/3 instead

Link to this section Types