如何在流拦截器中访问请求？

问题描述

func (m Middlewares) LocationInterceptor(c context.Context,req interface{},info *grpc.UnaryServerInfo,handler grpc.UnaryHandler) (interface{},error) {
    ctx := c.(HarmonyContext)
    location,ok := req.(interface{ GetLocation() *corev1.Location })
    if !ok {
        panic("location middleware used on message without a location")
    }
    
    ctx.Location := location.GetLocation()

    return handler(c,req)
}

如果我知道该流肯定只会从服务器流向客户端，该如何将其转换为流拦截器？另外，有什么方法可以让它仅在流开始的那一刻才拦截？

func (m Middlewares) LocationInterceptorStream(srv interface{},ss grpc.ServerStream,info *grpc.StreamServerInfo,handler grpc.StreamHandler) error {
    wrappedStream := ss.(HarmonyWrappedServerStream)

    return handler(srv,wrappedStream)
}

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

go grpc