add path option support for grpc

This commit is contained in:
ginuerzh
2022-07-27 18:01:22 +08:00
parent d7b56871a9
commit 818463260f
5 changed files with 84 additions and 6 deletions

View File

@ -66,11 +66,11 @@ func (l *grpcListener) Init(md md.Metadata) (err error) {
l.cqueue = make(chan net.Conn, l.md.backlog)
l.errChan = make(chan error, 1)
pb.RegisterGostTunelServer(l.server, &server{
pb.RegisterGostTunelServerX(l.server, &server{
cqueue: l.cqueue,
localAddr: l.addr,
logger: l.options.Logger,
})
}, l.md.path)
go func() {
err := l.server.Serve(ln)

View File

@ -12,12 +12,14 @@ const (
type metadata struct {
backlog int
insecure bool
path string
}
func (l *grpcListener) parseMetadata(md mdata.Metadata) (err error) {
const (
backlog = "backlog"
insecure = "grpcInsecure"
path = "path"
)
l.md.backlog = mdx.GetInt(md, backlog)
@ -26,5 +28,6 @@ func (l *grpcListener) parseMetadata(md mdata.Metadata) (err error) {
}
l.md.insecure = mdx.GetBool(md, insecure)
l.md.path = mdx.GetString(md, path)
return
}