First, ordered occasion streams. Each agent motion produces an occasion with a world sequence quantity. Any agent can reconstruct the present system state by studying the occasion stream. This eliminates the necessity for brokers to question one another straight, which is the place the latency was hiding in our system.
Second, context propagation. Every occasion carries a context envelope that features the originating consumer request, present session state and any constraints or deadlines. When an agent receives an occasion, it has the complete image with out making further calls. In our earlier structure, brokers have been making three to 5 round-trip calls simply to assemble sufficient context to behave on a single request. Third, coordination primitives. The backbone gives built-in assist for widespread patterns: sequential handoffs between brokers, parallel fan-out with aggregation, conditional routing based mostly on confidence scores and precedence preemption when pressing requests arrive. These patterns would in any other case have to be applied independently by every agent pair, duplicating logic and introducing inconsistency.
from collections import defaultdict
import time
class EventSpine:
def __init__(self):
self.sequence = 0
self.subscribers = defaultdict(checklist)
def publish(self, event_type, payload, context):
self.sequence += 1
occasion = Occasion(
seq=self.sequence,
sort=event_type,
payload=payload,
context=context,
timestamp=time.time()
)
for handler in self.subscribers[event_type]:
handler(occasion)
return occasion
def subscribe(self, event_type, handler):
self.subscribers[event_type].append(handler)
Sreenivasa Reddy Hulebeedu Reddy
3 issues the Occasion Backbone solves
Drawback one: race circumstances between brokers. With out coordination, our scheduling agent would guide conferences earlier than the inquiry agent had completed amassing necessities. Clients obtained calendar invites for appointments that have been lacking vital particulars. The Occasion Backbone solved this by imposing sequential processing for dependent operations. The scheduling agent subscribes to requirement-complete occasions and solely acts after receiving affirmation that the inquiry agent has gathered all the pieces wanted.
