Broker¶

class softs.Broker[source]¶

__init__(endpoints, supplier_timeout=60.0, client_timeout=120.0, max_queue_per_product=16, max_order_attempts=5)[source]¶

Parameters:

endpoints (EndpointConfig)
supplier_timeout (float)
client_timeout (float)
max_queue_per_product (int)
max_order_attempts (int)

start()[source]¶

Return type:: None

stop()[source]¶

Return type:: None

get_stats()[source]¶

Return type:: BrokerStats

class softs.BrokerStats[source]¶

BrokerStats(pending_orders: int, available_suppliers: int, connected_clients: int, connected_suppliers: int, total_completed: int, product_ids: list[str])

pending_orders: int¶

available_suppliers: int¶

connected_clients: int¶

connected_suppliers: int¶

total_completed: int¶

product_ids: list[str]¶

__init__(pending_orders, available_suppliers, connected_clients, connected_suppliers, total_completed, product_ids)¶

Parameters:

pending_orders (int)
available_suppliers (int)
connected_clients (int)
connected_suppliers (int)
total_completed (int)
product_ids (list[str])

Return type:

None