Function CheckBackendStreamMiddleware

controller/rpc/middleware.go:104–117

(s *Service)

}

func CheckBackendStreamMiddleware(s *Service) grpc.StreamServerInterceptor {
	return func(
		srv interface{},
		ss grpc.ServerStream,
		info *grpc.StreamServerInfo,
		handler grpc.StreamHandler,
	) error {
		if err := checkBackendStatus(s); err != nil {
			return err
		}

		return handler(srv, ss)
	}
}

func logRequest(ctx context.Context, method string, err error) {
	// Extract client IP