[Log Explorer] Add Explorer app locator

packages/deeplinks/observability/index.ts

@@ -9,3 +9,5 @@
 export { OBSERVABILITY_ONBOARDING_APP_ID } from './constants';
 
 export type { AppId, DeepLinkId } from './deep_links';
+
+export * from './locators';

packages/deeplinks/observability/locators/index.ts

@@ -0,0 +1,11 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License
+ * 2.0 and the Server Side Public License, v 1; you may not use this file except
+ * in compliance with, at your election, the Elastic License 2.0 or the Server
+ * Side Public License, v 1.
+ */
+
+export * from './log_explorer';
+export * from './observability_log_explorer';
+export * from './observability_onboarding';

packages/deeplinks/observability/locators/log_explorer.ts

@@ -0,0 +1,51 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License
+ * 2.0 and the Server Side Public License, v 1; you may not use this file except
+ * in compliance with, at your election, the Elastic License 2.0 or the Server
+ * Side Public License, v 1.
+ */
+import type { SerializableRecord } from '@kbn/utility-types';
+import type { Filter, TimeRange, Query, AggregateQuery } from '@kbn/es-query';
+
+// eslint-disable-next-line @typescript-eslint/consistent-type-definitions
+export type RefreshInterval = {
+  pause: boolean;
+  value: number;
+};
+
+export const LOG_EXPLORER_LOCATOR_ID = 'LOG_EXPLORER_LOCATOR';
+
+export interface LogExplorerNavigationParams extends SerializableRecord {
+  /**
+   * Optionally set the time range in the time picker.
+   */
+  timeRange?: TimeRange;
+  /**
+   * Optionally set the refresh interval.
+   */
+  refreshInterval?: RefreshInterval;
+  /**
+   * Optionally set a query.
+   */
+  query?: Query | AggregateQuery;
+  /**
+   * Columns displayed in the table
+   */
+  columns?: string[];
+  /**
+   * Array of the used sorting [[field,direction],...]
+   */
+  sort?: string[][];
+  /**
+   * Optionally apply filters.
+   */
+  filters?: Filter[];
+}
+
+export interface LogExplorerLocatorParams extends LogExplorerNavigationParams {
+  /**
+   * Dataset name to be selected.
+   */
+  dataset?: string;
+}

packages/deeplinks/observability/locators/observability_log_explorer.ts

@@ -0,0 +1,31 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License
+ * 2.0 and the Server Side Public License, v 1; you may not use this file except
+ * in compliance with, at your election, the Elastic License 2.0 or the Server
+ * Side Public License, v 1.
+ */
+
+import { LogExplorerNavigationParams } from './log_explorer';
+
+export type DatasetLocatorParams = LogExplorerNavigationParams;
+
+// All datasets locator
+export const ALL_DATASETS_LOCATOR_ID = 'ALL_DATASETS_LOCATOR';
+
+export type AllDatasetsLocatorParams = DatasetLocatorParams;
+
+// Single dataset locator
+export const SINGLE_DATASET_LOCATOR_ID = 'SINGLE_DATASET_LOCATOR';
+
+export interface SingleDatasetLocatorParams extends DatasetLocatorParams {
+  /**
+   * Integration name to be selected.
+   */
+  integration?: string;
+  /**
+   * Dataset name to be selected.
+   * ex: system.syslog
+   */
+  dataset: string;
+}

packages/deeplinks/observability/locators/observability_onboarding.ts

@@ -0,0 +1,15 @@
+/*
+ * Copyright Elasticsearch B.V. and/or licensed to Elasticsearch B.V. under one
+ * or more contributor license agreements. Licensed under the Elastic License
+ * 2.0 and the Server Side Public License, v 1; you may not use this file except
+ * in compliance with, at your election, the Elastic License 2.0 or the Server
+ * Side Public License, v 1.
+ */
+import { SerializableRecord } from '@kbn/utility-types';
+
+export const OBSERVABILITY_ONBOARDING_LOCATOR = 'OBSERVABILITY_ONBOARDING_LOCATOR' as const;
+
+export interface ObservabilityOnboardingLocatorParams extends SerializableRecord {
+  /** If given, it will load the given map else will load the create a new map page. */
+  source?: 'customLogs' | 'systemLogs';
+}

packages/deeplinks/observability/tsconfig.json

@@ -16,5 +16,7 @@
     "target/**/*"
   ],
   "kbn_references": [
+    "@kbn/utility-types",
+    "@kbn/es-query",
   ]
 }

x-pack/plugins/apm/public/application/index.tsx

@@ -58,6 +58,7 @@ export const renderApp = ({
     lens: pluginsStart.lens,
     uiActions: pluginsStart.uiActions,
     observabilityAIAssistant: pluginsStart.observabilityAIAssistant,
+    share: pluginsSetup.share,
   };
 
   // render APM feedback link in global help menu

x-pack/plugins/apm/public/components/app/service_overview/service_overview_instances_table/instance_actions_menu/index.tsx

@@ -15,6 +15,10 @@ import {
   SectionSubtitle,
   SectionTitle,
 } from '@kbn/observability-shared-plugin/public';
+import {
+  AllDatasetsLocatorParams,
+  ALL_DATASETS_LOCATOR_ID,
+} from '@kbn/deeplinks-observability/locators';
 import { isJavaAgentName } from '../../../../../../common/agent_name';
 import { SERVICE_NODE_NAME } from '../../../../../../common/es_fields/apm';
 import { useApmPluginContext } from '../../../../../context/apm_plugin/use_apm_plugin_context';
@@ -40,7 +44,7 @@ export function InstanceActionsMenu({
   kuery,
   onClose,
 }: Props) {
-  const { core, infra } = useApmPluginContext();
+  const { core, infra, share } = useApmPluginContext();
   const { data, status } = useInstanceDetailsFetcher({
     serviceName,
     serviceNodeName,
@@ -52,6 +56,10 @@ export function InstanceActionsMenu({
   const metricOverviewHref = useMetricOverviewHref(serviceName);
   const history = useHistory();
 
+  const allDatasetsLocator = share.url.locators.get<AllDatasetsLocatorParams>(
+    ALL_DATASETS_LOCATOR_ID
+  )!;
+
   if (isPending(status)) {
     return (
       <div
@@ -90,6 +98,7 @@ export function InstanceActionsMenu({
     onFilterByInstanceClick: handleFilterByInstanceClick,
     metricsHref,
     infraLocators: infra?.locators,
+    allDatasetsLocator,
   });
 
   return (

x-pack/plugins/apm/public/components/app/service_overview/service_overview_instances_table/instance_actions_menu/menu_sections.ts

@@ -9,6 +9,9 @@ import { i18n } from '@kbn/i18n';
 import { IBasePath } from '@kbn/core/public';
 import moment from 'moment';
 import type { InfraLocators } from '@kbn/infra-plugin/common/locators';
+import type { LocatorPublic } from '@kbn/share-plugin/public';
+import { AllDatasetsLocatorParams } from '@kbn/deeplinks-observability/locators';
+import { getNodeLogsHref } from '../../../../shared/links/observability_logs_link';
 import { APIReturnType } from '../../../../../services/rest/create_call_apm_api';
 import { getInfraHref } from '../../../../shared/links/infra_link';
 import {
@@ -39,12 +42,14 @@ export function getMenuSections({
   onFilterByInstanceClick,
   metricsHref,
   infraLocators,
+  allDatasetsLocator,
 }: {
   instanceDetails: InstaceDetails;
   basePath: IBasePath;
   onFilterByInstanceClick: () => void;
   metricsHref: string;
-  infraLocators: InfraLocators;
+  infraLocators?: InfraLocators;
+  allDatasetsLocator: LocatorPublic<AllDatasetsLocatorParams>;
 }) {
   const podId = instanceDetails.kubernetes?.pod?.uid;
   const containerId = instanceDetails.container?.id;
@@ -54,69 +59,72 @@ export function getMenuSections({
   const infraMetricsQuery = getInfraMetricsQuery(instanceDetails['@timestamp']);
   const infraNodeLocator = infraLocators?.nodeLogsLocator;
 
-  const podActions: Action[] = infraNodeLocator
-    ? [
-        {
-          key: 'podLogs',
-          label: i18n.translate(
-            'xpack.apm.serviceOverview.instancesTable.actionMenus.podLogs',
-            { defaultMessage: 'Pod logs' }
-          ),
-          href: infraNodeLocator?.getRedirectUrl({
-            nodeId: podId!,
-            nodeType: 'pod',
-            time,
-          }),
-          condition: !!podId,
-        },
-        {
-          key: 'podMetrics',
-          label: i18n.translate(
-            'xpack.apm.serviceOverview.instancesTable.actionMenus.podMetrics',
-            { defaultMessage: 'Pod metrics' }
-          ),
-          href: getInfraHref({
-            app: 'metrics',
-            basePath,
-            path: `/link-to/pod-detail/${podId}`,
-            query: infraMetricsQuery,
-          }),
-          condition: !!podId,
-        },
-      ]
-    : [];
+  const podLogsHref = getNodeLogsHref(
+    'pod',
+    podId!,
+    time,
+    allDatasetsLocator,
+    infraNodeLocator
+  );
+  const containerLogsHref = getNodeLogsHref(
+    'container',
+    containerId!,
+    time,
+    allDatasetsLocator,
+    infraNodeLocator
+  );
 
-  const containerActions: Action[] = infraNodeLocator
-    ? [
-        {
-          key: 'containerLogs',
-          label: i18n.translate(
-            'xpack.apm.serviceOverview.instancesTable.actionMenus.containerLogs',
-            { defaultMessage: 'Container logs' }
-          ),
-          href: infraNodeLocator?.getRedirectUrl({
-            nodeId: containerId!,
-            nodeType: 'container',
-            time,
-          }),
-          condition: !!containerId,
-        },
-        {
-          key: 'containerMetrics',
-          label: i18n.translate(
-            'xpack.apm.serviceOverview.instancesTable.actionMenus.containerMetrics',
-            { defaultMessage: 'Container metrics' }
-          ),
-          href: getInfraHref({
-            app: 'metrics',
-            basePath,
-            path: `/link-to/container-detail/${containerId}`,
-            query: infraMetricsQuery,
-          }),
-          condition: !!containerId,
-        },
-      ]
-    : [];
+  const podActions: Action[] = [
+    {
+      key: 'podLogs',
+      label: i18n.translate(
+        'xpack.apm.serviceOverview.instancesTable.actionMenus.podLogs',
+        { defaultMessage: 'Pod logs' }
+      ),
+      href: podLogsHref,
+      condition: !!podId,
+    },
+    {
+      key: 'podMetrics',
+      label: i18n.translate(
+        'xpack.apm.serviceOverview.instancesTable.actionMenus.podMetrics',
+        { defaultMessage: 'Pod metrics' }
+      ),
+      href: getInfraHref({
+        app: 'metrics',
+        basePath,
+        path: `/link-to/pod-detail/${podId}`,
+        query: infraMetricsQuery,
+      }),
+      condition: !!podId && !!infraLocators,
+    },
+  ];
+
+  const containerActions: Action[] = [
+    {
+      key: 'containerLogs',
+      label: i18n.translate(
+        'xpack.apm.serviceOverview.instancesTable.actionMenus.containerLogs',
+        { defaultMessage: 'Container logs' }
+      ),
+      href: containerLogsHref,
+      condition: !!containerId,
+    },
+    {
+      key: 'containerMetrics',
+      label: i18n.translate(
+        'xpack.apm.serviceOverview.instancesTable.actionMenus.containerMetrics',
+        { defaultMessage: 'Container metrics' }
+      ),
+      href: getInfraHref({
+        app: 'metrics',
+        basePath,
+        path: `/link-to/container-detail/${containerId}`,
+        query: infraMetricsQuery,
+      }),
+      condition: !!containerId && !!infraLocators,
+    },
+  ];
 
   const apmActions: Action[] = [
     {