Imlement Nexus

[Persists]

2 Prototype - Nexus

• Implement Nexus structure
• Manage dynamic registration of schedulers
• Capable of handling different scheduler types through interfaces

Documentation

Functions

• Init() *Nexus: Initializes a new Nexus queue.
• (n *Nexus) Push(elem *common.NexusItem): Pushes an item into the Nexus queue.
• (n *Nexus) Pop() interface{}: Pops an item from the Nexus queue.

Nexus-queue

• implement a heap, sorted based on deadlines
• add helper functions, to support the schedulers
• add mutex to make it thread safe

Documentation

Types

• NexusQueue: Represents the priority queue and provides methods for interacting with the queue.
• nexusHeap: Represents the underlying heap data structure used by NexusQueue.

Functions

• Init() *NexusQueue: Initializes a new NexusQueue instance.
• Len() int: Returns the number of items in the queue.
• Push(el *common.NexusItem): Adds a new item to the queue.
• Update(el *common.NexusItem, deadline time.Time): Updates the deadline of a specific item in the queue.
• Pop() *common.NexusItem: Removes and returns the item with the earliest deadline from the queue.
• Peek() *common.NexusItem: Returns the item with the earliest deadline without removing it from the queue.
• Remove(item *common.NexusItem): Removes a specific item from the queue.
• RemoveAll(nexusItems []*common.NexusItem): Removes all given items from the queue.
• GetMostCommonEntryItems() []*common.NexusItem: Returns the items with the most common entry based on their names.