Method Search

modules/frontend/interceptor/interceptor_test.go:69–77

(_ *tempopb.SearchRequest, ss tempopb.StreamingQuerier_SearchServer)

}

func (s *mockService) Search(_ *tempopb.SearchRequest, ss tempopb.StreamingQuerier_SearchServer) error {
	select {
	case <-time.After(s.apiTimeout):
	case <-ss.Context().Done():
		return ss.Context().Err()
	}

	return nil
}

func (s *mockService) PushBytes(ctx context.Context, _ *tempopb.PushBytesRequest) (*tempopb.PushResponse, error) {
	select {