github-mirrors/kibana
1
0
Fork 0
mirror of https://github.com/elastic/kibana.git synced 2025-04-24 17:59:23 -04:00
Code Issues Projects Releases Packages Wiki Activity

[Ingest Manager] Fix polling for new agent action (#77339)

Browse source
This commit is contained in:
Nicolas Chaulet 2020-09-14 15:42:38 -04:00 • committed by GitHub
parent 65b5f94a47
commit 0fb48950f5
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

8
x-pack/plugins/ingest_manager/server/services/agents/checkin/state_new_actions.ts
View file

@ -53,11 +53,15 @@ function getInternalUserSOClient() {
}
function createNewActionsSharedObservable(): Observable<AgentAction[]> {
const internalSOClient = getInternalUserSOClient();
let lastTimestamp = new Date().toISOString();
return timer(0, AGENT_UPDATE_ACTIONS_INTERVAL_MS).pipe(
switchMap(() => {
return from(getNewActionsSince(internalSOClient, new Date().toISOString()));
const internalSOClient = getInternalUserSOClient();
const timestamp = lastTimestamp;
lastTimestamp = new Date().toISOString();
return from(getNewActionsSince(internalSOClient, timestamp));
}),
shareReplay({ refCount: true, bufferSize: 1 })
);