rpc

typeA unary RPC handler: it maps a request message's wire bytes to a response message's wire bytes (the application/grpc+proto payload, sans the length-prefix framing that @moonrpc.encode_message adds). Streaming handlers arrive with the h2 transport; this is the unary shape zRPC registers today.

typeA server-streaming handler: one request message in, an ordered sequence of response messages out (each framed as its own length-prefixed gRPC message). Mirrors pb.XxxServer server-streaming method, which writes to a grpc.ServerStream instead of returning one reply.

typeA client-streaming handler: every request message the client sends is collected, and after the client half-closes the handler returns one reply.

structA live bidirectional call: on_message fires once per request message and returns the replies to send right then, so responses interleave with requests; on_end runs after the client half-closes and returns the final replies before the grpc-status trailer. The moonzero-local mirror of @moonrpc.BidiHandler, so callers register bidi methods without naming the transport package.

typeA factory that mints one BidiStreamHandler per call, so each stream gets its own handler state.

structA zRPC server: config plus a registry mapping each method's gRPC :path (/package.Service/Method) to its handler. Handlers are registered via @moonrpc.Method descriptors — directly or through a RpcGroup — and dispatched by path, mirroring how registers service implementations on the underlying gRPC server. Unary, server-streaming, and client-streaming methods live in separate registries so one path resolves to exactly one cardinality.

fnBuild an empty RPC server from its config.

fnA server whose unary calls run through interceptors, outermost first.

fnA server with interceptor added at the front of the chain, so the layers are named from the outermost in.

fnThe interceptors this server's unary calls run through, outermost first.

fnBuild a server from conf with the chain its Middlewares flags ask for.

fnDispatch one unary call through the interceptor chain, then the registered handler. An unregistered path answers Unimplemented from the innermost invoker, so the chain still sees and records it.

fnThe server's configuration.

fnRegister handler for method, keyed by its gRPC path. A later registration for the same path replaces the earlier one.

fnRegister a server-streaming handler for method, keyed by its gRPC path.

fnRegister a client-streaming handler for method, keyed by its gRPC path.

fnRegister a bidirectional-streaming handler for method, keyed by its gRPC path. factory runs once per call so each stream gets fresh handler state.

fnOpen a RpcGroup that registers methods under the fully-qualified package.Service name — per-service registration, without repeating the service name on each method.

fnLook up the handler registered for a gRPC :path, or None if unregistered.

fnThe gRPC paths of every registered method.

fnWhether a handler is registered for path.

fnDispatch a unary call to the handler registered for path, returning the response bytes. An unregistered path yields Err(Unimplemented) — exactly the grpc-status a real gRPC server returns for an unknown method — so a transport can translate the result straight onto the wire.

structA per-service registration handle: binds a set of methods to one package.Service on a shared RpcServer.

fnThe fully-qualified package.Service this group registers under.

fnRegister a method name on this group's service, building the @moonrpc.Method descriptor and installing handler under its gRPC path. (register, not method — the latter is a reserved word.)

fnRegister a server-streaming method name on this group's service.

fnRegister a client-streaming method name on this group's service.

fnRegister a bidirectional-streaming method name on this group's service.

fnDispatch a unary call through the shutdown gate: refuse with Unavailable when the server is shutting down, otherwise run the handler and count it as in-flight for the duration so a concurrent shutdown drains behind it. The gate wraps RpcServer::dispatch, so an unregistered path still yields Unimplemented.