bendonnect-rpc

Releases (1)

• 0.1.0.0 indexed

Definitions (710)

src/transport/client.bend

• def head.ok
• def head.status
• def head.of
• def opened
• def ss.run
• def server_stream
• def server_stream.eachLike server_stream, but calls on_msg for every message as it arrives (messages in the returned Response is empty).
• def upload.next
• def upload.all
• def one
• def cs.sent
• def cs.open
• def client_streamEach message is one chunked-upload write holding one envelope.

src/transport/rpc.bend

• type CtxWhat a handler learns about the call it serves.
• type OutA typed server-stream sender: pass it through Rpc.send / the generated per-method send.
• def err_reply
• def bad_request
• def reply_io
• def no_custom
• def no_routeUnknown procedure: the server answers 404.
• def bidi_unimplementedBidirectional streaming is not supported by the HTTP/1.1 transport.
• def route.pick
• def routeif call.procedure == procedure then hit(call) else miss(call); chain these, ending in no_route.
• def enc_res
• def unary.reply
• def unary.run
• def unary.one
• def unaryServes a unary method: decode the single request message, run impl, encode the response.
• def send.goSends one typed message on a server stream.
• def send
• def ss.fin
• def ss.exec
• def ss.reply
• def ss.one
• def server_streamServes a server-streaming method: impl gets the request and an Out to Rpc.send on, and returns the final Out with Done (stream ends cleanly) or Fail (error in the EndStream message).
• def dec_all
• def cs.run
• def client_streamServes a client-streaming method: all request messages are decoded first (the transport buffers them), impl answers with the single response.
• def bad_response
• def one_msg
• def one_res
• def dec_msgs
• def many_res
• def enc_all
• def call.unaryUnary call.
• def call.server_streamServer-streaming call; collects every message (an error end-stream turns the whole call into Fail).
• def call.client_streamClient-streaming call: sends all reqs, answers the single response.

src/transport/server.bend

• type Meta
• type Call
• type SinkWraps the HTTP writer of a server stream.
• type Reply
• def meta.empty
• def ok
• def fail
• def sendOne enveloped message, written (and flushed) immediately.
• type JobPer-request state carried from `start` to `write`.
• type PreResult of the pure half of `start`.
• def msg_max
• def merge.go
• def merge
• def end_env
• def end_bytes
• def json_hdr
• def head
• def err_status
• def early_jsonHTTP-level error (unary style): status from the code, JSON body.
• def early_streamStreaming-style error: 200 + a single EndStream envelope.
• def early.pick
• def reject_pre
• def env_flags_ok
• def msgs.cons
• def msgs.one
• def msgs
• def too_big
• def decode_err
• def ready
• def stream_done
• def stream_decoded
• def build.go
• def build.codecOnly JSON and Protobuf are served: the spec answers any other codec with 415.
• def build
• def pre.go
• def ct_of.finContent type -> (stream?, codec), used only to shape rejections.
• def ct_of
• def split_q.cons
• def split_q.pick
• def split_q"/p/q?a=b" -> ("/p/q", "a=b")
• def pre.split
• def pre
• def timed.fin
• def timedNOTE: IO.within does not cancel the loser; a handler that overruns keeps running unobserved.
• def ct_hdr
• def all_hdrs
• def unary_ok
• def unary_err
• def single_unary
• def stream_single.go
• def stream_single
• def many_head
• def not_found