diff --git a/x-pack/plugins/event_log/server/es/cluster_client_adapter.test.ts b/x-pack/plugins/event_log/server/es/cluster_client_adapter.test.ts index e07dace1969fa..ed740a27b81e4 100644 --- a/x-pack/plugins/event_log/server/es/cluster_client_adapter.test.ts +++ b/x-pack/plugins/event_log/server/es/cluster_client_adapter.test.ts @@ -44,7 +44,7 @@ describe('indexDocument', () => { }); expect(clusterClient.bulk).toHaveBeenCalledWith({ - body: [{ create: { _index: 'event-log' } }, { message: 'foo' }], + body: [{ create: { _index: 'event-log', require_alias: true } }, { message: 'foo' }], }); }); @@ -55,7 +55,7 @@ describe('indexDocument', () => { return logger.error.mock.calls.length !== 0; }); - const expectedMessage = `error writing bulk events: "expected failure"; docs: [{"create":{"_index":"event-log"}},{"message":"foo"}]`; + const expectedMessage = `error writing bulk events: "expected failure"; docs: [{"create":{"_index":"event-log","require_alias":true}},{"message":"foo"}]`; expect(logger.error).toHaveBeenCalledWith(expectedMessage); }); }); @@ -92,7 +92,10 @@ describe('buffering documents', () => { const expectedBody = []; for (let i = 0; i < EVENT_BUFFER_LENGTH - 1; i++) { - expectedBody.push({ create: { _index: 'event-log' } }, { message: `foo ${i}` }); + expectedBody.push( + { create: { _index: 'event-log', require_alias: true } }, + { message: `foo ${i}` } + ); } expect(clusterClient.bulk).toHaveBeenCalledWith({ @@ -112,7 +115,10 @@ describe('buffering documents', () => { const expectedBody = []; for (let i = 0; i < EVENT_BUFFER_LENGTH; i++) { - expectedBody.push({ create: { _index: 'event-log' } }, { message: `foo ${i}` }); + expectedBody.push( + { create: { _index: 'event-log', require_alias: true } }, + { message: `foo ${i}` } + ); } expect(clusterClient.bulk).toHaveBeenNthCalledWith(1, { @@ -120,7 +126,7 @@ describe('buffering documents', () => { }); expect(clusterClient.bulk).toHaveBeenNthCalledWith(2, { - body: [{ create: { _index: 'event-log' } }, { message: `foo 100` }], + body: [{ create: { _index: 'event-log', require_alias: true } }, { message: `foo 100` }], }); }); @@ -146,7 +152,7 @@ describe('buffering documents', () => { const expectedBody = []; for (let j = 0; j < EVENT_BUFFER_LENGTH; j++) { expectedBody.push( - { create: { _index: 'event-log' } }, + { create: { _index: 'event-log', require_alias: true } }, { message: `foo ${i * EVENT_BUFFER_LENGTH + j}` } ); } diff --git a/x-pack/plugins/event_log/server/es/cluster_client_adapter.ts b/x-pack/plugins/event_log/server/es/cluster_client_adapter.ts index 38a05bc626480..a3ea88cfb526b 100644 --- a/x-pack/plugins/event_log/server/es/cluster_client_adapter.ts +++ b/x-pack/plugins/event_log/server/es/cluster_client_adapter.ts @@ -123,7 +123,7 @@ export class ClusterClientAdapter