@brandonxiang/ges
v3.0.0
Published
gRPC experimental server that support koa-like interceptor
Downloads
2
Maintainers
Readme
grpc-experimental-server
gRPC experimental server that supports koa-like interceptors
Usage
npm i ges grpc
import ExperimentalServer from 'ges';
const server = new ExperimentalServer();
server.addService(/* ... */);
// add interceptor
server.use(async (context, next) => {
// preprocess
const start = Date.now();
try {
await next();
} finally {
// postprocess
const costtime = Date.now() - start;
console.log('costtime is', costtime);
console.log('unary response is ', context.response);
}
});
serer.bind(/* ... */);
server.start();
gRPC
has 4 kinds of call:
| handle type | request is stream or not | response is stream or not | | ------------------------- | :----------------------: | :-----------------------: | | handleUnaryCall | ❌ | ❌ | | handleClientStreamingCall | ✅ | ❌ | | handleServerStreamingCall | ❌ | ✅ | | handleBidiStreamingCall | ✅ | ✅ |
Context
call
current gRPC calldefinition
the method definition of current callresponse
response if response is notstream
onFinished(...)
you can listen on call finish event, no matter response of current call is stream or not. So you don't need to care about what kind is the call. It is very useful to do something liketracing
,logging
Notes
await next()
would wait the call to be finished if response is not stream.