Creates the source; nothing is sent before iterating.
The REST client of the agent.
The consumer name.
Settings, clock, heartbeat source, page size, random and logger.
ReadonlyclientThe REST client.
ReadonlyclockThe time source.
Why the source stopped, once it has.
ReadonlyconsumerThe consumer name.
ReadonlysettingsThe SDK settings.
ReadonlywindowThe acknowledgement window.
Polls until PollingSource.close is called.
The deliveries.
Calls ackAgentEvents; a failure is logged, the next acknowledgement covers it.
The highest settled seq.
A promise that resolves after the call, also when it failed.
Passes on a cursor; it never settles an open delivered event.
The cursor.
A promise that resolves after a needed acknowledgement.
Stops polling after the current request.
A resolved promise.
Marks seq settled and calls ackAgentEvents when the acknowledgement point moves.
The settled seq.
A promise that resolves after a needed acknowledgement.
Events by REST polling (
pollAgentEvents), acknowledged withackAgentEvents.It polls again at once after a non-empty page and waits
sdk.poll_intervalafter an empty one; it sends the agent heartbeat withsendHeartbeateveryHeartbeatAck.interval_ms(the first at once,sdk.poll_intervaluntil an answer names the interval). A failed poll waits with full jitter between zero andmin(sync.reconnect_backoff_cap, sync.reconnect_backoff_base * 2^n);401and403stop it for good.