Add dataset.type

elastic · Jun 16, 2020 · fbcf50c · fbcf50c
1 parent e67d5e7
commit fbcf50c
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 4 deletions.
diff --git a/x-pack/plugins/ingest_manager/common/services/datasources_to_agent_inputs.test.ts b/x-pack/plugins/ingest_manager/common/services/datasources_to_agent_inputs.test.ts
@@ -106,7 +106,7 @@ describe('Ingest Manager - storedDatasourcesToAgentInputs', () => {
         id: 'some-uuid',
         name: 'mock-datasource',
         type: 'test-logs',
-        dataset: { namespace: 'default' },
+        dataset: { namespace: 'default', type: 'test-logs' },
         use_output: 'default',
         streams: [
           {
@@ -142,7 +142,7 @@ describe('Ingest Manager - storedDatasourcesToAgentInputs', () => {
         id: 'some-uuid',
         name: 'mock-datasource',
         type: 'test-logs',
-        dataset: { namespace: 'default' },
+        dataset: { namespace: 'default', type: 'test-logs' },
         use_output: 'default',
         streams: [
           {

diff --git a/x-pack/plugins/ingest_manager/common/services/datasources_to_agent_inputs.ts b/x-pack/plugins/ingest_manager/common/services/datasources_to_agent_inputs.ts
@@ -24,7 +24,10 @@ export const storedDatasourcesToAgentInputs = (
         id: datasource.id || datasource.name,
         name: datasource.name,
         type: input.type,
-        dataset: { namespace: datasource.namespace || 'default' },
+        dataset: {
+          namespace: datasource.namespace || 'default',
+          type: input.type,
+        },
         use_output: DEFAULT_OUTPUT.name,
         ...Object.entries(input.config || {}).reduce((acc, [key, { value }]) => {
           acc[key] = value;

diff --git a/x-pack/plugins/ingest_manager/common/types/models/agent_config.ts b/x-pack/plugins/ingest_manager/common/types/models/agent_config.ts
@@ -39,7 +39,10 @@ export interface FullAgentConfigInput {
   id: string;
   name: string;
   type: string;
-  dataset: { namespace: string };
+  dataset: {
+    namespace: string;
+    type: string;
+  };
   use_output: string;
   package?: Pick<DatasourcePackage, 'name' | 'version'>;
   streams: FullAgentConfigInputStream[];