feat(performance): queues module destination search

static/app/views/performance/queues/charts/latencyChart.spec.tsx

@@ -23,7 +23,7 @@ describe('latencyChart', () => {
     });
   });
   it('renders', async () => {
-    render(<LatencyChart />);
+    render(<LatencyChart destination="events" />);
     screen.getByText('Avg Latency');
     expect(eventsStatsMock).toHaveBeenCalledWith(
       '/organizations/org-slug/events-stats/',
@@ -36,6 +36,8 @@ describe('latencyChart', () => {
             'count_op(queue.publish)',
             'count_op(queue.process)',
           ],
+          query:
+            'span.op:[queue.process,queue.publish] messaging.destination.name:events',
         }),
       })
     );

static/app/views/performance/queues/charts/latencyChart.tsx

@@ -1,19 +1,16 @@
 import {CHART_PALETTE} from 'sentry/constants/chartPalette';
 import {t} from 'sentry/locale';
-import {decodeScalar} from 'sentry/utils/queryString';
-import {useLocation} from 'sentry/utils/useLocation';
 import {CHART_HEIGHT} from 'sentry/views/performance/database/settings';
 import {useQueuesTimeSeriesQuery} from 'sentry/views/performance/queues/queries/useQueuesTimeSeriesQuery';
 import Chart, {ChartType} from 'sentry/views/starfish/components/chart';
 import ChartPanel from 'sentry/views/starfish/components/chartPanel';
 
 interface Props {
+  destination?: string;
   error?: Error | null;
 }
 
-export function LatencyChart({error}: Props) {
-  const {query} = useLocation();
-  const destination = decodeScalar(query.destination);
+export function LatencyChart({error, destination}: Props) {
   const {data, isLoading} = useQueuesTimeSeriesQuery({destination});
   return (
     <ChartPanel title={t('Avg Latency')}>

static/app/views/performance/queues/charts/throughputChart.spec.tsx

@@ -36,6 +36,7 @@ describe('throughputChart', () => {
             'count_op(queue.publish)',
             'count_op(queue.process)',
           ],
+          query: 'span.op:[queue.process,queue.publish]',
         }),
       })
     );

static/app/views/performance/queues/charts/throughputChart.tsx

@@ -1,19 +1,16 @@
 import {CHART_PALETTE} from 'sentry/constants/chartPalette';
 import {t} from 'sentry/locale';
-import {decodeScalar} from 'sentry/utils/queryString';
-import {useLocation} from 'sentry/utils/useLocation';
 import {CHART_HEIGHT} from 'sentry/views/performance/database/settings';
 import {useQueuesTimeSeriesQuery} from 'sentry/views/performance/queues/queries/useQueuesTimeSeriesQuery';
 import Chart, {ChartType} from 'sentry/views/starfish/components/chart';
 import ChartPanel from 'sentry/views/starfish/components/chartPanel';
 
 interface Props {
+  destination?: string;
   error?: Error | null;
 }
 
-export function ThroughputChart({error}: Props) {
-  const {query} = useLocation();
-  const destination = decodeScalar(query.destination);
+export function ThroughputChart({error, destination}: Props) {
   const {data, isLoading} = useQueuesTimeSeriesQuery({destination});
   return (
     <ChartPanel title={t('Published vs Processed')}>

static/app/views/performance/queues/destinationSummary/destinationSummaryPage.tsx

@@ -138,11 +138,11 @@ function DestinationSummaryPage() {
             {!onboardingProject && (
               <Fragment>
                 <ModuleLayout.Half>
-                  <LatencyChart />
+                  <LatencyChart destination={destination} />
                 </ModuleLayout.Half>
 
                 <ModuleLayout.Half>
-                  <ThroughputChart />
+                  <ThroughputChart destination={destination} />
                 </ModuleLayout.Half>
 
                 <ModuleLayout.Full>

static/app/views/performance/queues/queries/useQueuesByDestinationQuery.tsx

@@ -1,3 +1,4 @@
+import type {Sort} from 'sentry/utils/discover/fields';
 import {decodeScalar} from 'sentry/utils/queryString';
 import {MutableSearch} from 'sentry/utils/tokenizeSearch';
 import {useLocation} from 'sentry/utils/useLocation';
@@ -6,14 +7,19 @@ import {useSpanMetrics} from 'sentry/views/starfish/queries/useDiscover';
 import {QueryParameterNames} from 'sentry/views/starfish/views/queryParameters';
 
 type Props = {
+  destination?: string;
   enabled?: boolean;
+  sort?: Sort;
 };
 
-export function useQueuesByDestinationQuery({enabled}: Props) {
+export function useQueuesByDestinationQuery({enabled, destination, sort}: Props) {
   const location = useLocation();
   const cursor = decodeScalar(location.query?.[QueryParameterNames.DESTINATIONS_CURSOR]);
 
   const mutableSearch = new MutableSearch(DEFAULT_QUERY_FILTER);
+  if (destination) {
+    mutableSearch.addFilterValue('messaging.destination.name', destination, false);
+  }
   const response = useSpanMetrics(
     {
       search: mutableSearch,
@@ -27,9 +33,10 @@ export function useQueuesByDestinationQuery({enabled}: Props) {
         'avg_if(span.duration,span.op,queue.publish)',
         'avg_if(span.duration,span.op,queue.process)',
         'avg(messaging.message.receive.latency)',
+        'time_spent_percentage()',
       ],
       enabled,
-      sorts: [],
+      sorts: sort ? [sort] : [],
       limit: 10,
       cursor,
     },

static/app/views/performance/queues/queries/useQueuesTimeSeriesQuery.tsx

@@ -1,4 +1,5 @@
 import {MutableSearch} from 'sentry/utils/tokenizeSearch';
+import {DEFAULT_QUERY_FILTER} from 'sentry/views/performance/queues/settings';
 import {useSpanMetricsSeries} from 'sentry/views/starfish/queries/useDiscoverSeries';
 import type {SpanMetricsProperty} from 'sentry/views/starfish/types';
 
@@ -16,14 +17,15 @@ const yAxis: SpanMetricsProperty[] = [
 ];
 
 export function useQueuesTimeSeriesQuery({enabled, destination}: Props) {
+  const mutableSearch = new MutableSearch(DEFAULT_QUERY_FILTER);
+  if (destination) {
+    mutableSearch.addFilterValue('messaging.destination.name', destination, false);
+  }
+
   return useSpanMetricsSeries(
     {
       yAxis,
-      search: destination
-        ? MutableSearch.fromQueryObject({
-            'messaging.destination.name': destination,
-          })
-        : undefined,
+      search: mutableSearch,
       enabled,
     },
     'api.performance.queues.module-chart'

static/app/views/performance/queues/queuesLandingPage.spec.tsx

@@ -75,7 +75,7 @@ describe('queuesLandingPage', () => {
     render(<QueuesLandingPage />);
     await screen.findByRole('table', {name: 'Queues'});
     await waitForElementToBeRemoved(() => screen.queryAllByTestId('loading-indicator'));
-    screen.getByPlaceholderText('Search for events, users, tags, and more');
+    screen.getByPlaceholderText('Search for more destinations');
     screen.getByText('Avg Latency');
     screen.getByText('Published vs Processed');
     expect(eventsStatsMock).toHaveBeenCalled();

static/app/views/performance/queues/queuesLandingPage.tsx

@@ -10,9 +10,14 @@ import {DatePageFilter} from 'sentry/components/organizations/datePageFilter';
 import {EnvironmentPageFilter} from 'sentry/components/organizations/environmentPageFilter';
 import PageFilterBar from 'sentry/components/organizations/pageFilterBar';
 import {ProjectPageFilter} from 'sentry/components/organizations/projectPageFilter';
-import SmartSearchBar from 'sentry/components/smartSearchBar';
+import SearchBar from 'sentry/components/searchBar';
 import {t} from 'sentry/locale';
 import {space} from 'sentry/styles/space';
+import {browserHistory} from 'sentry/utils/browserHistory';
+import {decodeScalar, decodeSorts} from 'sentry/utils/queryString';
+import {escapeFilterValue} from 'sentry/utils/tokenizeSearch';
+import useLocationQuery from 'sentry/utils/url/useLocationQuery';
+import {useLocation} from 'sentry/utils/useLocation';
 import useOrganization from 'sentry/utils/useOrganization';
 import {normalizeUrl} from 'sentry/utils/withDomainRequired';
 import {useOnboardingProject} from 'sentry/views/performance/browser/webVitals/utils/useOnboardingProject';
@@ -21,12 +26,45 @@ import {ModulePageProviders} from 'sentry/views/performance/modulePageProviders'
 import Onboarding from 'sentry/views/performance/onboarding';
 import {LatencyChart} from 'sentry/views/performance/queues/charts/latencyChart';
 import {ThroughputChart} from 'sentry/views/performance/queues/charts/throughputChart';
-import {QueuesTable} from 'sentry/views/performance/queues/queuesTable';
+import {isAValidSort, QueuesTable} from 'sentry/views/performance/queues/queuesTable';
 import {MODULE_TITLE, RELEASE_LEVEL} from 'sentry/views/performance/queues/settings';
+import {QueryParameterNames} from 'sentry/views/starfish/views/queryParameters';
+
+const DEFAULT_SORT = {
+  field: 'time_spent_percentage()' as const,
+  kind: 'desc' as const,
+};
 
 function QueuesLandingPage() {
   const organization = useOrganization();
   const onboardingProject = useOnboardingProject();
+  const location = useLocation();
+
+  const query = useLocationQuery({
+    fields: {
+      destination: decodeScalar,
+      [QueryParameterNames.DOMAINS_SORT]: decodeScalar,
+    },
+  });
+
+  const sort =
+    decodeSorts(query[QueryParameterNames.DOMAINS_SORT]).filter(isAValidSort).at(0) ??
+    DEFAULT_SORT;
+
+  const handleSearch = (newDestination: string) => {
+    browserHistory.push({
+      ...location,
+      query: {
+        ...location.query,
+        destination: newDestination === '' ? undefined : newDestination,
+        [QueryParameterNames.SPANS_CURSOR]: undefined,
+      },
+    });
+  };
+
+  const wildCardDestinationFilter = query.destination
+    ? `*${escapeFilterValue(query.destination)}*`
+    : undefined;
 
   return (
     <Fragment>
@@ -86,9 +124,12 @@ function QueuesLandingPage() {
 
                 <ModuleLayout.Full>
                   <Flex>
-                    {/* TODO: Make search bar work */}
-                    <SmartSearchBar />
-                    <QueuesTable />
+                    <SearchBar
+                      query={query.destination}
+                      placeholder={t('Search for more destinations')}
+                      onSearch={handleSearch}
+                    />
+                    <QueuesTable sort={sort} destination={wildCardDestinationFilter} />
                   </Flex>
                 </ModuleLayout.Full>
               </Fragment>

static/app/views/performance/queues/queuesTable.spec.tsx

@@ -79,6 +79,7 @@ describe('queuesTable', () => {
             'avg_if(span.duration,span.op,queue.publish)',
             'avg_if(span.duration,span.op,queue.process)',
             'avg(messaging.message.receive.latency)',
+            'time_spent_percentage()',
           ],
           dataset: 'spansMetrics',
         }),
@@ -91,4 +92,36 @@ describe('queuesTable', () => {
     expect(screen.getByRole('cell', {name: '20.00ms'})).toBeInTheDocument();
     expect(screen.getByRole('button', {name: 'Next'})).toBeInTheDocument();
   });
+  it('searches for a destination and sorts', async () => {
+    render(
+      <QueuesTable
+        destination="*events*"
+        sort={{field: 'messaging.destination.name', kind: 'desc'}}
+      />
+    );
+    expect(eventsMock).toHaveBeenCalledWith(
+      '/organizations/org-slug/events/',
+      expect.objectContaining({
+        query: expect.objectContaining({
+          field: [
+            'messaging.destination.name',
+            'count()',
+            'count_op(queue.publish)',
+            'count_op(queue.process)',
+            'sum(span.duration)',
+            'avg(span.duration)',
+            'avg_if(span.duration,span.op,queue.publish)',
+            'avg_if(span.duration,span.op,queue.process)',
+            'avg(messaging.message.receive.latency)',
+            'time_spent_percentage()',
+          ],
+          dataset: 'spansMetrics',
+          sort: '-messaging.destination.name',
+          query:
+            'span.op:[queue.process,queue.publish] messaging.destination.name:*events*',
+        }),
+      })
+    );
+    await screen.findByText('celery.backend_cleanup');
+  });
 });

static/app/views/performance/queues/queuesTable.tsx

@@ -15,6 +15,7 @@ import type {Organization} from 'sentry/types';
 import {browserHistory} from 'sentry/utils/browserHistory';
 import type {EventsMetaType} from 'sentry/utils/discover/eventView';
 import {FIELD_FORMATTERS, getFieldRenderer} from 'sentry/utils/discover/fieldRenderers';
+import type {Sort} from 'sentry/utils/discover/fields';
 import {formatAbbreviatedNumber, formatPercentage} from 'sentry/utils/formatters';
 import {useLocation} from 'sentry/utils/useLocation';
 import useOrganization from 'sentry/utils/useOrganization';
@@ -73,17 +74,34 @@ const COLUMN_ORDER: Column[] = [
   },
 ];
 
+const SORTABLE_FIELDS = [
+  'messaging.destination.name',
+  'time_spent_percentage()',
+] as const;
+
+type ValidSort = Sort & {
+  field: (typeof SORTABLE_FIELDS)[number];
+};
+
+export function isAValidSort(sort: Sort): sort is ValidSort {
+  return (SORTABLE_FIELDS as unknown as string[]).includes(sort.field);
+}
+
 interface Props {
-  domain?: string;
+  destination?: string;
   error?: Error | null;
   meta?: EventsMetaType;
+  sort?: ValidSort;
 }
 
-export function QueuesTable({error}: Props) {
+export function QueuesTable({error, destination, sort}: Props) {
   const location = useLocation();
   const organization = useOrganization();
 
-  const {data, isLoading, meta, pageLinks} = useQueuesByDestinationQuery({});
+  const {data, isLoading, meta, pageLinks} = useQueuesByDestinationQuery({
+    destination,
+    sort,
+  });
 
   const handleCursor: CursorHandler = (newCursor, pathname, query) => {
     browserHistory.push({

static/app/views/starfish/views/queryParameters.tsx

@@ -9,4 +9,5 @@ export enum QueryParameterNames {
   ENDPOINTS_SORT = 'endpointsSort',
   PAGES_CURSOR = 'pagesCursor',
   DESTINATIONS_CURSOR = 'destinationsCursor',
+  DESTINATIONS_SORT = 'destinationsSort',
 }