Function CheckBackendMiddleware

controller/rpc/middleware.go:89–102

(s *Service)

}

func CheckBackendMiddleware(s *Service) grpc.UnaryServerInterceptor {
	return func(
		ctx context.Context,
		req interface{},
		info *grpc.UnaryServerInfo,
		handler grpc.UnaryHandler,
	) (interface{}, error) {
		if err := checkBackendStatus(s); err != nil {
			return nil, err
		}

		return handler(ctx, req)
	}
}

func CheckBackendStreamMiddleware(s *Service) grpc.StreamServerInterceptor {
	return func(