[YUNIKORN-1709] Add event streaming logic

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.5.0
• Component/s: core - scheduler
• Labels: pull-request-available
• Target Version: 1.5.0
• Assignee: Peter Bacsko
• Reporter: Peter Bacsko
• Created: 27/Apr/23 10:44
• Updated: 20/Mar/24 14:32
• Resolved: 24/Jan/24 09:29

Description

We want to support consumers who are listening for events. Every client is served on a separate goroutine to avoid blocking. Slow consumers (ie. channel buffer full) are automatically removed.

Scope of this JIRA:

• integration with existing code
• consumer registration / event update logic
• cleanup logic
• web service (REST) endpoint code

Issue Links

• Dependent: YUNIKORN-1710 Handle event streaming clients with websocket
• depends upon: YUNIKORN-1799 Create basic ringbuffer implementation
• links to: GitHub Pull Request #533