forked from p93542168/wheat-cache
17 lines
284 B
Go
17 lines
284 B
Go
|
package proxy
|
||
|
|
|
||
|
|
import (
|
||
|
|
"context"
|
||
|
|
|
||
|
|
"google.golang.org/grpc"
|
||
|
|
)
|
||
|
|
|
||
|
|
type StreamDirector func(ctx context.Context, fullMethodName string) (context.Context, *grpc.ClientConn, error)
|
||
|
|
|
||
|
|
var (
|
||
|
|
clientStreamDescForProxying = &grpc.StreamDesc{
|
||
|
|
ServerStreams: true,
|
||
|
|
ClientStreams: true,
|
||
|
|
}
|
||
|
|
)
|