mirror of
https://github.com/hanzoai/tasks.git
synced 2026-11-03 03:56:04 +00:00
zeekay
1c76604f15
- New zaptransport package: factory, client, server, rpcserver - Internode services (history, matching, worker) use ZAP - Frontend keeps gRPC for Temporal SDK backward compat (for now) - luxfi/zap added as dependency
24 lines
494 B
Go
24 lines
494 B
Go
package zaptransport
|
|
|
|
import (
|
|
"net"
|
|
|
|
"google.golang.org/grpc"
|
|
)
|
|
|
|
// RPCServer is the interface that both *grpc.Server and *zaptransport.Server
|
|
// implement. It allows services to register handlers and serve connections
|
|
// regardless of the underlying transport.
|
|
type RPCServer interface {
|
|
grpc.ServiceRegistrar
|
|
Serve(lis net.Listener) error
|
|
GracefulStop()
|
|
Stop()
|
|
}
|
|
|
|
// Verify interface compliance at compile time.
|
|
var (
|
|
_ RPCServer = (*grpc.Server)(nil)
|
|
_ RPCServer = (*Server)(nil)
|
|
)
|